Notionの新規記事が公開されたら自動で社内Slackにお知らせする方法

/** Notion → GAS（定期）→ Slack 通知（Webhook版）
 *  条件：
 *   - ステータス = 「公開」
 *   - 公開日時 > 前回チェック時刻
 *  重複通知防止：
 *   - 通知済みページIDをスクリプトプロパティに保存
 */


const SP = PropertiesService.getScriptProperties;


function CONF() {
  const p = SP().getProperties();
  return {
    NOTION_TOKEN: p.NOTION_TOKEN,
    NOTION_DATABASE_ID: p.NOTION_DATABASE_ID,
    SLACK_WEBHOOK_URL: p.SLACK_WEBHOOK_URL,
    SLACK_MENTION: p.SLACK_MENTION || "",
    DRY_RUN: String(p.DRY_RUN || "").toLowerCase() === "true",
    TZ: "Asia/Tokyo",
    PAGE_SIZE: 20,           // 1回の取得件数
    FIRST_LOOKBACK_HOURS: 24 // 初回のみ「何時間前まで」さかのぼるか
  };
}


// ===== エントリーポイント（トリガー用） =====
function pollNotionAndNotify() {
  const conf = CONF();
  assertRequired(conf);


  // 初回は少しだけさかのぼり、それ以降は前回時刻から
  const lastCheckedAt =
    SP().getProperty("LAST_CHECKED_AT") ||
    new Date(Date.now() - conf.FIRST_LOOKBACK_HOURS * 60 * 60 * 1000).toISOString();


  const notifiedMap = JSON.parse(SP().getProperty("NOTIFIED_MAP") || "{}"); // {pageId:true}


  // 取得（必要なら複数ページ分を繰り返し取得）
  const pages = fetchPublishedPagesSinceAll(lastCheckedAt, conf);


  // 未通知だけ
  const newPages = pages.filter(p => !notifiedMap[p.id]);


  // 送信
  newPages.forEach(page => {
    if (conf.DRY_RUN) {
      console.log("[DRY_RUN] Would notify:", page);
      notifiedMap[page.id] = true; // 動作確認では既読扱いにしておくと重複防止の挙動も確認しやすい
      return;
    }
    try {
      postToSlackWebhook(page, conf);
      notifiedMap[page.id] = true;
    } catch (e) {
      console.error("Slack通知に失敗:", page, e);
    }
  });


  // 保存
  SP().setProperty("NOTIFIED_MAP", JSON.stringify(notifiedMap));
  SP().setProperty("LAST_CHECKED_AT", new Date().toISOString());
}


// ===== Notion API：since以降の公開記事を全件とる（20件超の保険）=====
function fetchPublishedPagesSinceAll(sinceIso, conf) {
  let cursor = null;
  const all = [];
  do {
    const chunk = fetchPublishedPagesSince(sinceIso, conf, cursor);
    all.push(...chunk.results);
    cursor = chunk.next_cursor;
  } while (cursor);
  return all;
}


function fetchPublishedPagesSince(sinceIso, conf, startCursor) {
  const url = `https://api.notion.com/v1/databases/${conf.NOTION_DATABASE_ID}/query`;
  const headers = {
    "Authorization": `Bearer ${conf.NOTION_TOKEN}`,
    "Notion-Version": "2022-06-28",
    "Content-Type": "application/json",
  };


  const payload = {
    page_size: conf.PAGE_SIZE,
    filter: {
      and: [
        { property: "ステータス", status: { equals: "公開" } },
        { property: "公開日時", date: { after: sinceIso } }
      ]
    },
    sorts: [{ property: "公開日時", direction: "ascending" }]
  };
  if (startCursor) payload.start_cursor = startCursor;


  const res = UrlFetchApp.fetch(url, {
    method: "post",
    headers,
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });
  if (res.getResponseCode() >= 300) {
    throw new Error(`Notion API error: ${res.getResponseCode()} / ${res.getContentText()}`);
  }


  const data = JSON.parse(res.getContentText());
  const results = (data.results || []).map(page => shapePage(page));
  return { results, next_cursor: data.has_more ? data.next_cursor : null };
}


function shapePage(page) {
  const props = page.properties || {};
  const title = extractTitle(props);
  const publishedAt = props["公開日時"]?.date?.start || null;
  const link = extractPublicUrl(props) || page.url; // 公開URLがあれば使う。なければNotion内部URL
  return { id: page.id, title, publishedAt, url: link };
}


function extractTitle(props) {
  // 「名前」「タイトル」どちらでも拾う。なければ最初のtitle型を検索。
  const cand = props["名前"] || props["タイトル"] || Object.values(props).find(p => p.type === "title");
  const arr = cand?.title || [];
  const txt = arr.map(t => t.plain_text).join("").trim();
  return txt || "(無題)";
}


function extractPublicUrl(props) {
  const p = props["公開URL"] || props["URL"] || null;
  if (!p) return null;
  if (p.type === "url") return p.url || null;
  if (p.type === "rich_text") {
    const s = (p.rich_text || []).map(t => t.plain_text).join("").trim();
    return s || null;
  }
  if (p.type === "formula" && p.formula?.string) return p.formula.string || null;
  return null;
}


// ===== Slack（Incoming Webhook）=====
function postToSlackWebhook(page, conf) {
  const lines = [
    conf.SLACK_MENTION ? `${conf.SLACK_MENTION} 新規記事が公開されました！` : "新規記事が公開されました！",
    `*タイトル*: ${page.title}`,
    page.publishedAt ? `*公開日時*: ${formatJST(page.publishedAt, conf.TZ)}` : "",
    page.url ? `*リンク*: ${page.url}` : "",
  ].filter(Boolean);


  const payload = { text: lines.join("\n") };


  const res = UrlFetchApp.fetch(conf.SLACK_WEBHOOK_URL, {
    method: "post",
    contentType: "application/json",
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });
  const code = res.getResponseCode();
  if (code >= 300) throw new Error(`Slack Webhook error: ${code} / ${res.getContentText()}`);
}


function formatJST(iso, tz) {
  return Utilities.formatDate(new Date(iso), tz, "yyyy/MM/dd HH:mm");
}


function assertRequired(conf) {
  const miss = [];
  if (!conf.NOTION_TOKEN) miss.push("NOTION_TOKEN");
  if (!conf.NOTION_DATABASE_ID) miss.push("NOTION_DATABASE_ID");
  if (!conf.SLACK_WEBHOOK_URL) miss.push("SLACK_WEBHOOK_URL");
  if (miss.length) throw new Error("スクリプトプロパティ未設定: " + miss.join(", "));
}


// ===== 手動テスト用（任意）=====
// 実行：メニューから run → testOnce
function testOnce() {
  const conf = CONF();
  SP().deleteProperty("LAST_CHECKED_AT"); // ← 最終チェック時刻を消す
  SP().deleteProperty("NOTIFIED_MAP");    // ← 通知済みリストを消す（ここがリセット）
  SP().setProperty("DRY_RUN", "false");   // 本番モード
  pollNotionAndNotify();
}




function resetNotifiedMap() {
  SP().deleteProperty("NOTIFIED_MAP");
  SP().deleteProperty("LAST_CHECKED_AT");
  console.log("通知履歴をリセットしました。");
}