X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Fhelpers%2Fvideo.ts;h=6f76cbdfc755a23f14f882600b86a7366e93747d;hb=fc8aabd0bf38441c0591f21b9b435b52e99ffc23;hp=d066e2b1f42854ce5c110f79955a8226606a93d9;hpb=282e61e6c11f79e919c543871783fe1a00298d18;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/helpers/video.ts b/server/helpers/video.ts index d066e2b1f..6f76cbdfc 100644 --- a/server/helpers/video.ts +++ b/server/helpers/video.ts @@ -1,17 +1,26 @@ import { VideoModel } from '../models/video/video' import * as Bluebird from 'bluebird' import { + isStreamingPlaylist, + MStreamingPlaylistVideo, + MVideo, MVideoAccountLightBlacklistAllFiles, + MVideoFile, MVideoFullLight, MVideoIdThumbnail, + MVideoImmutable, MVideoThumbnail, MVideoWithRights } from '@server/typings/models' import { Response } from 'express' +import { DEFAULT_AUDIO_RESOLUTION } from '@server/initializers/constants' +import { JobQueue } from '@server/lib/job-queue' +import { VideoTranscodingPayload } from '@shared/models' -type VideoFetchType = 'all' | 'only-video' | 'only-video-with-rights' | 'id' | 'none' +type VideoFetchType = 'all' | 'only-video' | 'only-video-with-rights' | 'id' | 'none' | 'only-immutable-attributes' function fetchVideo (id: number | string, fetchType: 'all', userId?: number): Bluebird +function fetchVideo (id: number | string, fetchType: 'only-immutable-attributes'): Bluebird function fetchVideo (id: number | string, fetchType: 'only-video', userId?: number): Bluebird function fetchVideo (id: number | string, fetchType: 'only-video-with-rights', userId?: number): Bluebird function fetchVideo (id: number | string, fetchType: 'id' | 'none', userId?: number): Bluebird @@ -19,14 +28,16 @@ function fetchVideo ( id: number | string, fetchType: VideoFetchType, userId?: number -): Bluebird +): Bluebird function fetchVideo ( id: number | string, fetchType: VideoFetchType, userId?: number -): Bluebird { +): Bluebird { if (fetchType === 'all') return VideoModel.loadAndPopulateAccountAndServerAndTags(id, undefined, userId) + if (fetchType === 'only-immutable-attributes') return VideoModel.loadImmutableAttributes(id) + if (fetchType === 'only-video-with-rights') return VideoModel.loadWithRights(id) if (fetchType === 'only-video') return VideoModel.load(id) @@ -34,30 +45,63 @@ function fetchVideo ( if (fetchType === 'id' || fetchType === 'none') return VideoModel.loadOnlyId(id) } -type VideoFetchByUrlType = 'all' | 'only-video' +type VideoFetchByUrlType = 'all' | 'only-video' | 'only-immutable-attributes' function fetchVideoByUrl (url: string, fetchType: 'all'): Bluebird +function fetchVideoByUrl (url: string, fetchType: 'only-immutable-attributes'): Bluebird function fetchVideoByUrl (url: string, fetchType: 'only-video'): Bluebird -function fetchVideoByUrl (url: string, fetchType: VideoFetchByUrlType): Bluebird -function fetchVideoByUrl (url: string, fetchType: VideoFetchByUrlType): Bluebird { +function fetchVideoByUrl ( + url: string, + fetchType: VideoFetchByUrlType +): Bluebird +function fetchVideoByUrl ( + url: string, + fetchType: VideoFetchByUrlType +): Bluebird { if (fetchType === 'all') return VideoModel.loadByUrlAndPopulateAccount(url) - if (fetchType === 'only-video') return VideoModel.loadByUrl(url) -} + if (fetchType === 'only-immutable-attributes') return VideoModel.loadByUrlImmutableAttributes(url) -function getVideo (res: Response) { - return res.locals.videoAll || res.locals.onlyVideo || res.locals.onlyVideoWithRights || res.locals.videoId + if (fetchType === 'only-video') return VideoModel.loadByUrl(url) } function getVideoWithAttributes (res: Response) { return res.locals.videoAll || res.locals.onlyVideo || res.locals.onlyVideoWithRights } +function addOptimizeOrMergeAudioJob (video: MVideo, videoFile: MVideoFile) { + let dataInput: VideoTranscodingPayload + + if (videoFile.isAudio()) { + dataInput = { + type: 'merge-audio' as 'merge-audio', + resolution: DEFAULT_AUDIO_RESOLUTION, + videoUUID: video.uuid, + isNewVideo: true + } + } else { + dataInput = { + type: 'optimize' as 'optimize', + videoUUID: video.uuid, + isNewVideo: true + } + } + + return JobQueue.Instance.createJobWithPromise({ type: 'video-transcoding', payload: dataInput }) +} + +function extractVideo (videoOrPlaylist: MVideo | MStreamingPlaylistVideo) { + return isStreamingPlaylist(videoOrPlaylist) + ? videoOrPlaylist.Video + : videoOrPlaylist +} + export { VideoFetchType, VideoFetchByUrlType, fetchVideo, - getVideo, getVideoWithAttributes, - fetchVideoByUrl + fetchVideoByUrl, + addOptimizeOrMergeAudioJob, + extractVideo }