diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-11-09 17:51:58 +0100 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-11-27 19:40:51 +0100 |
commit | e4f97babf701481b55cc10fb3448feab5f97c867 (patch) | |
tree | af37402a594dc5ff09f71ecb0687e8cfe4cdb471 /server/lib/activitypub/send-request.ts | |
parent | 343ad675f2a26c15b86150a9a3552e619d5d44f4 (diff) | |
download | PeerTube-e4f97babf701481b55cc10fb3448feab5f97c867.tar.gz PeerTube-e4f97babf701481b55cc10fb3448feab5f97c867.tar.zst PeerTube-e4f97babf701481b55cc10fb3448feab5f97c867.zip |
Begin activitypub
Diffstat (limited to 'server/lib/activitypub/send-request.ts')
-rw-r--r-- | server/lib/activitypub/send-request.ts | 129 |
1 files changed, 129 insertions, 0 deletions
diff --git a/server/lib/activitypub/send-request.ts b/server/lib/activitypub/send-request.ts new file mode 100644 index 000000000..6a31c226d --- /dev/null +++ b/server/lib/activitypub/send-request.ts | |||
@@ -0,0 +1,129 @@ | |||
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 | } | ||