Compare commits
38 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 86dfc97c7a | |||
| 599b623b8d | |||
| c2b324dc6d | |||
| 3fe876a239 | |||
| b461304d65 | |||
| bf8e998d14 | |||
| 3c7fa8fe82 | |||
| aff5d4e54d | |||
| fc5256c681 | |||
| 11f29463a6 | |||
| 6fc5ab9d0d | |||
| 7774447b2b | |||
| b2ff3e481a | |||
| 5ed2f3a41e | |||
| 7aff4cdf7d | |||
| 70227278c0 | |||
| 896bb9aaf7 | |||
| 386555ecf3 | |||
| 734b573a3b | |||
| d974115606 | |||
| c1edf6c13b | |||
| 95ed876a47 | |||
| 9c09675205 | |||
| 9b6e790d4b | |||
| 7c4b5f7397 | |||
| 3db3a75f64 | |||
| 2951a248f5 | |||
| eb027d7daf | |||
| 4dfdb6fc4a | |||
| b92116f3a9 | |||
| 6b732b3110 | |||
| a986068372 | |||
| 3a446440d3 | |||
| 33435f4c46 | |||
| e7f0c3aed8 | |||
| 6e9ea20d33 | |||
| 83441a8eaf | |||
| 1c979939bb |
@@ -3,4 +3,3 @@
|
||||
/memory.json
|
||||
/config/**
|
||||
!/config/example.yaml
|
||||
/src/feature/earthquake/generateImage/data.json
|
||||
|
||||
@@ -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: 地震情報でのタイトルを変更
|
||||
|
||||
@@ -3,18 +3,20 @@
|
||||
uwuzu v1.6.7以上で利用可能です。
|
||||
|
||||
## 機能
|
||||
- 時報
|
||||
毎時0分に「h:00になりました。」と投稿します。
|
||||
- 天気予報
|
||||
[天気予報 API(livedoor 天気互換)](https://weather.tsukumijima.net/)を利用して、毎日7:00に天気予報を投稿します。
|
||||
- 地震情報
|
||||
- 時報
|
||||
毎時0分に「h:00になりました。」と投稿します。
|
||||
4:00は某画像で投稿します。
|
||||
- 天気予報
|
||||
[天気予報 API(livedoor 天気互換)](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
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -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
@@ -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",
|
||||
|
||||
Generated
+124
@@ -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
@@ -1,4 +1,5 @@
|
||||
onlyBuiltDependencies:
|
||||
- "better-uwuzu-sdk"
|
||||
- "miq"
|
||||
- sharp
|
||||
allowBuilds:
|
||||
canvas: true
|
||||
sharp: true
|
||||
better-uwuzu-sdk: true
|
||||
miq: true
|
||||
@@ -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);
|
||||
|
||||
@@ -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 |
@@ -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
@@ -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
@@ -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 |
@@ -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);
|
||||
}
|
||||
@@ -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);
|
||||
}
|
||||
@@ -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
@@ -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
@@ -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;
|
||||
}
|
||||
@@ -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
@@ -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");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user