server/controllers/activitypub/client.ts

   1 // Intercept ActivityPub client requests
   2 import * as express from 'express'
   3 import { activityPubCollectionPagination, pageToStartAndCount } from '../../helpers'
   4 import { ACTIVITY_PUB, CONFIG } from '../../initializers'
   5 import { buildVideoChannelAnnounceToFollowers } from '../../lib/activitypub/send'
   6 import { buildVideoAnnounceToFollowers } from '../../lib/index'
   7 import { asyncMiddleware, executeIfActivityPub, localAccountValidator } from '../../middlewares'
   8 import {
   9   videoChannelsGetValidator,
  10   videoChannelsShareValidator,
  11   videosGetValidator,
  12   videosShareValidator
  13 } from '../../middlewares/validators'
  14 import { AccountModel } from '../../models/account/account'
  15 import { AccountFollowModel } from '../../models/account/account-follow'
  16 import { VideoModel } from '../../models/video/video'
  17 import { VideoChannelModel } from '../../models/video/video-channel'
  18 import { VideoChannelShareModel } from '../../models/video/video-channel-share'
  19 import { VideoShareModel } from '../../models/video/video-share'
  20
  21 const activityPubClientRouter = express.Router()
  22
  23 activityPubClientRouter.get('/account/:name',
  24   executeIfActivityPub(asyncMiddleware(localAccountValidator)),
  25   executeIfActivityPub(accountController)
  26 )
  27
  28 activityPubClientRouter.get('/account/:name/followers',
  29   executeIfActivityPub(asyncMiddleware(localAccountValidator)),
  30   executeIfActivityPub(asyncMiddleware(accountFollowersController))
  31 )
  32
  33 activityPubClientRouter.get('/account/:name/following',
  34   executeIfActivityPub(asyncMiddleware(localAccountValidator)),
  35   executeIfActivityPub(asyncMiddleware(accountFollowingController))
  36 )
  37
  38 activityPubClientRouter.get('/videos/watch/:id',
  39   executeIfActivityPub(asyncMiddleware(videosGetValidator)),
  40   executeIfActivityPub(videoController)
  41 )
  42
  43 activityPubClientRouter.get('/videos/watch/:id/announces/:accountId',
  44   executeIfActivityPub(asyncMiddleware(videosShareValidator)),
  45   executeIfActivityPub(asyncMiddleware(videoAnnounceController))
  46 )
  47
  48 activityPubClientRouter.get('/video-channels/:id',
  49   executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)),
  50   executeIfActivityPub(asyncMiddleware(videoChannelController))
  51 )
  52
  53 activityPubClientRouter.get('/video-channels/:id/announces/:accountId',
  54   executeIfActivityPub(asyncMiddleware(videoChannelsShareValidator)),
  55   executeIfActivityPub(asyncMiddleware(videoChannelAnnounceController))
  56 )
  57
  58 // ---------------------------------------------------------------------------
  59
  60 export {
  61   activityPubClientRouter
  62 }
  63
  64 // ---------------------------------------------------------------------------
  65
  66 function accountController (req: express.Request, res: express.Response, next: express.NextFunction) {
  67   const account: AccountModel = res.locals.account
  68
  69   return res.json(account.toActivityPubObject()).end()
  70 }
  71
  72 async function accountFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) {
  73   const account: AccountModel = res.locals.account
  74
  75   const page = req.query.page || 1
  76   const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
  77
  78   const result = await AccountFollowModel.listAcceptedFollowerUrlsForApi([ account.id ], undefined, start, count)
  79   const activityPubResult = activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result)
  80
  81   return res.json(activityPubResult)
  82 }
  83
  84 async function accountFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) {
  85   const account: AccountModel = res.locals.account
  86
  87   const page = req.query.page || 1
  88   const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
  89
  90   const result = await AccountFollowModel.listAcceptedFollowingUrlsForApi([ account.id ], undefined, start, count)
  91   const activityPubResult = activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result)
  92
  93   return res.json(activityPubResult)
  94 }
  95
  96 function videoController (req: express.Request, res: express.Response, next: express.NextFunction) {
  97   const video: VideoModel = res.locals.video
  98
  99   return res.json(video.toActivityPubObject())
 100 }
 101
 102 async function videoAnnounceController (req: express.Request, res: express.Response, next: express.NextFunction) {
 103   const share = res.locals.videoShare as VideoShareModel
 104   const object = await buildVideoAnnounceToFollowers(share.Account, res.locals.video, undefined)
 105
 106   return res.json(object)
 107 }
 108
 109 async function videoChannelAnnounceController (req: express.Request, res: express.Response, next: express.NextFunction) {
 110   const share = res.locals.videoChannelShare as VideoChannelShareModel
 111   const object = await buildVideoChannelAnnounceToFollowers(share.Account, share.VideoChannel, undefined)
 112
 113   return res.json(object)
 114 }
 115
 116 async function videoChannelController (req: express.Request, res: express.Response, next: express.NextFunction) {
 117   const videoChannel: VideoChannelModel = res.locals.videoChannel
 118
 119   return res.json(videoChannel.toActivityPubObject())
 120 }