aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/lib/activitypub/process/process-undo.ts
diff options
context:
space:
mode:
authorChocobozzz <me@florianbigard.com>2019-08-09 08:17:16 +0200
committerChocobozzz <me@florianbigard.com>2019-08-09 08:17:16 +0200
commit5224c394b3bbac6ec1543e41fa0ec6db436e84fa (patch)
tree36eaecfe095547aca903a8a43fb6e0b0b01899a9 /server/lib/activitypub/process/process-undo.ts
parent511765c9f86fb07d5d856decd9dbf0ec2092f4fe (diff)
downloadPeerTube-5224c394b3bbac6ec1543e41fa0ec6db436e84fa.tar.gz
PeerTube-5224c394b3bbac6ec1543e41fa0ec6db436e84fa.tar.zst
PeerTube-5224c394b3bbac6ec1543e41fa0ec6db436e84fa.zip
Stronger actor association typing in AP functions
Diffstat (limited to 'server/lib/activitypub/process/process-undo.ts')
-rw-r--r--server/lib/activitypub/process/process-undo.ts11
1 files changed, 6 insertions, 5 deletions
diff --git a/server/lib/activitypub/process/process-undo.ts b/server/lib/activitypub/process/process-undo.ts
index 7a0f90adf..c37ee38bb 100644
--- a/server/lib/activitypub/process/process-undo.ts
+++ b/server/lib/activitypub/process/process-undo.ts
@@ -11,6 +11,7 @@ import { getOrCreateVideoAndAccountAndChannel } from '../videos'
11import { VideoShareModel } from '../../../models/video/video-share' 11import { VideoShareModel } from '../../../models/video/video-share'
12import { VideoRedundancyModel } from '../../../models/redundancy/video-redundancy' 12import { VideoRedundancyModel } from '../../../models/redundancy/video-redundancy'
13import { APProcessorOptions } from '../../../typings/activitypub-processor.model' 13import { APProcessorOptions } from '../../../typings/activitypub-processor.model'
14import { SignatureActorModel } from '../../../typings/models'
14 15
15async function processUndoActivity (options: APProcessorOptions<ActivityUndo>) { 16async function processUndoActivity (options: APProcessorOptions<ActivityUndo>) {
16 const { activity, byActor } = options 17 const { activity, byActor } = options
@@ -53,7 +54,7 @@ export {
53 54
54// --------------------------------------------------------------------------- 55// ---------------------------------------------------------------------------
55 56
56async function processUndoLike (byActor: ActorModel, activity: ActivityUndo) { 57async function processUndoLike (byActor: SignatureActorModel, activity: ActivityUndo) {
57 const likeActivity = activity.object as ActivityLike 58 const likeActivity = activity.object as ActivityLike
58 59
59 const { video } = await getOrCreateVideoAndAccountAndChannel({ videoObject: likeActivity.object }) 60 const { video } = await getOrCreateVideoAndAccountAndChannel({ videoObject: likeActivity.object })
@@ -76,7 +77,7 @@ async function processUndoLike (byActor: ActorModel, activity: ActivityUndo) {
76 }) 77 })
77} 78}
78 79
79async function processUndoDislike (byActor: ActorModel, activity: ActivityUndo) { 80async function processUndoDislike (byActor: SignatureActorModel, activity: ActivityUndo) {
80 const dislike = activity.object.type === 'Dislike' 81 const dislike = activity.object.type === 'Dislike'
81 ? activity.object 82 ? activity.object
82 : activity.object.object as DislikeObject 83 : activity.object.object as DislikeObject
@@ -101,7 +102,7 @@ async function processUndoDislike (byActor: ActorModel, activity: ActivityUndo)
101 }) 102 })
102} 103}
103 104
104async function processUndoCacheFile (byActor: ActorModel, activity: ActivityUndo) { 105async function processUndoCacheFile (byActor: SignatureActorModel, activity: ActivityUndo) {
105 const cacheFileObject = activity.object.object as CacheFileObject 106 const cacheFileObject = activity.object.object as CacheFileObject
106 107
107 const { video } = await getOrCreateVideoAndAccountAndChannel({ videoObject: cacheFileObject.object }) 108 const { video } = await getOrCreateVideoAndAccountAndChannel({ videoObject: cacheFileObject.object })
@@ -126,7 +127,7 @@ async function processUndoCacheFile (byActor: ActorModel, activity: ActivityUndo
126 }) 127 })
127} 128}
128 129
129function processUndoFollow (follower: ActorModel, followActivity: ActivityFollow) { 130function processUndoFollow (follower: SignatureActorModel, followActivity: ActivityFollow) {
130 return sequelizeTypescript.transaction(async t => { 131 return sequelizeTypescript.transaction(async t => {
131 const following = await ActorModel.loadByUrlAndPopulateAccountAndChannel(followActivity.object, t) 132 const following = await ActorModel.loadByUrlAndPopulateAccountAndChannel(followActivity.object, t)
132 const actorFollow = await ActorFollowModel.loadByActorAndTarget(follower.id, following.id, t) 133 const actorFollow = await ActorFollowModel.loadByActorAndTarget(follower.id, following.id, t)
@@ -139,7 +140,7 @@ function processUndoFollow (follower: ActorModel, followActivity: ActivityFollow
139 }) 140 })
140} 141}
141 142
142function processUndoAnnounce (byActor: ActorModel, announceActivity: ActivityAnnounce) { 143function processUndoAnnounce (byActor: SignatureActorModel, announceActivity: ActivityAnnounce) {
143 return sequelizeTypescript.transaction(async t => { 144 return sequelizeTypescript.transaction(async t => {
144 const share = await VideoShareModel.loadByUrl(announceActivity.id, t) 145 const share = await VideoShareModel.loadByUrl(announceActivity.id, t)
145 if (!share) throw new Error(`Unknown video share ${announceActivity.id}.`) 146 if (!share) throw new Error(`Unknown video share ${announceActivity.id}.`)