]>
Commit | Line | Data |
---|---|---|
0c9668f7 C |
1 | import express from 'express' |
2 | import { logger, loggerTagsFactory } from '@server/helpers/logger' | |
3 | import { proxifyHLS, proxifyWebTorrentFile } from '@server/lib/object-storage' | |
4 | import { VideoPathManager } from '@server/lib/video-path-manager' | |
5 | import { asyncMiddleware } from '@server/middlewares' | |
6 | import { jobOfRunnerGetValidator } from '@server/middlewares/validators/runners' | |
7 | import { runnerJobGetVideoTranscodingFileValidator } from '@server/middlewares/validators/runners/job-files' | |
8 | import { VideoStorage } from '@shared/models' | |
9 | ||
10 | const lTags = loggerTagsFactory('api', 'runner') | |
11 | ||
12 | const runnerJobFilesRouter = express.Router() | |
13 | ||
14 | runnerJobFilesRouter.post('/jobs/:jobUUID/files/videos/:videoId/max-quality', | |
15 | asyncMiddleware(jobOfRunnerGetValidator), | |
16 | asyncMiddleware(runnerJobGetVideoTranscodingFileValidator), | |
17 | asyncMiddleware(getMaxQualityVideoFile) | |
18 | ) | |
19 | ||
20 | runnerJobFilesRouter.post('/jobs/:jobUUID/files/videos/:videoId/previews/max-quality', | |
21 | asyncMiddleware(jobOfRunnerGetValidator), | |
22 | asyncMiddleware(runnerJobGetVideoTranscodingFileValidator), | |
23 | getMaxQualityVideoPreview | |
24 | ) | |
25 | ||
26 | // --------------------------------------------------------------------------- | |
27 | ||
28 | export { | |
29 | runnerJobFilesRouter | |
30 | } | |
31 | ||
32 | // --------------------------------------------------------------------------- | |
33 | ||
34 | async function getMaxQualityVideoFile (req: express.Request, res: express.Response) { | |
35 | const runnerJob = res.locals.runnerJob | |
36 | const runner = runnerJob.Runner | |
37 | const video = res.locals.videoAll | |
38 | ||
39 | logger.info( | |
40 | 'Get max quality file of video %s of job %s for runner %s', video.uuid, runnerJob.uuid, runner.name, | |
41 | lTags(runner.name, runnerJob.id, runnerJob.type) | |
42 | ) | |
43 | ||
44 | const file = video.getMaxQualityFile() | |
45 | ||
46 | if (file.storage === VideoStorage.OBJECT_STORAGE) { | |
47 | if (file.isHLS()) { | |
48 | return proxifyHLS({ | |
49 | req, | |
50 | res, | |
51 | filename: file.filename, | |
52 | playlist: video.getHLSPlaylist(), | |
53 | reinjectVideoFileToken: false, | |
54 | video | |
55 | }) | |
56 | } | |
57 | ||
58 | // Web video | |
59 | return proxifyWebTorrentFile({ | |
60 | req, | |
61 | res, | |
62 | filename: file.filename | |
63 | }) | |
64 | } | |
65 | ||
66 | return VideoPathManager.Instance.makeAvailableVideoFile(file, videoPath => { | |
67 | return res.sendFile(videoPath) | |
68 | }) | |
69 | } | |
70 | ||
71 | function getMaxQualityVideoPreview (req: express.Request, res: express.Response) { | |
72 | const runnerJob = res.locals.runnerJob | |
73 | const runner = runnerJob.Runner | |
74 | const video = res.locals.videoAll | |
75 | ||
76 | logger.info( | |
77 | 'Get max quality preview file of video %s of job %s for runner %s', video.uuid, runnerJob.uuid, runner.name, | |
78 | lTags(runner.name, runnerJob.id, runnerJob.type) | |
79 | ) | |
80 | ||
81 | const file = video.getPreview() | |
82 | ||
83 | return res.sendFile(file.getPath()) | |
84 | } |