Function runFfmpegOperation

apps/sim/lib/media/ffmpeg.ts:250–294

(
  operation: FfmpegOperation,
  inputs: MediaFile[],
  options: FfmpegOptions = {}
)

 * All inputs/outputs are buffers; temp files are created and cleaned up internally.
 */
export async function runFfmpegOperation(
  operation: FfmpegOperation,
  inputs: MediaFile[],
  options: FfmpegOptions = {}
): Promise<FfmpegResult> {
  if (inputs.length === 0) {
    throw new Error('At least one input file is required')
  }

  if (operation === 'probe') {
    return { probe: await probeMedia(inputs[0]) }
  }

  return withTempDir(async (dir) => {
    const inputPaths = await Promise.all(inputs.map((f, i) => writeInput(dir, f, i)))

    switch (operation) {
      case 'overlay_audio':
      case 'mux':
        return overlayAudio(dir, inputPaths, options)
      case 'mix_audio':
        return mixAudio(dir, inputPaths, options)
      case 'concat':
        return concat(dir, inputPaths)
      case 'trim':
        return trim(dir, inputPaths[0], inputs[0], options)
      case 'scale_pad':
        return scalePad(dir, inputPaths[0], options)
      case 'overlay_image':
        return overlayImage(dir, inputPaths, options)
      case 'add_text':
        return addText(dir, inputPaths[0], options)
      case 'fade':
        return fade(dir, inputPaths[0], inputs[0], options)
      case 'extract_audio':
        return extractAudio(dir, inputPaths[0], options)
      case 'convert':
        return convert(dir, inputPaths[0], options)
      case 'thumbnail':
        return thumbnail(dir, inputPaths[0], options)
      default:
        throw new Error(`Unsupported ffmpeg operation: ${operation}`)
    }
  })
}

async function readOut(outputPath: string, ext: string): Promise<FfmpegResult> {
  const buffer = await fs.readFile(outputPath)