server/lib/activitypub/send-request.ts

   1 import * as Sequelize from 'sequelize'
   2
   3 import {
   4   AccountInstance,
   5   VideoInstance,
   6   VideoChannelInstance
   7 } from '../../models'
   8 import { httpRequestJobScheduler } from '../jobs'
   9 import { signObject, activityPubContextify } from '../../helpers'
  10 import { Activity } from '../../../shared'
  11
  12 function sendCreateVideoChannel (videoChannel: VideoChannelInstance, t: Sequelize.Transaction) {
  13   const videoChannelObject = videoChannel.toActivityPubObject()
  14   const data = createActivityData(videoChannel.url, videoChannel.Account, videoChannelObject)
  15
  16   return broadcastToFollowers(data, t)
  17 }
  18
  19 function sendUpdateVideoChannel (videoChannel: VideoChannelInstance, t: Sequelize.Transaction) {
  20   const videoChannelObject = videoChannel.toActivityPubObject()
  21   const data = updateActivityData(videoChannel.url, videoChannel.Account, videoChannelObject)
  22
  23   return broadcastToFollowers(data, t)
  24 }
  25
  26 function sendDeleteVideoChannel (videoChannel: VideoChannelInstance, t: Sequelize.Transaction) {
  27   const videoChannelObject = videoChannel.toActivityPubObject()
  28   const data = deleteActivityData(videoChannel.url, videoChannel.Account, videoChannelObject)
  29
  30   return broadcastToFollowers(data, t)
  31 }
  32
  33 function sendAddVideo (video: VideoInstance, t: Sequelize.Transaction) {
  34   const videoObject = video.toActivityPubObject()
  35   const data = addActivityData(video.url, video.VideoChannel.Account, video.VideoChannel.url, videoObject)
  36
  37   return broadcastToFollowers(data, t)
  38 }
  39
  40 function sendUpdateVideo (video: VideoInstance, t: Sequelize.Transaction) {
  41   const videoObject = video.toActivityPubObject()
  42   const data = updateActivityData(video.url, video.VideoChannel.Account, videoObject)
  43
  44   return broadcastToFollowers(data, t)
  45 }
  46
  47 function sendDeleteVideo (video: VideoInstance, t: Sequelize.Transaction) {
  48   const videoObject = video.toActivityPubObject()
  49   const data = deleteActivityData(video.url, video.VideoChannel.Account, videoObject)
  50
  51   return broadcastToFollowers(data, t)
  52 }
  53
  54 // ---------------------------------------------------------------------------
  55
  56 export {
  57
  58 }
  59
  60 // ---------------------------------------------------------------------------
  61
  62 function broadcastToFollowers (data: any, t: Sequelize.Transaction) {
  63   return httpRequestJobScheduler.createJob(t, 'http-request', 'httpRequestBroadcastHandler', data)
  64 }
  65
  66 function buildSignedActivity (byAccount: AccountInstance, data: Object) {
  67   const activity = activityPubContextify(data)
  68
  69   return signObject(byAccount, activity) as Promise<Activity>
  70 }
  71
  72 async function getPublicActivityTo (account: AccountInstance) {
  73   const inboxUrls = await account.getFollowerSharedInboxUrls()
  74
  75   return inboxUrls.concat('https://www.w3.org/ns/activitystreams#Public')
  76 }
  77
  78 async function createActivityData (url: string, byAccount: AccountInstance, object: any) {
  79   const to = await getPublicActivityTo(byAccount)
  80   const base = {
  81     type: 'Create',
  82     id: url,
  83     actor: byAccount.url,
  84     to,
  85     object
  86   }
  87
  88   return buildSignedActivity(byAccount, base)
  89 }
  90
  91 async function updateActivityData (url: string, byAccount: AccountInstance, object: any) {
  92   const to = await getPublicActivityTo(byAccount)
  93   const base = {
  94     type: 'Update',
  95     id: url,
  96     actor: byAccount.url,
  97     to,
  98     object
  99   }
 100
 101   return buildSignedActivity(byAccount, base)
 102 }
 103
 104 async function deleteActivityData (url: string, byAccount: AccountInstance, object: any) {
 105   const to = await getPublicActivityTo(byAccount)
 106   const base = {
 107     type: 'Update',
 108     id: url,
 109     actor: byAccount.url,
 110     to,
 111     object
 112   }
 113
 114   return buildSignedActivity(byAccount, base)
 115 }
 116
 117 async function addActivityData (url: string, byAccount: AccountInstance, target: string, object: any) {
 118   const to = await getPublicActivityTo(byAccount)
 119   const base = {
 120     type: 'Add',
 121     id: url,
 122     actor: byAccount.url,
 123     to,
 124     object,
 125     target
 126   }
 127
 128   return buildSignedActivity(byAccount, base)
 129 }