X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fprocess%2Fprocess-update.ts;h=11c6de8f56bc5f6f99e5ccbd0ca2189b1aa15def;hb=25ed141c7c7631ef21d8764c1163fbf8a6591391;hp=a3bfb1bafcf28524cf451bf6ec58df1178477ec3;hpb=54141398354e6e7b94aa3065a705a1251390111c;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/process/process-update.ts b/server/lib/activitypub/process/process-update.ts index a3bfb1baf..11c6de8f5 100644 --- a/server/lib/activitypub/process/process-update.ts +++ b/server/lib/activitypub/process/process-update.ts @@ -1,17 +1,17 @@ +import * as Bluebird from 'bluebird' 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' import { database as db } from '../../../initializers' import { AccountInstance } from '../../../models/account/account-interface' import { VideoInstance } from '../../../models/video/video-interface' +import { getOrCreateAccountAndServer } from '../account' import { videoActivityObjectToDBAttributes, videoFileActivityUrlToDBAttributes } from './misc' -import Bluebird = require('bluebird') 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 } // ---------------------------------------------------------------------------