Merge branch 'main' into develop

Reviewed-on: #25

CHANGELOG.md

@@ -1,3 +1,127 @@
+# 2026.5.9
+- Fix: pnpmが動作しない問題
+
+# 2026.5.8
+- Fix: 地震情報の情報源と各震度の間に改行がない問題
+- Fix: 最大震度が不明な場合にも行が追加される問題
+- Fix: pnpmが動作しない問題
+
+# 2026.5.7
+- Feat: 朝四時に何してるんだい?
+- Chg: pnpm 11.1.3
+- Chg: 地震情報で不明な情報をそもそも投稿しないように
+- Del: helpコマンドとmiqコマンドを除く全てのi18nを廃止
+
+# 2026.5.6
+- Fix: 2026.5.5で修正されたと報告した「20件前のユーズを最後に応答したコマンドのユーズとして記録していた問題」を再発させていた問題
+
+# 2026.5.5
+- Chg: 毎日7:00の天気予報の日付表記
+- Fix: 20件前のユーズを最後に応答したコマンドのユーズとして記録していた問題
+- Fix: 毎日18:00の天気予報の仮投稿の表記が本日になっていた問題
+
+# 2026.5.4
+- Chg: メモリをキャッシュしないように
+
+# 2026.5.3
+- Chg: 震度分布画像のメッセージを変更
+- Fix: distに震度分布画像のアセットと地域マップがコピーされるように
+- Fix: 返信とメンションの返答が記録されない問題
+- Fix: 震度分布画像が投稿されない問題
+- Fix: 条件に合わなくても震度分布画像を生成する問題
+- Fix: 震度分布画像に隙間が空く問題
+- Del: 正確にスケジュールが動作する機能
+
+# 2026.5.2
+- Fix: `/weather`が利用できない問題
+
+# 2026.5.1
+- Feat: 地震の震度分布画像生成
+- Feat: 震度分布画に全タイルが埋まる機能
+- Feat: 震度分布画像の震源がタイル単位で中央になる機能
+- Feat: 震度分布画像で欠けているタイルが描画される機能
+- Feat: 震度分布画像のアセットの位置が中央基準になる機能
+- Chg: 全てのスケジュールが正確に動作するように
+- Chg: 毎日18:00に明日の天気予報を投稿するように
+- Chg: 震度分布画像のズームレベルを8から9へ
+- Chg: 震度分布画像の生成条件を震源と位置が存在するへ変更
+- Chg: 震度分布画像のアセットを並列に取得
+- Chg: 震度分布画像の震源のアセットに縁取りを追加
+- Chg: 震度分布画像の震度ではないアセットを拡大
+- Chg: ユーズの分割の案内文を太字に
+- Fix: 地震情報の画像生成での並び替えで、震度の位置が震源の位置として扱われる問題 
+- Fix: 毎日7:00に天気予報の返信をできない問題
+- Del: 最大震度が不明な場合に投稿するかどうかのconfigを削除
+
+# 2026.5.0
+- Feat(dev): 地震情報の画像生成機能は未完成のため、ユーズには適用されません
+- Chg: 地震情報でのタイトルを変更
+- Fix: 毎日7:00に天気予報が投稿されない問題
+
+# 2026.4.3
+- Chg: forループ内でlastReadを記録するように
+- Chg: lastReadを時刻ベースに
+
+# 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 +131,7 @@
 - Del: 各地震情報の情報源の信頼できるかどうかの内容を削除
 - Chg: 津波予報情報の各時刻情報を実際に取得できる値まで削減(例: 2:03:00 > 2:03)
 - Fix: フォロー・フォロー解除に失敗した際にreturnできていない問題
-- Feat: デバッグ用とで過去の地震情報を読み込み10秒おきに投稿する機能 
+- Feat: デバッグ用で過去の地震情報を読み込み10秒おきに投稿する機能 
 
 # 2026.4.0-alpha.0
 - Breaking: noticeUwuzuを0から作り直しました

README.md

@@ -1,17 +1,21 @@
 # noticeUwuzu
 [uwuzu](https://www.uwuzu.com)向けのお知らせBotです。  
-uwuzu v1.6.3以上で利用可能です。
+uwuzu v1.6.7以上で利用可能です。
 
 ## 機能
 - 時報  
   毎時0分に「h:00になりました。」と投稿します。  
+  4:00は某画像で投稿します。
 - 天気予報  
-  [天気予報 API（livedoor 天気互換）](https://weather.tsukumijima.net/)を利用して、毎日7:00に天気予報を投稿します。
+  [天気予報 API（livedoor 天気互換）](https://weather.tsukumijima.net/)を利用して、毎日7:00及び18:00に天気予報を投稿します。
+  18:00は明日の天気予報を投稿します。
 - 地震情報  
   [P2P地震情報](https://www.p2pquake.net/)のWebSocket APIを利用して、以下の情報を受信した際に投稿します。
   - 地震発生
   - 緊急地震速報（警報）
   - 津波予報
+- 新年迎春  
+  毎年1/1 0:00に投稿します。
 - デバッグモード  
   設定で有効化することで、以下の機能が利用できます。  
   開発以外では使用しないでください。
@@ -20,6 +24,8 @@ uwuzu v1.6.3以上で利用可能です。
   - 地震情報のWebSocketの接続先をテスト用サンドボックスに変更  
     P2P地震情報の接続先を本番環境から[テスト用サンドボックスのエンドポイント](https://www.p2pquake.net/develop/json_api_v2/)に変更します。  
     そのため、最新の情報は配信されません。
+  - 地震情報のid除外を無効化  
+    地震情報のid除外を記録も確認も行わなくなります。
   - i18nextのdebugを有効化  
     [i18nextでのdebug](https://www.i18next.com/overview/configuration-options#logging)が有効化されます。
 

config/example.yaml

@@ -1,10 +1,41 @@
 command:
+  # コマンド処理の間隔(分) number
+  # 自然数のみが有効です。
   interval: 10
-weather:
+  # コマンドの最大並列処理数 number
-  splits: 4
+  # 例: 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
+  # デバッグ用途のみで使用してください。
   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

@@ -1,55 +1,3 @@
-timeNotice: "{{ time }}になりました。"
-weatherProvisional: |
-  本日の天気
-  ※タイムラインが埋まるため返信に記載しています。
-weatherReply: |
-  【{{ city }}】
-  天気: {{ weather }}
-  最高気温: {{ maxTemp }}
-  最低気温: {{ minTemp }}
-  降水確率: {{ chanceOfRain }}
-earthquakeNotice: |
-  ### ==地震発生==
-  ⏰時刻: {{ occuredTime }}
-  🫨最大震度: {{ maxScale }}
-  📍震源地: {{ epicenter }}
-  💪マグニチュード: {{ magnitude }}
-  🪨深さ: {{ depth }}
-  {{ domesticTsunami }}
-  {{ foreignTsunami }}{{ points }}
-  {{ comment }}
-  🔬情報源: P2P地震速報 - {{ source }}
-tsunamiAreaMsg: |
-  【{{ name }}】{{ immediate }}
-  🏷️種別: {{ grade }}
-  ⏳第1波到達予想時刻: {{ arrivalTime }}
-  🌊第1波の状態: {{ condition }}
-  🗼予想される津波の高さ: {{ maxHeight }}
-tsunamiForecastNotice: |
-  ### ==津波予報**発表**==
-  ⏰発表時刻: {{ announceTime }}
-
-  {{ areasMsg }}
-
-  🔬情報源: P2P地震速報 - {{ source }}
-tsunamiCancelNotice: |
-  ### ==津波予報**解除**==
-  ⏰発表時刻: {{ announceTime }}
-  🔬情報源: P2P地震速報 - {{ source }}
-eewAreaMsg: |
-  【{{ name }}】
-  🫨最大予測震度: {{ maxScale }}
-  ⏰到達予想時刻: {{ arrivalTime }}
-  {{ kind }}
-eewNotice: |
-  ### ==***緊急地震速報（警報）***==
-  {{ isTest }}{{isAssume}}
-  ⏰発表時刻: {{ announceTime }}
-  ⏰地震発生時刻: {{ occuredTime }}
-  ⏰地震発現時刻: {{ arrivalTime }}
-  📍震源地: {{ epicenter }}
-  💪マグニチュード: {{ magnitude }}
-  🪨深さ: {{ depth }}{{ areas }}
 commandNotFound: |
   コマンドが本文から参照できませんでした。
   Botでは、このアカウントに対してのメンション部分を取り除きます。

package.json

@@ -1,28 +1,30 @@
 {
   "name": "notice-uwuzu",
-  "version": "26.4.0-alpha.1",
+  "version": "2026.5.9",
   "type": "module",
   "main": "dist/index.js",
   "scripts": {
     "start": "node .",
-    "build": "tsc && tsc-alias"
+    "build": "tsc && tsc-alias && cpy \"{**/*.json,**/*.png}\" ../dist --cwd=src && cpy \"260420.json\" dist"
   },
   "author": {
     "name": "Last2014",
     "email": "info@last2014.com",
     "url": "https://about.last2014.com"
   },
-  "packageManager": "pnpm@10.33.0",
+  "packageManager": "pnpm@11.1.3+sha512.c85357fe17ca12dd23dd7071822666dfd7e3cb76fe214e3370b5ea2fb34f2a231185509b63e717f3cd0acb38dd3f8d82bcd5e8172400ae678b70ea4fbed0896d",
   "dependencies": {
     "@types/node": "^25.5.2",
     "@types/ws": "^8.18.1",
     "better-uwuzu-sdk": "git+https://gitea.last2014.com/last2014/better-uwuzu-sdk.git#1.1.7",
+    "cpy-cli": "^7.0.0",
     "date-fns": "^4.1.0",
     "fs": "0.0.1-security",
     "i18next": "^26.0.3",
     "miq": "git+https://gitea.last2014.com/last2014/miq.git#1.0.1",
     "node-cron": "^4.2.1",
     "os": "^0.1.2",
+    "sharp": "^0.34.5",
     "tsc-alias": "^1.8.16",
     "typescript": "^5.9.3",
     "util": "^0.12.5",

pnpm-lock.yaml

@@ -17,6 +17,9 @@ importers:
       better-uwuzu-sdk:
         specifier: git+https://gitea.last2014.com/last2014/better-uwuzu-sdk.git#1.1.7
         version: git+https://gitea.last2014.com/last2014/better-uwuzu-sdk.git#8017146b1a2d6264d051b54afccdd46571b5fd00
+      cpy-cli:
+        specifier: ^7.0.0
+        version: 7.0.0
       date-fns:
         specifier: ^4.1.0
         version: 4.1.0
@@ -33,6 +36,9 @@ importers:
         specifier: ^4.2.1
         version: 4.2.1
       os: {specifier: ^0.1.2, version: 0.1.2}
+      sharp:
+        specifier: ^0.34.5
+        version: 0.34.5
       tsc-alias:
         specifier: ^1.8.16
         version: 1.8.16
@@ -226,6 +232,10 @@ packages:
     resolution: {integrity: sha512-oGB+UxlgWcgQkgwo8GcEGwemoTFt3FIO9ababBmaGwXIoBKZ+GTy0pP185beGg7Llih/NSHSV2XAs1lnznocSg==}
     engines: {node: '>= 8'}
 
+  '@sindresorhus/merge-streams@4.0.0':
+    resolution: {integrity: sha512-tlqY9xq5ukxTUZBmoOp+m61cqwQD5pHJtFY3Mn8CA8ps6yghLH/Hw8UPdqg4OLmFW3IFlcXnQNmo/dh8HzXYIQ==}
+    engines: {node: '>=18'}
+
   '@types/node@25.5.2':
     resolution: {integrity: sha512-tO4ZIRKNC+MDWV4qKVZe3Ql/woTnmHDr5JD8UI5hn2pwBrHEwOEMZK7WlNb5RKB6EoJ02gwmQS9OrjuFnZYdpg==}
 
@@ -295,6 +305,19 @@ packages:
     resolution: {integrity: sha512-KRs7WVDKg86PWiuAqhDrAQnTXZKraVcCc6vFdL14qrZ/DcWwuRo7VoiYXalXO7S5GKpqYiVEwCbgFDfxNHKJBQ==}
     engines: {node: ^12.20.0 || >=14}
 
+  copy-file@11.1.0:
+    resolution: {integrity: sha512-X8XDzyvYaA6msMyAM575CUoygY5b44QzLcGRKsK3MFmXcOvQa518dNPLsKYwkYsn72g3EiW+LE0ytd/FlqWmyw==}
+    engines: {node: '>=18'}
+
+  cpy-cli@7.0.0:
+    resolution: {integrity: sha512-uGCdhIxGfZcPXidCuT8w1jBknVXFx0un7NLjzqBZcdnkIWtLUnWMPk5TC37ceoVjwASLSNsRtTXXNTuFIyE2ng==}
+    engines: {node: '>=20'}
+    hasBin: true
+
+  cpy@13.2.2:
+    resolution: {integrity: sha512-FEc7gmNSj4mDQCWNt3mByVn3qZX3EjMvggiqgCQPF1yJAFfyX6Ai/emN89w18TRp+QcFmdTLgX3hfNnIVgYHcw==}
+    engines: {node: '>=20'}
+
   date-fns@4.1.0:
     resolution: {integrity: sha512-Ukq0owbQXxa/U3EGtsdVBkR1w7KOQ5gIBqdH2hkvknzZPYvBxb/aa6E8L7tmjFtkwZBu3UXBbjIgPo/Ez4xaNg==}
 
@@ -396,10 +419,17 @@ packages:
     resolution: {integrity: sha512-jhIXaOzy1sb8IyocaruWSn1TjmnBVs8Ayhcy83rmxNJ8q2uWKCAj3CnJY+KpGSXCueAPc0i05kVvVKtP1t9S3g==}
     engines: {node: '>=10'}
 
+  globby@16.2.0:
+    resolution: {integrity: sha512-QrJia2qDf5BB/V6HYlDTs0I0lBahyjLzpGQg3KT7FnCdTonAyPy2RtY802m2k4ALx6Dp752f82WsOczEVr3l6Q==}
+    engines: {node: '>=20'}
+
   gopd@1.2.0:
     resolution: {integrity: sha512-ZUKRh6/kUFoAiTAtTYPZJ3hw9wNxx+BIBOijnlG9PnrJsCcSjs1wyyD6vJpaYtgnzDrKYRSqf3OO6Rfa93xsRg==}
     engines: {node: '>= 0.4'}
 
+  graceful-fs@4.2.11:
+    resolution: {integrity: sha512-RbJ5/jmFcNNCcDV5o9eTnBLJ/HszWV0P73bc+Ff4nS/rJj+YaS6IGyiOL0VoBYX+l1Wrl3k63h/KrH+nhJ0XvQ==}
+
   has-property-descriptors@1.0.2:
     resolution: {integrity: sha512-55JNKuIW+vq4Ke1BjOTjM2YctQIvCT7GFzHwmfZPGo5wnrgkid0YQtnAleFSqumZm4az3n2BS+erby5ipJdgrg==}
 
@@ -430,6 +460,10 @@ packages:
     resolution: {integrity: sha512-hsBTNUqQTDwkWtcdYI2i06Y/nUBEsNEDJKjWdigLvegy8kDuJAS8uRlpkkcQpyEXL0Z/pjDy5HBmMjRCJ2gq+g==}
     engines: {node: '>= 4'}
 
+  ignore@7.0.5:
+    resolution: {integrity: sha512-Hs59xBNfUIunMFgWAbGX5cq6893IbWg4KnrjbYwX3tx0ztorVgTDA6B2sxf8ejHJ4wz8BqGUMYlnzNBer5NvGg==}
+    engines: {node: '>= 4'}
+
   inherits@2.0.4:
     resolution: {integrity: sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==}
 
@@ -464,6 +498,10 @@ packages:
     resolution: {integrity: sha512-41Cifkg6e8TylSpdtTpeLVMqvSBEVzTttHvERD741+pnZ8ANv0004MRL43QKPDlK9cGvNp6NZWZUBlbGXYxxng==}
     engines: {node: '>=0.12.0'}
 
+  is-path-inside@4.0.0:
+    resolution: {integrity: sha512-lJJV/5dYS+RcL8uQdBDW9c9uWFLLBNRyFhnAKXw5tVqLlKZ4RMGZKv+YQ/IA3OhD+RpbJa1LLFM1FQPGyIXvOA==}
+    engines: {node: '>=12'}
+
   is-regex@1.2.1:
     resolution: {integrity: sha512-MjYsKHO5O7mCsmRGxWcLWheFqN9DJ/2TmngvjKXihe6efViPqc274+Fx/4fYj/r03+ESvBdTXK0V6tA3rgez1g==}
     engines: {node: '>= 0.4'}
@@ -472,10 +510,18 @@ packages:
     resolution: {integrity: sha512-p3EcsicXjit7SaskXHs1hA91QxgTw46Fv6EFKKGS5DRFLD8yKnohjF3hxoju94b/OcMZoQukzpPpBE9uLVKzgQ==}
     engines: {node: '>= 0.4'}
 
+  junk@4.0.1:
+    resolution: {integrity: sha512-Qush0uP+G8ZScpGMZvHUiRfI0YBWuB3gVBYlI0v0vvOJt5FLicco+IkP0a50LqTTQhmts/m6tP5SWE+USyIvcQ==}
+    engines: {node: '>=12.20'}
+
   math-intrinsics@1.1.0:
     resolution: {integrity: sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==}
     engines: {node: '>= 0.4'}
 
+  meow@14.1.0:
+    resolution: {integrity: sha512-EDYo6VlmtnumlcBCbh1gLJ//9jvM/ndXHfVXIFrZVr6fGcwTUyCTFNTLCKuY3ffbK8L/+3Mzqnd58RojiZqHVw==}
+    engines: {node: '>=20'}
+
   merge2@1.4.1:
     resolution: {integrity: sha512-8q7VEgMJW4J8tcfVPy8g09NcQwZdbwFEqhe/WZkoIzjn/3TGDwtOCYtXGxA3O8tPzpczCCDgv+P2P5y00ZJOOg==}
     engines: {node: '>= 8'}
@@ -526,6 +572,22 @@ packages:
   os@0.1.2:
     resolution: {integrity: sha512-ZoXJkvAnljwvc56MbvhtKVWmSkzV712k42Is2mA0+0KTSRakq5XXuXpjZjgAt9ctzl51ojhQWakQQpmOvXWfjQ==}
 
+  p-event@6.0.1:
+    resolution: {integrity: sha512-Q6Bekk5wpzW5qIyUP4gdMEujObYstZl6DMMOSenwBvV0BlE5LkDwkjs5yHbZmdCEq2o4RJx4tE1vwxFVf2FG1w==}
+    engines: {node: '>=16.17'}
+
+  p-filter@4.1.0:
+    resolution: {integrity: sha512-37/tPdZ3oJwHaS3gNJdenCDB3Tz26i9sjhnguBtvN0vYlRIiDNnvTWkuh+0hETV9rLPdJ3rlL3yVOYPIAnM8rw==}
+    engines: {node: '>=18'}
+
+  p-map@7.0.4:
+    resolution: {integrity: sha512-tkAQEw8ysMzmkhgw8k+1U/iPhWNhykKnSk4Rd5zLoPJCuJaGRPo6YposrZgaxHKzDHdDWWZvE/Sk7hsL2X/CpQ==}
+    engines: {node: '>=18'}
+
+  p-timeout@6.1.4:
+    resolution: {integrity: sha512-MyIV3ZA/PmyBN/ud8vV9XzwTrNtR4jFrObymZYnZqMmW0zA8Z17vnT0rBgFE/TlohB+YCHqXMgZzb3Csp49vqg==}
+    engines: {node: '>=14.16'}
+
   path-type@4.0.0:
     resolution: {integrity: sha512-gDKb8aZMDeD/tZWs9P6+q0J9Mwkdl6xMV8TjnGP3qJVJ06bdMgkbBlLU8IdfOsIsFz2BW1rNVT3XuNEl8zPAvw==}
     engines: {node: '>=8'}
@@ -610,6 +672,10 @@ packages:
     resolution: {integrity: sha512-g9Q1haeby36OSStwb4ntCGGGaKsaVSjQ68fBxoQcutl5fS1vuY18H3wSt3jFyFtrkx+Kz0V1G85A4MyAdDMi2Q==}
     engines: {node: '>=8'}
 
+  slash@5.1.0:
+    resolution: {integrity: sha512-ZA6oR3T/pEyuqwMgAKT0/hAv8oAXckzbkmR0UkUosQ+Mc4RxGoJkRmwHgHufaenlyAgE1Mxgpdcrf75y6XcnDg==}
+    engines: {node: '>=14.16'}
+
   string_decoder@1.3.0:
     resolution: {integrity: sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==}
 
@@ -647,6 +713,10 @@ packages:
   undici-types@7.18.2:
     resolution: {integrity: sha512-AsuCzffGHJybSaRrmr5eHr81mwJU3kjw6M+uprWvCXiNeN9SOGwQ3Jn8jb8m3Z6izVgknn1R0FTCEAP2QrLY/w==}
 
+  unicorn-magic@0.4.0:
+    resolution: {integrity: sha512-wH590V9VNgYH9g3lH9wWjTrUoKsjLF6sGLjhR4sH1LWpLmCOH0Zf7PukhDA8BiS7KHe4oPNkcTHqYkj7SOGUOw==}
+    engines: {node: '>=20'}
+
   util-deprecate@1.0.2:
     resolution: {integrity: sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw==}
 
@@ -797,6 +867,8 @@ snapshots:
       '@nodelib/fs.scandir': 2.1.5
       fastq: 1.20.1
 
+  '@sindresorhus/merge-streams@4.0.0': {}
+
   '@types/node@25.5.2':
     dependencies:
       undici-types: 7.18.2
@@ -879,6 +951,26 @@ snapshots:
 
   commander@9.5.0: {}
 
+  copy-file@11.1.0:
+    dependencies:
+      graceful-fs: 4.2.11
+      p-event: 6.0.1
+
+  cpy-cli@7.0.0:
+    dependencies:
+      cpy: 13.2.2
+      globby: 16.2.0
+      meow: 14.1.0
+
+  cpy@13.2.2:
+    dependencies:
+      copy-file: 11.1.0
+      globby: 16.2.0
+      junk: 4.0.1
+      micromatch: 4.0.8
+      p-filter: 4.1.0
+      p-map: 7.0.4
+
   date-fns@4.1.0: {}
 
   decompress-response@6.0.0:
@@ -987,8 +1079,19 @@ snapshots:
       merge2: 1.4.1
       slash: 3.0.0
 
+  globby@16.2.0:
+    dependencies:
+      '@sindresorhus/merge-streams': 4.0.0
+      fast-glob: 3.3.3
+      ignore: 7.0.5
+      is-path-inside: 4.0.0
+      slash: 5.1.0
+      unicorn-magic: 0.4.0
+
   gopd@1.2.0: {}
 
+  graceful-fs@4.2.11: {}
+
   has-property-descriptors@1.0.2:
     dependencies:
       es-define-property: 1.0.1
@@ -1013,6 +1116,8 @@ snapshots:
 
   ignore@5.3.2: {}
 
+  ignore@7.0.5: {}
+
   inherits@2.0.4: {}
 
   ini@1.3.8: {}
@@ -1044,6 +1149,8 @@ snapshots:
 
   is-number@7.0.0: {}
 
+  is-path-inside@4.0.0: {}
+
   is-regex@1.2.1:
     dependencies:
       call-bound: 1.0.4
@@ -1055,8 +1162,12 @@ snapshots:
     dependencies:
       which-typed-array: 1.1.20
 
+  junk@4.0.1: {}
+
   math-intrinsics@1.1.0: {}
 
+  meow@14.1.0: {}
+
   merge2@1.4.1: {}
 
   micromatch@4.0.8:
@@ -1099,6 +1210,18 @@ snapshots:
 
   os@0.1.2: {}
 
+  p-event@6.0.1:
+    dependencies:
+      p-timeout: 6.1.4
+
+  p-filter@4.1.0:
+    dependencies:
+      p-map: 7.0.4
+
+  p-map@7.0.4: {}
+
+  p-timeout@6.1.4: {}
+
   path-type@4.0.0: {}
 
   picomatch@2.3.2: {}
@@ -1218,6 +1341,8 @@ snapshots:
 
   slash@3.0.0: {}
 
+  slash@5.1.0: {}
+
   string_decoder@1.3.0:
     dependencies:
       safe-buffer: 5.2.1
@@ -1264,6 +1389,8 @@ snapshots:
 
   undici-types@7.18.2: {}
 
+  unicorn-magic@0.4.0: {}
+
   util-deprecate@1.0.2: {}
 
   util@0.12.5:

pnpm-workspace.yaml

@@ -1,6 +1,5 @@
-onlyBuiltDependencies:
+allowBuilds:
-  - "better-uwuzu-sdk"
+  canvas: true
-  - canvas
+  sharp: true
-  - esbuild
+  better-uwuzu-sdk: true
-  - "miq"
+  miq: true
-  - sharp

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);
+    await createUeuse({
-      return;
-    }
-
-    const response = await client.request("ueuse/create", {
       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,38 +8,46 @@ 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("コマンドの処理を行います");
 
 try {
   let ueuses: ueuseModule[] = [];
 
+  const mem = Memory.memory;
+  let newLastReadReply = mem.lastReadReply;
+  let newLastReadMention = mem.lastReadMention;
+
   {
     const response = await client.request("me/notification/", {
+      page: 1,
       limit: 20,
     });
 
     if (response.success) {
-      for (const notification of response.data) {
+      const notifications = response.data.filter(n => n.category === "reply" && typeof n.valueid === "string");
-        if (notification.category !== "reply")
-          break;
 
-        if (!notification.valueid) {
+      for (const [index, notification] of notifications.entries()) {
-          console.warn("返信通知にvalueidが存在しないため、スキップします");
+        const ueuseResponse = await client.request("ueuse/get", { uniqid: notification.valueid });
-          break;
-        }
-
-        const ueuseResponse = await client.request("ueuse/get", {
-          uniqid: notification.valueid,
-        });
 
         if (!ueuseResponse.success || !ueuseResponse.data[0]) {
           console.warn("返信通知からユーズを参照できないため、スキップします");
-          break;
+          continue;
         }
 
-        ueuses.push(ueuseResponse.data[0]);
+        const ueuseData = ueuseResponse.data[0];
+        const time = new Date(ueuseData.datetime).getTime();
+
+        if (mem.lastReadReply >= time)
+          break;
+
+        if (index === 0)
+          newLastReadReply = time;
+
+        ueuses.push(ueuseData);
       }
     } else {
       console.warn("返信通知の取得に失敗しましたが、続行します");
@@ -48,26 +56,45 @@ try {
 
   {
     const response = await client.request("ueuse/mentions", {
+      page: 1,
       limit: 20,
     });
 
     if (response.success) {
-      ueuses.push(...response.data);
+      const mentions = response.data;
+
+      for (const [index, mention] of mentions.entries()) {
+        const time = new Date(mention.datetime).getTime();
+
+        if (mem.lastReadMention >= time)
+          break;
+
+        if (index === 0)
+          newLastReadMention = time;
+
+        ueuses.push(mention);
+      }
     } else {
       console.warn("メンションの取得に失敗しましたが、続行します");
     }
   }
 
-  ueuses = [...new Set(ueuses)];
+  mem.lastReadReply = newLastReadReply;
+  mem.lastReadMention = newLastReadMention;
+  Memory.memory = mem;
 
-  for (const ueuse of ueuses) {
+  const seenIds = new Set();
-    const repliedUeuse = (Memory.memory["repliedUeuse"] as string[]);
+  ueuses = ueuses.filter(ueuse => {
+    if (seenIds.has(ueuse.uniqid))
+      return false;
+    seenIds.add(ueuse.uniqid);
+    return true;
+  });
 
-    if (repliedUeuse.includes(ueuse.uniqid)) {
+  for (let i = 0; i < ueuses.length; i += config.command.maxParallels) {
-      console.log("既に応答しているため、スキップします");
+    const chunk = ueuses.slice(i, i + config.command.maxParallels);
-      break;
-    }
     
+    await Promise.all(chunk.map(async (ueuse) => {
       const mem = Memory.memory;
       let text = ueuse.text;
       text = text.replace(`@${mem.userid}`, "");
@@ -79,14 +106,12 @@ try {
       if (!commandRow || commandRow === "") {
         console.warn("コマンドが本文から参照できません");
 
-      const response = await client.request("ueuse/create", {
+        await createUeuse({
           text: i18next.t("commandNotFound"),
           replyid: ueuse.uniqid,
-      });
+        }, "コマンドが見つからない旨");
 
-      if (!response.success)
+        return;
-        console.warn("ユーズの作成に失敗しました:", response.error_code);
-      break;
       }
 
       const args = commandRow.replace("/", "").split(" ");
@@ -110,23 +135,14 @@ try {
         default:
           console.warn("不明なコマンドが入力されました:", args[0]);
 
-        const response = await client.request("ueuse/create", {
+          await createUeuse({
             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);
-      const mem = Memory.memory;
-      mem["repliedUeuse"] = repliedUeuse;
-      Memory.memory = mem;
-    }
   }
 
   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,
-        });
+        }, "Make it a Quoteの生成に失敗した旨");
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-        }
 
         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,
-      });
+      }, "Make it a Quote");
-
-      if (!response.success) {
-        console.warn("返信に失敗:", response.error_code);
-        return;
-      }
-
-      console.log("MiQを生成:", response.uniqid);
 
       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,
-        });
+        }, "返信元がこのBotではない旨");
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
 
         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,
-        });
+        }, "ソースのユーズと/miq allowのユーザーが一致しない旨");
-
-        if (!response.success) {
-          console.log("返信に失敗:", response.error_code);
-        }
-
-        console.warn("ソースのユーズと/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)
+          await createUeuse({
-            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);
-          }
 
           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,
-          });
+          }, "Make it a Quoteの生成に失敗した旨");
-
-          if (!response.success) {
-            console.warn("返信に失敗:", response.error_code);
-          }
 
           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,
-        });
+        }, "Make it a Quote");
-
-        if (!response.success) {
-          console.warn("返信に失敗:", response.error_code);
-          return;
-        }
-
-        console.log("MiQを生成:", response.uniqid);
       }
 
       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/command/weather.ts

@@ -2,5 +2,5 @@ import ueuseModule from "better-uwuzu-sdk/types/1.6.8/types/modules/ueuse";
 import { weatherReply } from "@/feature/weatherNotice";
 
 export default async function weatherCommand(ueuse: ueuseModule) {
-  await weatherReply(ueuse.uniqid);
+  await weatherReply(ueuse.uniqid, false);
 }

src/feature/earthquake/generateImage/index.ts

@@ -0,0 +1,533 @@
+import { readFileSync, writeFileSync } from "node:fs";
+import sharp from "sharp";
+
+/**
+ * 経度からX方向の座標情報を計算します
+ *
+ * 指定された経度とズームレベルに基づき、以下の4つの値を返します：
+ * - 世界座標系でのX（0〜1の範囲、グリニッジ子午線が0）
+ * - ズームレベルを考慮したピクセル単位のグローバルX座標
+ * - タイルグリッドにおけるX方向のタイル番号（tileNumberX）
+ * - タイル内（256×256ピクセル）でのX方向ピクセル位置（tileInnerX）
+ * @param lat - 経度
+ * @param z - ズームレベル（0以上の整数）
+ * @returns {{
+ *   worldCoordX: number, // 世界座標(0～1, グリニッジ子午線が原点(0))
+ *   globalPixelX: number, // ズームレベルを考慮したピクセル単位のY座標
+ *   tileNumberX: number, // 該当するタイル番号（0オリジン）
+ *   tileInnerX: number, // タイル内のピクセルY座標（0〜255）
+ * }}
+ * @copyright murasuke on Qiita - https://qiita.com/murasuke/items/ad81b7b726a3463fa3fe#%E7%B5%8C%E5%BA%A6
+ */
+function calcLngToTileX(lng: number, z: number) {
+  // 経度(-180〜180)を世界座標系のX(0〜1)に変換
+  const worldCoordX = (lng + 180) / 360;
+
+  // ズームレベル0(256×256px)の座標の位置を計算
+  let globalPixelX = worldCoordX * 256;
+
+  // ズームレベル(2^z)を考慮した座標を計算
+  globalPixelX = globalPixelX * Math.pow(2, z);
+
+  // 1つの画像タイルが256pxなので、256で割って左端からのタイルの枚数(位置)を求める
+  const tileNumberX = Math.floor(globalPixelX / 256);
+
+  // 該当タイル内のピクセル位置を算出する(タイル幅合計を引いた余り)
+  const tileInnerX = Math.floor(globalPixelX - tileNumberX * 256);
+
+  // 計算した値を返す
+  return {
+    worldCoordX, // 世界座標(0～1, グリニッジ子午線が原点(0))
+    globalPixelX, // ズームレベルを考慮したピクセル単位のY座標
+    tileNumberX, // 該当するタイル番号（0オリジン）
+    tileInnerX, // タイル内のピクセルY座標（0〜255）
+  };
+}
+
+/**
+ * 緯度からWebメルカトル投影によるY方向の座標情報を計算します。
+ *
+ * 指定された緯度とズームレベルに基づき、以下の4つの値を返します：
+ * - 世界座標系でのY（0〜1の範囲、北極が0）
+ * - ズームレベルを考慮したピクセル単位のグローバルY座標
+ * - タイルグリッドにおけるY方向のタイル番号（tileNumberY）
+ * - タイル内（256×256ピクセル）でのY方向ピクセル位置（tileInnerY）
+ *
+ * メルカトル図法で緯度から位置を算出する式 (https://qiita.com/Seo-4d696b75/items/aa6adfbfba404fcd65aa)
+ *  R ln(tan(π/4 + ϕ/2))
+ *    R: 半径
+ *    ϕ: 緯度(ラジアン)
+ * @param lat - 緯度（-85〜+85度の範囲が推奨）
+ * @param z - ズームレベル（0以上の整数）
+ * @returns {{
+ *   worldCoordY: number,    // 世界座標系Y（0〜1）
+ *   globalPixelY: number,   // ズームレベルを考慮したピクセル単位のY座標
+ *   tileNumberY: number,    // Y方向のタイル番号（0オリジン）
+ *   tileInnerY: number      // タイル内のピクセルY座標（0〜255）
+ * }}
+ * @copyright murasuke on Qiita - https://qiita.com/murasuke/items/ad81b7b726a3463fa3fe#%E7%B7%AF%E5%BA%A6
+ */
+function calcLatToTileY(lat: number, z: number) {
+  // 緯度からメルカトル図法の座標に変換して、世界座標系のY(0～1)を計算
+  let worldCoordY = latToWorldY(lat);
+
+  // ズームレベル0(256×256px)の座標の位置を計算
+  let globalPixelY = worldCoordY * 256;
+
+  // ズームレベル(2^z)を考慮した座標を計算
+  globalPixelY = globalPixelY * Math.pow(2, z);
+
+  // 1つの画像タイルが256pxなので、256で割って上端からのタイルの枚数(位置)を求める
+  const tileNumberY = Math.floor(globalPixelY / 256);
+
+  // 該当タイル内のピクセル位置を算出する(タイル幅合計を引いた余り)
+  const tileInnerY = Math.floor(globalPixelY - tileNumberY * 256);
+
+  // 計算した値を返す
+  return {
+    worldCoordY, // 世界座標(0～1, 北極側が原点(0))
+    globalPixelY, // ズームレベルを考慮したピクセル単位のY座標
+    tileNumberY, // 該当するタイル番号（0オリジン）
+    tileInnerY, // タイル内のピクセルY座標（0〜255）
+  };
+}
+
+/**
+ * メルカトル図法で投影した位置を元に世界座標系でのY(0〜1、北極が0)を計算する
+ *
+ * メルカトル図法の式（半径1の球体を想定）
+ *   ϕ = (π / 180) * 緯度
+ *   y = ln(tan(π/4 + ϕ/2))
+ *   ϕ:緯度(ラジアン)
+ *   y:投影した位置
+ *
+ * * 赤道を中心(0)にして、約-85〜+85度の範囲で-π～πの値になる
+ * * 高緯度では値が急増し無限大になる
+ * * y = ln((tan(ϕ) + 1) / cos(ϕ)) という式もある(同じ値になる)
+ *
+ * 地図で位置を計算するため、北極側が原点(0)で南極側が1となるように正規化した値を返す
+ *
+ * @param lat 緯度(-85～85)
+ * @returns {number} 世界座標系でのY（0〜1、北極が0）
+ * @copyright murasuke on Qiita - https://qiita.com/murasuke/items/ad81b7b726a3463fa3fe#%E7%B7%AF%E5%BA%A6
+ */
+function latToWorldY(lat: number) {
+  // 経度をラジアンに変換
+  const latRad = (Math.PI / 180) * lat;
+  // 緯度からメルカトル図法の座標に変換する
+  const mercatorY = Math.log(Math.tan(Math.PI / 4 + latRad / 2));
+
+  // -1～1 の範囲になるように調整(-85度～85度の範囲)
+  let worldCoordY = mercatorY / Math.PI;
+
+  // 原点(0)を赤道から、北極へ変換(0～1)
+  worldCoordY = 1 - (worldCoordY + 1) / 2;
+
+  return worldCoordY;
+}
+
+function getEdge<T extends any[]>(arr: T, property: keyof T[number]) {
+  if (arr.length === 0) {
+    return {
+      most: undefined,
+      least: undefined,
+    }
+  }
+
+  const counts = new Map<any, number>();
+  for (const item of arr) {
+    const val = item[property];
+    counts.set(val, (counts.get(val) || 0) + 1);
+  }
+
+  const uniqueValues = Array.from(counts.keys());
+  
+  const minVal = uniqueValues.reduce((a, b) => (a < b ? a : b));
+  const maxVal = uniqueValues.reduce((a, b) => (a > b ? a : b));
+
+  return {
+    most: maxVal,
+    least: minVal,
+  }
+}
+
+export default async function generateImage(message: any) {
+  if (
+    message.earthquake.hypocenter === undefined ||
+    message.earthquake.hypocenter?.name === "" ||
+    !(Array.isArray(message.points)) ||
+    message.points.length === 0
+  )
+    return "input_lack";
+
+  const ZOOM_LEVEL = 9;
+  
+  // タイル・地点取得
+  const tiles: {
+    tileX: number;
+    tileY: number;
+  }[] = [];
+
+  const positions: ({
+    tileIndex: number;
+    innerX: number;
+    innerY: number;
+  } & ({
+    type: "epicenter";
+  } | {
+    type: "point";
+    scale: number;
+  }))[] = [];
+
+  if (
+    message.earthquake.hypocenter?.latitude !== undefined &&
+    message.earthquake.hypocenter?.latitude !== -200 &&
+    message.earthquake.hypocenter?.longitude !== undefined &&
+    message.earthquake.hypocenter?.longitude !== -200
+  ) {
+    // 震源地
+    const lng = message.earthquake.hypocenter.longitude;
+    const lat = message.earthquake.hypocenter.latitude;
+    const xData = calcLngToTileX(lng, ZOOM_LEVEL);
+    const yData = calcLatToTileY(lat, ZOOM_LEVEL);
+
+    tiles.push({
+      tileX: xData.tileNumberX,
+      tileY: yData.tileNumberY,
+    });
+
+    positions.push({
+      tileIndex: 0,
+      innerX: xData.tileInnerX,
+      innerY: yData.tileInnerY,
+      type: "epicenter",
+    });
+  }
+
+  if (
+    Array.isArray(message.points) &&
+    message.points.length > 0
+  ) {
+    // 観測点・区域
+    const areas = JSON.parse(readFileSync(`${import.meta.dirname}/areas.json`, "utf-8"));
+    const points = JSON.parse(readFileSync(`${import.meta.dirname}/points.json`, "utf-8"));
+    message.points.forEach((point: any) => {
+      let areaData: {
+        longitude: number;
+        latitude: number;
+      }
+
+      if (point.isArea) {
+        areaData = areas[point.addr];
+      } else {
+        areaData = points[point.addr];
+      }
+
+      const lng = areaData.longitude;
+      const lat = areaData.latitude;
+      const xData = calcLngToTileX(lng, ZOOM_LEVEL);
+      const yData = calcLatToTileY(lat, ZOOM_LEVEL);
+      
+      const tilePosition = {
+        tileX: xData.tileNumberX,
+        tileY: yData.tileNumberY,
+      }
+
+      let tileIndex: number;
+
+      const sameTile = tiles
+        .map((value, index) => ({ value, index }))
+        .filter(tile => JSON.stringify(tile.value) === JSON.stringify(tilePosition))[0];
+
+      if (sameTile) {
+        tileIndex = sameTile.index;
+      } else {
+        tiles.push(tilePosition);
+        tileIndex = tiles.length - 1;
+      }
+
+      if (tiles.filter(tile => JSON.stringify(tile) === JSON.stringify(tilePosition)).length === 0) {
+        tiles.push(tilePosition);
+      }
+
+      positions.push({
+        tileIndex,
+        innerX: xData.tileInnerX,
+        innerY: yData.tileInnerY,
+        type: "point",
+        scale: point.scale,
+      });
+    });
+  }
+
+  // 画像生成
+  const WIDTH = 1920;
+  const HEIGHT = 1080;
+
+  let result = sharp({
+    create: {
+      width: WIDTH,
+      height: HEIGHT,
+      channels: 4,
+      background: "#ffffff",
+    }
+  });
+
+  let compounds: (sharp.OverlayOptions & ({
+    type: "tile" | "epicenter" | "other";
+  } | {
+    type: "scale";
+    scale: number;
+  }))[] = [];
+
+  // タイルの幅、最大最小
+  let tileXCount = getEdge(tiles, "tileX");
+  let tileYCount = getEdge(tiles, "tileY");
+  let xSize = tileXCount.most - tileXCount.least + 1;
+  let ySize = tileYCount.most - tileYCount.least + 1;
+
+  // タイルサイズ仮計算
+  let tileSize: number;
+
+  xSize = tileXCount.most - tileXCount.least + 1;
+  ySize = tileYCount.most - tileYCount.least + 1;
+  if (xSize > ySize) {
+    tileSize = Math.round(WIDTH / xSize);
+  } else {
+    tileSize = Math.round(HEIGHT / ySize);
+  }
+
+  // 震源を中心とする
+  const epicenterPosition = positions.filter(position => position.type === "epicenter")[0];
+  if (!epicenterPosition)
+    return "input_lack";
+
+  const epicenterTile = tiles[epicenterPosition.tileIndex];
+  if (!epicenterTile)
+    return "input_lack";
+
+  const leftPx = (epicenterTile.tileX - tileXCount.least) * tileSize + epicenterPosition.innerX;
+  const rightPx = xSize * tileSize - leftPx;
+  const topPx = (epicenterTile.tileY - tileYCount.least) * tileSize + epicenterPosition.innerY;
+  const bottomPx = ySize * tileSize - topPx;
+
+  if (leftPx > rightPx) {
+    const leftTiles = epicenterTile.tileX - tileXCount.least;
+    tileXCount = {
+      ...tileXCount,
+      most: epicenterTile.tileX + leftTiles,
+    }
+  } else {
+    const rightTiles = tileXCount.most - epicenterTile.tileX;
+    tileXCount = {
+      ...tileXCount,
+      least: epicenterTile.tileX - rightTiles,
+    }
+  }
+
+  if (topPx > bottomPx) {
+    const topTiles = epicenterTile.tileY - tileYCount.least;
+    tileYCount = {
+      ...tileYCount,
+      most: epicenterTile.tileY + topTiles,
+    }
+  } else {
+    const bottomTiles = tileYCount.most - epicenterTile.tileY;
+    tileYCount = {
+      ...tileYCount,
+      least: epicenterTile.tileY - bottomTiles,
+    }
+  }
+
+  // タイルサイズ再計算
+  xSize = tileXCount.most - tileXCount.least + 1;
+  ySize = tileYCount.most - tileYCount.least + 1;
+  if (xSize > ySize) {
+    tileSize = Math.round(WIDTH / xSize);
+  } else {
+    tileSize = Math.round(HEIGHT / ySize);
+  }
+
+  // 全画面
+  if (WIDTH - xSize * tileSize > 5) {
+    const requireTilesX = Math.ceil(WIDTH / tileSize);
+    const halfTilesX = Math.ceil(requireTilesX / 2);
+
+    tileXCount = {
+      least: tileXCount.least - halfTilesX,
+      most: tileXCount.most + halfTilesX,
+    }
+  }
+
+  if (HEIGHT - ySize * tileSize > 5) {
+    const requireTilesY = Math.ceil(HEIGHT / tileSize);
+    const halfTilesY = Math.ceil(requireTilesY / 2);
+
+    tileYCount = {
+      least: tileYCount.least - halfTilesY,
+      most: tileYCount.most + halfTilesY,
+    }
+  }
+
+  // タイル幅再計算
+  xSize = tileXCount.most - tileXCount.least + 1;
+  ySize = tileYCount.most - tileYCount.least + 1;
+
+  // 欠けているタイルを取得
+  for (let xIndex = 0; xIndex < xSize; xIndex++) {
+    const itX = xIndex + tileXCount.least;
+    
+    for (let yIndex = 0; yIndex < ySize; yIndex++) {
+      const itY = yIndex + tileYCount.least;
+
+      const itTile = tiles.filter(tile => tile.tileX === itX && tile.tileY === itY)[0];
+      if (itTile)
+        continue;
+
+      tiles.push({
+        tileX: itX,
+        tileY: itY,
+      });
+    }
+  }
+
+  // アセット
+  const assets: Record<string, {
+    buffer: Buffer<ArrayBuffer>;
+    size: number;
+  }> = {}
+  const assetsList = [
+    "scales/10",
+    "scales/20",
+    "scales/30",
+    "scales/40",
+    "scales/45",
+    "scales/46",
+    "scales/50",
+    "scales/55",
+    "scales/60",
+    "scales/70",
+    "epicenter",
+  ];
+
+  await Promise.all(assetsList.map(async name => {
+    const key = name.split("/").at(-1);
+    if (!key)
+      return;
+
+    const asset = readFileSync(`${import.meta.dirname}/assets/${name}.png`);
+    const assetMeta = await sharp(asset).metadata();
+    const assetSize = assetMeta.width;
+
+    assets[key] = {
+      buffer: asset,
+      size: assetSize,
+    }
+  }));
+
+  // 各画像処理
+  await Promise.all(tiles.map(async (tile, index) => {
+    const TYPE = "blank";
+    const BASE_URL = "https://cyberjapandata.gsi.go.jp/xyz";
+
+    const request = await fetch(`${BASE_URL}/${TYPE}/${ZOOM_LEVEL}/${tile.tileX}/${tile.tileY}.png`);
+
+    if (!request.ok)
+      return;
+
+    const tileImg = await sharp(await request.arrayBuffer()).resize({
+      width: tileSize,
+      height: tileSize,
+    }).png().toBuffer();
+
+    const top = tileSize * (tile.tileY - tileYCount.least);
+    const left = tileSize * (tile.tileX - tileXCount.least);
+
+    compounds.push({
+      type: "tile",
+      input: tileImg,
+      top,
+      left,
+    });
+
+    const itTilePositions = positions.filter(position => position.tileIndex === index);
+    itTilePositions.forEach(position => {
+      const requireAssetName = position.type === "epicenter"
+        ? "epicenter"
+        : String(position.scale);
+
+      const asset = assets[requireAssetName];
+      if (!asset)
+        return;
+
+      const tileResizedSize = tileSize / 256;
+
+      let about: any;
+
+      if (position.type === "epicenter") {
+        about = {
+          type: "epicenter",
+        }
+      } else {
+        about = {
+          type: "scale",
+          scale: position.scale,
+        }
+      }
+
+      compounds.push({
+        ...about,
+        input: asset.buffer,
+        top: Math.round(top + position.innerY * tileResizedSize - asset.size / 2),
+        left: Math.round(left + position.innerX * tileResizedSize - asset.size / 2),
+      });
+    });
+  }));
+
+  // compounds並び替え
+  const TYPE_PRIORITY: Record<string, number> = {
+    tile: 1,
+    scale: 2,
+    epicenter: 3,
+  }
+
+  compounds = [...compounds].sort((a, b) => {
+    if (TYPE_PRIORITY[a.type] !== TYPE_PRIORITY[b.type]) {
+      return (TYPE_PRIORITY[a.type] ?? 99) - (TYPE_PRIORITY[b.type] ?? 99);
+    }
+
+    if (a.type === "scale" && b.type === "scale") {
+      return a.scale - b.scale;
+    }
+
+    return 0;
+  });
+
+  // 案内部分
+  const informationPath = `${import.meta.dirname}/assets/information.png`;
+  const informationBuffer = readFileSync(informationPath);
+  const informationMeta = await sharp(informationPath).metadata();
+  const informationMargin = 20;
+  compounds.push({
+    type: "other",
+    input: informationBuffer,
+    top: HEIGHT - informationMeta.height - informationMargin,
+    left: WIDTH - informationMeta.width - informationMargin,
+  });
+
+  // クレジット部分
+  const creditPath = `${import.meta.dirname}/assets/credit.png`;
+  const creditBuffer = readFileSync(creditPath);
+  const creditMeta = await sharp(creditPath).metadata();
+  compounds.push({
+    type: "other",
+    input: creditBuffer,
+    top: HEIGHT - creditMeta.height,
+    left: 0,
+  });
+
+  result.composite(compounds);
+
+  const buffer = await result.png().toBuffer();
+  return buffer;
+}

src/feature/earthquake/index.ts

@@ -0,0 +1,360 @@
+import { createUeuse } from "@/lib/client";
+import config from "@/lib/config";
+import Memory from "@/lib/memory";
+import { format } from "date-fns";
+import { readFileSync } from "node:fs";
+import { EOL } from "node:os";
+import { WebSocket } from "ws";
+import generateImage from "@/feature/earthquake/generateImage";
+
+if (config.earthquake?.useHistoryData) {
+  console.log("過去の地震情報を配信します");
+  const history = JSON.parse(readFileSync(`${import.meta.dirname}/../../260420.json`, "utf-8"));
+  history.reverse();
+
+  let i = 0;
+  setInterval(() => {
+    processMessage(history[i]);
+    i++;
+  }, 10 * 1000);
+} else {
+  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);
+
+    socket.addEventListener("open", () => {
+      console.log("P2P地震情報のWebSocketに接続しました");
+    });
+
+    socket.addEventListener("close", (err) => {
+      const interval = config.earthquake.reconnectInterval;
+      console.log(`WebSocketが切断されました。${interval / 1000}秒後に再接続します:`, err.reason);
+      setTimeout(() => {
+        connect();
+      }, interval);
+    });
+
+    socket.addEventListener("error", (err) => {
+      console.error("WebSocketでエラーが発生しました:", err);
+      socket.close();
+    });
+
+    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",
+      "40": "震度4",
+      "45": "震度5弱",
+      "46": "**推定**震度5弱以上***(不明)***",
+      "50": "震度5強",
+      "55": "震度6弱",
+      "60": "震度6強",
+      "70": "震度7",
+      "99": "程度以上",
+    }
+
+    switch (message.code) {
+      case 555:
+        console.log("ピアの地域分布情報を受信しました");
+        break;
+      case 551:
+        {
+          console.log("地震発生情報を受信しました");
+
+          if (
+            message.earthquake.maxScale !== -1 &&
+            message.earthquake.maxScale < config.earthquake.requireMaxScale
+          ) {
+            console.log(`最大震度(${scaleMessages[message.earthquake.maxScale]})が投稿に必要な値(${scaleMessages[config.earthquake.requireMaxScale]})に満たないため、スキップします`);
+            break;
+          }
+
+          const typeMessage: Record<string, string> = {
+            "ScalePrompt": "震度速報",
+            "Destination": "震源情報",
+          }
+
+          const domesticTsunamiMessages: Record<string, string> = {
+            "None": "😌この地震による**国内**の津波の心配はありません。",
+            "Unknown": "😕この地震による**国内**の***津波情報は***不明です。",
+            "Checking": "🧐この地震による**国内**の津波情報を**調査中です。**",
+            "NonEffective": "😌この地震による**国内**の**海面変動が予想されますが**、被害の心配はありません。",
+            "Watch": "⚠️この地震により**国内**で津波注意報が発令しています。",
+            "Warning": "🚨この地震による**国内**の津波予報があります。",
+          }
+
+          const foreignTsunamiMessages: Record<string, string> = {
+            "None": "😌この地震による**国外**の津波の心配はありません。",
+            "Unknown": "😕この地震による**国外**の***津波情報は***不明です。",
+            "Checking": "🧐この地震による**国外**の津波情報を**調査中です。**",
+            "NonEffectiveNearby": "😌この地震によって**国外**にて震源の近傍で**小さな津波の可能性はありますが**、被害の心配はありません。",
+            "WarningNearby": "⚠️この地震によって**国外**にて震源の近傍で**津波の可能性**があります。",
+            "WarningPacific": "⚠️この地震によって**太平洋**にて**津波の可能性**があります。",
+            "WarningPacificWide": "🚨この地震によって**太平洋の広域**にて**津波の可能性**があります。",
+            "WarningIndian": "⚠️この地震によって**インド洋**にて**津波の可能性**があります。",
+            "WarningIndianWide": "🚨この地震によって**インド洋の広域**にて**津波の可能性**があります。",
+            "Potential": "🚨この地震によって**一般的に**この規模では津波の可能性があると考えられています。",
+          }
+
+          const grouped: Record<string, { scale: number; prefs: Record<string, string[]> }> = {};
+
+          for (const point of message.points) {
+            const { addr, scale, pref } = point;
+            const label = scaleMessages[String(scale)] ?? "不明";
+
+            if (!grouped[label]) {
+              grouped[label] = { scale, prefs: {} };
+            }
+
+            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, { prefs }]) => {
+              const prefLines = Object.entries(prefs)
+                .map(([pref, addrs]) => `**${pref}:** ${addrs.join("・")}`)
+                .join(EOL);
+
+              return `【${label}】${EOL}${prefLines}`;
+            })
+            .join(EOL.repeat(2))
+            .trim();
+
+          const earthquakeNoticeText = [];
+          earthquakeNoticeText.push(`### ${typeMessage[message.issue.type] ?? "地震情報"}`);
+          earthquakeNoticeText.push(`⏰時刻: ${format(new Date(message.earthquake.time), "yyyy年M月d日 H:mm")}頃`);
+          earthquakeNoticeText.push(...(message.earthquake.maxScale === -1
+            ? []
+            : [`🫨最大震度: ${scaleMessages[String(message.earthquake.maxScale)]}`]));
+          earthquakeNoticeText.push(...(message.earthquake.hypocenter.name === ""
+            ? []
+            : [`📍震源地: ${message.earthquake.hypocenter.name}`]));
+          earthquakeNoticeText.push(...(message.earthquake.hypocenter.magnitude === -1
+            ? []
+            : [`💪マグニチュード: M${message.earthquake.hypocenter.magnitude.toFixed(1)}`]));
+          earthquakeNoticeText.push(...(message.earthquake.hypocenter.depth === -1
+            ? []
+            : [`🪨深さ: ${message.earthquake.hypocenter.depth === 0
+              ? "ごく浅い"
+              : `${message.earthquake.hypocenter.depth}km`}`]));
+          earthquakeNoticeText.push(...(message.earthquake.domesticTsunami ?? "Unknown" === "Unknown"
+            ? []
+            : [domesticTsunamiMessages[(message.earthquake.domesticTsunami)]]));
+          earthquakeNoticeText.push(...(message.earthquake.foreignTsunami ?? "Unknown" === "Unknown"
+            ? []
+            : [foreignTsunamiMessages[(message.earthquake.foreignTsunami)]]));
+          earthquakeNoticeText.push(...(pointsMsg === ""
+            ? []
+            : [EOL + pointsMsg]));
+          earthquakeNoticeText.push(...(message.comments.freeFormComment === ""
+            ? []
+            : [message.comments.freeFormComment]));
+          earthquakeNoticeText.push(EOL + `🔬情報源: P2P地震速報 - ${message.issue.source ?? "不明"}`);
+          const earthquakeUeuses = await createUeuse({
+            text: earthquakeNoticeText.join(EOL),
+          }, "地震発生情報");
+
+          try {
+            const image = await generateImage(message);
+
+            if (typeof image === "string") {
+              throw "情報が不足しているため、地震の画像生成ができませんでした";
+            } else {
+              const infoUeuseURL = earthquakeUeuses[0]?.uniqid
+                ? `${config.uwuzu.origin}/!${earthquakeUeuses[0].uniqid}`
+                : "不明";
+
+              const earthquakeImageText = [];
+              earthquakeImageText.push("地震の震度分布画像を生成しました。");
+              earthquakeImageText.push(`地震情報ユーズ: ${infoUeuseURL}`);
+              await createUeuse({
+                text: earthquakeImageText.join(EOL),
+                media: {
+                  photo: [
+                    image.toString("base64"),
+                  ],
+                },
+              }, "震度分布画像");
+            }
+          } catch (err) {
+            console.warn(err);
+          }
+        }
+        break;
+      case 552:
+        {  
+          console.log("津波予報情報を受信しました");
+
+          if (message.cancelled) {
+            const tsunamiCancelledNoticeText = [];
+            tsunamiCancelledNoticeText.push("### 津波予報**解除**");
+            tsunamiCancelledNoticeText.push(`⏰発表時刻: ${format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss")}`);
+            tsunamiCancelledNoticeText.push(`🔬情報源: P2P地震速報 - ${message.issue.source ?? "不明"}`);
+            await createUeuse({
+              text: tsunamiCancelledNoticeText.join(EOL),
+            }, "津波予報解除情報");
+
+            break;
+          }
+
+          const gradeMessages: Record<string, string> = {
+            "Unknown": "不明",
+            "Watch": "津波注意報",
+            "Warning": "津波警報",
+            "MajorWarning": "大津波警報",
+          }
+
+          let areasMsg = "";
+          for (const area of message.areas) {
+            const tsunamiAreaText = [];
+            tsunamiAreaText.push(`【${area.name}】`);
+            tsunamiAreaText.push(...(area.immediate
+              ? ["🚨***直ちに津波が来襲すると予想されています。***"]
+              : []));
+            tsunamiAreaText.push(`🏷️種別: ${gradeMessages[area.grade]}`);
+            tsunamiAreaText.push(`⏳第1波到達予想時刻: ${format(new Date(area.firstHeight.arrivalTime), "yyyy年M月d日 H:mm")}`);
+            tsunamiAreaText.push(`🌊第1波の状態: ${area.firstHeight.condition
+              ? `${area.firstHeight.condition}されています`
+              : "不明"}`);
+            tsunamiAreaText.push(`🗼予想される津波の高さ: ${area.maxHeight.value === 0.2
+              ? "0.2m未満"
+              : (area.maxHeight.value
+                ? `${area.maxHeight.value}m`
+                : area.maxHeight.description)}`);
+            areasMsg += tsunamiAreaText.join(EOL) + EOL.repeat(2);
+          }
+
+          const tsunamiNoticeText = [];
+          tsunamiNoticeText.push("### 津波予報**発表**");
+          tsunamiNoticeText.push(`⏰発表時刻: ${format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss")}`);
+          tsunamiNoticeText.push(EOL + areasMsg.trim() + EOL);
+          tsunamiNoticeText.push(`🔬情報源: P2P地震速報 - message.issue.source ?? "不明"`);
+          await createUeuse({
+            text: tsunamiNoticeText.join(EOL),
+          }, "津波予報情報");
+        }
+        break;
+      case 556:
+        {
+          console.log("緊急地震速報（警報）を受信しました");
+
+          if (message.cancelled) {
+            const eewCancelledNotice = [];
+            eewCancelledNotice.push("### 緊急地震速報（警報）**解除**");
+            eewCancelledNotice.push(message.test
+              ? "⚒️これは**テストです。**"
+              : "🚨これは**テストではありません。**");
+            eewCancelledNotice.push(`⏰発表時刻: ${format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss")}`);
+            eewCancelledNotice.push(EOL + "🔬情報源: P2P地震速報");
+            await createUeuse({
+              text: eewCancelledNotice.join(EOL),
+            }, "緊急地震速報（警報）解除情報");
+          }
+
+          const kindMessages: Record<string, string> = {
+            "10": "⏳主要動は、**未到達と予測**されています。",
+            "11": "🫨主要動が、**既に到達していると予測**されています。",
+            "19": "🧐PLUM法によると、主要動の***到達予想は***ありません。",
+          }
+
+          let areasMsg = "";
+          for (const area of message.areas) {
+            const eewAreaText = [];
+            eewAreaText.push(`【${area.name}】`);
+            eewAreaText.push(`🫨最大予測震度: ${scaleMessages[String(Math.floor(area.scaleFrom))] +
+              (area.scaleTo === 99
+                ? "程度以上"
+                : area.scaleFrom !== area.scaleTo
+                  ? `から${scaleMessages[String(Math.floor(area.scaleTo))]}`
+                  : "")}`);
+            eewAreaText.push(`⏰到達予想時刻: ${typeof area.arrivalTime === "string" && area.arrivalTime !== ""
+              ? format(new Date(area.arrivalTime), "yyyy年M月d日 H:mm:ss")
+              : "不明"}`);
+            eewAreaText.push(kindMessages[area.kindCode] ?? "😕主要動の***到達予想は***ありません。");
+
+            areasMsg += eewAreaText.join(EOL) + EOL.repeat(2);
+          }
+
+          const eewNoticeText = [];
+          eewNoticeText.push("### ***緊急地震速報（警報）***");
+          eewNoticeText.push(message.test
+            ? "⚒️これは**テストです。**"
+            : "🚨これは**テストではありません。**");
+          eewNoticeText.push(...(message.earthquake.condition === "仮定震源要素"
+            ? ["❓これは、仮定震源要素です。そのため、震源に関する情報が保証できません。"]
+            : []));
+          eewNoticeText.push(`⏰発表時刻: ${format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss")}`);
+          eewNoticeText.push(`⏰地震発生時刻: ${format(new Date(message.earthquake.originTime), "yyyy年M月d日 H:mm:ss")}`);
+          eewNoticeText.push(`⏰地震発現時刻: ${format(new Date(message.earthquake.arrivalTime), "yyyy年M月d日 H:mm:ss")}`);
+          eewNoticeText.push(`📍震源地: ${message.earthquake.hypocenter.name ?? "不明"}`);
+          eewNoticeText.push(`💪マグニチュード: ${message.earthquake.hypocenter.magnitude === undefined ||
+            message.earthquake.hypocenter.magnitude === -1
+              ? "不明"
+              : `M${message.earthquake.hypocenter.magnitude.toFixed(1)}`}`);
+          eewNoticeText.push(`🪨深さ: ${message.earthquake.hypocenter.depth === undefined ||
+            message.earthquake.hypocenter.depth === -1
+              ? "不明"
+              : `${Math.floor(message.earthquake.hypocenter.depth)}km`}`);
+          eewNoticeText.push(...(areasMsg !== ""
+            ? [EOL + areasMsg.trim()]
+            : []));
+          eewNoticeText.push(EOL + "🔬情報源: P2P地震速報");
+
+          await createUeuse({
+            text: eewNoticeText.join(EOL),
+          }, "緊急地震速報（警報）情報");
+        }
+        break;
+      default:
+        console.log("未対応の情報:", message);
+        break;
+    }
+  } catch (err) {
+    console.warn("メッセージの処理に失敗しました:", err);
+  }
+}

src/feature/earthquakeNotice.ts

@@ -1,288 +0,0 @@
-import client from "@/lib/client";
-import config from "@/lib/config";
-import initI18n from "@/lib/i18n";
-import { format } from "date-fns";
-import i18next from "i18next";
-import { readFileSync } from "node:fs";
-import { EOL } from "node:os";
-import { WebSocket } from "ws";
-
-await initI18n();
-
-if (config.earthquake?.useHistoryData) {
-  console.log("過去の地震情報を配信します");
-  const history = JSON.parse(readFileSync(`${import.meta.dirname}/../../260420.json`, "utf-8"));
-  history.reverse();
-
-  let i = 0;
-  setInterval(() => {
-    processMessage(history[i]);
-    i++;
-  }, 10 * 1000);
-} else {
-  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);
-
-  socket.addEventListener("open", () => {
-    console.log("P2P地震情報のWebSocketに接続しました");
-  });
-
-  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;
-    }
-
-    processMessage(message);
-  });
-}
-
-const processMessage = async (message: any) => {
-  try {
-    const scaleMessages: Record<string, string> = {
-      "-1": "不明",
-      "10": "震度1",
-      "20": "震度2",
-      "30": "震度3",
-      "40": "震度4",
-      "45": "震度5弱",
-      "46": "**推定**震度5弱以上***(正確には不明)***",
-      "50": "震度5強",
-      "55": "震度6弱",
-      "60": "震度6強",
-      "70": "震度7",
-      "99": "程度以上",
-    }
-
-    switch (message.code) {
-      case 551:
-        {
-          console.log("地震発生情報を受信しました");
-
-          const domesticTsunamiMessages: Record<string, string> = {
-            "None": "😌この地震による**国内**の津波の心配はありません。",
-            "Unknown": "😕この地震による**国内**の***津波情報は***不明です。",
-            "Checking": "🧐この地震による**国内**の津波情報を**調査中です。**",
-            "NonEffective": "😌この地震による**国内**の**海面変動が予想されますが**、被害の心配はありません。",
-            "Watch": "⚠️この地震により**国内**で津波注意報が発令しています。",
-            "Warning": "🚨この地震による**国内**の津波予報があります。",
-          }
-
-          const foreignTsunamiMessages: Record<string, string> = {
-            "None": "😌この地震による**国外**の津波の心配はありません。",
-            "Unknown": "😕この地震による**国外**の***津波情報は***不明です。",
-            "Checking": "🧐この地震による**国外**の津波情報を**調査中です。**",
-            "NonEffectiveNearby": "😌この地震によって**国外**にて震源の近傍で**小さな津波の可能性はありますが**、被害の心配はありません。",
-            "WarningNearby": "⚠️この地震によって**国外**にて震源の近傍で**津波の可能性**があります。",
-            "WarningPacific": "⚠️この地震によって**太平洋**にて**津波の可能性**があります。",
-            "WarningPacificWide": "🚨この地震によって**太平洋の広域**にて**津波の可能性**があります。",
-            "WarningIndian": "⚠️この地震によって**インド洋**にて**津波の可能性**があります。",
-            "WarningIndianWide": "🚨この地震によって**インド洋の広域**にて**津波の可能性**があります。",
-            "Potential": "🚨この地震によって**一般的に**この規模では津波の可能性があると考えられています。",
-          }
-
-          let points: Record<string, any[]> = {};
-          for (const point of message.points) {
-            const scaleMsg = scaleMessages[String(point.scale)];
-            if (!scaleMsg)
-              break;
-
-            points[scaleMsg]?.push(point);
-          }
-
-          const grouped: Record<string, { scale: number; addrs: string[] }> = {};
-          for (const point of message.points) {
-            const { addr, scale } = point;
-            const label = scaleMessages[String(scale)] ?? "不明";
-
-            if (!grouped[label]) {
-              grouped[label] = { scale, addrs: [] };
-            }
-
-            grouped[label].addrs.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();
-
-          const response = await client.request("ueuse/create", {
-            text: i18next.t("earthquakeNotice", {
-              occuredTime: format(new Date(message.earthquake.time), "yyyy年M月d日 H:mm"),
-              maxScale: scaleMessages[String(message.earthquake.maxScale)],
-              epicenter: message.earthquake.hypocenter.name === ""
-                ? "不明"
-                : message.earthquake.hypocenter.name,
-              magnitude: message.earthquake.hypocenter.magnitude === -1
-                ? "不明"
-                : `M${message.earthquake.hypocenter.magnitude.toFixed(1)}`,
-              depth: message.earthquake.hypocenter.depth === 0
-                ? "ごく浅い"
-                : (message.earthquake.hypocenter.depth === -1
-                  ? "不明"
-                  : `${message.earthquake.hypocenter.depth}km`),
-              domesticTsunami: domesticTsunamiMessages[(message.earthquake.domesticTsunami ?? "Unknown")],
-              foreignTsunami: foreignTsunamiMessages[(message.earthquake.foreignTsunami ?? "Unknown")],
-              points: pointsMsg === ""
-                ? ""
-                : EOL.repeat(2) + pointsMsg,
-              source: message.issue.source ?? "不明",
-              comment: message.comments.freeFormComment === ""
-                ? ""
-                : EOL + message.comments.freeFormComment + EOL,
-            }),
-          });
-
-          if (!response.success) {
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-            break;
-          }
-
-          console.log("地震発生情報を投稿:", response.uniqid);
-        }
-        break;
-      case 552:
-        {  
-          console.log("津波予報情報を受信しました");
-
-          if (message.cancelled) {
-            const response = await client.request("ueuse/create", {
-              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;
-          }
-
-          const gradeMessages: Record<string, string> = {
-            "Unknown": "不明",
-            "Watch": "津波注意報",
-            "Warning": "津波警報",
-            "MajorWarning": "大津波警報",
-          }
-
-          let areasMsg = "";
-          for (const area of message.areas) {
-            areasMsg += i18next.t("tsunamiAreaMsg", {
-              name: area.name,
-              immediate: area.immediate
-                ? EOL + "🚨***直ちに津波が来襲すると予想されています。***"
-                : "",
-              grade: gradeMessages[area.grade],
-              arrivalTime: format(new Date(area.firstHeight.arrivalTime), "yyyy年M月d日 H:mm"),
-              condition: area.firstHeight.condition
-                ? `${area.firstHeight.condition}されています`
-                : "不明",
-              maxHeight: area.maxHeight.value === 0.2
-                ? "0.2m未満"
-                : (area.maxHeight.value
-                  ? `${area.maxHeight.value}m`
-                  : area.maxHeight.description),
-            }) + EOL.repeat(2);
-          }
-
-          const response = await client.request("ueuse/create", {
-            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("緊急地震速報（警報）を受信しました");
-
-          const kindMessages: Record<string, string> = {
-            "10": "⏳主要動は、**未到達と予測**されています。",
-            "11": "🫨主要動が、**既に到達していると予測**されています。",
-            "19": "🧐PLUM法によると、主要動の***到達予想は***ありません。",
-          }
-
-          let areasMsg = "";
-          for (const area of message.areas) {
-            areasMsg += i18next.t("eewAreaMsg", {
-              name: area.name,
-              maxScale: scaleMessages[String(Math.floor(area.scaleFrom))] +
-                (area.scaleTo === 99
-                  ? "程度以上"
-                  : area.scaleFrom !== area.scaleTo
-                    ? `から${scaleMessages[String(Math.floor(area.scaleTo))]}`
-                    : ""),
-              kind: kindMessages[area.kindCode] ?? "😕主要動の***到達予想は***ありません。",
-              arrivalTime: area.arrivalTime !== undefined
-                ? format(new Date(area.arrivalTime), "yyyy年M月d日 H:mm:ss")
-                : "不明",
-            }) + EOL.repeat(2);
-          }
-
-          const response = await client.request("ueuse/create", {
-            text: i18next.t("eewNotice", {
-              isTest: message.test
-                ? "⚒️これは**テストです。**"
-                : "🚨これは**テストではありません。**",
-              announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
-              occuredTime: format(new Date(message.earthquake.originTime), "yyyy年M月d日 H:mm:ss"),
-              arrivalTime: format(new Date(message.earthquake.arrivalTime), "yyyy年M月d日 H:mm:ss"),
-              isAssume: message.earthquake.condition === "仮定震源要素"
-                ? `${EOL}❓これは、仮定震源要素です。そのため、震源に関する情報が保証できません。`
-                : "",
-              epicenter: message.earthquake.hypocenter.name ?? "不明",
-              depth: message.earthquake.hypocenter.depth === undefined ||
-                message.earthquake.hypocenter.depth === -1
-                  ? "不明"
-                  : `${Math.floor(message.earthquake.hypocenter.depth)}km`,
-              magnitude: message.earthquake.hypocenter.magnitude === undefined ||
-                message.earthquake.hypocenter.magnitude === -1
-                  ? "不明"
-                  : `M${message.earthquake.hypocenter.magnitude}`,
-              areas: areasMsg !== ""
-                ? EOL.repeat(2) + areasMsg.trim()
-                : "",
-            }),
-          });
-
-          if (!response.success) {
-            console.warn("ユーズの作成に失敗しました:", response.error_code);
-            break;
-          }
-
-          console.log("緊急地震速報（警報）情報を投稿:", response.uniqid);
-        }
-        break;
-      default:
-        console.log("未対応の情報:", message);
-        break;
-    }
-  } catch (err) {
-    console.warn("メッセージの処理に失敗しました:", err);
-  }
-}

src/feature/hnyNotice.ts

@@ -0,0 +1,18 @@
+import { createUeuse } from "@/lib/client";
+import { format } from "date-fns";
+
+console.log("新年迎春の投稿を行います");
+
+try {
+  await createUeuse({
+    text: `あけましておめでとうございます。今年は、${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/time/index.ts

@@ -0,0 +1,28 @@
+import { createUeuse } from "@/lib/client";
+import { format } from "date-fns";
+import { readFileSync } from "node:fs";
+
+console.log("時報の投稿を行います");
+
+try {
+  if (new Date().getHours() !== 4) {
+    await createUeuse({
+      text: `${format(new Date(), "H:mm")}になりました。`,
+    }, "時報");
+  } else {
+    const asayoziImg = readFileSync(`${import.meta.dirname}/asayozi.png`);
+    await createUeuse({
+      text: "朝四時に何してるんだい?",
+      media: {
+        photo: [asayoziImg.toString("base64")],
+      },
+    }, "時報(午前4時)");
+  }
+
+  process.exit(0);
+} catch (err: any) {
+  console.error("message" in err
+    ? err.message
+    : err);
+  process.exit(1);
+}

src/feature/timeNotice.ts

@@ -1,26 +0,0 @@
-import client from "@/lib/client";
-import initI18n from "@/lib/i18n";
-import { format } from "date-fns";
-import i18next from "i18next";
-
-await initI18n();
-console.log("時報の投稿を行います");
-
-try {
-  const response = await client.request("ueuse/create", {
-    text: i18next.t("timeNotice", { time: format(new Date(), "HH: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
-    ? err.message
-    : err);
-  process.exit(1);
-}

src/feature/weatherNotice.ts

@@ -1,7 +1,6 @@
 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";
 import { isMainThread, workerData } from "node:worker_threads";
@@ -56,23 +55,46 @@ const cityList = [
   "471010",
 ];
 
-if (!isMainThread && workerData === "scheduledWeatherNotice") {
+if (
-  await initI18n();
+  !isMainThread &&
+  typeof workerData === "string" &&
+  workerData.startsWith("scheduledWeatherNotice")
+) {
   console.log("天気予報の投稿を行います");
 
   try {
-    const provisionalUeuse = await client.request("ueuse/create", {
+    let provisionalUeuse;
-      text: i18next.t("weatherProvisional"),
+    let success = false;
+
+    for (let attempt = 1; attempt <= config.ueuse.maxRetries; attempt++) {
+      const provisionalText = [];
+      provisionalText.push(`${workerData.endsWith("Tomorrow")
+        ? "明日"
+        : "今日"}の天気`);
+      provisionalText.push("※タイムラインが埋まるため返信に記載しています。");
+      provisionalUeuse = await client.request("ueuse/create", {
+        text: provisionalText.join(EOL),
       });
 
-    if (!provisionalUeuse.success) {
+      if (provisionalUeuse.success) {
-      console.error("天気仮投稿に失敗しました:", provisionalUeuse.error_code);
+        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);
     }
 
     console.log("天気仮投稿:", provisionalUeuse.uniqid);
 
-    weatherReply(provisionalUeuse.uniqid);
+    await weatherReply(provisionalUeuse.uniqid, workerData.endsWith("Tomorrow"));
     process.exit(0);
   } catch (err: any) {
     console.error("message" in err
@@ -82,9 +104,11 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
   }
 }
 
-export async function weatherReply(uniqid: string) {
+export async function weatherReply(uniqid: string, isTomorrow: boolean) {
   // インデックス
-  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)
@@ -119,42 +143,54 @@ export async function weatherReply(uniqid: string) {
       });
 
       const data = await res.json();
-      const today = data.forecasts[0];
+      const itDay = isTomorrow
+        ? data.forecasts[1]
+        : data.forecasts[0];
 
       // 天気
-      const weather = today.telop ?? "取得できませんでした";
+      const areaText = [];
-      const maxTemp = today.temperature.max.celsius
+      areaText.push(`【${data.location.city}】`);
-        ? `${today.temperature.max.celsius}℃`
+      areaText.push(`⛅天気: ${itDay.telop ?? "取得できませんでした"}`);
-        : "取得できませんでした";
+      areaText.push(`🔆最高気温: ${itDay.temperature.max.celsius
-      const minTemp = today.temperature.min.celsius
+        ? `${itDay.temperature.max.celsius}℃`
-        ? `${today.temperature.min.celsius}℃`
+        : "取得できませんでした"}`);
-        : "取得できませんでした";
+      areaText.push(`🔅最低気温: ${itDay.temperature.min.celsius
-      const chanceOfRain = (
+        ? `${itDay.temperature.min.celsius}℃`
-          today.chanceOfRain.T06_12 !== null &&
+        : "取得できませんでした"}`);
-          today.chanceOfRain.T06_12 !== "--%"
+      areaText.push(`☔降水確率: ${
-        )
+        itDay.chanceOfRain.T06_12 !== null &&
-        ? today.chanceOfRain.T06_12
+        itDay.chanceOfRain.T06_12 !== "--%"
-        : "取得できませんでした";
+          ? itDay.chanceOfRain.T06_12
-
+          : "取得できませんでした"}`);
-      weatherResults[chunkIndex] += `${i18next.t("weatherReply", {
+      weatherResults[chunkIndex] += areaText.join(EOL) + EOL.repeat(2);
-        city: data.location.city,
-        weather,
-        maxTemp,
-        minTemp,
-        chanceOfRain,
-      })}${EOL.repeat(2)}`;
     }
   }
 
   // 分割投稿
   for (let i = 0; i < splitCount; i++) {
-    const replyUeuse = await client.request("ueuse/create", {
+    let replyUeuse;
+    let success = false;
+
+    for (let attempt = 1; attempt <= config.ueuse.maxRetries; attempt++) {
+      replyUeuse = await client.request("ueuse/create", {
         text: weatherResults[i].trim(),
         replyid: uniqid,
       });
 
-    if (!replyUeuse.success) {
+      if (replyUeuse.success) {
-      console.error("天気返信に失敗しました:", replyUeuse.error_code);
+        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,9 +18,9 @@ try {
   }
   console.log();
 
-  await initUserID();
+  await initData();
 
-  new Worker(`${import.meta.dirname}/feature/earthquakeNotice.js`);
+  new Worker(`${import.meta.dirname}/feature/earthquake/index.js`);
 
   console.log("Botが起動しました");
 } catch (err: any) {
@@ -30,14 +30,38 @@ try {
   process.exit(1);
 }
 
+try {
   schedule("0 * * * *", async () => {
-  new Worker(`${import.meta.dirname}/feature/timeNotice.js`);
+    new Worker(`${import.meta.dirname}/feature/time/index.js`);
   });
 
   schedule("0 7 * * *", async () => {
-  new Worker(`${import.meta.dirname}/feature/weatherNotice.js`);
+    new Worker(`${import.meta.dirname}/feature/weatherNotice.js`, {
+      workerData: "scheduledWeatherNotice",
+    });
+  });
+
+  schedule("0 18 * * *", async () => {
+    new Worker(`${import.meta.dirname}/feature/weatherNotice.js`, {
+      workerData: "scheduledWeatherNoticeTomorrow",
+    });
   });
 
   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,98 @@ const client = new uwuzu<ApiMap>({
 });
 
 client.token = config.uwuzu.token;
-
 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;
+
+  type ExtractSuccess<T> = T extends { success: true } ? T : never;
+  const results: ExtractSuccess<ApiMap["ueuse/create"]["response"]>[] = [];
+
+  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;
+        results.push(response);
+        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();
+    }
+  }
+
+  return results;
+}

src/lib/config.ts

@@ -6,13 +6,23 @@ import { EOL } from "node:os";
 const schema = z.object({
   command: z.object({
     interval: z.number().int().positive(),
-  }),
+    maxParallels: z.number().int().positive(),
-  weather: z.object({
-    splits: 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),
+    ]),
     useHistoryData: z.boolean(),
-  }).optional(),
+    reconnectInterval: z.number().positive(),
+  }),
   uwuzu: z.object({
     token: z.string().length(64),
     origin: z.string().refine(data => {
@@ -23,6 +33,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,28 +9,30 @@ class MemoryClass {
   constructor() {
     if (!existsSync(path)) {
       writeFileSync(path, JSON.stringify({
-        repliedUeuse: [],
+        processedInfo: [],
         permissions: {},
+        lastReadMention: 0,
+        lastReadReply: 0,
         userid: "",
+        max_length: 0,
       }));
     }
-
-    this.cachedMemory = JSON.parse(readFileSync(path, "utf-8"));
   }
 
   get memory() {
-    return this.cachedMemory;
+    return JSON.parse(readFileSync(path, "utf-8"));
   }
 
   set memory(data: any) {
-    this.cachedMemory = data;
+    writeFileSync(path, JSON.stringify(data), "utf-8");
-    writeFileSync(path, JSON.stringify(this.cachedMemory), "utf-8");
   }
 }
 
 const Memory = new MemoryClass();
 
-export const initUserID = async () => {
+export const initData = async () => {
+  await Promise.all([
+    (async () => {
       const response = await client.request("me/");
 
       if (!response.success)
@@ -39,6 +41,15 @@ export const initUserID = async () => {
       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;