Function processVideoWorkflow

apps/web/workflows/process-video.ts:33–67

(
	payload: ProcessVideoWorkflowPayload,
)

}

export async function processVideoWorkflow(
	payload: ProcessVideoWorkflowPayload,
): Promise<VideoProcessingResult> {
	"use workflow";

	const { videoId, userId, rawFileKey, bucketId } = payload;

	try {
		await validateProcessingRequest(videoId, rawFileKey);

		const result = await processVideoOnMediaServer(
			videoId,
			userId,
			rawFileKey,
			bucketId,
		);

		await saveMetadataAndComplete(videoId, result.metadata);

		const outputKey = `${userId}/${videoId}/result.mp4`;
		if (rawFileKey !== outputKey) {
			await cleanupRawUpload(videoId, rawFileKey);
		}

		return {
			success: true,
			message: "Video processing completed",
			metadata: result.metadata,
		};
	} catch (error) {
		const errorMessage = error instanceof Error ? error.message : String(error);
		await setProcessingError(videoId, errorMessage);
		throw new FatalError(errorMessage);
	}
}

async function validateProcessingRequest(
	videoId: string,