X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fhelpers%2Factivitypub.ts;h=d710f5c9766ffb71f660470a3755937e385d7c70;hb=19ca8ca93975d99c16ab94c1526a34be74f63b95;hp=b91490a0b46d756196443f2953d0ef210e51d4a8;hpb=350e31d6b64e4973dfa5e9f7b46841cb09aeb1ad;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/helpers/activitypub.ts b/server/helpers/activitypub.ts index b91490a0b..d710f5c97 100644 --- a/server/helpers/activitypub.ts +++ b/server/helpers/activitypub.ts @@ -1,193 +1,116 @@ -import { join } from 'path' -import * as request from 'request' -import * as url from 'url' -import { ActivityIconObject } from '../../shared/index' -import { ActivityPubActor } from '../../shared/models/activitypub/activitypub-actor' -import { ResultList } from '../../shared/models/result-list.model' -import { database as db, REMOTE_SCHEME } from '../initializers' -import { ACTIVITY_PUB_ACCEPT_HEADER, CONFIG, STATIC_PATHS } from '../initializers/constants' -import { VideoInstance } from '../models/video/video-interface' -import { isRemoteAccountValid } from './custom-validators' -import { logger } from './logger' -import { doRequest, doRequestAndSaveToFile } from './requests' - -function generateThumbnailFromUrl (video: VideoInstance, icon: ActivityIconObject) { - const thumbnailName = video.getThumbnailName() - const thumbnailPath = join(CONFIG.STORAGE.THUMBNAILS_DIR, thumbnailName) - - const options = { - method: 'GET', - uri: icon.url - } - return doRequestAndSaveToFile(options, thumbnailPath) -} - -function getActivityPubUrl (type: 'video' | 'videoChannel' | 'account', id: string) { - if (type === 'video') return CONFIG.WEBSERVER.URL + '/videos/watch/' + id - else if (type === 'videoChannel') return CONFIG.WEBSERVER.URL + '/video-channels/' + id - else if (type === 'account') return CONFIG.WEBSERVER.URL + '/account/' + id +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' - return '' +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', + Hashtag: 'as:Hashtag', + uuid: 'http://schema.org/identifier', + category: 'http://schema.org/category', + licence: 'http://schema.org/license', + subtitleLanguage: 'http://schema.org/subtitleLanguage', + sensitive: 'as:sensitive', + language: 'http://schema.org/inLanguage', + views: 'http://schema.org/Number', + stats: 'http://schema.org/Number', + size: 'http://schema.org/Number', + commentsEnabled: 'http://schema.org/Boolean', + waitTranscoding: 'http://schema.org/Boolean', + support: 'http://schema.org/Text' + }, + { + likes: { + '@id': 'as:likes', + '@type': '@id' + }, + dislikes: { + '@id': 'as:dislikes', + '@type': '@id' + }, + shares: { + '@id': 'as:shares', + '@type': '@id' + }, + comments: { + '@id': 'as:comments', + '@type': '@id' + } + } + ] + }) } -async function getOrCreateAccount (accountUrl: string) { - let account = await db.Account.loadByUrl(accountUrl) +type ActivityPubCollectionPaginationHandler = (start: number, count: number) => Bluebird> | Promise> +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) - // We don't have this account in our database, fetch it on remote - if (!account) { - const res = await fetchRemoteAccountAndCreatePod(accountUrl) - if (res === undefined) throw new Error('Cannot fetch remote account.') - - // Save our new account in database - const account = res.account - await account.save() + return { + id: url, + type: 'OrderedCollection', + totalItems: result.total, + first: url + '?page=1' + } } - return account -} + const { start, count } = pageToStartAndCount(page, ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) + const result = await handler(start, count) -async function fetchRemoteAccountAndCreatePod (accountUrl: string) { - const options = { - uri: accountUrl, - method: 'GET', - headers: { - 'Accept': ACTIVITY_PUB_ACCEPT_HEADER - } - } + let next: string | undefined + let prev: string | undefined - logger.info('Fetching remote account %s.', accountUrl) + // Assert page is a number + page = parseInt(page, 10) - let requestResult - try { - requestResult = await doRequest(options) - } catch (err) { - logger.warn('Cannot fetch remote account %s.', accountUrl, err) - return undefined + // There are more results + if (result.total > page * ACTIVITY_PUB.COLLECTION_ITEMS_PER_PAGE) { + next = url + '?page=' + (page + 1) } - const accountJSON: ActivityPubActor = JSON.parse(requestResult.body) - if (isRemoteAccountValid(accountJSON) === false) { - logger.debug('Remote account JSON is not valid.', { accountJSON }) - return undefined + if (page > 1) { + prev = url + '?page=' + (page - 1) } - const followersCount = await fetchAccountCount(accountJSON.followers) - const followingCount = await fetchAccountCount(accountJSON.following) - - const account = db.Account.build({ - uuid: accountJSON.uuid, - name: accountJSON.preferredUsername, - url: accountJSON.url, - publicKey: accountJSON.publicKey.publicKeyPem, - privateKey: null, - followersCount: followersCount, - followingCount: followingCount, - inboxUrl: accountJSON.inbox, - outboxUrl: accountJSON.outbox, - sharedInboxUrl: accountJSON.endpoints.sharedInbox, - followersUrl: accountJSON.followers, - followingUrl: accountJSON.following - }) - - const accountHost = url.parse(account.url).host - const podOptions = { - where: { - host: accountHost - }, - defaults: { - host: accountHost - } + return { + id: url + '?page=' + page, + type: 'OrderedCollectionPage', + prev, + next, + partOf: url, + orderedItems: result.data, + totalItems: result.total } - const [ pod ] = await db.Pod.findOrCreate(podOptions) - account.set('podId', pod.id) - return { account, pod } } -function fetchRemoteVideoPreview (video: VideoInstance) { - // FIXME: use url - const host = video.VideoChannel.Account.Pod.host - const path = join(STATIC_PATHS.PREVIEWS, video.getPreviewName()) +function buildSignedActivity (byActor: ActorModel, data: Object) { + const activity = activityPubContextify(data) - return request.get(REMOTE_SCHEME.HTTP + '://' + host + path) + return signObject(byActor, activity) as Promise } -async function fetchRemoteVideoDescription (video: VideoInstance) { - const options = { - uri: video.url - } +function getActorUrl (activityActor: string | ActivityPubActor) { + if (typeof activityActor === 'string') return activityActor - const { body } = await doRequest(options) - return body.description ? body.description : '' -} - -function activityPubContextify (data: T) { - return Object.assign(data,{ - '@context': [ - 'https://www.w3.org/ns/activitystreams', - 'https://w3id.org/security/v1', - { - 'Hashtag': 'as:Hashtag', - 'uuid': 'http://schema.org/identifier', - 'category': 'http://schema.org/category', - 'licence': 'http://schema.org/license', - 'nsfw': 'as:sensitive', - 'language': 'http://schema.org/inLanguage', - 'views': 'http://schema.org/Number', - 'size': 'http://schema.org/Number' - } - ] - }) -} - -function activityPubCollectionPagination (url: string, page: number, result: ResultList) { - const baseUrl = url.split('?').shift - - const obj = { - id: baseUrl, - type: 'Collection', - totalItems: result.total, - first: { - id: baseUrl + '?page=' + page, - type: 'CollectionPage', - totalItems: result.total, - next: baseUrl + '?page=' + (page + 1), - partOf: baseUrl, - items: result.data - } - } - - return activityPubContextify(obj) + return activityActor.id } // --------------------------------------------------------------------------- export { - fetchRemoteAccountAndCreatePod, + getActorUrl, activityPubContextify, activityPubCollectionPagination, - getActivityPubUrl, - generateThumbnailFromUrl, - getOrCreateAccount, - fetchRemoteVideoPreview, - fetchRemoteVideoDescription -} - -// --------------------------------------------------------------------------- - -async function fetchAccountCount (url: string) { - const options = { - uri: url, - method: 'GET' - } - - let requestResult - try { - requestResult = await doRequest(options) - } catch (err) { - logger.warn('Cannot fetch remote account count %s.', url, err) - return undefined - } - - return requestResult.totalItems ? requestResult.totalItems : 0 + buildSignedActivity }