1 // Intercept ActivityPub client requests
2 import * as express from 'express'
3 import { VideoPrivacy } from '../../../shared/models/videos'
4 import { activityPubCollectionPagination, activityPubContextify } from '../../helpers/activitypub'
5 import { pageToStartAndCount } from '../../helpers/core-utils'
6 import { ACTIVITY_PUB, CONFIG } from '../../initializers'
7 import { buildVideoAnnounceToFollowers } from '../../lib/activitypub/send'
8 import { audiencify, getAudience } from '../../lib/activitypub/send/misc'
9 import { asyncMiddleware, executeIfActivityPub, localAccountValidator } from '../../middlewares'
10 import { videoChannelsGetValidator, videosGetValidator, videosShareValidator } from '../../middlewares/validators'
11 import { videoCommentGetValidator } from '../../middlewares/validators/video-comments'
12 import { AccountModel } from '../../models/account/account'
13 import { ActorModel } from '../../models/activitypub/actor'
14 import { ActorFollowModel } from '../../models/activitypub/actor-follow'
15 import { VideoModel } from '../../models/video/video'
16 import { VideoChannelModel } from '../../models/video/video-channel'
17 import { VideoCommentModel } from '../../models/video/video-comment'
18 import { VideoShareModel } from '../../models/video/video-share'
20 const activityPubClientRouter = express.Router()
22 activityPubClientRouter.get('/accounts?/:name',
23 executeIfActivityPub(asyncMiddleware(localAccountValidator)),
24 executeIfActivityPub(accountController)
26 activityPubClientRouter.get('/accounts?/:name/followers',
27 executeIfActivityPub(asyncMiddleware(localAccountValidator)),
28 executeIfActivityPub(asyncMiddleware(accountFollowersController))
30 activityPubClientRouter.get('/accounts?/:name/following',
31 executeIfActivityPub(asyncMiddleware(localAccountValidator)),
32 executeIfActivityPub(asyncMiddleware(accountFollowingController))
35 activityPubClientRouter.get('/videos/watch/:id',
36 executeIfActivityPub(asyncMiddleware(videosGetValidator)),
37 executeIfActivityPub(asyncMiddleware(videoController))
39 activityPubClientRouter.get('/videos/watch/:id/announces',
40 executeIfActivityPub(asyncMiddleware(videosGetValidator)),
41 executeIfActivityPub(asyncMiddleware(videoAnnouncesController))
43 activityPubClientRouter.get('/videos/watch/:id/announces/:accountId',
44 executeIfActivityPub(asyncMiddleware(videosShareValidator)),
45 executeIfActivityPub(asyncMiddleware(videoAnnounceController))
47 activityPubClientRouter.get('/videos/watch/:id/likes',
48 executeIfActivityPub(asyncMiddleware(videosGetValidator)),
49 executeIfActivityPub(asyncMiddleware(videoLikesController))
51 activityPubClientRouter.get('/videos/watch/:id/dislikes',
52 executeIfActivityPub(asyncMiddleware(videosGetValidator)),
53 executeIfActivityPub(asyncMiddleware(videoDislikesController))
55 activityPubClientRouter.get('/videos/watch/:id/comments',
56 executeIfActivityPub(asyncMiddleware(videosGetValidator)),
57 executeIfActivityPub(asyncMiddleware(videoCommentsController))
59 activityPubClientRouter.get('/videos/watch/:videoId/comments/:commentId',
60 executeIfActivityPub(asyncMiddleware(videoCommentGetValidator)),
61 executeIfActivityPub(asyncMiddleware(videoCommentController))
64 activityPubClientRouter.get('/video-channels/:id',
65 executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)),
66 executeIfActivityPub(asyncMiddleware(videoChannelController))
68 activityPubClientRouter.get('/video-channels/:id/followers',
69 executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)),
70 executeIfActivityPub(asyncMiddleware(videoChannelFollowersController))
72 activityPubClientRouter.get('/video-channels/:id/following',
73 executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)),
74 executeIfActivityPub(asyncMiddleware(videoChannelFollowingController))
77 // ---------------------------------------------------------------------------
80 activityPubClientRouter
83 // ---------------------------------------------------------------------------
85 function accountController (req: express.Request, res: express.Response, next: express.NextFunction) {
86 const account: AccountModel = res.locals.account
88 return res.json(activityPubContextify(account.toActivityPubObject()))
92 async function accountFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) {
93 const account: AccountModel = res.locals.account
94 const activityPubResult = await actorFollowers(req, account.Actor)
96 return res.json(activityPubContextify(activityPubResult))
99 async function accountFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) {
100 const account: AccountModel = res.locals.account
101 const activityPubResult = await actorFollowing(req, account.Actor)
103 return res.json(activityPubContextify(activityPubResult))
106 async function videoController (req: express.Request, res: express.Response, next: express.NextFunction) {
107 const video: VideoModel = res.locals.video
109 // We need more attributes
110 const videoAll = await VideoModel.loadAndPopulateAll(video.id)
111 const audience = await getAudience(video.VideoChannel.Account.Actor, undefined, video.privacy === VideoPrivacy.PUBLIC)
112 const videoObject = audiencify(videoAll.toActivityPubObject(), audience)
114 return res.json(activityPubContextify(videoObject))
117 async function videoAnnounceController (req: express.Request, res: express.Response, next: express.NextFunction) {
118 const share = res.locals.videoShare as VideoShareModel
119 const object = await buildVideoAnnounceToFollowers(share.Actor, share, res.locals.video, undefined)
121 return res.json(activityPubContextify(object))
124 async function videoAnnouncesController (req: express.Request, res: express.Response, next: express.NextFunction) {
125 const video: VideoModel = res.locals.video
127 // We need more attributes
128 const videoAll = await VideoModel.loadAndPopulateAll(video.id)
129 const object = videoAll.toAnnouncesActivityPubObject()
131 return res.json(activityPubContextify(object))
134 async function videoLikesController (req: express.Request, res: express.Response, next: express.NextFunction) {
135 const video: VideoModel = res.locals.video
137 // We need more attributes
138 const videoAll = await VideoModel.loadAndPopulateAll(video.id)
139 const { likesObject } = videoAll.toRatesActivityPubObjects()
141 return res.json(activityPubContextify(likesObject))
144 async function videoDislikesController (req: express.Request, res: express.Response, next: express.NextFunction) {
145 const video: VideoModel = res.locals.video
147 // We need more attributes
148 const videoAll = await VideoModel.loadAndPopulateAll(video.id)
149 const { dislikesObject } = videoAll.toRatesActivityPubObjects()
151 return res.json(activityPubContextify(dislikesObject))
154 async function videoCommentsController (req: express.Request, res: express.Response, next: express.NextFunction) {
155 const video: VideoModel = res.locals.video
157 // We need more attributes
158 const videoAll = await VideoModel.loadAndPopulateAll(video.id)
159 const commentsObject = videoAll.toCommentsActivityPubObject()
161 return res.json(activityPubContextify(commentsObject))
164 async function videoChannelController (req: express.Request, res: express.Response, next: express.NextFunction) {
165 const videoChannel: VideoChannelModel = res.locals.videoChannel
167 return res.json(activityPubContextify(videoChannel.toActivityPubObject()))
170 async function videoChannelFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) {
171 const videoChannel: VideoChannelModel = res.locals.videoChannel
172 const activityPubResult = await actorFollowers(req, videoChannel.Actor)
174 return res.json(activityPubContextify(activityPubResult))
177 async function videoChannelFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) {
178 const videoChannel: VideoChannelModel = res.locals.videoChannel
179 const activityPubResult = await actorFollowing(req, videoChannel.Actor)
181 return res.json(activityPubContextify(activityPubResult))
184 async function videoCommentController (req: express.Request, res: express.Response, next: express.NextFunction) {
185 const videoComment: VideoCommentModel = res.locals.videoComment
187 const threadParentComments = await VideoCommentModel.listThreadParentComments(videoComment, undefined)
188 const isPublic = true // Comments are always public
189 const audience = await getAudience(videoComment.Account.Actor, undefined, isPublic)
191 const videoCommentObject = audiencify(videoComment.toActivityPubObject(threadParentComments), audience)
193 return res.json(activityPubContextify(videoCommentObject))
196 // ---------------------------------------------------------------------------
198 async function actorFollowing (req: express.Request, actor: ActorModel) {
199 const page = req.query.page || 1
200 const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
202 const result = await ActorFollowModel.listAcceptedFollowingUrlsForApi([ actor.id ], undefined, start, count)
203 return activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result)
206 async function actorFollowers (req: express.Request, actor: ActorModel) {
207 const page = req.query.page || 1
208 const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
210 const result = await ActorFollowModel.listAcceptedFollowerUrlsForApi([ actor.id ], undefined, start, count)
211 return activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result)