perf(analytics): pre-fetch video data once and gate first-view email on firstViewEmailSentAt

Author: richiemcilroy

apps/web/app/api/analytics/track/route.ts

@@ -100,22 +100,34 @@ export async function POST(request: NextRequest) {
 				},
 			});
 
-			if (userId && (!body.ownerId || userId === body.ownerId)) {
-				const [videoRecord] = yield* Effect.tryPromise(() =>
-					db()
-						.select({ ownerId: videos.ownerId })
-						.from(videos)
-						.where(eq(videos.id, Video.VideoId.make(body.videoId)))
-						.limit(1),
-				).pipe(Effect.orElseSucceed(() => [] as { ownerId: string }[]));
-
-				if (videoRecord && userId === videoRecord.ownerId) {
-					return;
-				}
+			const [videoRecord] = yield* Effect.tryPromise(() =>
+				db()
+					.select({
+						ownerId: videos.ownerId,
+						firstViewEmailSentAt: videos.firstViewEmailSentAt,
+						videoName: videos.name,
+					})
+					.from(videos)
+					.where(eq(videos.id, Video.VideoId.make(body.videoId)))
+					.limit(1),
+			).pipe(
+				Effect.orElseSucceed(
+					() =>
+						[] as {
+							ownerId: string;
+							firstViewEmailSentAt: Date | null;
+							videoName: string;
+						}[],
+				),
+			);
+
+			if (videoRecord && userId === videoRecord.ownerId) {
+				return;
 			}
 
 			const tenantId =
 				body.orgId ||
+				videoRecord?.ownerId ||
 				body.ownerId ||
 				(hostname ? `domain:${hostname}` : "public");
 
@@ -139,46 +151,54 @@ export async function POST(request: NextRequest) {
 				},
 			]);
 
+			const shouldSendFirstViewEmail =
+				videoRecord && !videoRecord.firstViewEmailSentAt;
+
 			if (userId) {
-				yield* Effect.forkDaemon(
+				if (shouldSendFirstViewEmail) {
+					yield* Effect.forkDaemon(
+						Effect.tryPromise(() =>
+							sendFirstViewEmail({
+								videoId: body.videoId,
+								viewerUserId: userId,
+								isAnonymous: false,
+							}),
+						).pipe(
+							Effect.catchAll((error) => {
+								console.error("Failed to send first view email:", error);
+								return Effect.void;
+							}),
+						),
+					);
+				}
+			}
+
+			if (!userId && sessionId) {
+				const anonName = getAnonymousName(sessionId);
+				const location =
+					city && country ? `${city}, ${country}` : city || country || null;
+
+				const effects: Effect.Effect<void, never, never>[] = [
 					Effect.tryPromise(() =>
-						sendFirstViewEmail({
+						createAnonymousViewNotification({
 							videoId: body.videoId,
-							viewerUserId: userId,
-							isAnonymous: false,
+							sessionId,
+							anonName,
+							location,
 						}),
 					).pipe(
 						Effect.catchAll((error) => {
-							console.error("Failed to send first view email:", error);
+							console.error(
+								"Failed to create anonymous view notification:",
+								error,
+							);
 							return Effect.void;
 						}),
 					),
-				);
-			}
+				];
 
-			if (!userId && sessionId) {
-				const anonName = getAnonymousName(sessionId);
-				const location =
-					city && country ? `${city}, ${country}` : city || country || null;
-
-				yield* Effect.forkDaemon(
-					Effect.all([
-						Effect.tryPromise(() =>
-							createAnonymousViewNotification({
-								videoId: body.videoId,
-								sessionId,
-								anonName,
-								location,
-							}),
-						).pipe(
-							Effect.catchAll((error) => {
-								console.error(
-									"Failed to create anonymous view notification:",
-									error,
-								);
-								return Effect.void;
-							}),
-						),
+				if (shouldSendFirstViewEmail) {
+					effects.push(
 						Effect.tryPromise(() =>
 							sendFirstViewEmail({
 								videoId: body.videoId,
@@ -191,11 +211,13 @@ export async function POST(request: NextRequest) {
 								return Effect.void;
 							}),
 						),
-					]),
-				);
+					);
+				}
+
+				yield* Effect.forkDaemon(Effect.all(effects));
 			}
 
-			if (!userId && !sessionId) {
+			if (!userId && !sessionId && shouldSendFirstViewEmail) {
 				yield* Effect.forkDaemon(
 					Effect.tryPromise(() =>
 						sendFirstViewEmail({