GASでRSSの新着記事をAIで
要約しSlackに毎朝配信する方法

// スクリプトプロパティにAPIキーとSlack Webhookを保存（初回1回だけ実行）
function saveSecrets() {
  PropertiesService.getScriptProperties().setProperties({
    CLAUDE_API_KEY: "sk-ant-xxxxxxxx",
    SLACK_WEBHOOK_URL: "https://hooks.slack.com/services/xxxx/xxxx/xxxx",
  });
}

function getProp(name) {
  const v = PropertiesService.getScriptProperties().getProperty(name);
  if (!v) throw new Error(name + " が未設定です。saveSecrets を実行してください。");
  return v;
}

// 購読したいRSS/AtomフィードのURLを並べる
const FEEDS = [
  "https://example.com/blog/feed",     // RSS形式でもAtom形式でもOK
  "https://another-site.example/atom.xml",
  "https://news.example/rss",
];

// 1つのフィードを取得し、記事の配列にして返す（RSS・Atom両対応）
function fetchFeed(url) {
  const res = UrlFetchApp.fetch(url, { muteHttpExceptions: true });
  if (res.getResponseCode() !== 200) {
    Logger.log("取得失敗: " + url);
    return [];
  }

  // XmlServiceでXMLを解析する（GAS標準のXMLパーサー）
  const root = XmlService.parse(res.getContentText()).getRootElement();
  const atom = XmlService.getNamespace("http://www.w3.org/2005/Atom");

  // <rss> なら channel > item、<feed>（Atom）なら entry を取り出す
  if (root.getName() === "rss") {
    const channel = root.getChild("channel");
    return channel.getChildren("item").map((item) => ({
      id: text(item, "guid") || text(item, "link"),
      title: text(item, "title"),
      link: text(item, "link"),
      body: stripTags(text(item, "description")),
    }));
  } else {
    // Atom形式
    return root.getChildren("entry", atom).map((entry) => ({
      id: text(entry, "id", atom) || getAtomLink(entry, atom),
      title: text(entry, "title", atom),
      link: getAtomLink(entry, atom),
      body: stripTags(text(entry, "summary", atom) || text(entry, "content", atom)),
    }));
  }
}

// 子要素のテキストを安全に取り出す（無ければ空文字）
function text(parent, name, ns) {
  const child = ns ? parent.getChild(name, ns) : parent.getChild(name);
  return child ? child.getText().trim() : "";
}

// Atomの <link href="..."> からURLを取り出す
function getAtomLink(entry, ns) {
  const link = entry.getChild("link", ns);
  return link ? link.getAttribute("href").getValue() : "";
}

// 本文からHTMLタグを除いて短くする
function stripTags(html) {
  return html.replace(/<[^>]+>/g, "").replace(/\s+/g, " ").trim().slice(0, 400);
}

// 全フィードを回して、まだ配信していない新着記事だけを集める
function collectNewItems() {
  const props = PropertiesService.getScriptProperties();
  const sentIds = JSON.parse(props.getProperty("SENT_IDS") || "[]");
  const sentSet = {};
  sentIds.forEach((id) => (sentSet[id] = true));

  const fresh = [];
  FEEDS.forEach((url) => {
    fetchFeed(url).forEach((item) => {
      if (!item.id || sentSet[item.id]) return; // 配信済みはスキップ
      if (!item.title) return;
      fresh.push(item);
      sentSet[item.id] = true; // 同じ実行内での重複も防ぐ
    });
  });

  return fresh.slice(0, 15); // 1回の配信は多くても15件までに絞る
}

// 新着記事の配列を渡し、1〜2行の日本語要約をまとめて受け取る
function summarizeItems(items) {
  if (items.length === 0) return [];

  const prompt =
    "あなたはIT担当者向けのニュースキュレーターです。\n" +
    "次の記事それぞれを、日本語で40字以内・1文に要約してください。\n" +
    "本文が抜粋のみの場合は、分かる範囲で要約し、推測は書かないでください。\n" +
    "余計な説明は出力せず、JSON配列だけを返してください。\n" +
    "形式: [{\"index\":0,\"summary\":\"新機能Xが発表され無料枠が拡大\"}]\n\n" +
    "記事（番号: タイトル / 本文抜粋）:\n" +
    items.map((it, i) => i + ": " + it.title + " / " + it.body).join("\n");

  const payload = {
    model: "claude-sonnet-4-20250514",
    max_tokens: 1024,
    messages: [{ role: "user", content: prompt }],
  };

  const res = UrlFetchApp.fetch("https://api.anthropic.com/v1/messages", {
    method: "post",
    contentType: "application/json",
    headers: {
      "x-api-key": getProp("CLAUDE_API_KEY"),
      "anthropic-version": "2023-06-01",
    },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });

  if (res.getResponseCode() !== 200) {
    throw new Error("API error: " + res.getContentText());
  }

  const responseText = JSON.parse(res.getContentText()).content[0].text;
  const parsed = JSON.parse(extractJson(responseText));

  // 要約を元の記事にひも付ける
  return items.map((it, i) => {
    const found = parsed.find((p) => p.index === i);
    return { title: it.title, link: it.link, summary: found ? found.summary : "" };
  });
}

// レスポンスからJSON配列部分だけを取り出す（前後の余計な文字対策）
function extractJson(text) {
  const start = text.indexOf("[");
  const end = text.lastIndexOf("]");
  return text.slice(start, end + 1);
}

// 要約付きの記事一覧をBlock KitでSlackに投稿する
function postToSlack(summaries) {
  const blocks = [
    {
      type: "header",
      text: { type: "plain_text", text: "☀️ 今朝の新着記事（" + summaries.length + "件）" },
    },
    { type: "divider" },
  ];

  summaries.forEach((s) => {
    blocks.push({
      type: "section",
      text: {
        type: "mrkdwn",
        text: "*<" + s.link + "|" + escapeMrkdwn(s.title) + ">*\n" + s.summary,
      },
    });
  });

  UrlFetchApp.fetch(getProp("SLACK_WEBHOOK_URL"), {
    method: "post",
    contentType: "application/json",
    payload: JSON.stringify({ blocks: blocks }),
    muteHttpExceptions: true,
  });
}

// Slackのmrkdwnで意味を持つ記号をエスケープする
function escapeMrkdwn(t) {
  return t.replace(/&/g, "&amp;").replace(/</g, "&lt;").replace(/>/g, "&gt;");
}

// 収集 → 要約 → Slack投稿 → 配信済み記録 を一気に実行する
function runDailyDigest() {
  const items = collectNewItems();
  if (items.length === 0) {
    Logger.log("新着記事はありませんでした。");
    return;
  }

  const summaries = summarizeWithRetry(items);
  postToSlack(summaries);

  // 配信済みIDを記録（直近300件だけ保持して肥大化を防ぐ）
  const props = PropertiesService.getScriptProperties();
  const sentIds = JSON.parse(props.getProperty("SENT_IDS") || "[]");
  const merged = sentIds.concat(items.map((it) => it.id)).slice(-300);
  props.setProperty("SENT_IDS", JSON.stringify(merged));
}

// 一時的なAPIエラー時に最大3回まで再試行する
function summarizeWithRetry(items, maxRetry) {
  const limit = maxRetry || 3;
  for (let attempt = 1; attempt <= limit; attempt++) {
    try {
      return summarizeItems(items);
    } catch (e) {
      Logger.log("試行" + attempt + "回目で失敗: " + e.message);
      if (attempt === limit) throw e;
      Utilities.sleep(1000 * attempt); // 待ち時間を伸ばして再試行
    }
  }
}

// 毎朝8時台に自動実行するトリガーを作る（初回1回だけ実行）
function createDailyTrigger() {
  ScriptApp.newTrigger("runDailyDigest")
    .timeBased()
    .atHour(8)       // 8〜9時の間に実行される
    .everyDays(1)    // 毎日
    .create();
}