Function clearEditProcessingState

apps/web/workflows/edit-video.ts:758–786

(
	videoId: string,
	sourceKey: string,
	previousSpec: VideoEditSpec,
)

}

async function clearEditProcessingState(
	videoId: string,
	sourceKey: string,
	previousSpec: VideoEditSpec,
): Promise<void> {
	"use step";

	const previousDuration = getValidDuration(
		getEditSpecOutputDuration(previousSpec),
	);

	await db().transaction(async (tx) => {
		if (previousDuration !== undefined) {
			await tx
				.update(videos)
				.set({ duration: previousDuration })
				.where(eq(videos.id, videoId as Video.VideoId));
		}

		await tx
			.delete(videoUploads)
			.where(
				and(
					eq(videoUploads.videoId, videoId as Video.VideoId),
					eq(videoUploads.rawFileKey, sourceKey),
				),
			);
	});
}