]> git.immae.eu Git - github/Chocobozzz/PeerTube.git/blobdiff - server/lib/activitypub/process/process-update.ts
Fetch video likes/dislikes too
[github/Chocobozzz/PeerTube.git] / server / lib / activitypub / process / process-update.ts
index a3bfb1bafcf28524cf451bf6ec58df1178477ec3..84a62de9ff140d6e71901c8b1a74b458cf1f61aa 100644 (file)
@@ -1,6 +1,5 @@
 import { VideoChannelObject, VideoTorrentObject } from '../../../../shared'
 import { ActivityUpdate } from '../../../../shared/models/activitypub/activity'
-import { getOrCreateAccount } from '../../../helpers/activitypub'
 import { retryTransactionWrapper } from '../../../helpers/database-utils'
 import { logger } from '../../../helpers/logger'
 import { resetSequelizeInstance } from '../../../helpers/utils'
@@ -9,9 +8,10 @@ import { AccountInstance } from '../../../models/account/account-interface'
 import { VideoInstance } from '../../../models/video/video-interface'
 import { videoActivityObjectToDBAttributes, videoFileActivityUrlToDBAttributes } from './misc'
 import Bluebird = require('bluebird')
+import { getOrCreateAccountAndServer } from '../account'
 
 async function processUpdateActivity (activity: ActivityUpdate) {
-  const account = await getOrCreateAccount(activity.actor)
+  const account = await getOrCreateAccountAndServer(activity.actor)
 
   if (activity.object.type === 'Video') {
     return processUpdateVideo(account, activity.object)
@@ -19,7 +19,7 @@ async function processUpdateActivity (activity: ActivityUpdate) {
     return processUpdateVideoChannel(account, activity.object)
   }
 
-  return undefined
+  return
 }
 
 // ---------------------------------------------------------------------------