app/lib/refresh.server.ts

Functions

Imports

It imports app/db/schema.ts, app/lib/index.server.ts, app/lib/sites.server.ts. Imported by workers/app.ts.

Source

1// The cron's index refresh: every project that is a connected site. A site that is not connected yet
2// is skipped quietly; one that fails is logged, and the health check is where it gets reported.
3
4import { isNotNull } from "drizzle-orm";
5import { drizzle } from "drizzle-orm/d1";
6
7import { projects } from "~/db/schema";
8import { refreshIndex, type RefreshResult } from "~/lib/index.server";
9import { isSiteId, siteConnection } from "~/lib/sites.server";
10
11export async function refreshAllSites(env: Env, fetcher?: typeof fetch): Promise<Record<string, RefreshResult | string>> {
12  const rows = await drizzle(env.DB)
13    .select({ id: projects.id, slug: projects.slug, site: projects.site })
14    .from(projects)
15    .where(isNotNull(projects.site))
16    .all();
17  const out: Record<string, RefreshResult | string> = {};
18  for (const row of rows) {
19    if (!isSiteId(row.site)) continue;
20    if (siteConnection(env, row.site).state !== "connected") {
21      out[row.slug] = "not connected";
22      continue;
23    }
24    try {
25      out[row.slug] = await refreshIndex(env, { id: row.id, site: row.site }, fetcher);
26    } catch (error) {
27      const message = error instanceof Error ? error.message : String(error);
28      console.error(JSON.stringify({ refresh: "failed", project: row.slug, error: message }));
29      out[row.slug] = `failed: ${message}`;
30    }
31  }
32  return out;
33}