diff --git a/apps/web/src/app/api/checker/cron/10m/route.ts b/apps/web/src/app/api/checker/cron/10m/route.ts index d036e328..4130ea55 100644 --- a/apps/web/src/app/api/checker/cron/10m/route.ts +++ b/apps/web/src/app/api/checker/cron/10m/route.ts @@ -2,7 +2,7 @@ import { NextResponse } from "next/server"; import { cron, isAuthorizedDomain } from "../_cron"; -export const runtime = "edge"; +// export const runtime = "edge"; export const preferredRegion = ["auto"]; export const dynamic = "force-dynamic"; diff --git a/apps/web/src/app/api/checker/cron/1h/route.ts b/apps/web/src/app/api/checker/cron/1h/route.ts index 97c3461f..47c67e64 100644 --- a/apps/web/src/app/api/checker/cron/1h/route.ts +++ b/apps/web/src/app/api/checker/cron/1h/route.ts @@ -2,7 +2,7 @@ import { NextResponse } from "next/server"; import { cron, isAuthorizedDomain } from "../_cron"; -export const runtime = "edge"; +// export const runtime = "edge"; export const preferredRegion = ["auto"]; export const dynamic = "force-dynamic"; diff --git a/apps/web/src/app/api/checker/cron/30m/route.ts b/apps/web/src/app/api/checker/cron/30m/route.ts index 606acefa..2607befa 100644 --- a/apps/web/src/app/api/checker/cron/30m/route.ts +++ b/apps/web/src/app/api/checker/cron/30m/route.ts @@ -2,7 +2,7 @@ import { NextResponse } from "next/server"; import { cron, isAuthorizedDomain } from "../_cron"; -export const runtime = "edge"; +// export const runtime = "edge"; export const preferredRegion = ["auto"]; export const dynamic = "force-dynamic"; diff --git a/apps/web/src/app/api/checker/cron/5m/route.ts b/apps/web/src/app/api/checker/cron/5m/route.ts index 97d7f0af..f717ab2e 100644 --- a/apps/web/src/app/api/checker/cron/5m/route.ts +++ b/apps/web/src/app/api/checker/cron/5m/route.ts @@ -2,7 +2,7 @@ import { NextResponse } from "next/server"; import { cron, isAuthorizedDomain } from "../_cron"; -export const runtime = "edge"; +// export const runtime = "edge"; export const preferredRegion = ["auto"]; export const dynamic = "force-dynamic"; diff --git a/apps/web/src/app/api/checker/cron/_cron.ts b/apps/web/src/app/api/checker/cron/_cron.ts index 99c277ed..d7fa2022 100644 --- a/apps/web/src/app/api/checker/cron/_cron.ts +++ b/apps/web/src/app/api/checker/cron/_cron.ts @@ -38,6 +38,8 @@ export const cron = async ({ .where(and(eq(monitor.periodicity, periodicity), eq(monitor.active, true))) .all(); + const allResult = []; + for (const row of result) { // could be improved with a single query const allPages = await db @@ -55,10 +57,11 @@ export const cron = async ({ pageIds: allPages.map((p) => String(p.pageId)), }; - await c.publishJSON({ + const result = c.publishJSON({ url: `${DEFAULT_URL}/api/checker/regions/${region}`, body: payload, }); + allResult.push(result); } } // our first legacy monitor @@ -73,10 +76,12 @@ export const cron = async ({ pageIds: ["openstatus"], }; - await c.publishJSON({ + const result = c.publishJSON({ url: `${DEFAULT_URL}/api/checker/regions/${region}`, body: payload, }); + allResult.push(result); } } + await Promise.all(allResult); };