-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)
-}
-
-async function shareVideoChannelByServer (videoChannel: VideoChannelInstance, t: Sequelize.Transaction) {
- const serverAccount = await getServerAccount()
-
- await db.VideoChannelShare.create({
- accountId: serverAccount.id,
- videoChannelId: videoChannel.id
- }, { transaction: t })
-
- return sendVideoChannelAnnounce(serverAccount, videoChannel, t)
-}
-
-async function shareVideoByServer (video: VideoInstance, t: Sequelize.Transaction) {
- const serverAccount = await getServerAccount()
-
- await db.VideoShare.create({
- accountId: serverAccount.id,
- videoId: video.id
- }, { transaction: t })
-
- return sendVideoAnnounce(serverAccount, video, t)
-}
-
-function getVideoActivityPubUrl (video: VideoInstance) {
- return CONFIG.WEBSERVER.URL + '/videos/watch/' + video.uuid
-}
-
-function getVideoChannelActivityPubUrl (videoChannel: VideoChannelInstance) {
- return CONFIG.WEBSERVER.URL + '/video-channels/' + videoChannel.uuid
-}
-
-function getAccountActivityPubUrl (accountName: string) {
- return CONFIG.WEBSERVER.URL + '/account/' + accountName
-}
-
-function getVideoAbuseActivityPubUrl (videoAbuse: VideoAbuseInstance) {
- return CONFIG.WEBSERVER.URL + '/admin/video-abuses/' + videoAbuse.id
-}
-
-function getAccountFollowActivityPubUrl (accountFollow: AccountFollowInstance) {
- const me = accountFollow.AccountFollower
- const following = accountFollow.AccountFollowing
-
- return me.url + '#follows/' + following.id
-}
-
-function getAccountFollowAcceptActivityPubUrl (accountFollow: AccountFollowInstance) {
- const follower = accountFollow.AccountFollower
- const me = accountFollow.AccountFollowing
-
- return follower.url + '#accepts/follows/' + me.id
-}
-
-function getAnnounceActivityPubUrl (originalUrl: string, byAccount: AccountInstance) {
- return originalUrl + '#announces/' + byAccount.id
-}
-
-function getUpdateActivityPubUrl (originalUrl: string, updatedAt: string) {
- return originalUrl + '#updates/' + updatedAt
-}
-
-function getUndoActivityPubUrl (originalUrl: string) {
- return originalUrl + '/undo'
-}
-
-async function getOrCreateAccount (accountUrl: string) {
- let account = await db.Account.loadByUrl(accountUrl)
-
- // We don't have this account in our database, fetch it on remote
- if (!account) {
- const res = await fetchRemoteAccountAndCreateServer(accountUrl)
- if (res === undefined) throw new Error('Cannot fetch remote account.')
-
- // Save our new account in database
- account = await res.account.save()
- }
-
- return account
-}
-
-async function getOrCreateVideoChannel (ownerAccount: AccountInstance, videoChannelUrl: string) {
- let videoChannel = await db.VideoChannel.loadByUrl(videoChannelUrl)
-
- // We don't have this account in our database, fetch it on remote
- if (!videoChannel) {
- videoChannel = await fetchRemoteVideoChannel(ownerAccount, videoChannelUrl)
- if (videoChannel === undefined) throw new Error('Cannot fetch remote video channel.')
-
- // Save our new video channel in database
- await videoChannel.save()
- }
-
- return videoChannel
+function activityPubContextify <T> (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',
+ 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',
+ waitTranscoding: 'schema:Boolean',
+ expires: 'schema:expires',
+ support: 'schema:Text',
+ CacheFile: 'pt:CacheFile'
+ },
+ {
+ likes: {
+ '@id': 'as:likes',
+ '@type': '@id'
+ },
+ dislikes: {
+ '@id': 'as:dislikes',
+ '@type': '@id'
+ },
+ shares: {
+ '@id': 'as:shares',
+ '@type': '@id'
+ },
+ comments: {
+ '@id': 'as:comments',
+ '@type': '@id'
+ }
+ }
+ ]
+ })