Function processVideo

apps/media-server/src/lib/media-video.ts:1274–1436

(
	inputPath: string,
	metadata: VideoMetadata,
	options: VideoProcessingOptions = {},
	onProgress?: ProgressCallback,
	abortSignal?: AbortSignal,
	resilientFlags?: ResilientInputFlags,
)

}

export async function processVideo(
	inputPath: string,
	metadata: VideoMetadata,
	options: VideoProcessingOptions = {},
	onProgress?: ProgressCallback,
	abortSignal?: AbortSignal,
	resilientFlags?: ResilientInputFlags,
): Promise<TempFileHandle> {
	const definedOptions = Object.fromEntries(
		Object.entries(options).filter(([, value]) => value !== undefined),
	) as VideoProcessingOptions;
	const opts = { ...DEFAULT_OPTIONS, ...definedOptions };
	const outputTempFile = await createTempFile(".mp4");

	const remuxOnly = opts.remuxOnly;
	const sourceH264Level =
		!remuxOnly && metadata.videoCodec === "h264"
			? await probeH264Level(inputPath, abortSignal)
			: null;
	const targetH264Level = pickMobileSafeH264Level(metadata, opts);
	const videoTranscode = remuxOnly
		? false
		: needsVideoTranscode(metadata, opts, sourceH264Level);
	const audioTranscode = remuxOnly ? false : needsAudioTranscode(metadata);
	const extraInputArgs = resilientFlags
		? buildExtraInputFlags(resilientFlags)
		: [];
	const extraOutputArgs = resilientFlags
		? buildExtraOutputFlags(resilientFlags)
		: [];
	const processTimeoutMs = getProcessTimeoutMs(
		metadata.duration,
		opts.timeoutMs,
	);
	const ffmpegArgs: string[] = [
		"ffmpeg",
		"-threads",
		"2",
		...extraInputArgs,
		"-i",
		inputPath,
	];

	if (videoTranscode) {
		ffmpegArgs.push(
			"-c:v",
			"libx264",
			"-preset",
			opts.preset,
			"-crf",
			opts.crf.toString(),
			"-vf",
			`scale='min(${opts.maxWidth},iw)':'min(${opts.maxHeight},ih)':force_original_aspect_ratio=decrease,scale=trunc(iw/2)*2:trunc(ih/2)*2`,
			"-pix_fmt",
			"yuv420p",
			"-level:v",
			targetH264Level.ffmpegValue,
		);