app/lib/google/refresh.server.ts

Functions

Imports

It imports app/db/schema.ts, app/lib/google/drive.server.ts, app/lib/google/search-console.server.ts, app/lib/google/service-account.server.ts, app/lib/sites.server.ts. Imported by workers/app.ts.

Source

1// The cron's Google work: the manuscripts index (so files added to the folder appear) and each
2// site's Search Console rows (at most daily). Nothing runs until the service account is set up; a
3// failure is logged, and the health check is where a broken key is reported.
4
5import { isNotNull } from "drizzle-orm";
6import { drizzle } from "drizzle-orm/d1";
7
8import { projects } from "~/db/schema";
9import { isSiteId, siteConnection } from "~/lib/sites.server";
10
11import { manuscriptsFolder, refreshManuscripts } from "./drive.server";
12import { refreshSearchConsole } from "./search-console.server";
13import { saConnection } from "./service-account.server";
14
15export async function refreshGoogle(env: Env, fetcher?: typeof fetch): Promise<Record<string, unknown>> {
16  if (saConnection(env).state !== "connected") return { skipped: "service account not connected" };
17  const out: Record<string, unknown> = {};
18  const note = (key: string, error: unknown) => {
19    const message = error instanceof Error ? error.message : String(error);
20    console.error(JSON.stringify({ google: "refresh-failed", key, error: message }));
21    out[key] = `failed: ${message}`;
22  };
23  if (manuscriptsFolder(env)) {
24    try {
25      out.manuscripts = await refreshManuscripts(env, fetcher);
26    } catch (error) {
27      note("manuscripts", error);
28    }
29  }
30  const sites = await drizzle(env.DB).select({ id: projects.id, slug: projects.slug, site: projects.site }).from(projects).where(isNotNull(projects.site)).all();
31  for (const row of sites) {
32    if (!isSiteId(row.site) || siteConnection(env, row.site).state !== "connected") continue;
33    try {
34      out[`search-console:${row.slug}`] = await refreshSearchConsole(env, { id: row.id, site: row.site }, fetcher);
35    } catch (error) {
36      note(`search-console:${row.slug}`, error);
37    }
38  }
39  return out;
40}