scripts(register-schedules): drop @relaycron/sdk, use plain fetch

The SDK is ESM-only with strict exports; tsx kept routing through
CJS resolution and failing to find the entry. The relaycron API
surface is small enough that fetch is cleaner anyway — fewer deps,
no resolution drama, same surface used elsewhere in the repo.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: khaliqgant

package-lock.json

@@ -12,7 +12,6 @@
     "@cloudflare/workers-types": "^4.20260511.1",
     "@gsap/react": "^2.1.2",
     "@octokit/app": "^16.1.2",
-    "@relaycron/sdk": "^0.1.2",
     "class-variance-authority": "^0.7.1",
     "clsx": "^2.1.1",
     "gray-matter": "^4.0.3",

package.json

@@ -1,24 +1,32 @@
 /**
  * One-shot: register every time-triggered agent's cron with relaycron.
- * Idempotent — uses a stable schedule name; updates if it exists, creates
- * otherwise.
+ * Idempotent — looks up by stable schedule name; updates if it exists,
+ * creates otherwise.
  *
- * Run from your laptop after wrangler-pages secrets are set:
+ * Run from your laptop after the Pages secrets are set:
  *
  *   RELAYCRON_API_KEY=ac_... CRON_WEBHOOK_SECRET=... \
  *     npx tsx scripts/register-schedules.ts
  *
  * The CRON_WEBHOOK_SECRET passed here MUST match the value set as the
  * Cloudflare Pages secret of the same name. Otherwise the function rejects
  * the delivery 401.
+ *
+ * We use plain fetch instead of @relaycron/sdk to dodge ESM/CJS resolution
+ * drama; the API surface is small enough to inline.
  */
-import { AgentCron } from "@relaycron/sdk";
-
 import weeklyDigest from "../agents/weekly-digest/agent";
 
 const RELAYCRON_BASE = process.env.RELAYCRON_BASE_URL ?? "https://api.relaycron.dev";
 const SITE_BASE = process.env.SITE_BASE_URL ?? "https://proactiveagents.dev";
 
+type Schedule = {
+  id: string;
+  name: string;
+  cron_expression?: string;
+  timezone?: string;
+};
+
 type RegisterableSchedule = {
   agentName: string;
   cron: string;
@@ -44,48 +52,75 @@ function extractTz(s: unknown): string | null {
   return null;
 }
 
-async function main() {
+async function api<T>(method: string, path: string, body?: unknown): Promise<T> {
   const apiKey = required("RELAYCRON_API_KEY");
-  const webhookSecret = required("CRON_WEBHOOK_SECRET");
+  const res = await fetch(`${RELAYCRON_BASE}${path}`, {
+    method,
+    headers: {
+      Authorization: `Bearer ${apiKey}`,
+      "Content-Type": "application/json",
+    },
+    body: body ? JSON.stringify(body) : undefined,
+  });
+  const json = (await res.json()) as
+    | { ok: true; data: T }
+    | { ok: false; error: { code: string; message: string } };
+  if (!json.ok) {
+    throw new Error(`relaycron ${res.status} ${json.error.code}: ${json.error.message}`);
+  }
+  return json.data;
+}
+
+async function listAllSchedules(): Promise<Schedule[]> {
+  const out: Schedule[] = [];
+  let cursor: string | undefined;
+  do {
+    const qs = cursor ? `?cursor=${encodeURIComponent(cursor)}&limit=100` : "?limit=100";
+    const page = (await api<Schedule[]>("GET", `/v1/schedules${qs}`)) as Schedule[] & {
+      cursor?: string | null;
+    };
+    out.push(...page);
+    cursor = (page as unknown as { cursor?: string | null }).cursor ?? undefined;
+  } while (cursor);
+  return out;
+}
 
-  const ac = new AgentCron({ apiKey, baseUrl: RELAYCRON_BASE });
+async function main() {
+  required("RELAYCRON_API_KEY");
+  const webhookSecret = required("CRON_WEBHOOK_SECRET");
 
-  // List existing schedules so we can update by name rather than create dupes.
-  const list = await ac.listSchedules({ limit: 100 });
-  const byName = new Map(list.data.map((s) => [s.name, s]));
+  const existing = await listAllSchedules();
+  const byName = new Map(existing.map((s) => [s.name, s]));
 
   for (const reg of REGISTRY) {
     const name = `proactive-agents/${reg.agentName}`;
     const url = `${SITE_BASE}/api/cron/${reg.agentName}`;
 
-    const existing = byName.get(name);
-    if (existing) {
-      await ac.updateSchedule(existing.id, {
+    const transport = {
+      type: "webhook" as const,
+      url,
+      headers: { "X-Cron-Secret": webhookSecret },
+      timeout_ms: 30000,
+    };
+
+    const prior = byName.get(name);
+    if (prior) {
+      await api("PATCH", `/v1/schedules/${prior.id}`, {
         cron_expression: reg.cron,
         timezone: reg.tz,
-        transport: {
-          type: "webhook",
-          url,
-          headers: { "X-Cron-Secret": webhookSecret },
-          timeout_ms: 30000,
-        },
+        transport,
         status: "active",
       });
       console.log(`updated  ${name}  ${reg.cron} ${reg.tz}  → ${url}`);
     } else {
-      const created = await ac.createSchedule({
+      const created = await api<Schedule>("POST", "/v1/schedules", {
         name,
         description: `Auto-registered from agents/${reg.agentName}/agent.ts`,
         schedule_type: "cron",
         cron_expression: reg.cron,
         timezone: reg.tz,
         payload: { agent: reg.agentName },
-        transport: {
-          type: "webhook",
-          url,
-          headers: { "X-Cron-Secret": webhookSecret },
-          timeout_ms: 30000,
-        },
+        transport,
       });
       console.log(`created  ${name}  ${reg.cron} ${reg.tz}  → ${url}  (id ${created.id})`);
     }