X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fcontrollers%2Factivitypub%2Foutbox.ts;h=916a110a80aa24814e1b02921f1cc6125f3b8cbc;hb=bdd428a6d9138d751f8cde82867022a93f1a76cc;hp=38b6ec9764bd9365c84546b5178d8eb7e163a830;hpb=97567dd81f508dd6295ac4d73d849aa2ce0a6549;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/controllers/activitypub/outbox.ts b/server/controllers/activitypub/outbox.ts index 38b6ec976..916a110a8 100644 --- a/server/controllers/activitypub/outbox.ts +++ b/server/controllers/activitypub/outbox.ts @@ -6,20 +6,21 @@ import { logger } from '../../helpers/logger' import { buildAnnounceActivity, buildCreateActivity } from '../../lib/activitypub/send' import { buildAudience } from '../../lib/activitypub/audience' import { asyncMiddleware, localAccountValidator, localVideoChannelValidator } from '../../middlewares' -import { AccountModel } from '../../models/account/account' -import { ActorModel } from '../../models/activitypub/actor' import { VideoModel } from '../../models/video/video' import { activityPubResponse } from './utils' -import { VideoChannelModel } from '../../models/video/video-channel' +import { MActorLight } from '@server/typings/models' +import { apPaginationValidator } from '../../middlewares/validators/activitypub' const outboxRouter = express.Router() outboxRouter.get('/accounts/:name/outbox', + apPaginationValidator, localAccountValidator, asyncMiddleware(outboxController) ) outboxRouter.get('/video-channels/:name/outbox', + apPaginationValidator, localVideoChannelValidator, asyncMiddleware(outboxController) ) @@ -40,19 +41,15 @@ async function outboxController (req: express.Request, res: express.Response) { logger.info('Receiving outbox request for %s.', actorOutboxUrl) const handler = (start: number, count: number) => buildActivities(actor, start, count) - const json = await activityPubCollectionPagination(actorOutboxUrl, handler, req.query.page) + const json = await activityPubCollectionPagination(actorOutboxUrl, handler, req.query.page, req.query.size) 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)