7.2 排程任務：Cron Triggers 與定時抓取#

分   時   日   月   週(0=週日, 6=週六)
*    *    *    *    *

# wrangler.toml
name = "release-watcher"
main = "src/index.ts"
compatibility_date = "2025-01-15"

[[d1_databases]]
binding = "DB"
database_name = "cccbook"
database_id = "xxxxx"

[triggers]
crons = ["0 16 * * *"]        # 每天台灣 00:00（UTC 16:00）

// src/index.ts
export default {
  async fetch(req: Request, env: Env, ctx: ExecutionContext) {
    return new Response("ok");
  },

  async scheduled(event: ScheduledEvent, env: Env, ctx: ExecutionContext) {
    ctx.waitUntil(syncReleases(env));   // 給背景時間，不會被硬殺
  },
};

interface Release { repo: string; tag: string; published: string }

export async function syncReleases(env: Env): Promise<number> {
  const repos = ["cloudflare/workers-sdk", "denoland/deno", "rust-lang/rust"];
  const stmt = env.DB.prepare(
    `INSERT INTO github_releases (repo,tag,published_at,fetched_at)
     VALUES (?1,?2,?3,?4)
     ON CONFLICT(repo,tag) DO UPDATE SET published_at=?3, fetched_at=?4`
  );
  let count = 0;
  for (const repo of repos) {
    const res = await fetch(`https://api.github.com/repos/${repo}/releases?per_page=5`, {
      headers: { "User-Agent": "cccbook-watcher" },
    });
    if (!res.ok) continue;                       // 單一失敗不影響其他 repo
    const list: Array<{ tag_name: string; published_at: string }> = await res.json();
    for (const r of list) {
      stmt.bind(repo, r.tag_name, r.published_at, new Date().toISOString());
      await stmt.run();
      count++;
    }
  }
  return count;
}

CREATE TABLE IF NOT EXISTS github_releases (
  repo TEXT, tag TEXT,
  published_at TEXT, fetched_at TEXT,
  PRIMARY KEY (repo, tag)
);