]>
Commit | Line | Data |
---|---|---|
1 | import { VideoModel } from '../models/video/video' | |
2 | import * as Bluebird from 'bluebird' | |
3 | import { | |
4 | isStreamingPlaylist, | |
5 | MStreamingPlaylistVideo, | |
6 | MVideo, | |
7 | MVideoAccountLightBlacklistAllFiles, | |
8 | MVideoFile, | |
9 | MVideoFullLight, | |
10 | MVideoIdThumbnail, | |
11 | MVideoImmutable, | |
12 | MVideoThumbnail, | |
13 | MVideoWithRights | |
14 | } from '@server/typings/models' | |
15 | import { Response } from 'express' | |
16 | import { DEFAULT_AUDIO_RESOLUTION } from '@server/initializers/constants' | |
17 | import { JobQueue } from '@server/lib/job-queue' | |
18 | import { VideoTranscodingPayload } from '@shared/models' | |
19 | ||
20 | type VideoFetchType = 'all' | 'only-video' | 'only-video-with-rights' | 'id' | 'none' | 'only-immutable-attributes' | |
21 | ||
22 | function fetchVideo (id: number | string, fetchType: 'all', userId?: number): Bluebird<MVideoFullLight> | |
23 | function fetchVideo (id: number | string, fetchType: 'only-immutable-attributes'): Bluebird<MVideoImmutable> | |
24 | function fetchVideo (id: number | string, fetchType: 'only-video', userId?: number): Bluebird<MVideoThumbnail> | |
25 | function fetchVideo (id: number | string, fetchType: 'only-video-with-rights', userId?: number): Bluebird<MVideoWithRights> | |
26 | function fetchVideo (id: number | string, fetchType: 'id' | 'none', userId?: number): Bluebird<MVideoIdThumbnail> | |
27 | function fetchVideo ( | |
28 | id: number | string, | |
29 | fetchType: VideoFetchType, | |
30 | userId?: number | |
31 | ): Bluebird<MVideoFullLight | MVideoThumbnail | MVideoWithRights | MVideoIdThumbnail | MVideoImmutable> | |
32 | function fetchVideo ( | |
33 | id: number | string, | |
34 | fetchType: VideoFetchType, | |
35 | userId?: number | |
36 | ): Bluebird<MVideoFullLight | MVideoThumbnail | MVideoWithRights | MVideoIdThumbnail | MVideoImmutable> { | |
37 | if (fetchType === 'all') return VideoModel.loadAndPopulateAccountAndServerAndTags(id, undefined, userId) | |
38 | ||
39 | if (fetchType === 'only-immutable-attributes') return VideoModel.loadImmutableAttributes(id) | |
40 | ||
41 | if (fetchType === 'only-video-with-rights') return VideoModel.loadWithRights(id) | |
42 | ||
43 | if (fetchType === 'only-video') return VideoModel.load(id) | |
44 | ||
45 | if (fetchType === 'id' || fetchType === 'none') return VideoModel.loadOnlyId(id) | |
46 | } | |
47 | ||
48 | type VideoFetchByUrlType = 'all' | 'only-video' | 'only-immutable-attributes' | |
49 | ||
50 | function fetchVideoByUrl (url: string, fetchType: 'all'): Bluebird<MVideoAccountLightBlacklistAllFiles> | |
51 | function fetchVideoByUrl (url: string, fetchType: 'only-immutable-attributes'): Bluebird<MVideoImmutable> | |
52 | function fetchVideoByUrl (url: string, fetchType: 'only-video'): Bluebird<MVideoThumbnail> | |
53 | function fetchVideoByUrl ( | |
54 | url: string, | |
55 | fetchType: VideoFetchByUrlType | |
56 | ): Bluebird<MVideoAccountLightBlacklistAllFiles | MVideoThumbnail | MVideoImmutable> | |
57 | function fetchVideoByUrl ( | |
58 | url: string, | |
59 | fetchType: VideoFetchByUrlType | |
60 | ): Bluebird<MVideoAccountLightBlacklistAllFiles | MVideoThumbnail | MVideoImmutable> { | |
61 | if (fetchType === 'all') return VideoModel.loadByUrlAndPopulateAccount(url) | |
62 | ||
63 | if (fetchType === 'only-immutable-attributes') return VideoModel.loadByUrlImmutableAttributes(url) | |
64 | ||
65 | if (fetchType === 'only-video') return VideoModel.loadByUrl(url) | |
66 | } | |
67 | ||
68 | function getVideoWithAttributes (res: Response) { | |
69 | return res.locals.videoAll || res.locals.onlyVideo || res.locals.onlyVideoWithRights | |
70 | } | |
71 | ||
72 | function addOptimizeOrMergeAudioJob (video: MVideo, videoFile: MVideoFile) { | |
73 | let dataInput: VideoTranscodingPayload | |
74 | ||
75 | if (videoFile.isAudio()) { | |
76 | dataInput = { | |
77 | type: 'merge-audio' as 'merge-audio', | |
78 | resolution: DEFAULT_AUDIO_RESOLUTION, | |
79 | videoUUID: video.uuid, | |
80 | isNewVideo: true | |
81 | } | |
82 | } else { | |
83 | dataInput = { | |
84 | type: 'optimize' as 'optimize', | |
85 | videoUUID: video.uuid, | |
86 | isNewVideo: true | |
87 | } | |
88 | } | |
89 | ||
90 | return JobQueue.Instance.createJobWithPromise({ type: 'video-transcoding', payload: dataInput }) | |
91 | } | |
92 | ||
93 | function extractVideo (videoOrPlaylist: MVideo | MStreamingPlaylistVideo) { | |
94 | return isStreamingPlaylist(videoOrPlaylist) | |
95 | ? videoOrPlaylist.Video | |
96 | : videoOrPlaylist | |
97 | } | |
98 | ||
99 | export { | |
100 | VideoFetchType, | |
101 | VideoFetchByUrlType, | |
102 | fetchVideo, | |
103 | getVideoWithAttributes, | |
104 | fetchVideoByUrl, | |
105 | addOptimizeOrMergeAudioJob, | |
106 | extractVideo | |
107 | } |