Function retryVideoProcessing

apps/web/actions/video/retry-processing.ts:44–131

({
	videoId,
}: {
	videoId: Video.VideoId;
})

};

export async function retryVideoProcessing({
	videoId,
}: {
	videoId: Video.VideoId;
}): Promise<{ success: boolean; status: VideoProcessingStartStatus }> {
	const user = await getCurrentUser();
	if (!user) throw new Error("Unauthorized");

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

	if (!video) throw new Error("Video not found");
	if (video.ownerId !== user.id) throw new Error("Unauthorized");

	const [upload] = await db()
		.select()
		.from(videoUploads)
		.where(eq(videoUploads.videoId, videoId));

	if (!upload) throw new Error("No upload record found");
	if (!upload.rawFileKey) throw new Error("No raw file key found for retry");

	const [importedVideo] = await db()
		.select({
			source: importedVideos.source,
			sourceId: importedVideos.sourceId,
		})
		.from(importedVideos)
		.where(eq(importedVideos.id, videoId));

	if (importedVideo?.source === "loom") {
		if (upload.phase === "processing" && !shouldForceRetryProcessing(upload)) {
			return { success: true, status: "already-processing" };
		}

		await db()
			.update(videoUploads)
			.set({
				phase: "processing",
				processingProgress: 0,
				processingMessage: "Retrying Loom import...",
				processingError: null,
				rawFileKey: upload.rawFileKey,
				updatedAt: new Date(),
			})
			.where(eq(videoUploads.videoId, videoId));

		try {
			await start(importLoomVideoWorkflow, [
				{
					videoId,
					userId: user.id,
					rawFileKey: upload.rawFileKey,
					bucketId: video.bucket ?? null,
					loomDownloadUrl: "",
					loomVideoId: importedVideo.sourceId,