server/helpers/custom-validators/activitypub/activity.ts

   1 import validator from 'validator'
   2 import { Activity, ActivityType } from '../../../../shared/models/activitypub'
   3 import { isAbuseReasonValid } from '../abuses'
   4 import { exists } from '../misc'
   5 import { sanitizeAndCheckActorObject } from './actor'
   6 import { isCacheFileObjectValid } from './cache-file'
   7 import { isActivityPubUrlValid, isBaseActivityValid, isObjectValid } from './misc'
   8 import { isPlaylistObjectValid } from './playlist'
   9 import { sanitizeAndCheckVideoCommentObject } from './video-comments'
  10 import { sanitizeAndCheckVideoTorrentObject } from './videos'
  11 import { isWatchActionObjectValid } from './watch-action'
  12
  13 function isRootActivityValid (activity: any) {
  14   return isCollection(activity) || isActivity(activity)
  15 }
  16
  17 function isCollection (activity: any) {
  18   return (activity.type === 'Collection' || activity.type === 'OrderedCollection') &&
  19     validator.isInt(activity.totalItems, { min: 0 }) &&
  20     Array.isArray(activity.items)
  21 }
  22
  23 function isActivity (activity: any) {
  24   return isActivityPubUrlValid(activity.id) &&
  25     exists(activity.actor) &&
  26     (isActivityPubUrlValid(activity.actor) || isActivityPubUrlValid(activity.actor.id))
  27 }
  28
  29 const activityCheckers: { [ P in ActivityType ]: (activity: Activity) => boolean } = {
  30   Create: isCreateActivityValid,
  31   Update: isUpdateActivityValid,
  32   Delete: isDeleteActivityValid,
  33   Follow: isFollowActivityValid,
  34   Accept: isAcceptActivityValid,
  35   Reject: isRejectActivityValid,
  36   Announce: isAnnounceActivityValid,
  37   Undo: isUndoActivityValid,
  38   Like: isLikeActivityValid,
  39   View: isViewActivityValid,
  40   Flag: isFlagActivityValid,
  41   Dislike: isDislikeActivityValid
  42 }
  43
  44 function isActivityValid (activity: any) {
  45   const checker = activityCheckers[activity.type]
  46   // Unknown activity type
  47   if (!checker) return false
  48
  49   return checker(activity)
  50 }
  51
  52 function isFlagActivityValid (activity: any) {
  53   return isBaseActivityValid(activity, 'Flag') &&
  54     isAbuseReasonValid(activity.content) &&
  55     isActivityPubUrlValid(activity.object)
  56 }
  57
  58 function isLikeActivityValid (activity: any) {
  59   return isBaseActivityValid(activity, 'Like') &&
  60     isObjectValid(activity.object)
  61 }
  62
  63 function isDislikeActivityValid (activity: any) {
  64   return isBaseActivityValid(activity, 'Dislike') &&
  65     isObjectValid(activity.object)
  66 }
  67
  68 function isAnnounceActivityValid (activity: any) {
  69   return isBaseActivityValid(activity, 'Announce') &&
  70     isObjectValid(activity.object)
  71 }
  72
  73 function isViewActivityValid (activity: any) {
  74   return isBaseActivityValid(activity, 'View') &&
  75     isActivityPubUrlValid(activity.actor) &&
  76     isActivityPubUrlValid(activity.object)
  77 }
  78
  79 function isCreateActivityValid (activity: any) {
  80   return isBaseActivityValid(activity, 'Create') &&
  81     (
  82       isViewActivityValid(activity.object) ||
  83       isDislikeActivityValid(activity.object) ||
  84       isFlagActivityValid(activity.object) ||
  85       isPlaylistObjectValid(activity.object) ||
  86       isWatchActionObjectValid(activity.object) ||
  87
  88       isCacheFileObjectValid(activity.object) ||
  89       sanitizeAndCheckVideoCommentObject(activity.object) ||
  90       sanitizeAndCheckVideoTorrentObject(activity.object)
  91     )
  92 }
  93
  94 function isUpdateActivityValid (activity: any) {
  95   return isBaseActivityValid(activity, 'Update') &&
  96     (
  97       isCacheFileObjectValid(activity.object) ||
  98       isPlaylistObjectValid(activity.object) ||
  99       sanitizeAndCheckVideoTorrentObject(activity.object) ||
 100       sanitizeAndCheckActorObject(activity.object)
 101     )
 102 }
 103
 104 function isDeleteActivityValid (activity: any) {
 105   // We don't really check objects
 106   return isBaseActivityValid(activity, 'Delete') &&
 107     isObjectValid(activity.object)
 108 }
 109
 110 function isFollowActivityValid (activity: any) {
 111   return isBaseActivityValid(activity, 'Follow') &&
 112     isObjectValid(activity.object)
 113 }
 114
 115 function isAcceptActivityValid (activity: any) {
 116   return isBaseActivityValid(activity, 'Accept')
 117 }
 118
 119 function isRejectActivityValid (activity: any) {
 120   return isBaseActivityValid(activity, 'Reject')
 121 }
 122
 123 function isUndoActivityValid (activity: any) {
 124   return isBaseActivityValid(activity, 'Undo') &&
 125     (
 126       isFollowActivityValid(activity.object) ||
 127       isLikeActivityValid(activity.object) ||
 128       isDislikeActivityValid(activity.object) ||
 129       isAnnounceActivityValid(activity.object) ||
 130       isCreateActivityValid(activity.object)
 131     )
 132 }
 133
 134 // ---------------------------------------------------------------------------
 135
 136 export {
 137   isRootActivityValid,
 138   isActivityValid,
 139   isFlagActivityValid,
 140   isLikeActivityValid,
 141   isDislikeActivityValid,
 142   isAnnounceActivityValid,
 143   isViewActivityValid,
 144   isCreateActivityValid,
 145   isUpdateActivityValid,
 146   isDeleteActivityValid,
 147   isFollowActivityValid,
 148   isAcceptActivityValid,
 149   isRejectActivityValid,
 150   isUndoActivityValid
 151 }