path: root/server/lib/jobs/handlers/video-file-optimizer.ts

import * as Promise from 'bluebird'

import { database as db } from '../../../initializers/database'
import { logger, computeResolutionsToTranscode } from '../../../helpers'
import { VideoInstance } from '../../../models'
import { addVideoToFriends } from '../../friends'
import { JobScheduler } from '../job-scheduler'

function process (data: { videoUUID: string }) {
  return db.Video.loadByUUIDAndPopulateAuthorAndPodAndTags(data.videoUUID).then(video => {
    return video.optimizeOriginalVideofile().then(() => video)
  })
}

function onError (err: Error, jobId: number) {
  logger.error('Error when optimized video file in job %d.', jobId, err)
  return Promise.resolve()
}

function onSuccess (jobId: number, video: VideoInstance) {
  logger.info('Job %d is a success.', jobId)

  video.toAddRemoteJSON()
    .then(remoteVideo => {
      // Now we'll add the video's meta data to our friends
      return addVideoToFriends(remoteVideo, null)
    })
    .then(() => {
      return video.getOriginalFileHeight()
    })
    .then(originalFileHeight => {
      // Create transcoding jobs if there are enabled resolutions
      const resolutionsEnabled = computeResolutionsToTranscode(originalFileHeight)
      logger.info(
        'Resolutions computed for video %s and origin file height of %d.', video.uuid, originalFileHeight,
        { resolutions: resolutionsEnabled }
      )

      if (resolutionsEnabled.length === 0) return undefined

      return db.sequelize.transaction(t => {
        const tasks: Promise<any>[] = []

        resolutionsEnabled.forEach(resolution => {
          const dataInput = {
            videoUUID: video.uuid,
            resolution
          }

          const p = JobScheduler.Instance.createJob(t, 'videoFileTranscoder', dataInput)
          tasks.push(p)
        })

        return Promise.all(tasks).then(() => resolutionsEnabled)
      })
    })
    .then(resolutionsEnabled => {
      if (resolutionsEnabled === undefined) {
        logger.info('No transcoding jobs created for video %s (no resolutions enabled).')
        return undefined
      }

      logger.info('Transcoding jobs created for uuid %s.', video.uuid, { resolutionsEnabled })
    })
    .catch((err: Error) => {
      logger.debug('Cannot transcode the video.', err)
      throw err
    })

}

// ---------------------------------------------------------------------------

export {
  process,
  onError,
  onSuccess
}