+import * as Bluebird from 'bluebird'
+import * as validator from 'validator'
import { ResultList } from '../../shared/models'
import { Activity, ActivityPubActor } from '../../shared/models/activitypub'
import { ACTIVITY_PUB } from '../initializers'
import { ActorModel } from '../models/activitypub/actor'
import { signObject } from './peertube-crypto'
+import { pageToStartAndCount } from './core-utils'
function activityPubContextify <T> (data: T) {
- return Object.assign(data,{
+ return Object.assign(data, {
'@context': [
'https://www.w3.org/ns/activitystreams',
'https://w3id.org/security/v1',
{
- 'RsaSignature2017': 'https://w3id.org/security#RsaSignature2017',
- 'Hashtag': 'as:Hashtag',
- 'uuid': 'http://schema.org/identifier',
- 'category': 'http://schema.org/category',
- 'licence': 'http://schema.org/license',
- 'sensitive': 'as:sensitive',
- 'language': 'http://schema.org/inLanguage',
- 'views': 'http://schema.org/Number',
- 'size': 'http://schema.org/Number',
- 'commentsEnabled': 'http://schema.org/Boolean',
- 'support': 'http://schema.org/Text'
+ RsaSignature2017: 'https://w3id.org/security#RsaSignature2017',
+ pt: 'https://joinpeertube.org/ns',
+ schema: 'http://schema.org#',
+ Hashtag: 'as:Hashtag',
+ uuid: 'schema:identifier',
+ category: 'schema:category',
+ licence: 'schema:license',
+ subtitleLanguage: 'schema:subtitleLanguage',
+ sensitive: 'as:sensitive',
+ language: 'schema:inLanguage',
+ views: 'schema:Number',
+ stats: 'schema:Number',
+ size: 'schema:Number',
+ fps: 'schema:Number',
+ commentsEnabled: 'schema:Boolean',
+ downloadEnabled: 'schema:Boolean',
+ waitTranscoding: 'schema:Boolean',
+ expires: 'schema:expires',
+ support: 'schema:Text',
+ CacheFile: 'pt:CacheFile'
},
{
likes: {
})
}
-function activityPubCollection (url: string, results: any[]) {
- return {
- id: url,
- type: 'OrderedCollection',
- totalItems: results.length,
- orderedItems: results
+type ActivityPubCollectionPaginationHandler = (start: number, count: number) => Bluebird<ResultList<any>> | Promise<ResultList<any>>
+async function activityPubCollectionPagination (url: string, handler: ActivityPubCollectionPaginationHandler, page?: any) {
+ if (!page || !validator.isInt(page)) {
+ // We just display the first page URL, we only need the total items
+ const result = await handler(0, 1)
+
+ return {
+ id: url,
+ type: 'OrderedCollection',
+ totalItems: result.total,
+ first: url + '?page=1'
+ }
}
-}
-function activityPubCollectionPagination (url: string, page: any, result: ResultList<any>) {
- let next: string
- let prev: string
+ const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE)
+ const result = await handler(start, count)
+
+ let next: string | undefined
+ let prev: string | undefined
// Assert page is a number
page = parseInt(page, 10)
prev = url + '?page=' + (page - 1)
}
- const orderedCollectionPagination = {
+ return {
id: url + '?page=' + page,
type: 'OrderedCollectionPage',
prev,
next,
partOf: url,
- orderedItems: result.data
- }
-
- if (page === 1) {
- return activityPubContextify({
- id: url,
- type: 'OrderedCollection',
- totalItems: result.total,
- first: orderedCollectionPagination
- })
- } else {
- orderedCollectionPagination['totalItems'] = result.total
+ orderedItems: result.data,
+ totalItems: result.total
}
- return orderedCollectionPagination
}
function buildSignedActivity (byActor: ActorModel, data: Object) {
getActorUrl,
activityPubContextify,
activityPubCollectionPagination,
- activityPubCollection,
buildSignedActivity
}