Compare commits

...

38 Commits

Author SHA1 Message Date
last2014 86dfc97c7a Merge pull request '2026.5.9' (#26) from develop into main
Reviewed-on: #26
2026-05-21 13:50:58 +00:00
last2014 599b623b8d Merge branch 'main' into develop 2026-05-21 13:50:51 +00:00
last2014 c2b324dc6d Merge remote-tracking branch 'refs/remotes/origin/develop' into develop 2026-05-21 22:50:15 +09:00
last2014 3fe876a239 Fix: pnpmが動作しない問題 / 2026.5.9 2026-05-21 22:49:41 +09:00
last2014 b461304d65 Merge pull request '2026.5.8' (#25) from develop into main
Reviewed-on: #25
2026-05-21 13:46:18 +00:00
last2014 bf8e998d14 Merge branch 'main' into develop 2026-05-21 13:46:12 +00:00
last2014 3c7fa8fe82 Fix: 地震情報の情報源と各震度の間に改行がない問題 / Fix: 最大震度が不明な場合にも行が追加される問題 / Fix: pnpmが動作しない問題 / 2026.5.8 2026-05-21 22:45:48 +09:00
last2014 aff5d4e54d Merge pull request '2026.5.7' (#24) from develop into main
Reviewed-on: #24
2026-05-21 13:36:30 +00:00
last2014 fc5256c681 Merge branch 'main' into develop 2026-05-21 13:36:24 +00:00
last2014 11f29463a6 Chg: 地震情報で不明な情報をそもそも投稿しないように / 2026.5.7 2026-05-21 22:35:56 +09:00
last2014 6fc5ab9d0d Chg: pnpm 11.1.3 / Del: helpコマンドとmiqコマンドを除く全てのi18n / Feat: 朝四時に何してるんだい? 2026-05-21 22:22:45 +09:00
last2014 7774447b2b Merge pull request '2026.5.6' (#23) from develop into main
Reviewed-on: #23
2026-05-17 10:38:15 +00:00
last2014 b2ff3e481a Merge branch 'main' into develop 2026-05-17 10:38:08 +00:00
last2014 5ed2f3a41e Merge remote-tracking branch 'refs/remotes/origin/develop' into develop 2026-05-17 19:37:44 +09:00
last2014 7aff4cdf7d Fix: 2026.5.5で修正されたと報告した「20件前のユーズを最後に応答したコマンドのユーズとして記録していた問題」を再発させていた問題 / 2026.5.6 2026-05-17 19:37:38 +09:00
last2014 70227278c0 Merge pull request '2026.5.5' (#22) from develop into main
Reviewed-on: #22
2026-05-17 10:35:52 +00:00
last2014 896bb9aaf7 Merge branch 'main' into develop 2026-05-17 10:35:45 +00:00
last2014 386555ecf3 Fix: 毎日18:00の天気予報の仮投稿の表記が本日になっていた問題 / Chg: 毎日7:00の天気予報の日付表記 / Fix: 20件前のユーズを最後に応答したコマンドのユーズとして記録していた問題 / 2026.5.5 2026-05-17 19:35:13 +09:00
last2014 734b573a3b Merge pull request '2026.5.4' (#21) from develop into main
Reviewed-on: #21
2026-05-17 05:43:39 +00:00
last2014 d974115606 Merge branch 'main' into develop 2026-05-17 05:43:33 +00:00
last2014 c1edf6c13b Merge remote-tracking branch 'refs/remotes/origin/develop' into develop 2026-05-17 14:42:50 +09:00
last2014 95ed876a47 Chg: メモリをキャッシュしないように / 2026.5.4 2026-05-17 14:42:30 +09:00
last2014 9c09675205 Merge pull request '2026.5.3' (#20) from develop into main
Reviewed-on: #20
2026-05-17 04:56:17 +00:00
last2014 9b6e790d4b Merge branch 'main' into develop 2026-05-17 04:56:10 +00:00
last2014 7c4b5f7397 2026.5.3 2026-05-17 13:55:47 +09:00
last2014 3db3a75f64 Fix: distに震度分布画像のアセットと地域マップがコピーされるように / Del: 正確にスケジュールが動作する機能 / Fix: 返信とメンションの返答が記録されない問題 / Fix: 震度分布画像が投稿されない問題 / Chg: 震度分布画像のメッセージを変更 / Fix: 条件に合わなくても震度分布画像を生成する問題 / Fix: 震度分布画像に隙間が空く問題 2026-05-17 13:54:22 +09:00
last2014 2951a248f5 Merge pull request '2026.5.2' (#19) from develop into main
Reviewed-on: #19
2026-05-16 10:30:55 +00:00
last2014 eb027d7daf Merge branch 'main' into develop 2026-05-16 10:30:48 +00:00
last2014 4dfdb6fc4a Fix: /weatherが利用できない問題 / 2026.5.2 2026-05-16 19:30:09 +09:00
last2014 b92116f3a9 Merge pull request '2026.5.1' (#18) from develop into main
Reviewed-on: #18
2026-05-16 10:25:48 +00:00
last2014 6b732b3110 Merge branch 'main' into develop 2026-05-16 10:25:40 +00:00
last2014 a986068372 2026.5.1 2026-05-16 19:24:54 +09:00
last2014 3a446440d3 Chg: 全てのスケジュールが正確に動作するように 2026-05-16 19:20:16 +09:00
last2014 33435f4c46 Chg: 毎日18:00の天気予報は明日の天気予報を投稿するように 2026-05-16 18:53:25 +09:00
last2014 e7f0c3aed8 Chg: 毎日18:00にも天気予報が投稿されるように 2026-05-16 18:47:00 +09:00
last2014 6e9ea20d33 Feat: 地震の震度分布画像生成 / Chg: 震度分布画像のズームレベルを8から9へ / Chg: 震度分布画像の生成条件を震源と位置が存在するへ変更 / Feat: 震度分布画に全タイルが埋まる機能 / Feat: 震度分布画像の震源がタイル単位で中央になる機能 / Feat: 震度分布画像で欠けているタイルが描画される機能 / Chg: 震度分布画像のアセットを並列に取得 / Feat: 震度分布画像のアセットの位置が中央基準になる機能 / Chg: 震度分布画像の震源のアセットに縁取りを追加 / Chg: 震度分布画像の震度ではないアセットを拡大 / Chg: ユーズの分割の案内文を太字に / Del: 最大震度が不明な場合に投稿するかどうかのconfigを削除 2026-05-16 18:45:13 +09:00
last2014 83441a8eaf Fix: 地震情報の画像生成での並び替えで、震度の位置が震源の位置として扱われる問題 2026-05-11 13:42:40 +09:00
last2014 1c979939bb Fix: 毎日7:00に天気予報の返信をできない問題 2026-05-11 07:02:21 +09:00
23 changed files with 576 additions and 315 deletions
-1
View File
@@ -3,4 +3,3 @@
/memory.json
/config/**
!/config/example.yaml
/src/feature/earthquake/generateImage/data.json
+55
View File
@@ -1,3 +1,58 @@
# 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: 地震情報でのタイトルを変更
+9 -7
View File
@@ -3,18 +3,20 @@
uwuzu v1.6.7以上で利用可能です。
## 機能
- 時報
毎時0分に「h:00になりました。」と投稿します。
- 天気予報
[天気予報 APIlivedoor 天気互換)](https://weather.tsukumijima.net/)を利用して、毎日7:00に天気予報を投稿します。
- 地震情報
- 時報
毎時0分に「h:00になりました。」と投稿します。
4:00は某画像で投稿します。
- 天気予報
[天気予報 APIlivedoor 天気互換)](https://weather.tsukumijima.net/)を利用して、毎日7:00及び18:00に天気予報を投稿します。
18:00は明日の天気予報を投稿します。
- 地震情報
[P2P地震情報](https://www.p2pquake.net/)のWebSocket APIを利用して、以下の情報を受信した際に投稿します。
- 地震発生
- 緊急地震速報(警報)
- 津波予報
- 新年迎春
- 新年迎春
毎年1/1 0:00に投稿します。
- デバッグモード
- デバッグモード
設定で有効化することで、以下の機能が利用できます。
開発以外では使用しないでください。
- NODE_TLS_REJECT_UNAUTHORIZED=1
-2
View File
@@ -12,8 +12,6 @@ earthquake:
# 例: 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
-62
View File
@@ -1,65 +1,3 @@
timeNotice: "{{ time }}になりました。"
weatherProvisional: |
本日の天気
※タイムラインが埋まるため返信に記載しています。
weatherReply: |
【{{ city }}】
天気: {{ weather }}
最高気温: {{ maxTemp }}
最低気温: {{ minTemp }}
降水確率: {{ chanceOfRain }}
earthquakeNotice: |
### {{ type }}
⏰時刻: {{ 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 }}
🔬情報源: P2P地震速報
eewCancelNotice: |
### 緊急地震速報(警報)**解除**
{{ isTest }}
⏰発表時刻: {{ announceTime }}
🔬情報源: P2P地震速報
hnyNotice: |
あけましておめでとうございます。今年は、{{ year }}年です。
commandNotFound: |
コマンドが本文から参照できませんでした。
Botでは、このアカウントに対してのメンション部分を取り除きます。
+4 -3
View File
@@ -1,22 +1,23 @@
{
"name": "notice-uwuzu",
"version": "2026.5.0",
"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",
+124
View File
@@ -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
@@ -229,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==}
@@ -298,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==}
@@ -399,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==}
@@ -433,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==}
@@ -467,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'}
@@ -475,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'}
@@ -529,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'}
@@ -613,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==}
@@ -650,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==}
@@ -800,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
@@ -882,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:
@@ -990,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
@@ -1016,6 +1116,8 @@ snapshots:
ignore@5.3.2: {}
ignore@7.0.5: {}
inherits@2.0.4: {}
ini@1.3.8: {}
@@ -1047,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
@@ -1058,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:
@@ -1102,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: {}
@@ -1221,6 +1341,8 @@ snapshots:
slash@3.0.0: {}
slash@5.1.0: {}
string_decoder@1.3.0:
dependencies:
safe-buffer: 5.2.1
@@ -1267,6 +1389,8 @@ snapshots:
undici-types@7.18.2: {}
unicorn-magic@0.4.0: {}
util-deprecate@1.0.2: {}
util@0.12.5:
+5 -4
View File
@@ -1,4 +1,5 @@
onlyBuiltDependencies:
- "better-uwuzu-sdk"
- "miq"
- sharp
allowBuilds:
canvas: true
sharp: true
better-uwuzu-sdk: true
miq: true
+29 -30
View File
@@ -11,11 +11,16 @@ 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,
@@ -23,36 +28,26 @@ try {
});
if (response.success) {
const notifications = response.data.filter(notification => notification.category === "reply" && typeof notification.valueid === "string");
const mem = Memory.memory;
const lastReadReply = mem.lastReadReply;
const notifications = response.data.filter(n => n.category === "reply" && typeof n.valueid === "string");
for (const [index, notification] of notifications.entries()) {
if (notification.category !== "reply" || typeof notification.valueid !== "string")
continue;
const ueuseResponse = await client.request("ueuse/get", {
uniqid: notification.valueid,
});
const ueuseResponse = await client.request("ueuse/get", { uniqid: notification.valueid });
if (!ueuseResponse.success || !ueuseResponse.data[0]) {
console.warn("返信通知からユーズを参照できないため、スキップします");
continue;
}
const time = new Date(ueuseResponse.data[0].datetime).getTime();
const ueuseData = ueuseResponse.data[0];
const time = new Date(ueuseData.datetime).getTime();
if (index === 0) {
const mem = Memory.memory;
mem.lastReadReply = time;
Memory.memory = mem;
}
if (lastReadReply >= time)
if (mem.lastReadReply >= time)
break;
ueuses.push(ueuseResponse.data[0]);
if (index === 0)
newLastReadReply = time;
ueuses.push(ueuseData);
}
} else {
console.warn("返信通知の取得に失敗しましたが、続行します");
@@ -68,21 +63,15 @@ try {
if (response.success) {
const mentions = response.data;
const mem = Memory.memory;
const lastReadMention = mem.lastReadMention;
for (const [index, mention] of mentions.entries()) {
const time = new Date(mention.datetime).getTime();
if (index === 0) {
const mem = Memory.memory;
mem.lastReadMention = time;
Memory.memory = mem;
}
if (lastReadMention >= time)
if (mem.lastReadMention >= time)
break;
if (index === 0)
newLastReadMention = time;
ueuses.push(mention);
}
} else {
@@ -90,7 +79,17 @@ try {
}
}
ueuses = [...new Set(ueuses)];
mem.lastReadReply = newLastReadReply;
mem.lastReadMention = newLastReadMention;
Memory.memory = mem;
const seenIds = new Set();
ueuses = ueuses.filter(ueuse => {
if (seenIds.has(ueuse.uniqid))
return false;
seenIds.add(ueuse.uniqid);
return true;
});
for (let i = 0; i < ueuses.length; i += config.command.maxParallels) {
const chunk = ueuses.slice(i, i + config.command.maxParallels);
+1 -1
View File
@@ -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);
}
Binary file not shown.

Before

Width:  |  Height:  |  Size: 693 B

After

Width:  |  Height:  |  Size: 559 B

Binary file not shown.

Before

Width:  |  Height:  |  Size: 39 KiB

After

Width:  |  Height:  |  Size: 17 KiB

+126 -22
View File
@@ -153,12 +153,14 @@ function getEdge<T extends any[]>(arr: T, property: keyof T[number]) {
export default async function generateImage(message: any) {
if (
message.earthquake.hypocenter === undefined &&
message.points === undefined
message.earthquake.hypocenter === undefined ||
message.earthquake.hypocenter?.name === "" ||
!(Array.isArray(message.points)) ||
message.points.length === 0
)
return "input_lack";
const ZOOM_LEVEL = 8;
const ZOOM_LEVEL = 9;
// タイル・地点取得
const tiles: {
@@ -278,23 +280,122 @@ export default async function generateImage(message: any) {
scale: number;
}))[] = [];
// タイルのXYの各最大最小を取得
const tileXCount = getEdge(tiles, "tileX");
const tileYCount = getEdge(tiles, "tileY");
// タイルの幅、最大最小
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;
const xSize = tileXCount.most - tileXCount.least + 1;
const ySize = tileYCount.most - tileYCount.least + 1;
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<ArrayBuffer>> = {}
const assets: Record<string, {
buffer: Buffer<ArrayBuffer>;
size: number;
}> = {}
const assetsList = [
"scales/10",
"scales/20",
@@ -309,15 +410,20 @@ export default async function generateImage(message: any) {
"epicenter",
];
assetsList.forEach(name => {
const asset = readFileSync(`${import.meta.dirname}/assets/${name}.png`);
await Promise.all(assetsList.map(async name => {
const key = name.split("/").at(-1);
if (!key)
return;
assets[key] = asset;
});
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) => {
@@ -364,16 +470,16 @@ export default async function generateImage(message: any) {
}
} else {
about = {
type: "epicenter",
type: "scale",
scale: position.scale,
}
}
compounds.push({
...about,
input: asset,
top: Math.round(top + position.innerY * tileResizedSize),
left: Math.round(left + position.innerX * tileResizedSize),
input: asset.buffer,
top: Math.round(top + position.innerY * tileResizedSize - asset.size / 2),
left: Math.round(left + position.innerX * tileResizedSize - asset.size / 2),
});
});
}));
@@ -424,6 +530,4 @@ export default async function generateImage(message: any) {
const buffer = await result.png().toBuffer();
return buffer;
}
writeFileSync("result.png", await generateImage(JSON.parse(readFileSync(`${import.meta.dirname}/data.json`, "utf8"))));
}
+135 -106
View File
@@ -1,14 +1,11 @@
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";
import { EOL } from "node:os";
import { WebSocket } from "ws";
await initI18n();
import generateImage from "@/feature/earthquake/generateImage";
if (config.earthquake?.useHistoryData) {
console.log("過去の地震情報を配信します");
@@ -104,15 +101,6 @@ const processMessage = async (message: any) => {
{
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
@@ -177,33 +165,65 @@ const processMessage = async (message: any) => {
.join(EOL.repeat(2))
.trim();
await createUeuse({
text: i18next.t("earthquakeNotice", {
type: typeMessage[message.issue.type] ?? "地震情報",
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,
}),
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:
@@ -211,12 +231,14 @@ const processMessage = async (message: any) => {
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: i18next.t("tsunamiCancelNotice", {
announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
source: message.issue.source ?? "不明",
}),
text: tsunamiCancelledNoticeText.join(EOL),
}, "津波予報解除情報");
break;
}
@@ -229,30 +251,31 @@ const processMessage = async (message: any) => {
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 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: i18next.t("tsunamiForecastNotice", {
announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
areasMsg: areasMsg.trim(),
source: message.issue.source ?? "不明",
}),
text: tsunamiNoticeText.join(EOL),
}, "津波予報情報");
}
break;
@@ -261,13 +284,15 @@ const processMessage = async (message: any) => {
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: i18next.t("eewCancelNotice", {
isTest: message.test
? "⚒️これは**テストです。**"
: "🚨これは**テストではありません。**",
announceTime: format(new Date(message.issue.time), "yyyy年M月d日 H:mm:ss"),
}),
text: eewCancelledNotice.join(EOL),
}, "緊急地震速報(警報)解除情報");
}
@@ -279,45 +304,49 @@ const processMessage = async (message: any) => {
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: typeof area.arrivalTime === "string" && area.arrivalTime !== ""
? format(new Date(area.arrivalTime), "yyyy年M月d日 H:mm:ss")
: "不明",
}) + EOL.repeat(2);
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: 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.toFixed(1)}`,
areas: areasMsg !== ""
? EOL.repeat(2) + areasMsg.trim()
: "",
}),
text: eewNoticeText.join(EOL),
}, "緊急地震速報(警報)情報");
}
break;
+13 -20
View File
@@ -1,25 +1,18 @@
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();
console.log("新年迎春の投稿を行います");
parentPort?.on("message", async () => {
console.log("新年迎春の投稿を行います");
try {
await createUeuse({
text: `あけましておめでとうございます。今年は、${new Date().getFullYear()}年です。`,
}, "新年迎春");
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);
}
});
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);
}
Binary file not shown.

After

Width:  |  Height:  |  Size: 1.2 MiB

+28
View File
@@ -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);
}
-20
View File
@@ -1,20 +0,0 @@
import { createUeuse } from "@/lib/client";
import initI18n from "@/lib/i18n";
import { format } from "date-fns";
import i18next from "i18next";
await initI18n();
console.log("時報の投稿を行います");
try {
await createUeuse({
text: i18next.t("timeNotice", { time: format(new Date(), "H:mm") }),
}, "時報");
process.exit(0);
} catch (err: any) {
console.error("message" in err
? err.message
: err);
process.exit(1);
}
+31 -29
View File
@@ -1,8 +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";
@@ -57,8 +55,11 @@ const cityList = [
"471010",
];
if (!isMainThread && workerData === "scheduledWeatherNotice") {
await initI18n();
if (
!isMainThread &&
typeof workerData === "string" &&
workerData.startsWith("scheduledWeatherNotice")
) {
console.log("天気予報の投稿を行います");
try {
@@ -66,8 +67,13 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
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: i18next.t("weatherProvisional"),
text: provisionalText.join(EOL),
});
if (provisionalUeuse.success) {
@@ -88,7 +94,7 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
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
@@ -98,7 +104,7 @@ if (!isMainThread && workerData === "scheduledWeatherNotice") {
}
}
export async function weatherReply(uniqid: string) {
export async function weatherReply(uniqid: string, isTomorrow: boolean) {
// インデックス
const aboutFullLength = 3100;
const mem = Memory.memory;
@@ -137,30 +143,26 @@ 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 maxTemp = today.temperature.max.celsius
? `${today.temperature.max.celsius}`
: "取得できませんでした";
const minTemp = today.temperature.min.celsius
? `${today.temperature.min.celsius}`
: "取得できませんでした";
const chanceOfRain = (
today.chanceOfRain.T06_12 !== null &&
today.chanceOfRain.T06_12 !== "--%"
)
? today.chanceOfRain.T06_12
: "取得できませんでした";
weatherResults[chunkIndex] += `${i18next.t("weatherReply", {
city: data.location.city,
weather,
maxTemp,
minTemp,
chanceOfRain,
})}${EOL.repeat(2)}`;
const areaText = [];
areaText.push(`${data.location.city}`);
areaText.push(`⛅天気: ${itDay.telop ?? "取得できませんでした"}`);
areaText.push(`🔆最高気温: ${itDay.temperature.max.celsius
? `${itDay.temperature.max.celsius}`
: "取得できませんでした"}`);
areaText.push(`🔅最低気温: ${itDay.temperature.min.celsius
? `${itDay.temperature.min.celsius}`
: "取得できませんでした"}`);
areaText.push(`☔降水確率: ${
itDay.chanceOfRain.T06_12 !== null &&
itDay.chanceOfRain.T06_12 !== "--%"
? itDay.chanceOfRain.T06_12
: "取得できませんでした"}`);
weatherResults[chunkIndex] += areaText.join(EOL) + EOL.repeat(2);
}
}
+7 -1
View File
@@ -32,7 +32,7 @@ try {
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 () => {
@@ -41,6 +41,12 @@ try {
});
});
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`);
});
+7 -1
View File
@@ -15,12 +15,15 @@ export default client;
export const createUeuse = async (data: ApiMap["ueuse/create"]["body"], title: string) => {
const mem = Memory.memory;
const excessedMessage = "👉返信に続きがあります。";
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 = "";
@@ -76,6 +79,7 @@ export const createUeuse = async (data: ApiMap["ueuse/create"]["body"], title: s
if (response.success) {
success = true;
postedUniqid = response.uniqid;
results.push(response);
break;
}
@@ -99,4 +103,6 @@ export const createUeuse = async (data: ApiMap["ueuse/create"]["body"], title: s
lines.shift();
}
}
return results;
}
-1
View File
@@ -20,7 +20,6 @@ const schema = z.object({
z.literal(60),
z.literal(70),
]),
canUnknownMaxScale: z.boolean(),
useHistoryData: z.boolean(),
reconnectInterval: z.number().positive(),
}),
+2 -5
View File
@@ -17,17 +17,14 @@ class MemoryClass {
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(this.cachedMemory), "utf-8");
writeFileSync(path, JSON.stringify(data), "utf-8");
}
}