diff options
author | Chocobozzz <florian.bigard@gmail.com> | 2017-10-02 12:20:26 +0200 |
---|---|---|
committer | Chocobozzz <florian.bigard@gmail.com> | 2017-10-03 15:31:26 +0200 |
commit | 40298b02546e8225dd21bf6048fe7f224aefc32a (patch) | |
tree | 0a0b981dbeb2af47810adff6553a0df995a03734 /server/lib/jobs/handlers/video-file-transcoder.ts | |
parent | f0adb2701c1cf404ff63095f71e542bfe6d025ae (diff) | |
download | PeerTube-40298b02546e8225dd21bf6048fe7f224aefc32a.tar.gz PeerTube-40298b02546e8225dd21bf6048fe7f224aefc32a.tar.zst PeerTube-40298b02546e8225dd21bf6048fe7f224aefc32a.zip |
Implement video transcoding on server side
Diffstat (limited to 'server/lib/jobs/handlers/video-file-transcoder.ts')
-rw-r--r-- | server/lib/jobs/handlers/video-file-transcoder.ts | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/server/lib/jobs/handlers/video-file-transcoder.ts b/server/lib/jobs/handlers/video-file-transcoder.ts new file mode 100644 index 000000000..0e45b4dca --- /dev/null +++ b/server/lib/jobs/handlers/video-file-transcoder.ts | |||
@@ -0,0 +1,33 @@ | |||
1 | import { database as db } from '../../../initializers/database' | ||
2 | import { updateVideoToFriends } from '../../friends' | ||
3 | import { logger } from '../../../helpers' | ||
4 | import { VideoInstance } from '../../../models' | ||
5 | import { VideoResolution } from '../../../../shared' | ||
6 | |||
7 | function process (data: { videoUUID: string, resolution: VideoResolution }) { | ||
8 | return db.Video.loadByUUIDAndPopulateAuthorAndPodAndTags(data.videoUUID).then(video => { | ||
9 | return video.transcodeOriginalVideofile(data.resolution).then(() => video) | ||
10 | }) | ||
11 | } | ||
12 | |||
13 | function onError (err: Error, jobId: number) { | ||
14 | logger.error('Error when transcoding video file in job %d.', jobId, err) | ||
15 | return Promise.resolve() | ||
16 | } | ||
17 | |||
18 | function onSuccess (jobId: number, video: VideoInstance) { | ||
19 | logger.info('Job %d is a success.', jobId) | ||
20 | |||
21 | const remoteVideo = video.toUpdateRemoteJSON() | ||
22 | |||
23 | // Now we'll add the video's meta data to our friends | ||
24 | return updateVideoToFriends(remoteVideo, null) | ||
25 | } | ||
26 | |||
27 | // --------------------------------------------------------------------------- | ||
28 | |||
29 | export { | ||
30 | process, | ||
31 | onError, | ||
32 | onSuccess | ||
33 | } | ||