Function waitForEditCompletion

apps/web/workflows/edit-video.ts:537–592

(
	videoId: string,
)

}

async function waitForEditCompletion(
	videoId: string,
): Promise<VideoEditRenderResult> {
	let lastStatus = "processing";

	for (
		let attempt = 0;
		attempt < MEDIA_SERVER_COMPLETION_MAX_ATTEMPTS;
		attempt++
	) {
		await waitForRetry(MEDIA_SERVER_COMPLETION_POLL_INTERVAL_MS);

		const [upload] = await db()
			.select({
				phase: videoUploads.phase,
				processingProgress: videoUploads.processingProgress,
				processingMessage: videoUploads.processingMessage,
				processingError: videoUploads.processingError,
			})
			.from(videoUploads)
			.where(eq(videoUploads.videoId, videoId as Video.VideoId));

		if (!upload) {
			throw new Error("Edit processing state disappeared");
		}

		if (upload.phase === "complete") {
			const metadata = await getCompletedMetadata(videoId);
			if (!metadata) {
				throw new Error("Edit completed but video metadata is missing");
			}

			return { metadata };
		}

		if (upload.processingError) {
			throw new Error(upload.processingError);
		}

		if (upload.phase === "error") {
			throw new Error(upload.processingMessage || "Video edit failed");
		}

		lastStatus = [
			upload.phase,
			typeof upload.processingProgress === "number"
				? `${upload.processingProgress}%`
				: null,
			upload.processingMessage,
		]
			.filter(Boolean)
			.join(" ");
	}

	throw new Error(`Video edit timed out while ${lastStatus}`);
}

function getEditInvalidationCallerReference(