effectify everywhere

Author: Brendonovich

.git-blame-ignore-revs

@@ -1 +1 @@
-d3b3a0bb176ac922bc623271fc64a60cf7f5bd8b
+b0773ee5cd650542153d189bc020753467af21a2

apps/web/actions/videos/get-status.ts

@@ -5,10 +5,13 @@ import { getCurrentUser } from "@cap/database/auth/session";
 import { users, videos } from "@cap/database/schema";
 import type { VideoMetadata } from "@cap/database/types";
 import { eq } from "drizzle-orm";
-import { userHasAccessToVideo } from "@/utils/auth";
 import { isAiGenerationEnabled } from "@/utils/flags";
 import { transcribeVideo } from "../../lib/transcribe";
 import { generateAiMetadata } from "./generate-ai-metadata";
+import { Cause, Effect, Exit, Option } from "effect";
+import { provideOptionalAuth, VideosPolicy } from "@cap/web-backend";
+import { Policy, Video } from "@cap/web-domain";
+import { EffectRuntime } from "@/lib/server";
 
 const MAX_AI_PROCESSING_TIME = 10 * 60 * 1000;
 
@@ -23,20 +26,26 @@ export interface VideoStatusResult {
 }
 
 export async function getVideoStatus(
-	videoId: string,
-): Promise<VideoStatusResult | { success: false; access: string }> {
-	const userPromise = getCurrentUser();
+	videoId: Video.VideoId,
+): Promise<VideoStatusResult | { success: false }> {
+	if (!videoId) throw new Error("Video ID not provided");
 
-	if (!videoId) {
-		throw new Error("Video ID not provided");
-	}
+	const exit = await Effect.gen(function* () {
+		const videosPolicy = yield* VideosPolicy;
 
-	const result = await db().select().from(videos).where(eq(videos.id, videoId));
-	if (result.length === 0 || !result[0]) {
-		throw new Error("Video not found");
-	}
+		return yield* Effect.promise(() =>
+			db().select().from(videos).where(eq(videos.id, videoId))
+		).pipe(Policy.withPublicPolicy(videosPolicy.canView(videoId)));
+	}).pipe(
+		provideOptionalAuth,
+		EffectRuntime.runPromiseExit,
+	);
+
+	if (Exit.isFailure(exit)) return { success: false }
+
+	const video = exit.value[0];
+	if (!video) throw new Error("Video not found");
 
-	const video = result[0];
 	const metadata: VideoMetadata = (video.metadata as VideoMetadata) || {};
 
 	if (!video.transcriptionStatus) {
@@ -226,9 +235,6 @@ export async function getVideoStatus(
 		}
 	}
 
-	const access = await userHasAccessToVideo(userPromise, video);
-	if (access !== "has-access") return { success: false, access };
-
 	return {
 		transcriptionStatus:
 			(video.transcriptionStatus as "PROCESSING" | "COMPLETE" | "ERROR") ||

apps/web/app/api/playlist/route.ts

@@ -41,7 +41,7 @@ class Api extends HttpApi.make("CapWebApi").add(
 			.addError(HttpApiError.InternalServerError)
 			.addError(HttpApiError.NotFound),
 	),
-) {}
+) { }
 
 const ApiLive = HttpApiBuilder.api(Api).pipe(
 	Layer.provide(
@@ -198,13 +198,9 @@ const getPlaylistResponse = (
 				const generatedPlaylist = generateMasterPlaylist(
 					videoMetadata?.Metadata?.resolution ?? "",
 					videoMetadata?.Metadata?.bandwidth ?? "",
-					`${serverEnv().WEB_URL}/api/playlist?userId=${
-						video.ownerId
-					}&videoId=${video.id}&videoType=video`,
+					`${serverEnv().WEB_URL}/api/playlist?videoId=${video.id}&videoType=video`,
 					audioMetadata
-						? `${serverEnv().WEB_URL}/api/playlist?userId=${
-								video.ownerId
-							}&videoId=${video.id}&videoType=audio`
+						? `${serverEnv().WEB_URL}/api/playlist?videoId=${video.id}&videoType=audio`
 						: null,
 				);