import * as Bluebird from 'bluebird' import * as validator from 'validator' import { ResultList } from '../../shared/models' import { Activity } from '../../shared/models/activitypub' import { ACTIVITY_PUB } from '../initializers' import { ActorModel } from '../models/activitypub/actor' import { signJsonLDObject } from './peertube-crypto' import { pageToStartAndCount } from './core-utils' import { parse } from 'url' function activityPubContextify (data: T) { return Object.assign(data, { '@context': [ 'https://www.w3.org/ns/activitystreams', 'https://w3id.org/security/v1', { RsaSignature2017: 'https://w3id.org/security#RsaSignature2017', pt: 'https://joinpeertube.org/ns#', sc: 'http://schema.org#', Hashtag: 'as:Hashtag', uuid: 'sc:identifier', category: 'sc:category', licence: 'sc:license', subtitleLanguage: 'sc:subtitleLanguage', sensitive: 'as:sensitive', language: 'sc:inLanguage', views: 'sc:Number', state: 'sc:Number', size: 'sc:Number', fps: 'sc:Number', startTimestamp: 'sc:Number', stopTimestamp: 'sc:Number', position: 'sc:Number', commentsEnabled: 'sc:Boolean', downloadEnabled: 'sc:Boolean', waitTranscoding: 'sc:Boolean', expires: 'sc:expires', support: 'sc:Text', CacheFile: 'pt:CacheFile', Infohash: 'pt:Infohash', originallyPublishedAt: 'sc:DateTime' }, { likes: { '@id': 'as:likes', '@type': '@id' }, dislikes: { '@id': 'as:dislikes', '@type': '@id' }, playlists: { '@id': 'pt:playlists', '@type': '@id' }, shares: { '@id': 'as:shares', '@type': '@id' }, comments: { '@id': 'as:comments', '@type': '@id' } } ] }) } type ActivityPubCollectionPaginationHandler = (start: number, count: number) => Bluebird> | Promise> async function activityPubCollectionPagination (baseUrl: 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: baseUrl, type: 'OrderedCollectionPage', totalItems: result.total, first: baseUrl + '?page=1' } } 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) // There are more results if (result.total > page * ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) { next = baseUrl + '?page=' + (page + 1) } if (page > 1) { prev = baseUrl + '?page=' + (page - 1) } return { id: baseUrl + '?page=' + page, type: 'OrderedCollectionPage', prev, next, partOf: baseUrl, orderedItems: result.data, totalItems: result.total } } function buildSignedActivity (byActor: ActorModel, data: Object) { const activity = activityPubContextify(data) return signJsonLDObject(byActor, activity) as Promise } function getAPId (activity: string | { id: string }) { if (typeof activity === 'string') return activity return activity.id } function checkUrlsSameHost (url1: string, url2: string) { const idHost = parse(url1).host const actorHost = parse(url2).host return idHost && actorHost && idHost.toLowerCase() === actorHost.toLowerCase() } // --------------------------------------------------------------------------- export { checkUrlsSameHost, getAPId, activityPubContextify, activityPubCollectionPagination, buildSignedActivity }