add: 差分を検出し、既に投稿されたお知らせを再投稿しない

Author: seieric

src/index.ts

@@ -1,26 +1,49 @@
-import { app } from '@azure/functions';
-
-import NewsFetcher from './lib/NewsFetcher';
-import NewsPoster from './lib/NewsPoster';
-
-app.timer('checkNewsAndPost', {
-    schedule: '0 */5 * * * *',
-    handler: async (myTimer, context) => {
-        // お知らせを取得
-        const newsFetcher = new NewsFetcher();
-        const newsItems = await newsFetcher.fetch();
-
-        // 本日のお知らせを絞り込む
-        const today = new Date(new Date().setHours(0, 0, 0, 0));
-        const latestItems = newsItems.filter((item) => item.isNewerThan(today));
-
-        if (latestItems.length === 0) return;
-
-        // お知らせを投稿
-        const newsPoster = new NewsPoster();
-        for (const newsItem of latestItems) {
-            context.log(`[New News]${newsItem.toString()}`);
-            newsPoster.post(newsItem);
-        }
-    },
-});
+import { app, input, output, InvocationContext } from "@azure/functions";
+
+import NewsFetcher from "./lib/NewsFetcher";
+import NewsPoster from "./lib/NewsPoster";
+import { detectNewNewsItem } from "./lib/utils";
+
+const blobInput = input.storageBlob({
+  path: "samples-workitems/newsitems.json",
+  connection: "MyStorageConnectionAppSetting",
+});
+
+const blobOutput = output.storageBlob({
+  // 任意のパスやファイル名を設定してください
+  path: "samples-workitems/newsitems.json",
+  connection: "MyStorageConnectionAppSetting",
+});
+
+app.timer("checkNewsAndPost", {
+  schedule: "0 */5 * * * *",
+  handler: async (myTimer, context: InvocationContext) => {
+    // 最新のお知らせを取得
+    const newsFetcher = new NewsFetcher();
+    const newsItems = await newsFetcher.fetch();
+
+    // 本日のお知らせを絞り込む
+    const today = new Date(new Date().setHours(0, 0, 0, 0));
+    const latestItems = newsItems.filter((item) => item.isNewerThan(today));
+
+    if (latestItems.length === 0) return;
+
+    // ストレージから本日配信したお知らせを取得
+    const blobContent = await context.extraInputs.get(blobInput);
+    const previousItems = blobContent ? JSON.parse(blobContent as string) : [];
+
+    // 新しいお知らせを検出
+    const newItems = detectNewNewsItem(previousItems, latestItems);
+
+    // 本日のお知らせをストレージに保存
+    const updatedItems = previousItems.concat(newItems);
+    context.extraOutputs.set(blobOutput, JSON.stringify(updatedItems));
+
+    // お知らせを投稿
+    const newsPoster = new NewsPoster();
+    for (const item of newItems) {
+      context.log(`[New News]${item.toString()}`);
+      newsPoster.post(item);
+    }
+  },
+});

src/lib/utils.ts

@@ -0,0 +1,22 @@
+import NewsItem from "./NewsItem";
+
+// 新しいお知らせを検出する関数
+// URLが一致するお知らせが配信済みであるかを確認する
+export function detectNewNewsItem(
+  previousItems: Array<NewsItem>,
+  latestItems: Array<NewsItem>
+): Array<NewsItem> {
+  const newItems: Array<NewsItem> = [];
+
+  for (const latestItem of latestItems) {
+    // URLが一致するお知らせが通知済みのお知らせにあるか
+    const linkMatchItem = previousItems.find(
+      (previousItem) => previousItem.link === latestItem.link
+    );
+
+    // URLが一致するお知らせがない場合、新しいお知らせとして扱う
+    if (!linkMatchItem) newItems.push(latestItem);
+  }
+
+  return newItems;
+}