X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fcontrollers%2Factivitypub%2Foutbox.ts;h=f3dd2ad7d3e5fed8e1be89003813054cde20a24b;hb=47581df0737ebcc058a5863143c752f9112a4424;hp=ae7adcd4c30aad11ab782c97261009fd0442f587;hpb=2186386cca113506791583cb07d6ccacba7af4e0;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/controllers/activitypub/outbox.ts b/server/controllers/activitypub/outbox.ts index ae7adcd4c..f3dd2ad7d 100644 --- a/server/controllers/activitypub/outbox.ts +++ b/server/controllers/activitypub/outbox.ts @@ -3,13 +3,12 @@ import { Activity } from '../../../shared/models/activitypub/activity' import { VideoPrivacy } from '../../../shared/models/videos' import { activityPubCollectionPagination, activityPubContextify } from '../../helpers/activitypub' import { logger } from '../../helpers/logger' -import { announceActivityData, createActivityData } from '../../lib/activitypub/send' +import { buildAnnounceActivity, buildCreateActivity } from '../../lib/activitypub/send' import { buildAudience } from '../../lib/activitypub/audience' -import { asyncMiddleware, localAccountValidator } from '../../middlewares' -import { AccountModel } from '../../models/account/account' -import { ActorModel } from '../../models/activitypub/actor' +import { asyncMiddleware, localAccountValidator, localVideoChannelValidator } from '../../middlewares' import { VideoModel } from '../../models/video/video' import { activityPubResponse } from './utils' +import { MActorLight } from '@server/typings/models' const outboxRouter = express.Router() @@ -18,6 +17,11 @@ outboxRouter.get('/accounts/:name/outbox', asyncMiddleware(outboxController) ) +outboxRouter.get('/video-channels/:name/outbox', + localVideoChannelValidator, + asyncMiddleware(outboxController) +) + // --------------------------------------------------------------------------- export { @@ -26,10 +30,10 @@ export { // --------------------------------------------------------------------------- -async function outboxController (req: express.Request, res: express.Response, next: express.NextFunction) { - const account: AccountModel = res.locals.account - const actor = account.Actor - const actorOutboxUrl = account.Actor.url + '/outbox' +async function outboxController (req: express.Request, res: express.Response) { + const accountOrVideoChannel = res.locals.account || res.locals.videoChannel + const actor = accountOrVideoChannel.Actor + const actorOutboxUrl = actor.url + '/outbox' logger.info('Receiving outbox request for %s.', actorOutboxUrl) @@ -39,14 +43,10 @@ async function outboxController (req: express.Request, res: express.Response, ne return activityPubResponse(activityPubContextify(json), res) } -async function buildActivities (actor: ActorModel, start: number, count: number) { +async function buildActivities (actor: MActorLight, start: number, count: number) { const data = await VideoModel.listAllAndSharedByActorForOutbox(actor.id, start, count) const activities: Activity[] = [] - // Avoid too many SQL requests - const actors = data.data.map(v => v.VideoChannel.Account.Actor) - actors.push(actor) - for (const video of data.data) { const byActor = video.VideoChannel.Account.Actor const createActivityAudience = buildAudience([ byActor.followersUrl ], video.privacy === VideoPrivacy.PUBLIC) @@ -54,12 +54,12 @@ async function buildActivities (actor: ActorModel, start: number, count: number) // This is a shared video if (video.VideoShares !== undefined && video.VideoShares.length !== 0) { const videoShare = video.VideoShares[0] - const announceActivity = announceActivityData(videoShare.url, actor, video.url, createActivityAudience) + const announceActivity = buildAnnounceActivity(videoShare.url, actor, video.url, createActivityAudience) activities.push(announceActivity) } else { const videoObject = video.toActivityPubObject() - const createActivity = createActivityData(video.url, byActor, videoObject, createActivityAudience) + const createActivity = buildCreateActivity(video.url, byActor, videoObject, createActivityAudience) activities.push(createActivity) }