Function verifyRenderedEditOutput

apps/web/workflows/edit-video.ts:416–487

(
	videoId: string,
	userId: string,
	editSpec: VideoEditSpec,
	reportedMetadata: VideoEditRenderResult["metadata"],
)

}

async function verifyRenderedEditOutput(
	videoId: string,
	userId: string,
	editSpec: VideoEditSpec,
	reportedMetadata: VideoEditRenderResult["metadata"],
): Promise<void> {
	"use step";

	const expectedDuration = getEditSpecOutputDuration(editSpec);
	if (!isDurationClose(reportedMetadata.duration, expectedDuration)) {
		throw new Error(
			`Media server reported edited duration ${reportedMetadata.duration.toFixed(3)}s, expected ${expectedDuration.toFixed(3)}s`,
		);
	}

	const mediaServerUrl = serverEnv().MEDIA_SERVER_URL;
	if (!mediaServerUrl) {
		throw new FatalError("MEDIA_SERVER_URL is not configured");
	}

	const [video] = await db()
		.select()
		.from(videos)
		.where(eq(videos.id, Video.VideoId.make(videoId)));

	if (!video) {
		throw new FatalError("Video does not exist");
	}

	const [bucket] = await Storage.getAccessForVideo(
		decodeStorageVideo(video),
	).pipe(runPromise);
	const outputKey = `${userId}/${videoId}/result.mp4`;
	const outputUrl = await bucket
		.getInternalSignedObjectUrl(outputKey, {
			expiresIn: MEDIA_SERVER_PRESIGNED_GET_EXPIRES_SECONDS,
		})
		.pipe(runPromise);

	let lastError: Error | undefined;

	for (
		let attempt = 0;
		attempt < MEDIA_SERVER_OUTPUT_VERIFICATION_MAX_ATTEMPTS;
		attempt++
	) {
		try {
			const actualMetadata = await probeVideoOnMediaServer(
				mediaServerUrl,
				outputUrl,
				serverEnv().MEDIA_SERVER_WEBHOOK_SECRET || undefined,
			);
			if (isDurationClose(actualMetadata.duration, expectedDuration)) {
				return;
			}

			lastError = new Error(
				`Rendered video duration mismatch: expected ${expectedDuration.toFixed(3)}s, got ${actualMetadata.duration.toFixed(3)}s`,