Function saveEditResultAndComplete

apps/web/workflows/edit-video.ts:665–756

(
	videoId: string,
	sourceKey: string,
	previousSpec: VideoEditSpec,
	editSpec: VideoEditSpec,
	metadata: { duration: number; width: number; height: number; fps: number },
)

}

async function saveEditResultAndComplete(
	videoId: string,
	sourceKey: string,
	previousSpec: VideoEditSpec,
	editSpec: VideoEditSpec,
	metadata: { duration: number; width: number; height: number; fps: number },
): Promise<void> {
	"use step";

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

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

	const nextMetadata = clearAiMetadata(video.metadata as VideoMetadata | null);

	await db().transaction(async (tx) => {
		await tx
			.update(videos)
			.set({
				width: metadata.width,
				height: metadata.height,
				fps: metadata.fps,
				metadata: nextMetadata,
				transcriptionStatus: null,
				...(duration === undefined ? {} : { duration }),
			})
			.where(eq(videos.id, videoId as Video.VideoId));

		await tx
			.insert(videoEdits)
			.values({
				videoId: videoId as Video.VideoId,
				sourceKey,
				editSpec,
				updatedAt: new Date(),
			})
			.onDuplicateKeyUpdate({
				set: {
					sourceKey,
					editSpec,
					updatedAt: new Date(),
				},
			});

		const timestampedComments = await tx
			.select({
				id: comments.id,
				timestamp: comments.timestamp,
			})
			.from(comments)
			.where(eq(comments.videoId, videoId as Video.VideoId));