Function translateTranscript

apps/web/actions/videos/translate-transcript.ts:25–137

(
	videoId: Video.VideoId,
	targetLanguage: LanguageCode,
)

}

export async function translateTranscript(
	videoId: Video.VideoId,
	targetLanguage: LanguageCode,
): Promise<TranslateResult> {
	if (!videoId || !targetLanguage) {
		return {
			success: false,
			message: "Missing required parameters",
		};
	}

	if (!SUPPORTED_LANGUAGES[targetLanguage]) {
		return {
			success: false,
			message: "Unsupported language",
		};
	}

	const groq = getGroqClient();
	if (!groq) {
		return {
			success: false,
			message: "Translation service not configured",
		};
	}

	if (await isRateLimited(RATE_LIMIT_IDS.TRANSLATE_TRANSCRIPT)) {
		return { success: false, message: "Too many requests" };
	}

	const exit = await Effect.gen(function* () {
		const videosPolicy = yield* VideosPolicy;

		return yield* Effect.promise(() =>
			db().select({ video: videos }).from(videos).where(eq(videos.id, videoId)),
		).pipe(Policy.withPublicPolicy(videosPolicy.canView(videoId)));
	}).pipe(provideOptionalAuth, EffectRuntime.runPromiseExit);

	if (Exit.isFailure(exit)) {
		return { success: false, message: "Video not found" };
	}

	const query = exit.value;

	if (query.length === 0 || !query[0]?.video) {
		return { success: false, message: "Video not found" };
	}

	const { video } = query[0];

	const translatedKey = `${video.ownerId}/${videoId}/transcription.${targetLanguage}.vtt`;

	try {
		const existingTranslation = await Effect.gen(function* () {
			const [bucket] = yield* Storage.getAccessForVideo(
				decodeStorageVideo(video),
			);
			return yield* bucket.getObject(translatedKey);