X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fshare.ts;h=0fefcbbc560fdfafb0febaa0d611ae9365803bc8;hb=082d32eb8873190e48329b61b91f87d71f3cf812;hp=327955dd26089c795aa3cb47a6480ccaf9f55c01;hpb=49af5ac8c2653cb0ef23479c9d3256c5b724d49d;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/share.ts b/server/lib/activitypub/share.ts index 327955dd2..0fefcbbc5 100644 --- a/server/lib/activitypub/share.ts +++ b/server/lib/activitypub/share.ts @@ -1,15 +1,15 @@ -import * as Bluebird from 'bluebird' +import { map } from 'bluebird' import { Transaction } from 'sequelize' import { getServerActor } from '@server/models/application/application' -import { checkUrlsSameHost, getAPId } from '../../helpers/activitypub' import { logger, loggerTagsFactory } from '../../helpers/logger' import { doJSONRequest } from '../../helpers/requests' import { CRAWL_REQUEST_CONCURRENCY } from '../../initializers/constants' import { VideoShareModel } from '../../models/video/video-share' import { MChannelActorLight, MVideo, MVideoAccountLight, MVideoId } from '../../types/models/video' -import { getOrCreateActorAndServerAndModel } from './actor' +import { getAPId } from './activity' +import { getOrCreateAPActor } from './actors' import { sendUndoAnnounce, sendVideoAnnounce } from './send' -import { getLocalVideoAnnounceActivityPubUrl } from './url' +import { checkUrlsSameHost, getLocalVideoAnnounceActivityPubUrl } from './url' const lTags = loggerTagsFactory('share') @@ -38,7 +38,7 @@ async function changeVideoChannelShare ( } async function addVideoShares (shareUrls: string[], video: MVideoId) { - await Bluebird.map(shareUrls, async shareUrl => { + await map(shareUrls, async shareUrl => { try { await addVideoShare(shareUrl, video) } catch (err) { @@ -64,7 +64,7 @@ async function addVideoShare (shareUrl: string, video: MVideoId) { throw new Error(`Actor url ${actorUrl} has not the same host than the share url ${shareUrl}`) } - const actor = await getOrCreateActorAndServerAndModel(actorUrl) + const actor = await getOrCreateAPActor(actorUrl) const entry = { actorId: actor.id,