X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fcontrollers%2Factivitypub%2Foutbox.ts;h=8c63eeb2ec8ed02b57955fb017fd8aa4c2978c37;hb=40ff57078e15d5b86ee6b71e198b95d3feb78eaf;hp=396fa2db56ef7b7e66bf1170c1349f7c3ce4e0bb;hpb=e71bcc0f4b31ecfd84a786411febfc6d18a85258;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/controllers/activitypub/outbox.ts b/server/controllers/activitypub/outbox.ts index 396fa2db5..8c63eeb2e 100644 --- a/server/controllers/activitypub/outbox.ts +++ b/server/controllers/activitypub/outbox.ts @@ -1,14 +1,14 @@ import * as express from 'express' import { Activity, ActivityAdd } from '../../../shared/models/activitypub/activity' -import { activityPubCollectionPagination, activityPubContextify } from '../../helpers/activitypub' +import { activityPubCollectionPagination } from '../../helpers/activitypub' +import { pageToStartAndCount } from '../../helpers/core-utils' import { database as db } from '../../initializers' +import { ACTIVITY_PUB } from '../../initializers/constants' import { addActivityData } from '../../lib/activitypub/send/send-add' import { getAnnounceActivityPubUrl } from '../../lib/activitypub/url' import { announceActivityData } from '../../lib/index' import { asyncMiddleware, localAccountValidator } from '../../middlewares' import { AccountInstance } from '../../models/account/account-interface' -import { pageToStartAndCount } from '../../helpers/core-utils' -import { ACTIVITY_PUB } from '../../initializers/constants' const outboxRouter = express.Router() @@ -28,24 +28,26 @@ export { async function outboxController (req: express.Request, res: express.Response, next: express.NextFunction) { const account: AccountInstance = res.locals.account - const page = req.params.page || 1 + const page = req.query.page || 1 const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) const data = await db.Video.listAllAndSharedByAccountForOutbox(account.id, start, count) const activities: Activity[] = [] - console.log(account.url) - for (const video of data.data) { const videoObject = video.toActivityPubObject() - let addActivity: ActivityAdd = await addActivityData(video.url, account, video, video.VideoChannel.url, videoObject) // This is a shared video - if (video.VideoShare !== undefined) { + if (video.VideoShares !== undefined && video.VideoShares.length !== 0) { + const addActivity = await addActivityData(video.url, video.VideoChannel.Account, video, video.VideoChannel.url, videoObject) + const url = getAnnounceActivityPubUrl(video.url, account) const announceActivity = await announceActivityData(url, account, addActivity) + activities.push(announceActivity) } else { + const addActivity = await addActivityData(video.url, account, video, video.VideoChannel.url, videoObject) + activities.push(addActivity) } }