index.mjs

  knex.addHook('after', 'insert', 'follows', async (when, method, table, params) => {
    try {
      const { follower_id, follow_id, id } = params.result[0]

      const follower = client.feed('timeline', follower_id)
      await follower.follow('user', follow_id)

      const activity = {
        actor: `users:${follower_id}`,
        verb: 'follow',
        object: `users:${follow_id}`,
        foreign_id: `follows:${id}`,
        time: new Date().toISOString()
      }

      const user = await client.feed('user', follower_id)
      await user.addActivity(activity)
      const notifications = await client.feed('notification', follow_id)
      await notifications.addActivity(activity)
    } catch (err) {
      throw err
    }
  })