Merge pull request '2026.4.2' (#15) from develop into main

Reviewed-on: #15

CHANGELOG.md

@@ -1,3 +1,63 @@
+# 2026.4.2
+- Fix: id除外が機能しない問題
+
+# 2026.4.1
+- Chg: notificationsもfor内でlastReadを更新しないように
+
+# 2026.4.0
+- Breaking: noticeUwuzuを0から作り直しました
+- Breaking: 25.12.0-alpha.1までの方針を全て廃止しました
+- Chg: パッケージマネージャーをnpmからpnpmへ変更しました
+- Chg: 全コードをsrcへ移動しました
+- Chg: ユーズのメッセージをyamlとi18nextで管理することで先頭と末尾の改行のある問題などに対策しました
+- Chg: 全ての保存データをmemory.jsonとして保管し、memory.tsを実装しました
+- Note: 以下のログは全て実装として記録しています
+- Feat: ユーザーは以下のコマンドを使用することができます。
+  - `/weather`: 天気予報を取得できます。
+  - `/help`: コマンドの利用方法などを取得できます。
+  - `/miq`: Make it a Quoteを操作できます。
+  - `/follow`: Botからフォローされます。
+  - `/unfollow`: Botからフォロー解除されます。
+- Feat: 地震情報が利用できます。以下の情報を投稿します。
+  - 地震発生情報
+  - 津波予報
+  - 緊急地震速報（警報）
+- Feat: 時報が利用できます。毎時0分に投稿します。
+- Feat: 天気予報を利用できます。毎日7:00に投稿します。
+- Feat: 新年迎春の投稿を行います。遅延が最低限になるように出来ています。
+- Feat: worker_threadsによる並列処理
+- Feat: ユーズの再試行
+- Feat: ユーズの文字数制限回避
+- Feat: コマンドを並列処理
+- Feat: 地震情報のWebSocket再接続
+- Feat: 最大震度の要求を設定できる機能
+- Feat: 最大震度が不明な場合に投稿するかどうかを設定できる機能
+- Feat: デバッグ用とで過去の地震情報を読み込み10秒おきに投稿する機能
+
+# 2026.4.0-beta.0
+- Feat: 地震発生情報の地域を都道府県でグループ化する機能 
+- Feat: ユーズの再試行
+- Feat: ユーズの文字数制限回避
+- Feat: ユーズ送信関数
+- Feat: コマンドを並列処理
+- Feat: 地震情報のWebSocket再接続
+- Feat: 天気予報の分割数を自動的に計算する機能
+- Feat: 最大震度の要求を設定できる機能
+- Feat: 最大震度が不明な場合に投稿するかどうかを設定できる機能
+- Chg: 地震発生情報の時刻に頃を追加
+- Chg: weatherNotice.tsのマジックナンバーに命名
+- Fix: 震度0の地震情報に対応していない問題
+- Fix: コマンド処理済みのユーズのid除外が正しく動作しない問題
+- Fix: miqコマンドのコンソール出力に値が存在しない問題
+
+# 2026.4.0-alpha.2
+- Feat: 地震情報のid除外
+- Feat: 新年迎春
+- Fix: for文でスキップではなくループの終了を行っていた問題
+- Feat: 返信済みかどうかをuniqidのみで判断する機能
+- Chg: 時報の時刻フォーマットをHH:mmからH:mmに変更
+- Feat: 緊急地震速報（警報）解除  
+
 # 2026.4.0-alpha.1
 - Del: tsxの開発環境を削除
 - Chg: typescriptを5.9.3にダウングレード
@@ -7,7 +67,7 @@
 - Del: 各地震情報の情報源の信頼できるかどうかの内容を削除
 - Chg: 津波予報情報の各時刻情報を実際に取得できる値まで削減(例: 2:03:00 > 2:03)
 - Fix: フォロー・フォロー解除に失敗した際にreturnできていない問題
-- Feat: デバッグ用とで過去の地震情報を読み込み10秒おきに投稿する機能 
+- Feat: デバッグ用で過去の地震情報を読み込み10秒おきに投稿する機能 
 
 # 2026.4.0-alpha.0
 - Breaking: noticeUwuzuを0から作り直しました

README.md

@@ -12,15 +12,19 @@ uwuzu v1.6.3以上で利用可能です。
   - 地震発生
   - 緊急地震速報（警報）
   - 津波予報
+- 新年迎春
+  毎年1/1 0:00に投稿します。
 - デバッグモード
   設定で有効化することで、以下の機能が利用できます。  
   開発以外では使用しないでください。
-  - NODE_TLS_REJECT_UNAUTHORIZED=1
+  - NODE_TLS_REJECT_UNAUTHORIZED=1  
     暗号化通信を無効化します。
-  - 地震情報のWebSocketの接続先をテスト用サンドボックスに変更
+  - 地震情報のWebSocketの接続先をテスト用サンドボックスに変更  
     P2P地震情報の接続先を本番環境から[テスト用サンドボックスのエンドポイント](https://www.p2pquake.net/develop/json_api_v2/)に変更します。  
     そのため、最新の情報は配信されません。
-  - i18nextのdebugを有効化
+  - 地震情報のid除外を無効化  
+    地震情報のid除外を記録も確認も行わなくなります。
+  - i18nextのdebugを有効化  
     [i18nextでのdebug](https://www.i18next.com/overview/configuration-options#logging)が有効化されます。
 
 ## 260420.jsonについて

config/example.yaml

@@ -1,10 +1,43 @@
 command:
+  # コマンド処理の間隔(分) number
+  # 自然数のみが有効です。
   interval: 10
-weather:
-  splits: 4
+  # コマンドの最大並列処理数 number
+  # 例: 2を指定すると、コマンドを並列に2つずつ処理します。
+  # 並列処理の数であるため、最終的なコマンドの処理数は変わりません。
+  # 自然数のみが有効です。
+  maxParallels: 3
 earthquake:
+  # 地震発生情報を投稿することに必要な最大震度 number
+  # 例: 30を指定すると、最大震度が震度3以上の地震発生情報のみを投稿します。
+  # 10(震度1), 20(震度2), 30(震度3), 40(震度4), 45(震度5弱), 50(震度5強), 55(震度6弱), 60(震度6強), 70(震度7)が有効です。
+  requireMaxScale: 30
+  # 最大震度が不明な地震発生情報を投稿するかどうか boolean
+  canUnknownMaxScale: true
+  # 過去のデバッグ用データを使用して地震情報を配信するかどうか boolean
+  # デバッグ用途のみで使用してください。
   useHistoryData: false
+  # 再接続の間隔(ミリ秒) number
+  # 正数のみが有効です。
+  reconnectInterval: 3000
 uwuzu:
+  # APIトークン string
+  # とくに理由がない限り、全権限を与えてください。
   token: API_TOKEN
+  # uwuzuサーバーのorigin string
   origin: https://uwuzu.example.com
+ueuse:
+  # 最大再試行数 number
+  # 自然数のみが有効です。
+  maxRetries: 3
+  # 再試行の間隔(ミリ秒) number
+  # 正数のみが有効です。
+  retryInterval: 1000
+  # 公開されたユーズの自主規制文字数 number
+  # 返信ではない(公開された)ユーズで使用する自主的な文字数制限です。
+  # 返信では、サーバーの設定に従います。
+  # 0にすると、返信ではないユーズでもサーバーの設定に従います。
+  # 0以上の整数が有効です。
+  maxLengthWithPublic: 512
+# デバッグモードにするかどうか boolean
 debug: false

locales/ja.yaml

@@ -10,7 +10,7 @@ weatherReply: |
   降水確率: {{ chanceOfRain }}
 earthquakeNotice: |
   ### ==地震発生==
-  ⏰時刻: {{ occuredTime }}
+  ⏰時刻: {{ occuredTime }}頃
   🫨最大震度: {{ maxScale }}
   📍震源地: {{ epicenter }}
   💪マグニチュード: {{ magnitude }}
@@ -50,6 +50,16 @@ eewNotice: |
   📍震源地: {{ epicenter }}
   💪マグニチュード: {{ magnitude }}
   🪨深さ: {{ depth }}{{ areas }}
+
+  🔬情報源: P2P地震速報
+eewCancelNotice: |
+  ### ==緊急地震速報（警報）**解除**==
+  {{ isTest }}
+  ⏰発表時刻: {{ announceTime }}
+
+  🔬情報源: P2P地震速報
+hnyNotice: |
+  あけましておめでとうございます。今年は、{{ year }}年です。
 commandNotFound: |
   コマンドが本文から参照できませんでした。
   Botでは、このアカウントに対してのメンション部分を取り除きます。

package.json

@@ -1,6 +1,6 @@
 {
   "name": "notice-uwuzu",
-  "version": "26.4.0-alpha.1",
+  "version": "2026.4.2",
   "type": "module",
   "main": "dist/index.js",
   "scripts": {

src/feature/command/follow.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import client, { createUeuse } from "@/lib/client";
 import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import i18next from "i18next";
 
@@ -14,15 +14,8 @@ export default async function followCommand(ueuse: ueuseModule) {
 
   console.log("フォロー:", follow.userid);
 
-  const notice = await client.request("ueuse/create", {
+  await createUeuse({
     text: i18next.t("followedNotification", { username: ueuse.account.username }),
     replyid: ueuse.uniqid,
-  });
-
-  if (!notice.success) {
-    console.warn("フォロー通知に失敗:", notice.error_code);
-    return;
-  }
-
-  console.log("フォロー通知:", notice.uniqid);
+  }, "フォロー通知");
 }

src/feature/command/help.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import { createUeuse } from "@/lib/client";
 import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import i18next from "i18next";
 import { EOL } from "node:os";
@@ -14,31 +14,19 @@ const helps = [
 export default async function helpCommand(ueuse: ueuseModule, args: string[]) {
   if (args[1] !== undefined) {
     if (!(helps.includes(args[1]))) {
-      const response = await client.request("ueuse/create", {
+      await createUeuse({
         text: i18next.t("invalidOption", { option: args[1], command: "help" }),
         replyid: ueuse.uniqid,
-      });
+      }, "無効なオプションである旨");
 
-      if (!response.success) {
-        console.warn("コマンド詳細の返信に失敗:", response.error_code);
-        return;
-      }
-
-      console.warn("コマンド詳細:", response.uniqid);
       return;
     }
 
-    const response = await client.request("ueuse/create", {
+    await createUeuse({
       text: i18next.t(`fullHelp${args[1].charAt(0).toUpperCase()}${args[1].slice(1)}`),
       replyid: ueuse.uniqid,
-    });
+    }, "コマンド詳細");
 
-    if (!response.success) {
-      console.warn("コマンド詳細の返信に失敗:", response.error_code);
-      return;
-    }
-
-    console.warn("コマンド詳細:", response.uniqid);
     return;
   }
 
@@ -47,20 +35,13 @@ export default async function helpCommand(ueuse: ueuseModule, args: string[]) {
   for (let i = 0; i < helps.length; i++) {
     const help = helps[i];
     if (!help)
-      break;
+      continue;
 
     summarys += `${i18next.t(`help${help.charAt(0).toUpperCase()}${help.slice(1)}`)}${EOL}`;
   }
 
-  const response = await client.request("ueuse/create", {
+  await createUeuse({
     text: summarys.trim(),
     replyid: ueuse.uniqid,
-  });
-
-  if (!response.success) {
-    console.warn("コマンド概要の返信に失敗:", response.error_code);
-    return;
-  }
-
-  console.warn("コマンド概要:", response.uniqid);
+  }, "コマンド概要");
 }

src/feature/command/index.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import client, { createUeuse } from "@/lib/client";
 import Memory from "@/lib/memory";
 import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import i18next from "i18next";
@@ -8,6 +8,7 @@ import followCommand from "@/feature/command/follow";
 import unfollowCommand from "@/feature/command/unfollow";
 import miqCommand from "@/feature/command/miq";
 import initI18n from "@/lib/i18n";
+import config from "@/lib/config";
 
 await initI18n();
 console.log("コマンドの処理を行います");
@@ -17,18 +18,24 @@ try {
 
   {
     const response = await client.request("me/notification/", {
+      page: 1,
       limit: 20,
     });
 
     if (response.success) {
-      for (const notification of response.data) {
-        if (notification.category !== "reply")
-          break;
+      const notifications = response.data.filter(notification => notification.category === "reply" && typeof notification.valueid === "string");
 
-        if (!notification.valueid) {
-          console.warn("返信通知にvalueidが存在しないため、スキップします");
+      const mem = Memory.memory;
+      const lastReadReply = mem.lastReadReply;
+      mem.lastReadReply = notifications[0]?.valueid ?? lastReadReply;
+      Memory.memory = mem;
+
+      for (const notification of notifications) {
+        if (notification.category !== "reply" || typeof notification.valueid !== "string")
+          continue;
+
+        if (lastReadReply === notification.valueid)
           break;
-        }
 
         const ueuseResponse = await client.request("ueuse/get", {
           uniqid: notification.valueid,
@@ -36,7 +43,7 @@ try {
 
         if (!ueuseResponse.success || !ueuseResponse.data[0]) {
           console.warn("返信通知からユーズを参照できないため、スキップします");
-          break;
+          continue;
         }
 
         ueuses.push(ueuseResponse.data[0]);
@@ -48,11 +55,25 @@ try {
 
   {
     const response = await client.request("ueuse/mentions", {
+      page: 1,
       limit: 20,
     });
 
     if (response.success) {
-      ueuses.push(...response.data);
+      const mentions = response.data;
+
+      const mem = Memory.memory;
+      const lastReadMention = mem.lastReadMention;
+      mem.lastReadMention = mentions[0]?.uniqid ?? lastReadMention;
+      Memory.memory = mem;
+
+      for (const mention of mentions) {
+        if (lastReadMention === mention.uniqid) {
+          break;
+        }
+
+        ueuses.push(mention);
+      }
     } else {
       console.warn("メンションの取得に失敗しましたが、続行します");
     }
@@ -60,73 +81,58 @@ try {
 
   ueuses = [...new Set(ueuses)];
 
-  for (const ueuse of ueuses) {
-    const repliedUeuse = (Memory.memory["repliedUeuse"] as string[]);
-
-    if (repliedUeuse.includes(ueuse.uniqid)) {
-      console.log("既に応答しているため、スキップします");
-      break;
-    }
-
-    const mem = Memory.memory;
-    let text = ueuse.text;
-    text = text.replace(`@${mem.userid}`, "");
-    text = text.trim();
-
-    const rows = text.split(/\r\n|\r|\n/).map(row => row.trim());
-    const commandRow = rows.filter(row => row.startsWith("/"))[0];
-
-    if (!commandRow || commandRow === "") {
-      console.warn("コマンドが本文から参照できません");
-
-      const response = await client.request("ueuse/create", {
-        text: i18next.t("commandNotFound"),
-        replyid: ueuse.uniqid,
-      });
-
-      if (!response.success)
-        console.warn("ユーズの作成に失敗しました:", response.error_code);
-      break;
-    }
-
-    const args = commandRow.replace("/", "").split(" ");
+  for (let i = 0; i < ueuses.length; i += config.command.maxParallels) {
+    const chunk = ueuses.slice(i, i + config.command.maxParallels);
     
-    switch (args[0]) {
-      case "help":
-        await helpCommand(ueuse, args);
-        break;
-      case "weather":
-        await weatherCommand(ueuse);
-        break;
-      case "follow":
-        await followCommand(ueuse);
-        break;
-      case "unfollow":
-        await unfollowCommand(ueuse);
-        break;
-      case "miq":
-        await miqCommand(ueuse, args);
-        break;
-      default:
-        console.warn("不明なコマンドが入力されました:", args[0]);
-
-        const response = await client.request("ueuse/create", {
-          text: i18next.t("unknownCommand", { command: args[0] }),
-          replyid: ueuse.uniqid,
-        });
-
-        if (!response.success)
-          console.warn("ユーズの作成に失敗しました:", response.error_code);
-        break;
-    }
-
-    {
-      const repliedUeuse = (Memory.memory["repliedUeuse"] as string[]);
-      repliedUeuse.push(ueuse.uniqid);
+    await Promise.all(chunk.map(async (ueuse) => {
       const mem = Memory.memory;
-      mem["repliedUeuse"] = repliedUeuse;
-      Memory.memory = mem;
-    }
+      let text = ueuse.text;
+      text = text.replace(`@${mem.userid}`, "");
+      text = text.trim();
+
+      const rows = text.split(/\r\n|\r|\n/).map(row => row.trim());
+      const commandRow = rows.filter(row => row.startsWith("/"))[0];
+
+      if (!commandRow || commandRow === "") {
+        console.warn("コマンドが本文から参照できません");
+
+        await createUeuse({
+          text: i18next.t("commandNotFound"),
+          replyid: ueuse.uniqid,
+        }, "コマンドが見つからない旨");
+
+        return;
+      }
+
+      const args = commandRow.replace("/", "").split(" ");
+      
+      switch (args[0]) {
+        case "help":
+          await helpCommand(ueuse, args);
+          break;
+        case "weather":
+          await weatherCommand(ueuse);
+          break;
+        case "follow":
+          await followCommand(ueuse);
+          break;
+        case "unfollow":
+          await unfollowCommand(ueuse);
+          break;
+        case "miq":
+          await miqCommand(ueuse, args);
+          break;
+        default:
+          console.warn("不明なコマンドが入力されました:", args[0]);
+
+          await createUeuse({
+            text: i18next.t("unknownCommand", { command: args[0] }),
+            replyid: ueuse.uniqid,
+          }, "コマンドが不明である旨");
+
+          break;
+      }
+    }));
   }
 
   process.exit(0);

src/feature/command/miq.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import client, { createUeuse } from "@/lib/client";
 import Memory from "@/lib/memory";
 import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import i18next from "i18next";
@@ -7,14 +7,10 @@ import { EOL } from "node:os";
 
 export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
   if (!args[1]) {
-    const response = await client.request("ueuse/create", {
+    await createUeuse({
       text: i18next.t("lackOption", { command: "miq" }),
       replyid: ueuse.uniqid,
-    });
-
-    if (!response.success) {
-      console.warn("返信に失敗:", response.error_code);
-    }
+    }, "オプションが不足している旨");
 
     return;
   }
@@ -32,14 +28,10 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           ? itUeuse.error_code
           : "データなし");
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceFailed"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
+        }, "ソースが見つからない旨");
 
         return;
       }
@@ -49,27 +41,19 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
       switch (permission) {
         case "me":
           if (itUeuse.data[0].account.userid !== ueuse.account.userid) {
-            const response = await client.request("ueuse/create", {
+            await createUeuse({
               text: i18next.t("miqPermissionMe"),
               replyid: ueuse.uniqid,
-            });
-
-            if (!response.success) {
-              console.warn("返信に失敗:", response.error_code);
-            }
+            }, "権限が自分自身のみである旨");
 
             return;
           }
         case "consent":
           if (itUeuse.data[0].account.userid !== ueuse.account.userid) {
-            const response = await client.request("ueuse/create", {
+            await createUeuse({
               text: i18next.t("miqPermissionConsent", { userid: itUeuse.data[0].account.userid }),
               replyid: ueuse.uniqid,
-            });
-
-            if (!response.success) {
-              console.warn("返信に失敗:", response.error_code);
-            }
+            }, "権限が許可制である旨");
 
             return;
           }
@@ -85,19 +69,15 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
       });
 
       if (!(typeof result === "string")) {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("miqGenerateFailed"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-        }
+        }, "Make it a Quoteの生成に失敗した旨");
 
         return;
       }
 
-      const response = await client.request("ueuse/create", {
+      await createUeuse({
         text: i18next.t("miqSuccess", { message: (args[2] ?? "") === "color"
             ? "カラーモードで生成しました。"
             : "モノクロモードで生成しました。"
@@ -106,14 +86,7 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           photo: [result],
         },
         replyid: ueuse.uniqid,
-      });
-
-      if (!response.success) {
-        console.warn("返信に失敗:", response.error_code);
-        return;
-      }
-
-      console.log("MiQを生成:", response.uniqid);
+      }, "Make it a Quote");
 
       break;
     case "permission":
@@ -121,33 +94,21 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
         mem = Memory.memory;
         const permission = mem["permissions"][ueuse.account.userid] ?? "consent";
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("permissionResponse", { permission }),
           replyid: ueuse.uniqid,
-        });
+        }, "権限");
 
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
         return;
       }
 
       const availablePermission = ["me", "everyone", "consent"];
       if (!(availablePermission.includes(args[2]))) {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("invalidOption", { option: args[2], command: "miq" }),
           replyid: ueuse.uniqid,
-        });
+        }, "無効なオプションである旨");
 
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
         return;
       }
 
@@ -156,33 +117,20 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
         mem["permissions"][ueuse.account.userid] = args[2];
         Memory.memory = mem;
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("permissionChangeSuccess", { username: ueuse.account.username, permission: args[2] }),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
+        }, "権限の変更に成功した旨");
       }
 
       break;
     case "allow":
       if (ueuse.replyid === "") {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("injusticeFormat"),
           replyid: ueuse.uniqid,
-        });
+        }, "形式が異なる旨");
 
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
         return;
       }
 
@@ -191,17 +139,11 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
         const permission = mem["permissions"][ueuse.account.userid] ?? "consent";
 
         if (permission !== "consent") {
-          const response = await client.request("ueuse/create", {
+          await createUeuse({
             text: i18next.t("permisionIsNotConsent"),
             replyid: ueuse.uniqid,
-          });
+          }, "権限が許可制ではない旨");
 
-          if (!response.success) {
-            console.warn("返信に失敗:", response.error_code);
-            return;
-          }
-
-          console.log("返信:", response.uniqid);
           return;
         }
       }
@@ -215,30 +157,20 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           ? confirmUeuse.error_code
           : "データなし");
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceFailed"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
+        }, "ソースが見つからない旨");
 
         return;
       }
 
       if (confirmUeuse.data[0].replyid === "") {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("injusticeFormat"),
           replyid: ueuse.uniqid,
-        });
+        }, "形式が異なる旨");
 
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
         return;
       }
 
@@ -248,14 +180,10 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           ? confirmUeuse.error_code
           : "データなし");
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceIsNotThis"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
+        }, "返信元がこのBotではない旨");
 
         return;
       }
@@ -269,30 +197,19 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           ? requestUeuse.error_code
           : "データなし");
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceFailed"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
+        }, "ソースが見つからない旨");
 
         return;
       }
 
       if (requestUeuse.data[0].replyid === "") {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("injusticeFormat"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("返信:", response.uniqid);
+        }, "形式が異なる旨");
         return;
       }
 
@@ -305,29 +222,19 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
           ? sourceUeuse.error_code
           : "データなし");
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceFailed"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
+        }, "ソースが見つからない旨");
 
         return;
       }
 
       if (sourceUeuse.data[0].account.userid !== ueuse.account.userid) {
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("replySourceIsNotSourceUser"),
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
-
-        console.warn("ソースのユーズと/miq allowのユーザーが一致しない:", );
+        }, "ソースのユーズと/miq allowのユーザーが一致しない旨");
 
         return;
       }
@@ -344,27 +251,15 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
         if (!commandRow || commandRow === "") {
           console.warn("コマンドが本文から参照できません");
 
-          const response = await client.request("ueuse/create", {
+          await createUeuse({
             text: i18next.t("commandNotFound"),
             replyid: requestUeuse.data[0].uniqid,
-          });
+          }, "コマンドが見つからない旨");
 
-          if (!response.success)
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-
-          {
-            const response = await client.request("ueuse/create", {
-              text: i18next.t("injusticeFormat"),
-              replyid: ueuse.uniqid,
-            });
-
-            if (!response.success) {
-              console.warn("返信に失敗:", response.error_code);
-              return;
-            }
-
-            console.log("返信:", response.uniqid);
-          }
+          await createUeuse({
+            text: i18next.t("injusticeFormat"),
+            replyid: ueuse.uniqid,
+          }, "形式が異なる旨");
 
           break;
         }
@@ -381,19 +276,15 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
         });
 
         if (!(typeof result === "string")) {
-          const response = await client.request("ueuse/create", {
+          await createUeuse({
             text: i18next.t("miqGenerateFailed"),
             replyid: ueuse.uniqid,
-          });
-
-          if (!response.success) {
-            console.warn("返信に失敗:", response.error_code);
-          }
+          }, "Make it a Quoteの生成に失敗した旨");
 
           return;
         }
 
-        const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("miqSuccess", { message: ((requestUeuseArgs[2] ?? "") === "color"
                 ? "カラーモードで生成しました。"
                 : "モノクロモードで生成しました。")
@@ -403,14 +294,7 @@ export default async function miqCommand(ueuse: ueuseModule, args: string[]) {
             photo: [result],
           },
           replyid: ueuse.uniqid,
-        });
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("MiQを生成:", response.uniqid);
+        }, "Make it a Quote");
       }
 
       break;

src/feature/command/unfollow.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import client, { createUeuse } from "@/lib/client";
 import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import i18next from "i18next";
 
@@ -14,15 +14,8 @@ export default async function unfollowCommand(ueuse: ueuseModule) {
 
   console.log("フォロー解除:", unfollow.userid);
 
-  const notice = await client.request("ueuse/create", {
+  await createUeuse({
     text: i18next.t("unfollowedNotification", { username: ueuse.account.username }),
     replyid: ueuse.uniqid,
-  });
-
-  if (!notice.success) {
-    console.warn("フォロー解除通知に失敗:", notice.error_code);
-    return;
-  }
-
-  console.log("フォロー解除通知:", notice.uniqid);
+  }, "フォロー解除通知");
 }

src/feature/earthquakeNotice.ts

@@ -1,6 +1,7 @@
-import client from "@/lib/client";
+import { createUeuse } from "@/lib/client";
 import config from "@/lib/config";
 import initI18n from "@/lib/i18n";
+import Memory from "@/lib/memory";
 import { format } from "date-fns";
 import i18next from "i18next";
 import { readFileSync } from "node:fs";
@@ -20,37 +21,68 @@ if (config.earthquake?.useHistoryData) {
     i++;
   }, 10 * 1000);
 } else {
-  const WEBSOCKET_URL = config.debug
-    ? "wss://api-realtime-sandbox.p2pquake.net/v2/ws"
-    : "wss://api.p2pquake.net/v2/ws";
+  const connect = () => {
+    const WEBSOCKET_URL = config.debug
+      ? "wss://api-realtime-sandbox.p2pquake.net/v2/ws"
+      : "wss://api.p2pquake.net/v2/ws";
 
-  console.log("P2P地震情報のWebSocketに接続します");
-  const socket = new WebSocket(WEBSOCKET_URL);
+    console.log("P2P地震情報のWebSocketに接続します");
+    const socket = new WebSocket(WEBSOCKET_URL);
 
-  socket.addEventListener("open", () => {
-    console.log("P2P地震情報のWebSocketに接続しました");
-  });
+    socket.addEventListener("open", () => {
+      console.log("P2P地震情報のWebSocketに接続しました");
+    });
 
-  socket.addEventListener("message", async (event) => {
-    let message;
+    socket.addEventListener("close", (err) => {
+      const interval = config.earthquake.reconnectInterval;
+      console.log(`WebSocketが切断されました。${interval / 1000}秒後に再接続します:`, err.reason);
+      setTimeout(() => {
+        connect();
+      }, interval);
+    });
 
-    try {
-      message = typeof event.data === "string"
-        ? JSON.parse(event.data)
-        : event.data;
-    } catch (err) {
-      console.error(`メッセージのパースでエラーが発生: ${err}`);
-      return;
-    }
+    socket.addEventListener("error", (err) => {
+      console.error("WebSocketでエラーが発生しました:", err);
+      socket.close();
+    });
 
-    processMessage(message);
-  });
+    socket.addEventListener("message", async (event) => {
+      let message;
+
+      try {
+        message = typeof event.data === "string"
+          ? JSON.parse(event.data)
+          : event.data;
+      } catch (err) {
+        console.error("地震情報メッセージのパースでエラーが発生:", err);
+        return;
+      }
+
+      const id = message.id ?? message._id;
+      const mem = Memory.memory;
+      if (mem.processedInfo.includes(id) && !config.debug) {
+        console.log("重複した地震情報:", message.id);
+        return;
+      }
+
+      processMessage(message);
+
+      if (!config.debug) {
+        const mem = Memory.memory;
+        mem.processedInfo = mem.processedInfo.concat([id]);
+        Memory.memory = mem;
+      }
+    });
+  }
+
+  connect();
 }
 
 const processMessage = async (message: any) => {
   try {
     const scaleMessages: Record<string, string> = {
       "-1": "不明",
+      "0": "震度0",
       "10": "震度1",
       "20": "震度2",
       "30": "震度3",
@@ -65,10 +97,30 @@ const processMessage = async (message: any) => {
     }
 
     switch (message.code) {
+      case 555:
+        console.log("ピアの地域分布情報を受信しました");
+        break;
       case 551:
         {
           console.log("地震発生情報を受信しました");
 
+          if (
+            (message.earthquake.maxScale === -1 ||
+            message.earthquake.maxScale === undefined) &&
+            !config.earthquake.canUnknownMaxScale
+          ) {
+            console.log("最大震度が不明であり、最大震度が不明な場合の投稿が許可されていないため、スキップします");
+            break;
+          }
+
+          if (
+            message.earthquake.maxScale !== -1 &&
+            message.earthquake.maxScale < config.earthquake.requireMaxScale
+          ) {
+            console.log(`最大震度(${scaleMessages[message.earthquake.maxScale]})が投稿に必要な値(${scaleMessages[config.earthquake.requireMaxScale]})に満たないため、スキップします`);
+            break;
+          }
+
           const domesticTsunamiMessages: Record<string, string> = {
             "None": "😌この地震による**国内**の津波の心配はありません。",
             "Unknown": "😕この地震による**国内**の***津波情報は***不明です。",
@@ -91,34 +143,36 @@ const processMessage = async (message: any) => {
             "Potential": "🚨この地震によって**一般的に**この規模では津波の可能性があると考えられています。",
           }
 
-          let points: Record<string, any[]> = {};
-          for (const point of message.points) {
-            const scaleMsg = scaleMessages[String(point.scale)];
-            if (!scaleMsg)
-              break;
+          const grouped: Record<string, { scale: number; prefs: Record<string, string[]> }> = {};
 
-            points[scaleMsg]?.push(point);
-          }
-
-          const grouped: Record<string, { scale: number; addrs: string[] }> = {};
           for (const point of message.points) {
-            const { addr, scale } = point;
+            const { addr, scale, pref } = point;
             const label = scaleMessages[String(scale)] ?? "不明";
 
             if (!grouped[label]) {
-              grouped[label] = { scale, addrs: [] };
+              grouped[label] = { scale, prefs: {} };
             }
 
-            grouped[label].addrs.push(addr);
+            if (!grouped[label].prefs[pref]) {
+              grouped[label].prefs[pref] = [];
+            }
+
+            grouped[label].prefs[pref].push(addr);
           }
 
           const pointsMsg = Object.entries(grouped)
             .sort((a, b) => b[1].scale - a[1].scale)
-            .map(([label, { addrs }]) => 
-              `【${label}】${EOL}${addrs.join("・")}`)
-            .join(EOL.repeat(2)).trim();
+            .map(([label, { prefs }]) => {
+              const prefLines = Object.entries(prefs)
+                .map(([pref, addrs]) => `**${pref}:** ${addrs.join("・")}`)
+                .join(EOL);
 
-          const response = await client.request("ueuse/create", {
+              return `【${label}】${EOL}${prefLines}`;
+            })
+            .join(EOL.repeat(2))
+            .trim();
+
+          await createUeuse({
             text: i18next.t("earthquakeNotice", {
               occuredTime: format(new Date(message.earthquake.time), "yyyy年M月d日 H:mm"),
               maxScale: scaleMessages[String(message.earthquake.maxScale)],
@@ -143,14 +197,7 @@ const processMessage = async (message: any) => {
                 ? ""
                 : EOL + message.comments.freeFormComment + EOL,
             }),
-          });
-
-          if (!response.success) {
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-            break;
-          }
-
-          console.log("地震発生情報を投稿:", response.uniqid);
+          }, "地震発生情報");
         }
         break;
       case 552:
@@ -158,19 +205,12 @@ const processMessage = async (message: any) => {
           console.log("津波予報情報を受信しました");
 
           if (message.cancelled) {
-            const response = await client.request("ueuse/create", {
+            await createUeuse({
               text: i18next.t("tsunamiCancelNotice", {
                 announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
                 source: message.issue.source ?? "不明",
               }),
-            });
-
-            if (!response.success) {
-              console.warn("ユーズの作成に失敗しました:", response.error_code);
-              break;
-            }
-
-            console.log("津波予報解除情報を投稿:", response.uniqid);
+            }, "津波予報解除情報");
             break;
           }
 
@@ -201,26 +241,30 @@ const processMessage = async (message: any) => {
             }) + EOL.repeat(2);
           }
 
-          const response = await client.request("ueuse/create", {
+          await createUeuse({
             text: i18next.t("tsunamiForecastNotice", {
               announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
               areasMsg: areasMsg.trim(),
               source: message.issue.source ?? "不明",
             }),
-          });
-
-          if (!response.success) {
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-            break;
-          }
-
-          console.log("津波予報情報を投稿:", response.uniqid);
+          }, "津波予報情報");
         }
         break;
       case 556:
         {
           console.log("緊急地震速報（警報）を受信しました");
 
+          if (message.cancelled) {
+            await createUeuse({
+              text: i18next.t("eewCancelNotice", {
+                isTest: message.test
+                  ? "⚒️これは**テストです。**"
+                  : "🚨これは**テストではありません。**",
+                announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
+              }),
+            }, "緊急地震速報（警報）解除情報");
+          }
+
           const kindMessages: Record<string, string> = {
             "10": "⏳主要動は、**未到達と予測**されています。",
             "11": "🫨主要動が、**既に到達していると予測**されています。",
@@ -238,13 +282,13 @@ const processMessage = async (message: any) => {
                     ? `から${scaleMessages[String(Math.floor(area.scaleTo))]}`
                     : ""),
               kind: kindMessages[area.kindCode] ?? "😕主要動の***到達予想は***ありません。",
-              arrivalTime: area.arrivalTime !== undefined
+              arrivalTime: typeof area.arrivalTime === "string" && area.arrivalTime !== ""
                 ? format(new Date(area.arrivalTime), "yyyy年M月d日 H:mm:ss")
                 : "不明",
             }) + EOL.repeat(2);
           }
 
-          const response = await client.request("ueuse/create", {
+          await createUeuse({
             text: i18next.t("eewNotice", {
               isTest: message.test
                 ? "⚒️これは**テストです。**"
@@ -263,19 +307,12 @@ const processMessage = async (message: any) => {
               magnitude: message.earthquake.hypocenter.magnitude === undefined ||
                 message.earthquake.hypocenter.magnitude === -1
                   ? "不明"
-                  : `M${message.earthquake.hypocenter.magnitude}`,
+                  : `M${message.earthquake.hypocenter.magnitude.toFixed(1)}`,
               areas: areasMsg !== ""
                 ? EOL.repeat(2) + areasMsg.trim()
                 : "",
             }),
-          });
-
-          if (!response.success) {
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-            break;
-          }
-
-          console.log("緊急地震速報（警報）情報を投稿:", response.uniqid);
+          }, "緊急地震速報（警報）情報");
         }
         break;
       default:

src/feature/hnyNotice.ts

@@ -0,0 +1,25 @@
+import { createUeuse } from "@/lib/client";
+import initI18n from "@/lib/i18n";
+import { format } from "date-fns";
+import i18next from "i18next";
+import { parentPort } from "node:worker_threads";
+
+await initI18n();
+
+parentPort?.on("message", async () => {
+  console.log("新年迎春の投稿を行います");
+
+  try {
+    await createUeuse({
+      text: i18next.t("hnyNotice", { year: String(new Date().getFullYear()) }),
+    }, "新年迎春");
+
+    console.log("新年迎春投稿時刻:", format(new Date(), "yyyy/M/d H:mm:ss:SSS"));
+    process.exit(0);
+  } catch (err: any) {
+    console.error("message" in err
+      ? err.message
+      : err);
+    process.exit(1);
+  }
+});

src/feature/timeNotice.ts

@@ -1,4 +1,4 @@
-import client from "@/lib/client";
+import { createUeuse } from "@/lib/client";
 import initI18n from "@/lib/i18n";
 import { format } from "date-fns";
 import i18next from "i18next";
@@ -7,16 +7,10 @@ await initI18n();
 console.log("時報の投稿を行います");
 
 try {
-  const response = await client.request("ueuse/create", {
-    text: i18next.t("timeNotice", { time: format(new Date(), "HH:mm") }),
-  });
+  await createUeuse({
+    text: i18next.t("timeNotice", { time: format(new Date(), "H:mm") }),
+  }, "時報");
 
-  if (!response.success) {
-    console.warn("時報投稿に失敗しました:", response.error_code);
-    process.exit(1);
-  }
-
-  console.log("時報投稿:", response.uniqid);
   process.exit(0);
 } catch (err: any) {
   console.error("message" in err

src/feature/weatherNotice.ts

@@ -1,6 +1,7 @@
 import client from "@/lib/client";
 import config from "@/lib/config";
 import initI18n from "@/lib/i18n";
+import Memory from "@/lib/memory";
 import i18next from "i18next";
 import { readFileSync } from "node:fs";
 import { EOL } from "node:os";
@@ -61,12 +62,27 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
   console.log("天気予報の投稿を行います");
 
   try {
-    const provisionalUeuse = await client.request("ueuse/create", {
-      text: i18next.t("weatherProvisional"),
-    });
+    let provisionalUeuse;
+    let success = false;
 
-    if (!provisionalUeuse.success) {
-      console.error("天気仮投稿に失敗しました:", provisionalUeuse.error_code);
+    for (let attempt = 1; attempt <= config.ueuse.maxRetries; attempt++) {
+      provisionalUeuse = await client.request("ueuse/create", {
+        text: i18next.t("weatherProvisional"),
+      });
+
+      if (provisionalUeuse.success) {
+        success = true;
+        break;
+      }
+
+      console.warn(`天気仮投稿に失敗しました (試行 ${attempt}/${config.ueuse.maxRetries}):`, provisionalUeuse.error_code);
+      if (attempt < config.ueuse.maxRetries) {
+        await new Promise(resolve => setTimeout(resolve, 1000));
+      }
+    }
+
+    if (!success || !provisionalUeuse?.success) {
+      console.error("天気仮投稿の全試行に失敗したため、終了します。");
       process.exit(1);
     }
 
@@ -84,7 +100,9 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
 
 export async function weatherReply(uniqid: string) {
   // インデックス
-  const splitCount = config.weather.splits;
+  const aboutFullLength = 3100;
+  const mem = Memory.memory;
+  const splitCount = Math.round(aboutFullLength / mem.max_length);
   const total = cityList.length;
   const chunkSizes = Array(splitCount).fill(0).map((_, i) =>
     Math.floor((total + i) / splitCount)
@@ -148,13 +166,29 @@ export async function weatherReply(uniqid: string) {
 
   // 分割投稿
   for (let i = 0; i < splitCount; i++) {
-    const replyUeuse = await client.request("ueuse/create", {
-      text: weatherResults[i].trim(),
-      replyid: uniqid,
-    });
+    let replyUeuse;
+    let success = false;
 
-    if (!replyUeuse.success) {
-      console.error("天気返信に失敗しました:", replyUeuse.error_code);
+    for (let attempt = 1; attempt <= config.ueuse.maxRetries; attempt++) {
+      replyUeuse = await client.request("ueuse/create", {
+        text: weatherResults[i].trim(),
+        replyid: uniqid,
+      });
+
+      if (replyUeuse.success) {
+        success = true;
+        break;
+      }
+
+      console.warn(`天気返信に失敗しました (試行 ${attempt}/${config.ueuse.maxRetries}):`, replyUeuse.error_code);
+      if (attempt < config.ueuse.maxRetries) {
+        await new Promise(resolve => setTimeout(resolve, config.ueuse.retryInterval));
+      }
+    }
+
+    if (!success || !replyUeuse?.success) {
+      console.error("天気返信の全試行に失敗したため、終了します。");
+      process.exit(1);
     }
 
     console.log("天気返信:", replyUeuse.uniqid);

src/index.ts

@@ -1,7 +1,7 @@
 import { schedule } from "node-cron";
 import { readFileSync } from "node:fs";
 import config from "@/lib/config";
-import { initUserID } from "@/lib/memory";
+import { initData } from "@/lib/memory";
 import { styleText } from "node:util";
 import { Worker } from "node:worker_threads";
 
@@ -18,7 +18,7 @@ try {
   }
   console.log();
 
-  await initUserID();
+  await initData();
 
   new Worker(`${import.meta.dirname}/feature/earthquakeNotice.js`);
 
@@ -30,14 +30,30 @@ try {
   process.exit(1);
 }
 
-schedule("0 * * * *", async () => {
-  new Worker(`${import.meta.dirname}/feature/timeNotice.js`);
-});
+try {
+  schedule("0 * * * *", async () => {
+    new Worker(`${import.meta.dirname}/feature/timeNotice.js`);
+  });
 
-schedule("0 7 * * *", async () => {
-  new Worker(`${import.meta.dirname}/feature/weatherNotice.js`);
-});
+  schedule("0 7 * * *", async () => {
+    new Worker(`${import.meta.dirname}/feature/weatherNotice.js`);
+  });
 
-schedule(`*/${config.command.interval} * * * *`, async () => {
-  new Worker(`${import.meta.dirname}/feature/command/index.js`);
-});
+  schedule(`*/${config.command.interval} * * * *`, async () => {
+    new Worker(`${import.meta.dirname}/feature/command/index.js`);
+  });
+
+  let hnyWorker: Worker | undefined = undefined;
+
+  schedule("57 59 23 31 12 *", () => {
+    hnyWorker = new Worker(`${import.meta.dirname}/feature/hnyNotice.js`);
+  });
+
+  schedule("0 0 0 1 1 *", () => {
+    hnyWorker?.postMessage("");
+  });
+} catch (err: any) {
+  console.error("message" in err
+    ? err.message
+    : err);
+}

src/lib/client.ts

@@ -2,6 +2,8 @@ import uwuzu from "better-uwuzu-sdk";
 import config from "@/lib/config";
 import Parser from "better-uwuzu-sdk/1.6.8/parser";
 import ApiMap from "better-uwuzu-sdk/types/1.6.8/map";
+import Memory from "@/lib/memory";
+import { EOL } from "node:os";
 
 const client = new uwuzu<ApiMap>({
   origin: config.uwuzu.origin,
@@ -9,5 +11,92 @@ const client = new uwuzu<ApiMap>({
 });
 
 client.token = config.uwuzu.token;
+export default client;
 
-export default client;
+export const createUeuse = async (data: ApiMap["ueuse/create"]["body"], title: string) => {
+  const mem = Memory.memory;
+  const excessedMessage = "👉返信に続きがあります。";
+  
+  let lines = data.text.split(EOL);
+  let firstUniqid = "";
+  let count = 0;
+
+  while (lines.length > 0) {
+    count++;
+    let currentText = "";
+    
+    const currentMaxLength = (data.replyid !== undefined || firstUniqid !== "") 
+      ? mem.max_length 
+      : config.ueuse.maxLengthWithPublic === 0
+        ? mem.max_length
+        : config.ueuse.maxLengthWithPublic;
+
+    const limit = currentMaxLength - (excessedMessage.length + EOL.length * 2);
+
+    while (lines.length > 0) {
+      const nextLine = lines[0];
+      if (nextLine === undefined)
+        break;
+
+      if (nextLine.length > limit && currentText === "") {
+        const targetLine = lines.shift() || "";
+        currentText = targetLine.slice(0, limit);
+
+        lines.unshift(targetLine.slice(limit));
+        break;
+      }
+
+      const potentialText = currentText ? currentText + EOL + nextLine : nextLine;
+      if (potentialText.length <= limit) {
+        currentText = potentialText;
+        lines.shift();
+      } else {
+        break;
+      }
+    }
+
+    currentText = currentText.trimEnd();
+
+    if (lines.length > 0) {
+      currentText += EOL.repeat(2) + excessedMessage;
+    }
+
+    let postedUniqid = "";
+    let success = false;
+
+    for (let attempt = 1; attempt <= config.ueuse.maxRetries; attempt++) {
+      const response = await client.request("ueuse/create", {
+        ...data,
+        text: currentText,
+        replyid: data.replyid === undefined && firstUniqid !== ""
+          ? firstUniqid
+          : data.replyid,
+      });
+
+      if (response.success) {
+        success = true;
+        postedUniqid = response.uniqid;
+        break;
+      }
+
+      console.warn(`${title}の投稿に失敗しました (試行 ${attempt}/${config.ueuse.maxRetries}):`, response.error_code);
+      if (attempt < config.ueuse.maxRetries) {
+        await new Promise(resolve => setTimeout(resolve, config.ueuse.retryInterval));
+      }
+    }
+
+    if (!success) {
+      console.error(`${title}の全試行が失敗したため、処理を中断します。`);
+      break;
+    }
+
+    if (firstUniqid === "")
+      firstUniqid = postedUniqid;
+
+    console.log(`${title}を投稿(${count}):`, postedUniqid);
+
+    while (lines.length > 0 && lines[0]?.trim() === "") {
+      lines.shift();
+    }
+  }
+}

src/lib/config.ts

@@ -6,13 +6,24 @@ import { EOL } from "node:os";
 const schema = z.object({
   command: z.object({
     interval: z.number().int().positive(),
-  }),
-  weather: z.object({
-    splits: z.number().int().positive(),
+    maxParallels: z.number().int().positive(),
   }),
   earthquake: z.object({
+    requireMaxScale: z.union([
+      z.literal(10),
+      z.literal(20),
+      z.literal(30),
+      z.literal(40),
+      z.literal(45),
+      z.literal(50),
+      z.literal(55),
+      z.literal(60),
+      z.literal(70),
+    ]),
+    canUnknownMaxScale: z.boolean(),
     useHistoryData: z.boolean(),
-  }).optional(),
+    reconnectInterval: z.number().positive(),
+  }),
   uwuzu: z.object({
     token: z.string().length(64),
     origin: z.string().refine(data => {
@@ -23,6 +34,11 @@ const schema = z.object({
       }
     }),
   }),
+  ueuse: z.object({
+    maxRetries: z.number().int().positive(),
+    retryInterval: z.number().positive(),
+    maxLengthWithPublic: z.number().int().nonnegative(),
+  }),
   debug: z.boolean().optional(),
 });
 

src/lib/memory.ts

@@ -9,9 +9,12 @@ class MemoryClass {
   constructor() {
     if (!existsSync(path)) {
       writeFileSync(path, JSON.stringify({
-        repliedUeuse: [],
+        processedInfo: [],
         permissions: {},
+        lastReadMention: "",
+        lastReadReply: "",
         userid: "",
+        max_length: 0,
       }));
     }
 
@@ -30,15 +33,26 @@ class MemoryClass {
 
 const Memory = new MemoryClass();
 
-export const initUserID = async () => {
-  const response = await client.request("me/");
+export const initData = async () => {
+  await Promise.all([
+    (async () => {
+      const response = await client.request("me/");
 
-  if (!response.success)
-    throw new Error("meの取得に失敗しました");
+      if (!response.success)
+        throw new Error("meの取得に失敗しました");
 
-  const mem = Memory.memory;
-  mem.userid = response.userid;
-  Memory.memory = mem;
+      const mem = Memory.memory;
+      mem.userid = response.userid;
+      Memory.memory = mem;
+    })(),
+    (async () => {
+      const response = await client.request("serverinfo-api");
+
+      const mem = Memory.memory;
+      mem.max_length = response.server_info.max_ueuse_length;
+      Memory.memory = mem;
+    })(),
+  ]);
 }
 
 export default Memory;