fix(ops): resolve live services at request time

app/api/events/admin/route.ts

@@ -1,3 +1,5 @@
+import { connection } from "next/server";
+
 import {
   AdminAuthorizationError,
   requireAdmin,
@@ -8,6 +10,7 @@ import {
 } from "@/lib/events/redis-stream";
 
 export async function GET(request: Request) {
+  await connection();
   try {
     await requireAdmin();
   } catch (cause) {

app/api/events/directory/route.ts

@@ -1,9 +1,12 @@
+import { connection } from "next/server";
+
 import {
   createRedisEventResponse,
   eventsUnavailableResponse,
 } from "@/lib/events/redis-stream";
 
 export async function GET(request: Request) {
+  await connection();
   try {
     return await createRedisEventResponse("directory", request.signal);
   } catch {

app/api/events/page/[id]/route.ts

@@ -1,3 +1,5 @@
+import { connection } from "next/server";
+
 import {
   createRedisEventResponse,
   eventsUnavailableResponse,
@@ -10,6 +12,7 @@ export async function GET(
   request: Request,
   { params }: { params: Promise<{ id: string }> },
 ) {
+  await connection();
   const { id } = await params;
   if (!UUID_PATTERN.test(id)) {
     return Response.json({ error: "invalid-page-id" }, { status: 400 });

app/api/health/route.ts

@@ -1,4 +1,5 @@
 import { sql } from "drizzle-orm";
+import { connection } from "next/server";
 
 import { getDb } from "@/db/client";
 import { checkReadiness } from "@/lib/health/readiness";
@@ -7,6 +8,7 @@ import { getRedisClient } from "@/lib/redis/client";
 const NO_STORE_HEADERS = { "Cache-Control": "no-store" };
 
 export async function GET(request: Request) {
+  await connection();
   const deploymentId = process.env.NEXT_DEPLOYMENT_ID || "unknown";
   const readiness = new URL(request.url).searchParams.get("ready") === "1";
   if (!readiness) {