Function editVideoWorkflow

apps/web/workflows/edit-video.ts:85–118

(
	payload: EditVideoWorkflowPayload,
)

}

export async function editVideoWorkflow(
	payload: EditVideoWorkflowPayload,
): Promise<VideoEditRenderResult> {
	"use workflow";

	const {
		videoId,
		userId,
		sourceKey,
		previousSpec,
		editSpec,
		aiGenerationEnabled,
	} = payload;

	try {
		await validateEditRequest(videoId, sourceKey);
		const result = await renderVideoEditOnMediaServer(payload);
		await verifyRenderedEditOutput(videoId, userId, editSpec, result.metadata);
		await invalidateEditedVideoCache(videoId, editSpec);
		await saveEditResultAndComplete(
			videoId,
			sourceKey,
			previousSpec,
			editSpec,
			result.metadata,
		);
		await queueTranscriptionRegeneration(videoId, userId, aiGenerationEnabled);
		return result;
	} catch (error) {
		const errorMessage = error instanceof Error ? error.message : String(error);
		await clearEditProcessingState(videoId, sourceKey, previousSpec);
		throw new FatalError(errorMessage);
	}
}

async function validateEditRequest(
	videoId: string,