]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blame_incremental - server/helpers/custom-validators/activitypub/activity.ts
Merge branch 'release/2.1.0' into develop
[github/Chocobozzz/PeerTube.git] / server / helpers / custom-validators / activitypub / activity.ts
... / ...
CommitLineData
1import validator from 'validator'
2import { Activity, ActivityType } from '../../../../shared/models/activitypub'
3import { sanitizeAndCheckActorObject } from './actor'
4import { isActivityPubUrlValid, isBaseActivityValid, isObjectValid } from './misc'
5import { isDislikeActivityValid } from './rate'
6import { sanitizeAndCheckVideoCommentObject } from './video-comments'
7import { sanitizeAndCheckVideoTorrentObject } from './videos'
8import { isViewActivityValid } from './view'
9import { exists } from '../misc'
10import { isCacheFileObjectValid } from './cache-file'
11import { isFlagActivityValid } from './flag'
12import { isPlaylistObjectValid } from './playlist'
13
14function isRootActivityValid (activity: any) {
15 return isCollection(activity) || isActivity(activity)
16}
17
18function isCollection (activity: any) {
19 return (activity.type === 'Collection' || activity.type === 'OrderedCollection') &&
20 validator.isInt(activity.totalItems, { min: 0 }) &&
21 Array.isArray(activity.items)
22}
23
24function isActivity (activity: any) {
25 return isActivityPubUrlValid(activity.id) &&
26 exists(activity.actor) &&
27 (isActivityPubUrlValid(activity.actor) || isActivityPubUrlValid(activity.actor.id))
28}
29
30const activityCheckers: { [ P in ActivityType ]: (activity: Activity) => boolean } = {
31 Create: checkCreateActivity,
32 Update: checkUpdateActivity,
33 Delete: checkDeleteActivity,
34 Follow: checkFollowActivity,
35 Accept: checkAcceptActivity,
36 Reject: checkRejectActivity,
37 Announce: checkAnnounceActivity,
38 Undo: checkUndoActivity,
39 Like: checkLikeActivity,
40 View: checkViewActivity,
41 Flag: checkFlagActivity,
42 Dislike: checkDislikeActivity
43}
44
45function isActivityValid (activity: any) {
46 const checker = activityCheckers[activity.type]
47 // Unknown activity type
48 if (!checker) return false
49
50 return checker(activity)
51}
52
53// ---------------------------------------------------------------------------
54
55export {
56 isRootActivityValid,
57 isActivityValid
58}
59
60// ---------------------------------------------------------------------------
61
62function checkViewActivity (activity: any) {
63 return isBaseActivityValid(activity, 'View') &&
64 isViewActivityValid(activity)
65}
66
67function checkFlagActivity (activity: any) {
68 return isBaseActivityValid(activity, 'Flag') &&
69 isFlagActivityValid(activity)
70}
71
72function checkDislikeActivity (activity: any) {
73 return isBaseActivityValid(activity, 'Dislike') &&
74 isDislikeActivityValid(activity)
75}
76
77function checkCreateActivity (activity: any) {
78 return isBaseActivityValid(activity, 'Create') &&
79 (
80 isViewActivityValid(activity.object) ||
81 isDislikeActivityValid(activity.object) ||
82 isFlagActivityValid(activity.object) ||
83 isPlaylistObjectValid(activity.object) ||
84
85 isCacheFileObjectValid(activity.object) ||
86 sanitizeAndCheckVideoCommentObject(activity.object) ||
87 sanitizeAndCheckVideoTorrentObject(activity.object)
88 )
89}
90
91function checkUpdateActivity (activity: any) {
92 return isBaseActivityValid(activity, 'Update') &&
93 (
94 isCacheFileObjectValid(activity.object) ||
95 isPlaylistObjectValid(activity.object) ||
96 sanitizeAndCheckVideoTorrentObject(activity.object) ||
97 sanitizeAndCheckActorObject(activity.object)
98 )
99}
100
101function checkDeleteActivity (activity: any) {
102 // We don't really check objects
103 return isBaseActivityValid(activity, 'Delete') &&
104 isObjectValid(activity.object)
105}
106
107function checkFollowActivity (activity: any) {
108 return isBaseActivityValid(activity, 'Follow') &&
109 isObjectValid(activity.object)
110}
111
112function checkAcceptActivity (activity: any) {
113 return isBaseActivityValid(activity, 'Accept')
114}
115
116function checkRejectActivity (activity: any) {
117 return isBaseActivityValid(activity, 'Reject')
118}
119
120function checkAnnounceActivity (activity: any) {
121 return isBaseActivityValid(activity, 'Announce') &&
122 isObjectValid(activity.object)
123}
124
125function checkUndoActivity (activity: any) {
126 return isBaseActivityValid(activity, 'Undo') &&
127 (
128 checkFollowActivity(activity.object) ||
129 checkLikeActivity(activity.object) ||
130 checkDislikeActivity(activity.object) ||
131 checkAnnounceActivity(activity.object) ||
132 checkCreateActivity(activity.object)
133 )
134}
135
136function checkLikeActivity (activity: any) {
137 return isBaseActivityValid(activity, 'Like') &&
138 isObjectValid(activity.object)
139}