Process images in a dedicated worker

[github/Chocobozzz/PeerTube.git] / server / lib / worker / workers / image-downloader.ts

import { remove } from 'fs-extra'
import { join } from 'path'
import { processImage } from '@server/helpers/image-utils'
import { doRequestAndSaveToFile } from '@server/helpers/requests'
import { CONFIG } from '@server/initializers/config'

async function downloadImage (options: {
  url: string
  destDir: string
  destName: string
  size: { width: number, height: number }
}) {
  const { url, destDir, destName, size } = options

  const tmpPath = join(CONFIG.STORAGE.TMP_DIR, 'pending-' + destName)
  await doRequestAndSaveToFile(url, tmpPath)

  const destPath = join(destDir, destName)

  try {
    await processImage({ path: tmpPath, destination: destPath, newSize: size })
  } catch (err) {
    await remove(tmpPath)

    throw err
  }
}

module.exports = downloadImage

export {
  downloadImage
}