X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Fvideo-transcoding.ts;h=a7b73a30db2a4be67525bc33f2af52868afc4ae0;hb=ef680f68351ec10ab73a1131570a6d14ce14c195;hp=dcda82e0a169ad549813062cd68eada603662181;hpb=c547bbf96a46166c4b4548413b092c58f7b0e37a;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/video-transcoding.ts b/server/lib/video-transcoding.ts index dcda82e0a..a7b73a30d 100644 --- a/server/lib/video-transcoding.ts +++ b/server/lib/video-transcoding.ts @@ -13,13 +13,14 @@ import { copyFile, ensureDir, move, remove, stat } from 'fs-extra' import { logger } from '../helpers/logger' import { VideoResolution } from '../../shared/models/videos' import { VideoFileModel } from '../models/video/video-file' -import { updateMasterHLSPlaylist, updateSha256Segments } from './hls' +import { updateMasterHLSPlaylist, updateSha256VODSegments } from './hls' import { VideoStreamingPlaylistModel } from '../models/video/video-streaming-playlist' import { VideoStreamingPlaylistType } from '../../shared/models/videos/video-streaming-playlist.type' import { CONFIG } from '../initializers/config' -import { MStreamingPlaylistFilesVideo, MVideoFile, MVideoWithAllFiles, MVideoWithFile } from '@server/typings/models' +import { MStreamingPlaylistFilesVideo, MVideoFile, MVideoWithAllFiles, MVideoWithFile } from '@server/types/models' import { createTorrentAndSetInfoHash } from '@server/helpers/webtorrent' import { generateVideoStreamingPlaylistName, getVideoFilename, getVideoFilePath } from './video-paths' +import { spawn } from 'child_process' /** * Optimize the original video file and replace it. The resolution is not changed. @@ -182,7 +183,7 @@ async function generateHlsPlaylist (video: MVideoWithFile, resolution: VideoReso const [ videoStreamingPlaylist ] = await VideoStreamingPlaylistModel.upsert({ videoId: video.id, playlistUrl, - segmentsSha256Url: WEBSERVER.URL + VideoStreamingPlaylistModel.getHlsSha256SegmentsStaticPath(video.uuid), + segmentsSha256Url: WEBSERVER.URL + VideoStreamingPlaylistModel.getHlsSha256SegmentsStaticPath(video.uuid, video.isLive), p2pMediaLoaderInfohashes: VideoStreamingPlaylistModel.buildP2PMediaLoaderInfoHashes(playlistUrl, video.VideoFiles), p2pMediaLoaderPeerVersion: P2P_MEDIA_LOADER_PEER_VERSION, @@ -213,7 +214,7 @@ async function generateHlsPlaylist (video: MVideoWithFile, resolution: VideoReso video.setHLSPlaylist(videoStreamingPlaylist) await updateMasterHLSPlaylist(video) - await updateSha256Segments(video) + await updateSha256VODSegments(video) return video } @@ -234,7 +235,7 @@ async function onVideoFileTranscoding (video: MVideoWithFile, videoFile: MVideoF const fps = await getVideoFileFPS(transcodingPath) const metadata = await getMetadataFromFile(transcodingPath) - await move(transcodingPath, outputPath) + await move(transcodingPath, outputPath, { overwrite: true }) videoFile.size = stats.size videoFile.fps = fps @@ -242,12 +243,8 @@ async function onVideoFileTranscoding (video: MVideoWithFile, videoFile: MVideoF await createTorrentAndSetInfoHash(video, videoFile) - const updatedVideoFile = await videoFile.save() - - // Add it if this is a new created file - if (video.VideoFiles.some(f => f.id === videoFile.id) === false) { - video.VideoFiles.push(updatedVideoFile) - } + await VideoFileModel.customUpsert(videoFile, 'video', undefined) + video.VideoFiles = await video.$get('VideoFiles') return video }