server/lib/transcoding/ended-transcoding.ts

   1 import { retryTransactionWrapper } from '@server/helpers/database-utils'
   2 import { VideoJobInfoModel } from '@server/models/video/video-job-info'
   3 import { MVideo } from '@server/types/models'
   4 import { moveToNextState } from '../video-state'
   5
   6 export async function onTranscodingEnded (options: {
   7   video: MVideo
   8   isNewVideo: boolean
   9   moveVideoToNextState: boolean
  10 }) {
  11   const { video, isNewVideo, moveVideoToNextState } = options
  12
  13   await VideoJobInfoModel.decrease(video.uuid, 'pendingTranscode')
  14
  15   if (moveVideoToNextState) {
  16     await retryTransactionWrapper(moveToNextState, { video, isNewVideo })
  17   }
  18 }