function main() { const scriptProperties = PropertiesService.getScriptProperties(); const lastUpdated = (() => { const value = scriptProperties.getProperty('LAST_UPDATED'); return !isNaN(value) && yesterday() < value ? value : yesterday(); })(); const settigns = getSettings(); const updatedTitleList = getModifiedScrapboxTitle({ projects: [...new Set(settigns.map(({ project }) => project))], from: lastUpdated }); // 最終更新日時を更新する scriptProperties.setProperty('LAST_UPDATED', Math.max(...updatedTitleList.map(({ updated }) => parseInt(updated)), isNaN(lastUpdated) ? yesterday() : lastUpdated)); //更新された行のみを抽出する const pageDataList = getScrapboxPages(...updatedTitleList) .map(({ project, title, lines }) => { return { project, title, lineBlocks: getModifiedLines({ lines, from: lastUpdated }) } }); // 送り先を振り分ける const params = settigns.flatMap(({ webhook, project, include, exclude }) => pageDataList.flatMap(({ project: project_, title, lineBlocks }) => { if (project_ !== project) return []; const lines = lineBlocks.flat(); if (include && !lines.some(({ text }) => include.test(text))) return []; if (exclude && lines.some(({ text }) => exclude.test(text))) return []; // データを変換しておく return [{ url: webhook, ...convertLinesToBlocks({ project, title, lineBlocks }), }]; }) ); // データを整形してpostする postToSlack(...params); } const yesterday = () => { let now = new Date(); now.setDate(now.getDate() - 1); return Math.floor(now.getTime() / 1000); } function convertLinesToBlocks({ project, title, lineBlocks }) { return { blocks: [ { type: 'section', text: { type: 'mrkdwn', text: `*<https://scrapbox.io/${project}/${title}|${title}>*`, }, }, ...lineBlocks.flatMap(lines => [ ...sb2mrkdwn(lines.map(line => line.text).join('\n'), { project }), { type: 'divider', }, ]), ],

originalBlocks: [ { type: 'section', text: { type: 'mrkdwn', text: `*<https://scrapbox.io/${project}/${title}|${title}>*`, }, }, ...lineBlocks.flatMap(lines => [ { type: 'section', text: { type: 'plain_text', text: lines.map(({ text }) => text).join('\n'), } }, { type: 'divider', }, ]), ], }; } function getModifiedLines({ lines, from }) { const result = []; let chunk = []; // 更新された行を、連続した部分ごとに分割する for (const line of lines) { if (line.updated <= from) { if (chunk.length === 0) continue; result.push([...chunk]); chunk = []; continue; } chunk.push(line); } if (chunk.length > 0) result.push([...chunk]); return result; } function getSettings() { return createDefaultSettings(); } function getScrapboxPages(...params) { console.log(`Start fetching scrapbox pages: `, params); const responses = UrlFetchApp.fetchAll(params .map(({ project, title }) => { return { url: `https://scrapbox.io/api/pages/${project}/${encodeURIComponent(title)}`, }; })); const jsons = responses.map(response => JSON.parse(response.getContentText())) console.log(`Finish fetching.`); return jsons.map(({ title, lines }, i) => { return { project: params[i].project, title, lines }; }); } // 各projectで最大1000件まで取得する // 一日に1000件以上ページが更新されるなんてことは無いだろうからこれで大丈夫だとは思うが………… // もしそういう状況が起きるのであれば、skipパラメータを使う function getModifiedScrapboxTitle({ projects, from }) { console.log(`Start searching ${projects.length} scrapbox projects for pages which are updated from ${toYYYYMMDD_HHMMSS(from)}: `, projects); const responses = UrlFetchApp.fetchAll(projects .map((project) => { return { url: `https://scrapbox.io/api/pages/${project}?limit=1000`, }; })); const jsons = responses.map(response => JSON.parse(response.getContentText())); console.log(`Finish fetching.`); // 更新されたページのタイトルだけ取得する return jsons.flatMap(({ projectName: project, pages }) => pages.flatMap(({ title, updated }) => updated > from ? [{ project, title, updated }] : [])); } const MAX_BLOCK_NUM = 50; function postToSlack(...params) { // blocksが長いときは分割する // MAX_BLOCK_NUM * 3以上長いと対処できない const temp = []; for (const { url, blocks, originalBlocks } of params) { if (blocks.length > MAX_BLOCK_NUM) { temp.push({ url, blocks: blocks.slice(0, MAX_BLOCK_NUM - 1), originalBlocks: originalBlocks.slice(0, MAX_BLOCK_NUM - 1) }, { url, blocks: blocks.slice(MAX_BLOCK_NUM - 1), originalBlocks: originalBlocks.slice(MAX_BLOCK_NUM - 1) }); } temp.push({ url, blocks, originalBlocks }); } const responses = UrlFetchApp.fetchAll(temp.map(({ url, blocks }) => { return { url, method: 'POST', headers: { 'Content-Type': 'application/json' }, payload: JSON.stringify({ blocks }), muteHttpExceptions: true, }; })); const responses2 = UrlFetchApp.fetchAll(responses.flatMap((response, i) => { if (response.getResponseCode() === 200) return []; // 記法のparseを飛ばして送り直す console.log(`Retry to post it to ${params[i].url}\n`, temp[i].originalBlocks); return { url: temp[i].url, method: 'POST', headers: { 'Content-Type': 'application/json' }, payload: JSON.stringify({ blocks: temp[i].originalBlocks }), muteHttpExceptions: true, }; })); responses2.forEach((response, i) => { if (response.getResponseCode() === 200) return; console.info(response.getContentText(), '\n', temp[i].originalBlocks); }) } const zero = n => String(n).padStart(2, '0'); const toYYYYMMDD = seconds => { const d = new Date(seconds * 1000); return `${d.getFullYear()}-${zero(d.getMonth() + 1)}-${zero(d.getDate())}`; }; const toHHMMSS = seconds => { const d = new Date(seconds * 1000); return `${zero(d.getHours())}:${zero(d.getMinutes())}:${zero(d.getSeconds())}`; }; const toYYYYMMDD_HHMMSS = seconds => `${toYYYYMMDD(seconds)} ${toHHMMSS(seconds)}`;

function createDefaultSettings() { return [ { webhook: 'https://hooks.slack.com/services/xxxxx', project: 'villagepump', include: /コミュニケーション|communication/i, }, { webhook: 'https://hooks.slack.com/services/yyyyyy', project: 'villagepump', include: /takker/, },

{ webhook: 'https://hooks.slack.com/services/zzzzzz', project: 'villagepump', }, ] }