diff options
author | Chocobozzz <me@florianbigard.com> | 2018-01-15 09:46:46 +0100 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2018-01-15 09:47:19 +0100 |
commit | 7006bc6378eb0d480bc5b60f2c18876f0bb2a97d (patch) | |
tree | 1d914b217a7374ed6315ef2f4d38e921689d3705 /server/controllers/activitypub | |
parent | 304016c52ba275a293a2c8ee3287e569b398dc68 (diff) | |
download | PeerTube-7006bc6378eb0d480bc5b60f2c18876f0bb2a97d.tar.gz PeerTube-7006bc6378eb0d480bc5b60f2c18876f0bb2a97d.tar.zst PeerTube-7006bc6378eb0d480bc5b60f2c18876f0bb2a97d.zip |
Fix actor followers/following counts
Diffstat (limited to 'server/controllers/activitypub')
-rw-r--r-- | server/controllers/activitypub/client.ts | 63 |
1 files changed, 45 insertions, 18 deletions
diff --git a/server/controllers/activitypub/client.ts b/server/controllers/activitypub/client.ts index ec3f72b64..ba659984f 100644 --- a/server/controllers/activitypub/client.ts +++ b/server/controllers/activitypub/client.ts | |||
@@ -10,6 +10,7 @@ import { asyncMiddleware, executeIfActivityPub, localAccountValidator } from '.. | |||
10 | import { videoChannelsGetValidator, videosGetValidator, videosShareValidator } from '../../middlewares/validators' | 10 | import { videoChannelsGetValidator, videosGetValidator, videosShareValidator } from '../../middlewares/validators' |
11 | import { videoCommentGetValidator } from '../../middlewares/validators/video-comments' | 11 | import { videoCommentGetValidator } from '../../middlewares/validators/video-comments' |
12 | import { AccountModel } from '../../models/account/account' | 12 | import { AccountModel } from '../../models/account/account' |
13 | import { ActorModel } from '../../models/activitypub/actor' | ||
13 | import { ActorFollowModel } from '../../models/activitypub/actor-follow' | 14 | import { ActorFollowModel } from '../../models/activitypub/actor-follow' |
14 | import { VideoModel } from '../../models/video/video' | 15 | import { VideoModel } from '../../models/video/video' |
15 | import { VideoChannelModel } from '../../models/video/video-channel' | 16 | import { VideoChannelModel } from '../../models/video/video-channel' |
@@ -22,13 +23,11 @@ activityPubClientRouter.get('/accounts?/:name', | |||
22 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), | 23 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), |
23 | executeIfActivityPub(accountController) | 24 | executeIfActivityPub(accountController) |
24 | ) | 25 | ) |
25 | 26 | activityPubClientRouter.get('/accounts?/:name/followers', | |
26 | activityPubClientRouter.get('/accounts/:name/followers', | ||
27 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), | 27 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), |
28 | executeIfActivityPub(asyncMiddleware(accountFollowersController)) | 28 | executeIfActivityPub(asyncMiddleware(accountFollowersController)) |
29 | ) | 29 | ) |
30 | 30 | activityPubClientRouter.get('/accounts?/:name/following', | |
31 | activityPubClientRouter.get('/accounts/:name/following', | ||
32 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), | 31 | executeIfActivityPub(asyncMiddleware(localAccountValidator)), |
33 | executeIfActivityPub(asyncMiddleware(accountFollowingController)) | 32 | executeIfActivityPub(asyncMiddleware(accountFollowingController)) |
34 | ) | 33 | ) |
@@ -37,12 +36,10 @@ activityPubClientRouter.get('/videos/watch/:id', | |||
37 | executeIfActivityPub(asyncMiddleware(videosGetValidator)), | 36 | executeIfActivityPub(asyncMiddleware(videosGetValidator)), |
38 | executeIfActivityPub(asyncMiddleware(videoController)) | 37 | executeIfActivityPub(asyncMiddleware(videoController)) |
39 | ) | 38 | ) |
40 | |||
41 | activityPubClientRouter.get('/videos/watch/:id/announces/:accountId', | 39 | activityPubClientRouter.get('/videos/watch/:id/announces/:accountId', |
42 | executeIfActivityPub(asyncMiddleware(videosShareValidator)), | 40 | executeIfActivityPub(asyncMiddleware(videosShareValidator)), |
43 | executeIfActivityPub(asyncMiddleware(videoAnnounceController)) | 41 | executeIfActivityPub(asyncMiddleware(videoAnnounceController)) |
44 | ) | 42 | ) |
45 | |||
46 | activityPubClientRouter.get('/videos/watch/:videoId/comments/:commentId', | 43 | activityPubClientRouter.get('/videos/watch/:videoId/comments/:commentId', |
47 | executeIfActivityPub(asyncMiddleware(videoCommentGetValidator)), | 44 | executeIfActivityPub(asyncMiddleware(videoCommentGetValidator)), |
48 | executeIfActivityPub(asyncMiddleware(videoCommentController)) | 45 | executeIfActivityPub(asyncMiddleware(videoCommentController)) |
@@ -52,6 +49,14 @@ activityPubClientRouter.get('/video-channels/:id', | |||
52 | executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)), | 49 | executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)), |
53 | executeIfActivityPub(asyncMiddleware(videoChannelController)) | 50 | executeIfActivityPub(asyncMiddleware(videoChannelController)) |
54 | ) | 51 | ) |
52 | activityPubClientRouter.get('/video-channels/:id/followers', | ||
53 | executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)), | ||
54 | executeIfActivityPub(asyncMiddleware(videoChannelFollowersController)) | ||
55 | ) | ||
56 | activityPubClientRouter.get('/video-channels/:id/following', | ||
57 | executeIfActivityPub(asyncMiddleware(videoChannelsGetValidator)), | ||
58 | executeIfActivityPub(asyncMiddleware(videoChannelFollowingController)) | ||
59 | ) | ||
55 | 60 | ||
56 | // --------------------------------------------------------------------------- | 61 | // --------------------------------------------------------------------------- |
57 | 62 | ||
@@ -70,24 +75,14 @@ function accountController (req: express.Request, res: express.Response, next: e | |||
70 | 75 | ||
71 | async function accountFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) { | 76 | async function accountFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) { |
72 | const account: AccountModel = res.locals.account | 77 | const account: AccountModel = res.locals.account |
73 | 78 | const activityPubResult = await actorFollowers(req, account.Actor) | |
74 | const page = req.query.page || 1 | ||
75 | const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) | ||
76 | |||
77 | const result = await ActorFollowModel.listAcceptedFollowerUrlsForApi([ account.Actor.id ], undefined, start, count) | ||
78 | const activityPubResult = activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result) | ||
79 | 79 | ||
80 | return res.json(activityPubResult) | 80 | return res.json(activityPubResult) |
81 | } | 81 | } |
82 | 82 | ||
83 | async function accountFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) { | 83 | async function accountFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) { |
84 | const account: AccountModel = res.locals.account | 84 | const account: AccountModel = res.locals.account |
85 | 85 | const activityPubResult = await actorFollowing(req, account.Actor) | |
86 | const page = req.query.page || 1 | ||
87 | const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) | ||
88 | |||
89 | const result = await ActorFollowModel.listAcceptedFollowingUrlsForApi([ account.Actor.id ], undefined, start, count) | ||
90 | const activityPubResult = activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result) | ||
91 | 86 | ||
92 | return res.json(activityPubResult) | 87 | return res.json(activityPubResult) |
93 | } | 88 | } |
@@ -115,9 +110,41 @@ async function videoChannelController (req: express.Request, res: express.Respon | |||
115 | return res.json(videoChannel.toActivityPubObject()) | 110 | return res.json(videoChannel.toActivityPubObject()) |
116 | } | 111 | } |
117 | 112 | ||
113 | async function videoChannelFollowersController (req: express.Request, res: express.Response, next: express.NextFunction) { | ||
114 | const videoChannel: VideoChannelModel = res.locals.videoChannel | ||
115 | const activityPubResult = await actorFollowers(req, videoChannel.Actor) | ||
116 | |||
117 | return res.json(activityPubResult) | ||
118 | } | ||
119 | |||
120 | async function videoChannelFollowingController (req: express.Request, res: express.Response, next: express.NextFunction) { | ||
121 | const videoChannel: VideoChannelModel = res.locals.videoChannel | ||
122 | const activityPubResult = await actorFollowing(req, videoChannel.Actor) | ||
123 | |||
124 | return res.json(activityPubResult) | ||
125 | } | ||
126 | |||
118 | async function videoCommentController (req: express.Request, res: express.Response, next: express.NextFunction) { | 127 | async function videoCommentController (req: express.Request, res: express.Response, next: express.NextFunction) { |
119 | const videoComment: VideoCommentModel = res.locals.videoComment | 128 | const videoComment: VideoCommentModel = res.locals.videoComment |
120 | 129 | ||
121 | const threadParentComments = await VideoCommentModel.listThreadParentComments(videoComment, undefined) | 130 | const threadParentComments = await VideoCommentModel.listThreadParentComments(videoComment, undefined) |
122 | return res.json(videoComment.toActivityPubObject(threadParentComments)) | 131 | return res.json(videoComment.toActivityPubObject(threadParentComments)) |
123 | } | 132 | } |
133 | |||
134 | // --------------------------------------------------------------------------- | ||
135 | |||
136 | async function actorFollowing (req: express.Request, actor: ActorModel) { | ||
137 | const page = req.query.page || 1 | ||
138 | const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) | ||
139 | |||
140 | const result = await ActorFollowModel.listAcceptedFollowingUrlsForApi([ actor.id ], undefined, start, count) | ||
141 | return activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result) | ||
142 | } | ||
143 | |||
144 | async function actorFollowers (req: express.Request, actor: ActorModel) { | ||
145 | const page = req.query.page || 1 | ||
146 | const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) | ||
147 | |||
148 | const result = await ActorFollowModel.listAcceptedFollowerUrlsForApi([ actor.id ], undefined, start, count) | ||
149 | return activityPubCollectionPagination(CONFIG.WEBSERVER.URL + req.url, page, result) | ||
150 | } | ||