From eba901ffc8a22879b0b518b1212d5508e799711b Mon Sep 17 00:00:00 2001 From: gunshiz Date: Sat, 29 Aug 2026 05:47:21 +0000 Subject: [PATCH] fix(ops): resolve live services at request time --- app/api/events/admin/route.ts | 3 +++ app/api/events/directory/route.ts | 3 +++ app/api/events/page/[id]/route.ts | 3 +++ app/api/health/route.ts | 2 ++ 4 files changed, 11 insertions(+) diff --git a/app/api/events/admin/route.ts b/app/api/events/admin/route.ts index df99276..e9e4709 100644 --- a/app/api/events/admin/route.ts +++ b/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) { diff --git a/app/api/events/directory/route.ts b/app/api/events/directory/route.ts index 9298c59..9a7e5ca 100644 --- a/app/api/events/directory/route.ts +++ b/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 { diff --git a/app/api/events/page/[id]/route.ts b/app/api/events/page/[id]/route.ts index fed7121..7210679 100644 --- a/app/api/events/page/[id]/route.ts +++ b/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 }); diff --git a/app/api/health/route.ts b/app/api/health/route.ts index d0e9f3d..0ef0aee 100644 --- a/app/api/health/route.ts +++ b/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) {