Notionの更新履歴を自動でSlackに週次報告する方法

https://www.notion.so/XXXXXXXX?v=YYYYYYYY

// ---- Notion → Google Sheets に蓄積、週次で Slack に送信してクリアするサンプル ----
// 使い方（簡易）:
// 1) 以下の設定値をスクリプトプロパティに登録（またはコード先頭に直接埋めても良い。推奨はスクリプトプロパティ）:
//    NOTION_TOKEN, DATABASE_ID, SPREADSHEET_ID, SLACK_WEBHOOK_URL
// 2) トリガーを設定:
//    - pollNotionAndAppend を「時間主導」で例えば毎時実行
//    - sendWeeklyReportToSlack を「週次」で任意の曜日/時間に実行
// 3) 最初は手動で関数を実行して動作確認してください。

/* ---------- ユーティリティ: 簡単なログ表示 ---------- */
function logLine(msg) {
  Logger.log(msg);
}

/* ---------- Notion を問い合わせてデータベースをページネーション付きで取得 ---------- */
function fetchNotionDatabaseQuery(notionToken, databaseId, startCursor) {
  const url = 'https://api.notion.com/v1/databases/' + databaseId + '/query';
  const headers = {
    'Authorization': 'Bearer ' + notionToken,
    'Notion-Version': '2022-06-28',
    'Content-Type': 'application/json'
  };
  const payload = startCursor ? JSON.stringify({start_cursor: startCursor}) : JSON.stringify({});
  const options = {
    method: 'post',
    headers: headers,
    payload: payload,
    muteHttpExceptions: true
  };
  const resp = UrlFetchApp.fetch(url, options);
  const code = resp.getResponseCode();
  if (code < 200 || code >= 300) {
    throw new Error('Notion API error: ' + code + ' / ' + resp.getContentText());
  }
  return JSON.parse(resp.getContentText());
}

/* ---------- ページのタイトルを安全に取り出す ---------- */
function extractTitleFromProperties(props) {
  // Notion の title プロパティの取り方はプロパティ名が環境で違うことがあるため、
  // 全プロパティを走査して type === 'title' を探す
  for (let key in props) {
    if (!props.hasOwnProperty(key)) continue;
    const p = props[key];
    if (p && p.type === 'title') {
      const arr = p.title || [];
      return arr.map(r => r.plain_text).join('') || '(no title)';
    }
  }
  // fallback
  if (props.Name && props.Name.title) {
    return props.Name.title.map(r => r.plain_text).join('') || '(no title)';
  }
  return '(untitled)';
}

/* ---------- 定期実行：Notion をチェックしてシートに追加する ---------- */
function pollNotionAndAppend() {
  const props = PropertiesService.getScriptProperties();
  const NOTION_TOKEN = props.getProperty('NOTION_TOKEN');
  const DATABASE_ID = props.getProperty('DATABASE_ID');
  const SPREADSHEET_ID = props.getProperty('SPREADSHEET_ID');

  if (!NOTION_TOKEN || !DATABASE_ID || !SPREADSHEET_ID) {
    throw new Error('必要な設定値がありません。スクリプトプロパティに NOTION_TOKEN, DATABASE_ID, SPREADSHEET_ID を設定してください。');
  }

  // 最後にチェックした時刻を保存しておき、これ以降に編集されたものだけを取る
  const lastChecked = props.getProperty('LAST_CHECKED') || new Date(0).toISOString();
  const nowIso = new Date().toISOString();

  const sheet = SpreadsheetApp.openById(SPREADSHEET_ID).getActiveSheet();

  let startCursor = null;
  do {
    const respJson = fetchNotionDatabaseQuery(NOTION_TOKEN, DATABASE_ID, startCursor);
    startCursor = respJson.next_cursor;
    const results = respJson.results || [];
    results.forEach(page => {
      const pageEdited = page.last_edited_time;
      if (pageEdited > lastChecked) {
        // 抽出
        const title = extractTitleFromProperties(page.properties || {});
        const url = page.url || ('https://www.notion.so/' + page.id.replace(/-/g,''));
        let editor = '';
        try {
          if (page.last_edited_by && page.last_edited_by.type === 'person') {
            editor = page.last_edited_by.person.name || page.last_edited_by.id || '';
          } else if (page.last_edited_by && page.last_edited_by.name) {
            editor = page.last_edited_by.name;
          } else {
            editor = '';
          }
        } catch (e) {
          editor = '';
        }
        // 重複防止のため、すぐに同じ page.id と lastEdited が既にあるか確認できる処理を入れるとより安全です（後述）
        sheet.appendRow([new Date().toISOString(), title, editor, url, pageEdited]);
        logLine('Appended: ' + title);
      }
    });
  } while (startCursor);

  // チェック時刻を更新（成功時）
  props.setProperty('LAST_CHECKED', nowIso);
}

/* ---------- 週次処理：シートの内容を Slack に送信し、成功したらシートをクリア ---------- */
function sendWeeklyReportToSlack() {
  const props = PropertiesService.getScriptProperties();
  const SPREADSHEET_ID = props.getProperty('SPREADSHEET_ID');
  const SLACK_WEBHOOK_URL = props.getProperty('SLACK_WEBHOOK_URL');

  if (!SPREADSHEET_ID || !SLACK_WEBHOOK_URL) {
    throw new Error('必要な設定値がありません。スクリプトプロパティに SPREADSHEET_ID と SLACK_WEBHOOK_URL を設定してください。');
  }

  const sheet = SpreadsheetApp.openById(SPREADSHEET_ID).getActiveSheet();
  const rows = sheet.getDataRange().getValues();
  if (rows.length <= 1) {
    logLine('No updates to send this week.');
    return;
  }
  const header = rows[0];
  const data = rows.slice(1);

  // Slack に投げるテキストを作る（短め）
  let text = '*Notion 更新週次レポート*\n';
  text += '期間: ' + getWeekRangeText() + '\n\n';
  data.forEach(r => {
    const recordedAt = r[0];
    const title = r[1];
    const editor = r[2] || '不明';
    const url = r[3];
    const lastEdited = r[4];
    text += `• ${title} （編集: ${editor}）\n  ${url}\n  最終編集: ${lastEdited}\n\n`;
  });

  const payload = JSON.stringify({text: text});
  const options = {
    method: 'post',
    contentType: 'application/json',
    payload: payload,
    muteHttpExceptions: true
  };
  const resp = UrlFetchApp.fetch(SLACK_WEBHOOK_URL, options);
  const code = resp.getResponseCode();
  if (code >= 200 && code < 300) {
    // 成功したらヘッダ行を残して削除
    if (sheet.getLastRow() > 1) {
      sheet.deleteRows(2, sheet.getLastRow()-1);
    }
    logLine('Slack への送信成功。シートをクリアしました。');
  } else {
    logLine('Slack webhook failed: ' + code + ' / ' + resp.getContentText());
    throw new Error('Slack に送信できませんでした。レスポンスコード: ' + code);
  }
}

/* ---------- 補助: 今週の期間を返す（見出し用） ---------- */
function getWeekRangeText() {
  const now = new Date();
  // 日曜始まりを仮定
  const day = now.getDay();
  const start = new Date(now);
  start.setDate(now.getDate() - day);
  const end = new Date(start);
  end.setDate(start.getDate() + 6);
  const tz = Session.getScriptTimeZone();
  return Utilities.formatDate(start, tz, 'yyyy-MM-dd') + ' 〜 ' + Utilities.formatDate(end, tz, 'yyyy-MM-dd');
}