diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-11-21 18:23:10 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-11-27 19:40:53 +0100 |
commit | e71bcc0f4b31ecfd84a786411febfc6d18a85258 (patch) | |
tree | ea31776b6bc69bd3b72e6c6f615cf94072271c82 /server/controllers/activitypub/outbox.ts | |
parent | b1cbc0dd3ee0fce6d8390b6d3996386a5b6097ac (diff) | |
download | PeerTube-e71bcc0f4b31ecfd84a786411febfc6d18a85258.tar.gz PeerTube-e71bcc0f4b31ecfd84a786411febfc6d18a85258.tar.zst PeerTube-e71bcc0f4b31ecfd84a786411febfc6d18a85258.zip |
Add outbox
Diffstat (limited to 'server/controllers/activitypub/outbox.ts')
-rw-r--r-- | server/controllers/activitypub/outbox.ts | 60 |
1 files changed, 60 insertions, 0 deletions
diff --git a/server/controllers/activitypub/outbox.ts b/server/controllers/activitypub/outbox.ts new file mode 100644 index 000000000..396fa2db5 --- /dev/null +++ b/server/controllers/activitypub/outbox.ts | |||
@@ -0,0 +1,60 @@ | |||
1 | import * as express from 'express' | ||
2 | import { Activity, ActivityAdd } from '../../../shared/models/activitypub/activity' | ||
3 | import { activityPubCollectionPagination, activityPubContextify } from '../../helpers/activitypub' | ||
4 | import { database as db } from '../../initializers' | ||
5 | import { addActivityData } from '../../lib/activitypub/send/send-add' | ||
6 | import { getAnnounceActivityPubUrl } from '../../lib/activitypub/url' | ||
7 | import { announceActivityData } from '../../lib/index' | ||
8 | import { asyncMiddleware, localAccountValidator } from '../../middlewares' | ||
9 | import { AccountInstance } from '../../models/account/account-interface' | ||
10 | import { pageToStartAndCount } from '../../helpers/core-utils' | ||
11 | import { ACTIVITY_PUB } from '../../initializers/constants' | ||
12 | |||
13 | const outboxRouter = express.Router() | ||
14 | |||
15 | outboxRouter.get('/account/:name/outbox', | ||
16 | localAccountValidator, | ||
17 | asyncMiddleware(outboxController) | ||
18 | ) | ||
19 | |||
20 | // --------------------------------------------------------------------------- | ||
21 | |||
22 | export { | ||
23 | outboxRouter | ||
24 | } | ||
25 | |||
26 | // --------------------------------------------------------------------------- | ||
27 | |||
28 | async function outboxController (req: express.Request, res: express.Response, next: express.NextFunction) { | ||
29 | const account: AccountInstance = res.locals.account | ||
30 | |||
31 | const page = req.params.page || 1 | ||
32 | const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) | ||
33 | |||
34 | const data = await db.Video.listAllAndSharedByAccountForOutbox(account.id, start, count) | ||
35 | const activities: Activity[] = [] | ||
36 | |||
37 | console.log(account.url) | ||
38 | |||
39 | for (const video of data.data) { | ||
40 | const videoObject = video.toActivityPubObject() | ||
41 | let addActivity: ActivityAdd = await addActivityData(video.url, account, video, video.VideoChannel.url, videoObject) | ||
42 | |||
43 | // This is a shared video | ||
44 | if (video.VideoShare !== undefined) { | ||
45 | const url = getAnnounceActivityPubUrl(video.url, account) | ||
46 | const announceActivity = await announceActivityData(url, account, addActivity) | ||
47 | activities.push(announceActivity) | ||
48 | } else { | ||
49 | activities.push(addActivity) | ||
50 | } | ||
51 | } | ||
52 | |||
53 | const newResult = { | ||
54 | data: activities, | ||
55 | total: data.total | ||
56 | } | ||
57 | const json = activityPubCollectionPagination(account.url + '/outbox', page, newResult) | ||
58 | |||
59 | return res.json(json).end() | ||
60 | } | ||