Compare commits
41 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| f14999be13 | |||
| 6ec9831ed4 | |||
| 718e97ed45 | |||
| f6f7030d8c | |||
| a2576f961b | |||
| 844a9cd058 | |||
| 2a30fdf1e9 | |||
| dc67845bc8 | |||
| 50db83cc8c | |||
| d7a5d8a43e | |||
| 1c10aeb9e4 | |||
| 081d1eca6e | |||
| 0e9c8f8225 | |||
| 724e18ba3b | |||
| 3955d91978 | |||
| d28ca6ce4c | |||
| ad0d975a12 | |||
| 7f07710d23 | |||
| 3b58e7ee2d | |||
| 22ec582e0a | |||
| 05194ad7b8 | |||
| ef374b1639 | |||
| 563d70aacd | |||
| 568ae7abf6 | |||
| c3ab3a8456 | |||
| 678f4aa1b1 | |||
| a96c3f0e4f | |||
| 53ba26f417 | |||
| 6b68b6e1b5 | |||
| e3451323f3 | |||
| 8be3684a78 | |||
| 600626d071 | |||
| 5c0c34bbb4 | |||
| 88bd2e88a5 | |||
| 7c7dfdcf3c | |||
| dd70fe5494 | |||
| 73091bb92f | |||
| 6c69ce80ef | |||
| 7e3c4840d3 | |||
| 007efd85a8 | |||
| 2689dfd777 |
@@ -1,2 +0,0 @@
|
||||
TOKEN=
|
||||
SERVER=
|
||||
+2
-2
@@ -1,5 +1,5 @@
|
||||
/dist/
|
||||
/.env
|
||||
/.env.local
|
||||
/.env*
|
||||
/node_modules/
|
||||
/package-lock.json
|
||||
/config.ts
|
||||
|
||||
@@ -0,0 +1,13 @@
|
||||
Copyright 2025 Last2014
|
||||
|
||||
Licensed under the Apache License, Version 2.0 (the "License");
|
||||
you may not use this file except in compliance with the License.
|
||||
You may obtain a copy of the License at
|
||||
|
||||
https://www.apache.org/licenses/LICENSE-2.0
|
||||
|
||||
Unless required by applicable law or agreed to in writing, software
|
||||
distributed under the License is distributed on an "AS IS" BASIS,
|
||||
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
See the License for the specific language governing permissions and
|
||||
limitations under the License.
|
||||
@@ -1,19 +1,44 @@
|
||||
# uwuzuお知らせBOT
|
||||
# noticeUwuzu
|
||||
|
||||
# uwuzuお知らせBOTについて
|
||||
# Overview
|
||||
|
||||
uwuzuで動作するお知らせBOTです。
|
||||
Automatic notification bot for uwuzu
|
||||
|
||||
# .env形式
|
||||
# Functions
|
||||
|
||||
`.env.example`をご覧ください。
|
||||
- Time notification
|
||||
- Earthquake information notification
|
||||
- Earthquake Early Warning
|
||||
- Earthquake occurs
|
||||
- Tsunami forecast
|
||||
- Weather notification
|
||||
- Commands that users can use freely
|
||||
- About BOT
|
||||
- Command Help
|
||||
- Report to the operator
|
||||
- Follow back
|
||||
- Unfollow
|
||||
- Weather Repost
|
||||
- Startup requirements check
|
||||
- Check package existence
|
||||
- Required package version check
|
||||
- Check uwuzu API
|
||||
- Check the configuration file
|
||||
- Version change notification
|
||||
- ASCII art at startup
|
||||
- Confirm normal completion
|
||||
|
||||
# サーバー起動
|
||||
# Config
|
||||
An example configuration file is available in `examples/config.ts`.
|
||||
|
||||
```
|
||||
# Start the server
|
||||
|
||||
```bash
|
||||
npm install
|
||||
npm run build
|
||||
npm run start
|
||||
```
|
||||
Recommended Node.js version: v22.16.0
|
||||
|
||||
※Node.js・npmがインストールされている必要があります。
|
||||
# License
|
||||
[Apache 2.0 License](https://www.apache.org/licenses/LICENSE-2.0)
|
||||
|
||||
@@ -0,0 +1,5 @@
|
||||
# # ###### ##### ### ###### ####### # # # # # # ###### # #
|
||||
## # # # # # # # # # # # # # # # # #
|
||||
# ## # # # # # # ####### # # # # # # # # ## # #
|
||||
# ## # # # # # # # # # # # # # # #
|
||||
# # ###### # ### ###### ####### ###### # # ###### ###### ######
|
||||
@@ -0,0 +1,29 @@
|
||||
import { styleText } from "util";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function APICheck() {
|
||||
try {
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/me/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
})
|
||||
});
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
if (res.error_code !== undefined) {
|
||||
console.log(styleText("red", "APIトークンあるいはuwuzuサーバーホストが無効です"));
|
||||
process.exit();
|
||||
}
|
||||
|
||||
if (res.isBot === false) {
|
||||
setTimeout(() => {
|
||||
console.log(styleText("yellow", "使用するアカウントでBOTフラグが設定されていません"));
|
||||
}, 1500);
|
||||
}
|
||||
} catch (err) {
|
||||
console.log(styleText("red", `uwuzuサーバーへ接続できませんでした: ${err}`));
|
||||
process.exit();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,9 @@
|
||||
import * as fs from "fs";
|
||||
import { styleText } from "util";
|
||||
|
||||
export default function ConfigCheck() {
|
||||
if (!fs.existsSync("config.ts")) {
|
||||
console.log(styleText("red", "config.tsがありません"));
|
||||
process.exit();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,13 @@
|
||||
import PackagesIsExist from "./packagesExist.js";
|
||||
import PackagesCheck from "./packages.js";
|
||||
import ConfigCheck from "./config.js";
|
||||
import APICheck from "./api.js";
|
||||
import VersionCheck from "./version.js";
|
||||
|
||||
export default async function Check() {
|
||||
PackagesIsExist();
|
||||
PackagesCheck();
|
||||
ConfigCheck();
|
||||
await APICheck();
|
||||
await VersionCheck();
|
||||
}
|
||||
@@ -0,0 +1,59 @@
|
||||
import * as fs from "fs";
|
||||
import { styleText } from "util";
|
||||
|
||||
export default function PackagesCheck() {
|
||||
try {
|
||||
if (!fs.existsSync("package.json")) {
|
||||
console.log(styleText("red", "package.jsonがありません。正規のリポジトリでgit pullを実行してください。"));
|
||||
process.exit();
|
||||
}
|
||||
|
||||
// package.json取得
|
||||
const packages = JSON.parse(fs.readFileSync("package.json", "utf-8"));
|
||||
const dependencies = packages.dependencies;
|
||||
|
||||
const packageNames: Array<string> = [];
|
||||
|
||||
Object.keys(dependencies).forEach((packageName) => {
|
||||
let version: string;
|
||||
|
||||
if (dependencies[packageName].charAt(0) === "^") {
|
||||
version = dependencies[packageName].replace('^', '');
|
||||
} else {
|
||||
version = dependencies[packageName]
|
||||
}
|
||||
|
||||
dependencies[packageName] = version;
|
||||
packageNames.push(packageName);
|
||||
});
|
||||
|
||||
// パッケージのバージョン取得
|
||||
const mismatchPackages: Array<string> = [];
|
||||
|
||||
packageNames.forEach((packageName) => {
|
||||
const packagePath = `node_modules/${packageName}/package.json`;
|
||||
|
||||
if (fs.existsSync(packagePath)) {
|
||||
const modulePackage = JSON.parse(fs.readFileSync(packagePath, "utf-8"));
|
||||
|
||||
if (modulePackage.version !== dependencies[packageName]) {
|
||||
mismatchPackages.push(packageName);
|
||||
}
|
||||
} else {
|
||||
console.log(styleText("red", `パッケージ「${packageName}」が見つかりません。`));
|
||||
process.exit();
|
||||
}
|
||||
});
|
||||
|
||||
if (mismatchPackages.length !== 0) {
|
||||
console.log(styleText("red", "以下のパッケージのバージョンが異なります:"));
|
||||
mismatchPackages.forEach((mismatch) => {
|
||||
console.log(styleText("red", mismatch));
|
||||
console.log(styleText("red", ` 要求バージョン: ${dependencies[mismatch]}`));
|
||||
});
|
||||
process.exit();
|
||||
}
|
||||
} catch (err) {
|
||||
console.log("パッケージの存在確認でエラーが発生しました: ", err);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
import * as fs from "fs";
|
||||
import { styleText } from "util";
|
||||
|
||||
export default function PackagesIsExist() {
|
||||
try {
|
||||
if (!fs.existsSync("node_modules/.package-lock.json")) {
|
||||
console.log(styleText("red", `
|
||||
node_modules/.package-lock.jsonがありません。
|
||||
プロジェクト直下でnpm installを実行してください。
|
||||
`));
|
||||
process.exit();
|
||||
}
|
||||
} catch (err) {
|
||||
console.log("node_modules/.package-lock.jsonの存在確認でエラーが発生しました: ", err);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
import config from "../config.js";
|
||||
import { readFileSync, writeFileSync, existsSync } from "fs";
|
||||
|
||||
export default async function VersionCheck() {
|
||||
const packageJson = JSON.parse(readFileSync("package.json", "utf-8"));
|
||||
|
||||
// 初期化
|
||||
if (!existsSync("logs/version.txt")) {
|
||||
writeFileSync(
|
||||
"logs/version.txt",
|
||||
packageJson.version,
|
||||
"utf-8",
|
||||
);
|
||||
}
|
||||
|
||||
// 最終起動バージョン取得
|
||||
const oldVersion = readFileSync("logs/version.txt", "utf-8");
|
||||
|
||||
if (oldVersion !== packageJson.version) {
|
||||
try {
|
||||
writeFileSync(
|
||||
"logs/version.txt",
|
||||
packageJson.version,
|
||||
"utf-8",
|
||||
);
|
||||
|
||||
const releaseUrl = `${packageJson.repository.url}/releases/tag/${packageJson.tag}`;
|
||||
|
||||
await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
${packageJson.version}にBOTがアップデートされました!
|
||||
リリース内容:${releaseUrl}
|
||||
`,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
} catch (err) {
|
||||
console.log("アップデート通知にエラーが発生しました: ", err);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,2 @@
|
||||
*
|
||||
!.gitignore
|
||||
@@ -0,0 +1,59 @@
|
||||
import type { configTypes } from "types/config";
|
||||
|
||||
// READMEの設定項目を参照
|
||||
const config: configTypes = {
|
||||
// 時報設定
|
||||
time: {
|
||||
// 時報休止期間
|
||||
stopTimes: {
|
||||
start: 23, // 開始
|
||||
stop: 6, // 停止
|
||||
},
|
||||
},
|
||||
// 地震速報設定
|
||||
earthquake: {
|
||||
reconnectTimes: 5000, // 再接続時間(ミリ秒)
|
||||
websocketUrl: "wss://api.p2pquake.net/v2/ws", // WebSocketのURL
|
||||
areasCsvUrl: "https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv", // 対象地域CSVファイルのURL
|
||||
maxScaleMin: 30, // 地震発生の際の最低震度(10-70)
|
||||
},
|
||||
// 天気お知らせ設定
|
||||
weather: {
|
||||
splitCount: 4, // 返信の分割数
|
||||
},
|
||||
|
||||
// 緊急時設定
|
||||
emergency: {
|
||||
function: true, // 緊急時のコンソール表示
|
||||
report: false, // reportコマンド
|
||||
mail: {
|
||||
function: true, // 緊急時のメール送信
|
||||
host: "smtp.example.com", // SMTPサーバー
|
||||
port: 465, // SMTPポート
|
||||
user: "mailUser@example.com", // BOTメール送信元
|
||||
password: "mailPassword", // SMTPパスワード
|
||||
secure: false, // SMTPsecure設定
|
||||
to: "admin@noticeuwuzu.example.com", // 緊急時メール送信先(配列可)
|
||||
},
|
||||
},
|
||||
// 規約等
|
||||
legal: {
|
||||
terms: `
|
||||
`, // 利用規約
|
||||
privacy: `
|
||||
`, // プライバシーポリシー
|
||||
},
|
||||
// 管理者情報設定
|
||||
admin: {
|
||||
name: "あどみん", // BOT管理者名
|
||||
showMail: true, // メールアドレスを公開するか(emergency.mail.toが使用されます)
|
||||
},
|
||||
// uwuzuサーバー設定
|
||||
uwuzu: {
|
||||
apiToken: "TOKEN_EXAMPLE", // APIトークン
|
||||
clientToken: "TOKEN_EXAMPLE", // クライアントトークン(任意)
|
||||
host: "uwuzu.example.com", // サーバーホスト(HTTPSである必要があります)
|
||||
},
|
||||
};
|
||||
|
||||
export default config;
|
||||
-166
@@ -1,166 +0,0 @@
|
||||
地震情報サーバーに接続します
|
||||
P2P地震情報に接続中
|
||||
サーバーが起動しました
|
||||
P2P地震情報に接続しました
|
||||
受信したメッセージ: {
|
||||
_id: '6862177ac5875700073d7010',
|
||||
areas: [
|
||||
{ id: 900, peer: 211 }, { id: 250, peer: 266 }, { id: 70, peer: 4 },
|
||||
{ id: 905, peer: 13 }, { id: 150, peer: 16 }, { id: 460, peer: 48 },
|
||||
{ id: 125, peer: 19 }, { id: 601, peer: 8 }, { id: 275, peer: 28 },
|
||||
{ id: 231, peer: 69 }, { id: 205, peer: 15 }, { id: 405, peer: 14 },
|
||||
{ id: 411, peer: 12 }, { id: 425, peer: 60 }, { id: 416, peer: 11 },
|
||||
{ id: 570, peer: 1 }, { id: 301, peer: 5 }, { id: 351, peer: 8 },
|
||||
{ id: 410, peer: 5 }, { id: 270, peer: 122 }, { id: 225, peer: 26 },
|
||||
{ id: 475, peer: 33 }, { id: 130, peer: 14 }, { id: 455, peer: 14 },
|
||||
{ id: 430, peer: 15 }, { id: 230, peer: 15 }, { id: 420, peer: 14 },
|
||||
{ id: 241, peer: 60 }, { id: 215, peer: 14 }, { id: 115, peer: 13 },
|
||||
{ id: 560, peer: 12 }, { id: 665, peer: 14 }, { id: 465, peer: 23 },
|
||||
{ id: 550, peer: 4 }, { id: 240, peer: 8 }, { id: 105, peer: 7 },
|
||||
{ id: 525, peer: 15 }, { id: 210, peer: 3 }, { id: 310, peer: 4 },
|
||||
{ id: 620, peer: 2 }, { id: 100, peer: 14 }, { id: 575, peer: 4 },
|
||||
{ id: 315, peer: 4 }, { id: 480, peer: 6 }, { id: 300, peer: 6 },
|
||||
{ id: 200, peer: 6 }, { id: 641, peer: 3 }, { id: 302, peer: 10 },
|
||||
{ id: 705, peer: 2 }, { id: 625, peer: 2 }, { id: 535, peer: 20 },
|
||||
{ id: 415, peer: 17 }, { id: 515, peer: 3 }, { id: 651, peer: 6 },
|
||||
{ id: 10, peer: 26 }, { id: 55, peer: 9 }, { id: 701, peer: 7 },
|
||||
{ id: 20, peer: 2 }, { id: 345, peer: 3 }, { id: 335, peer: 1 },
|
||||
{ id: 545, peer: 5 }, { id: 325, peer: 10 }, { id: 45, peer: 1 },
|
||||
{ id: 350, peer: 4 }, { id: 901, peer: 2 }, { id: 600, peer: 14 },
|
||||
{ id: 151, peer: 3 }, { id: 670, peer: 4 }, { id: 581, peer: 5 },
|
||||
{ id: 330, peer: 4 }, { id: 355, peer: 7 }, { id: 135, peer: 7 },
|
||||
{ id: 152, peer: 5 }, { id: 242, peer: 4 }, { id: 440, peer: 1 },
|
||||
{ id: 120, peer: 15 }, { id: 646, peer: 2 }, { id: 65, peer: 8 },
|
||||
{ id: 60, peer: 1 }, { id: 35, peer: 2 }, { id: 320, peer: 6 },
|
||||
{ id: 110, peer: 2 }, { id: 220, peer: 1 }, { id: 400, peer: 2 },
|
||||
{ id: 656, peer: 1 }, { id: 530, peer: 2 }, { id: 50, peer: 3 },
|
||||
{ id: 490, peer: 8 }, { id: 605, peer: 5 }, { id: 645, peer: 1 },
|
||||
{ id: 541, peer: 2 }, { id: 450, peer: 1 }, { id: 675, peer: 2 },
|
||||
{ id: 142, peer: 9 }, { id: 685, peer: 1 }, { id: 576, peer: 1 },
|
||||
{ id: 30, peer: 2 }, { id: 15, peer: 3 }, { id: 615, peer: 2 },
|
||||
{ id: 305, peer: 1 },
|
||||
... 13 more items
|
||||
],
|
||||
code: 555,
|
||||
created_at: '2025/06/30 13:50:02.640',
|
||||
expire: '2025/06/30 13:55:02',
|
||||
hop: 4,
|
||||
time: '2025/06/30 13:50:02.634',
|
||||
uid: '2025/06/30 13:55:02',
|
||||
ver: '20150406'
|
||||
}
|
||||
震度情報を受信しました
|
||||
{"_id":"6862177ac5875700073d7010","areas":[{"id":900,"peer":211},{"id":250,"peer":266},{"id":70,"peer":4},{"id":905,"peer":13},{"id":150,"peer":16},{"id":460,"peer":48},{"id":125,"peer":19},{"id":601,"peer":8},{"id":275,"peer":28},{"id":231,"peer":69},{"id":205,"peer":15},{"id":405,"peer":14},{"id":411,"peer":12},{"id":425,"peer":60},{"id":416,"peer":11},{"id":570,"peer":1},{"id":301,"peer":5},{"id":351,"peer":8},{"id":410,"peer":5},{"id":270,"peer":122},{"id":225,"peer":26},{"id":475,"peer":33},{"id":130,"peer":14},{"id":455,"peer":14},{"id":430,"peer":15},{"id":230,"peer":15},{"id":420,"peer":14},{"id":241,"peer":60},{"id":215,"peer":14},{"id":115,"peer":13},{"id":560,"peer":12},{"id":665,"peer":14},{"id":465,"peer":23},{"id":550,"peer":4},{"id":240,"peer":8},{"id":105,"peer":7},{"id":525,"peer":15},{"id":210,"peer":3},{"id":310,"peer":4},{"id":620,"peer":2},{"id":100,"peer":14},{"id":575,"peer":4},{"id":315,"peer":4},{"id":480,"peer":6},{"id":300,"peer":6},{"id":200,"peer":6},{"id":641,"peer":3},{"id":302,"peer":10},{"id":705,"peer":2},{"id":625,"peer":2},{"id":535,"peer":20},{"id":415,"peer":17},{"id":515,"peer":3},{"id":651,"peer":6},{"id":10,"peer":26},{"id":55,"peer":9},{"id":701,"peer":7},{"id":20,"peer":2},{"id":345,"peer":3},{"id":335,"peer":1},{"id":545,"peer":5},{"id":325,"peer":10},{"id":45,"peer":1},{"id":350,"peer":4},{"id":901,"peer":2},{"id":600,"peer":14},{"id":151,"peer":3},{"id":670,"peer":4},{"id":581,"peer":5},{"id":330,"peer":4},{"id":355,"peer":7},{"id":135,"peer":7},{"id":152,"peer":5},{"id":242,"peer":4},{"id":440,"peer":1},{"id":120,"peer":15},{"id":646,"peer":2},{"id":65,"peer":8},{"id":60,"peer":1},{"id":35,"peer":2},{"id":320,"peer":6},{"id":110,"peer":2},{"id":220,"peer":1},{"id":400,"peer":2},{"id":656,"peer":1},{"id":530,"peer":2},{"id":50,"peer":3},{"id":490,"peer":8},{"id":605,"peer":5},{"id":645,"peer":1},{"id":541,"peer":2},{"id":450,"peer":1},{"id":675,"peer":2},{"id":142,"peer":9},{"id":685,"peer":1},{"id":576,"peer":1},{"id":30,"peer":2},{"id":15,"peer":3},{"id":615,"peer":2},{"id":305,"peer":1},{"id":580,"peer":1},{"id":706,"peer":1},{"id":140,"peer":1},{"id":445,"peer":4},{"id":143,"peer":3},{"id":650,"peer":1},{"id":25,"peer":2},{"id":340,"peer":1},{"id":660,"peer":2},{"id":510,"peer":1},{"id":470,"peer":1},{"id":661,"peer":1},{"id":265,"peer":1}],"code":555,"created_at":"2025/06/30 13:50:02.640","expire":"2025/06/30 13:55:02","hop":4,"time":"2025/06/30 13:50:02.634","uid":"2025/06/30 13:55:02","ver":"20150406"}
|
||||
=== 地震速報検知 ===
|
||||
時刻: 2025/06/30 13:50:02.634
|
||||
コード: 555
|
||||
対象地域: [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object]
|
||||
📊 震度情報が更新されました
|
||||
受信したメッセージ: {
|
||||
_id: '686217a9c5875700073d7011',
|
||||
areas: [
|
||||
{ id: 10, peer: 26 }, { id: 15, peer: 3 }, { id: 20, peer: 2 },
|
||||
{ id: 25, peer: 2 }, { id: 30, peer: 2 }, { id: 35, peer: 2 },
|
||||
{ id: 45, peer: 1 }, { id: 50, peer: 3 }, { id: 55, peer: 9 },
|
||||
{ id: 60, peer: 1 }, { id: 65, peer: 9 }, { id: 70, peer: 4 },
|
||||
{ id: 100, peer: 14 }, { id: 105, peer: 7 }, { id: 110, peer: 2 },
|
||||
{ id: 115, peer: 13 }, { id: 120, peer: 15 }, { id: 125, peer: 19 },
|
||||
{ id: 130, peer: 14 }, { id: 135, peer: 7 }, { id: 140, peer: 1 },
|
||||
{ id: 142, peer: 9 }, { id: 143, peer: 3 }, { id: 150, peer: 16 },
|
||||
{ id: 151, peer: 3 }, { id: 152, peer: 5 }, { id: 200, peer: 6 },
|
||||
{ id: 205, peer: 15 }, { id: 210, peer: 3 }, { id: 215, peer: 14 },
|
||||
{ id: 220, peer: 1 }, { id: 225, peer: 26 }, { id: 230, peer: 15 },
|
||||
{ id: 231, peer: 69 }, { id: 240, peer: 8 }, { id: 241, peer: 60 },
|
||||
{ id: 242, peer: 4 }, { id: 250, peer: 267 }, { id: 265, peer: 1 },
|
||||
{ id: 270, peer: 122 }, { id: 275, peer: 28 }, { id: 300, peer: 6 },
|
||||
{ id: 301, peer: 5 }, { id: 302, peer: 10 }, { id: 305, peer: 1 },
|
||||
{ id: 310, peer: 4 }, { id: 315, peer: 4 }, { id: 320, peer: 5 },
|
||||
{ id: 325, peer: 10 }, { id: 330, peer: 4 }, { id: 335, peer: 1 },
|
||||
{ id: 340, peer: 1 }, { id: 345, peer: 3 }, { id: 350, peer: 4 },
|
||||
{ id: 351, peer: 8 }, { id: 355, peer: 7 }, { id: 400, peer: 2 },
|
||||
{ id: 405, peer: 14 }, { id: 410, peer: 5 }, { id: 411, peer: 12 },
|
||||
{ id: 415, peer: 17 }, { id: 416, peer: 11 }, { id: 420, peer: 14 },
|
||||
{ id: 425, peer: 61 }, { id: 430, peer: 15 }, { id: 440, peer: 1 },
|
||||
{ id: 445, peer: 4 }, { id: 450, peer: 1 }, { id: 455, peer: 14 },
|
||||
{ id: 460, peer: 48 }, { id: 465, peer: 23 }, { id: 470, peer: 1 },
|
||||
{ id: 475, peer: 32 }, { id: 480, peer: 6 }, { id: 490, peer: 8 },
|
||||
{ id: 510, peer: 1 }, { id: 515, peer: 3 }, { id: 525, peer: 15 },
|
||||
{ id: 530, peer: 2 }, { id: 535, peer: 20 }, { id: 541, peer: 2 },
|
||||
{ id: 545, peer: 5 }, { id: 550, peer: 4 }, { id: 560, peer: 12 },
|
||||
{ id: 570, peer: 1 }, { id: 575, peer: 4 }, { id: 576, peer: 1 },
|
||||
{ id: 580, peer: 1 }, { id: 581, peer: 5 }, { id: 600, peer: 14 },
|
||||
{ id: 601, peer: 8 }, { id: 605, peer: 5 }, { id: 615, peer: 2 },
|
||||
{ id: 620, peer: 2 }, { id: 625, peer: 2 }, { id: 641, peer: 3 },
|
||||
{ id: 645, peer: 1 }, { id: 646, peer: 2 }, { id: 650, peer: 1 },
|
||||
{ id: 651, peer: 6 },
|
||||
... 13 more items
|
||||
],
|
||||
code: 555,
|
||||
created_at: '2025/06/30 13:50:49.437',
|
||||
expire: '2025/06/30 13:53:48',
|
||||
hop: 11,
|
||||
time: '2025/06/30 13:50:49.434',
|
||||
uid: '2025/06/30 13:53:48',
|
||||
ver: '20150406'
|
||||
}
|
||||
震度情報を受信しました
|
||||
{"_id":"686217a9c5875700073d7011","areas":[{"id":10,"peer":26},{"id":15,"peer":3},{"id":20,"peer":2},{"id":25,"peer":2},{"id":30,"peer":2},{"id":35,"peer":2},{"id":45,"peer":1},{"id":50,"peer":3},{"id":55,"peer":9},{"id":60,"peer":1},{"id":65,"peer":9},{"id":70,"peer":4},{"id":100,"peer":14},{"id":105,"peer":7},{"id":110,"peer":2},{"id":115,"peer":13},{"id":120,"peer":15},{"id":125,"peer":19},{"id":130,"peer":14},{"id":135,"peer":7},{"id":140,"peer":1},{"id":142,"peer":9},{"id":143,"peer":3},{"id":150,"peer":16},{"id":151,"peer":3},{"id":152,"peer":5},{"id":200,"peer":6},{"id":205,"peer":15},{"id":210,"peer":3},{"id":215,"peer":14},{"id":220,"peer":1},{"id":225,"peer":26},{"id":230,"peer":15},{"id":231,"peer":69},{"id":240,"peer":8},{"id":241,"peer":60},{"id":242,"peer":4},{"id":250,"peer":267},{"id":265,"peer":1},{"id":270,"peer":122},{"id":275,"peer":28},{"id":300,"peer":6},{"id":301,"peer":5},{"id":302,"peer":10},{"id":305,"peer":1},{"id":310,"peer":4},{"id":315,"peer":4},{"id":320,"peer":5},{"id":325,"peer":10},{"id":330,"peer":4},{"id":335,"peer":1},{"id":340,"peer":1},{"id":345,"peer":3},{"id":350,"peer":4},{"id":351,"peer":8},{"id":355,"peer":7},{"id":400,"peer":2},{"id":405,"peer":14},{"id":410,"peer":5},{"id":411,"peer":12},{"id":415,"peer":17},{"id":416,"peer":11},{"id":420,"peer":14},{"id":425,"peer":61},{"id":430,"peer":15},{"id":440,"peer":1},{"id":445,"peer":4},{"id":450,"peer":1},{"id":455,"peer":14},{"id":460,"peer":48},{"id":465,"peer":23},{"id":470,"peer":1},{"id":475,"peer":32},{"id":480,"peer":6},{"id":490,"peer":8},{"id":510,"peer":1},{"id":515,"peer":3},{"id":525,"peer":15},{"id":530,"peer":2},{"id":535,"peer":20},{"id":541,"peer":2},{"id":545,"peer":5},{"id":550,"peer":4},{"id":560,"peer":12},{"id":570,"peer":1},{"id":575,"peer":4},{"id":576,"peer":1},{"id":580,"peer":1},{"id":581,"peer":5},{"id":600,"peer":14},{"id":601,"peer":8},{"id":605,"peer":5},{"id":615,"peer":2},{"id":620,"peer":2},{"id":625,"peer":2},{"id":641,"peer":3},{"id":645,"peer":1},{"id":646,"peer":2},{"id":650,"peer":1},{"id":651,"peer":6},{"id":656,"peer":1},{"id":660,"peer":2},{"id":661,"peer":1},{"id":665,"peer":14},{"id":670,"peer":4},{"id":675,"peer":2},{"id":685,"peer":1},{"id":701,"peer":7},{"id":705,"peer":2},{"id":706,"peer":1},{"id":900,"peer":211},{"id":901,"peer":2},{"id":905,"peer":13}],"code":555,"created_at":"2025/06/30 13:50:49.437","expire":"2025/06/30 13:53:48","hop":11,"time":"2025/06/30 13:50:49.434","uid":"2025/06/30 13:53:48","ver":"20150406"}
|
||||
=== 地震速報検知 ===
|
||||
時刻: 2025/06/30 13:50:49.434
|
||||
コード: 555
|
||||
対象地域: [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object]
|
||||
📊 震度情報が更新されました
|
||||
受信したメッセージ: {
|
||||
_id: '68621858c5875700073d7012',
|
||||
areas: [
|
||||
{ id: 10, peer: 26 }, { id: 15, peer: 3 }, { id: 20, peer: 2 },
|
||||
{ id: 25, peer: 2 }, { id: 30, peer: 2 }, { id: 35, peer: 2 },
|
||||
{ id: 45, peer: 1 }, { id: 50, peer: 3 }, { id: 55, peer: 9 },
|
||||
{ id: 60, peer: 1 }, { id: 65, peer: 9 }, { id: 70, peer: 4 },
|
||||
{ id: 100, peer: 13 }, { id: 105, peer: 7 }, { id: 110, peer: 2 },
|
||||
{ id: 115, peer: 13 }, { id: 120, peer: 15 }, { id: 125, peer: 19 },
|
||||
{ id: 130, peer: 14 }, { id: 135, peer: 7 }, { id: 140, peer: 1 },
|
||||
{ id: 142, peer: 9 }, { id: 143, peer: 3 }, { id: 150, peer: 16 },
|
||||
{ id: 151, peer: 3 }, { id: 152, peer: 5 }, { id: 200, peer: 6 },
|
||||
{ id: 205, peer: 15 }, { id: 210, peer: 3 }, { id: 215, peer: 14 },
|
||||
{ id: 220, peer: 1 }, { id: 225, peer: 26 }, { id: 230, peer: 15 },
|
||||
{ id: 231, peer: 69 }, { id: 240, peer: 8 }, { id: 241, peer: 60 },
|
||||
{ id: 242, peer: 4 }, { id: 250, peer: 264 }, { id: 265, peer: 1 },
|
||||
{ id: 270, peer: 123 }, { id: 275, peer: 28 }, { id: 300, peer: 5 },
|
||||
{ id: 301, peer: 5 }, { id: 302, peer: 10 }, { id: 305, peer: 1 },
|
||||
{ id: 310, peer: 4 }, { id: 315, peer: 4 }, { id: 320, peer: 5 },
|
||||
{ id: 325, peer: 9 }, { id: 330, peer: 4 }, { id: 335, peer: 1 },
|
||||
{ id: 340, peer: 1 }, { id: 345, peer: 3 }, { id: 350, peer: 4 },
|
||||
{ id: 351, peer: 8 }, { id: 355, peer: 7 }, { id: 400, peer: 2 },
|
||||
{ id: 405, peer: 14 }, { id: 410, peer: 5 }, { id: 411, peer: 12 },
|
||||
{ id: 415, peer: 17 }, { id: 416, peer: 12 }, { id: 420, peer: 14 },
|
||||
{ id: 425, peer: 60 }, { id: 430, peer: 14 }, { id: 440, peer: 1 },
|
||||
{ id: 445, peer: 4 }, { id: 450, peer: 1 }, { id: 455, peer: 14 },
|
||||
{ id: 460, peer: 48 }, { id: 465, peer: 22 }, { id: 470, peer: 1 },
|
||||
{ id: 475, peer: 32 }, { id: 480, peer: 6 }, { id: 490, peer: 8 },
|
||||
{ id: 510, peer: 1 }, { id: 515, peer: 3 }, { id: 525, peer: 15 },
|
||||
{ id: 530, peer: 2 }, { id: 535, peer: 20 }, { id: 541, peer: 2 },
|
||||
{ id: 545, peer: 5 }, { id: 550, peer: 4 }, { id: 560, peer: 12 },
|
||||
{ id: 570, peer: 1 }, { id: 575, peer: 4 }, { id: 576, peer: 1 },
|
||||
{ id: 580, peer: 1 }, { id: 581, peer: 5 }, { id: 600, peer: 14 },
|
||||
{ id: 601, peer: 8 }, { id: 605, peer: 5 }, { id: 615, peer: 2 },
|
||||
{ id: 620, peer: 2 }, { id: 625, peer: 2 }, { id: 641, peer: 3 },
|
||||
{ id: 645, peer: 1 }, { id: 646, peer: 2 }, { id: 650, peer: 1 },
|
||||
{ id: 651, peer: 6 },
|
||||
... 13 more items
|
||||
],
|
||||
code: 555,
|
||||
created_at: '2025/06/30 13:53:44.508',
|
||||
expire: '2025/06/30 13:56:43',
|
||||
hop: 6,
|
||||
time: '2025/06/30 13:53:44.505',
|
||||
uid: '2025/06/30 13:56:43',
|
||||
ver: '20150406'
|
||||
}
|
||||
震度情報を受信しました
|
||||
{"_id":"68621858c5875700073d7012","areas":[{"id":10,"peer":26},{"id":15,"peer":3},{"id":20,"peer":2},{"id":25,"peer":2},{"id":30,"peer":2},{"id":35,"peer":2},{"id":45,"peer":1},{"id":50,"peer":3},{"id":55,"peer":9},{"id":60,"peer":1},{"id":65,"peer":9},{"id":70,"peer":4},{"id":100,"peer":13},{"id":105,"peer":7},{"id":110,"peer":2},{"id":115,"peer":13},{"id":120,"peer":15},{"id":125,"peer":19},{"id":130,"peer":14},{"id":135,"peer":7},{"id":140,"peer":1},{"id":142,"peer":9},{"id":143,"peer":3},{"id":150,"peer":16},{"id":151,"peer":3},{"id":152,"peer":5},{"id":200,"peer":6},{"id":205,"peer":15},{"id":210,"peer":3},{"id":215,"peer":14},{"id":220,"peer":1},{"id":225,"peer":26},{"id":230,"peer":15},{"id":231,"peer":69},{"id":240,"peer":8},{"id":241,"peer":60},{"id":242,"peer":4},{"id":250,"peer":264},{"id":265,"peer":1},{"id":270,"peer":123},{"id":275,"peer":28},{"id":300,"peer":5},{"id":301,"peer":5},{"id":302,"peer":10},{"id":305,"peer":1},{"id":310,"peer":4},{"id":315,"peer":4},{"id":320,"peer":5},{"id":325,"peer":9},{"id":330,"peer":4},{"id":335,"peer":1},{"id":340,"peer":1},{"id":345,"peer":3},{"id":350,"peer":4},{"id":351,"peer":8},{"id":355,"peer":7},{"id":400,"peer":2},{"id":405,"peer":14},{"id":410,"peer":5},{"id":411,"peer":12},{"id":415,"peer":17},{"id":416,"peer":12},{"id":420,"peer":14},{"id":425,"peer":60},{"id":430,"peer":14},{"id":440,"peer":1},{"id":445,"peer":4},{"id":450,"peer":1},{"id":455,"peer":14},{"id":460,"peer":48},{"id":465,"peer":22},{"id":470,"peer":1},{"id":475,"peer":32},{"id":480,"peer":6},{"id":490,"peer":8},{"id":510,"peer":1},{"id":515,"peer":3},{"id":525,"peer":15},{"id":530,"peer":2},{"id":535,"peer":20},{"id":541,"peer":2},{"id":545,"peer":5},{"id":550,"peer":4},{"id":560,"peer":12},{"id":570,"peer":1},{"id":575,"peer":4},{"id":576,"peer":1},{"id":580,"peer":1},{"id":581,"peer":5},{"id":600,"peer":14},{"id":601,"peer":8},{"id":605,"peer":5},{"id":615,"peer":2},{"id":620,"peer":2},{"id":625,"peer":2},{"id":641,"peer":3},{"id":645,"peer":1},{"id":646,"peer":2},{"id":650,"peer":1},{"id":651,"peer":6},{"id":656,"peer":1},{"id":660,"peer":2},{"id":661,"peer":1},{"id":665,"peer":14},{"id":670,"peer":4},{"id":675,"peer":2},{"id":685,"peer":1},{"id":701,"peer":7},{"id":705,"peer":2},{"id":706,"peer":1},{"id":900,"peer":211},{"id":901,"peer":2},{"id":905,"peer":12}],"code":555,"created_at":"2025/06/30 13:53:44.508","expire":"2025/06/30 13:56:43","hop":6,"time":"2025/06/30 13:53:44.505","uid":"2025/06/30 13:56:43","ver":"20150406"}
|
||||
=== 地震速報検知 ===
|
||||
時刻: 2025/06/30 13:53:44.505
|
||||
コード: 555
|
||||
対象地域: [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object], [object Object]
|
||||
📊 震度情報が更新されました
|
||||
@@ -0,0 +1,2 @@
|
||||
*
|
||||
!.gitignore
|
||||
@@ -1,24 +1,47 @@
|
||||
// 起動チェック
|
||||
import Check from "./checks/main.js";
|
||||
(async () => {
|
||||
await Check();
|
||||
})();
|
||||
|
||||
// 定期実行読み込み
|
||||
import * as cron from "node-cron";
|
||||
|
||||
// 機能読み込み
|
||||
import timeNotice from "./scripts/timeNotice.js";
|
||||
import weatherNotice from "./scripts/weatherNotice.js";
|
||||
import earthquakeNotice from "./scripts/earthquakeNotice.js"
|
||||
import { weatherNotice } from "./scripts/weatherNotice.js";
|
||||
import earthquakeNotice from "./scripts/earthquakeNotice.js";
|
||||
import birthdayNotice from "./scripts/birthdayNotice.js";
|
||||
import Commands from "./scripts/commands/main.js";
|
||||
import BirthdayDataSet from "./scripts/birthdayDataSet.js";
|
||||
|
||||
import followBack from "./scripts/followBack.js";
|
||||
// その他機能
|
||||
import asciiArt from "./scripts/asciiart.js";
|
||||
asciiArt();
|
||||
import successExit from "./scripts/successExit.js";
|
||||
successExit();
|
||||
BirthdayDataSet();
|
||||
|
||||
// 地震情報観測開始
|
||||
earthquakeNotice();
|
||||
|
||||
// 時報・フォローバック(毎時)
|
||||
// 時報(1時間/1回)
|
||||
cron.schedule("0 * * * *", () => {
|
||||
timeNotice();
|
||||
followBack();
|
||||
});
|
||||
|
||||
// コマンド(10分/1回)
|
||||
cron.schedule('*/10 * * * *', () => {
|
||||
Commands();
|
||||
});
|
||||
|
||||
// 天気お知らせ(毎日7:00)
|
||||
cron.schedule("0 7 * * *", () => {
|
||||
setTimeout(() => {
|
||||
weatherNotice();
|
||||
}, 100)
|
||||
birthdayNotice();
|
||||
}, 100);
|
||||
});
|
||||
|
||||
console.log("サーバーが起動しました");
|
||||
// 起動表示
|
||||
console.log("BOTサーバーが起動しました");
|
||||
|
||||
+26
-11
@@ -1,41 +1,56 @@
|
||||
{
|
||||
"name": "noticeuwuzu",
|
||||
"version": "v3.0@uwuzu1.5.4",
|
||||
"description": "uwuzu Notice Bot",
|
||||
"name": "notice-uwuzu",
|
||||
"version": "v7.3@uwuzu1.5.4",
|
||||
"tag": "v7.3",
|
||||
"description": "Notice Bot for uwuzu",
|
||||
"main": "dist/main.js",
|
||||
"scripts": {
|
||||
"start": "node .",
|
||||
"build": "tsc",
|
||||
"dev": "tsx main.ts"
|
||||
"main": "tsc && node .",
|
||||
"dev": "tsx main.ts",
|
||||
"clean": "tsc && node dist/scripts/clean/main.js"
|
||||
},
|
||||
"repository": {
|
||||
"type": "git",
|
||||
"url": "https://gitea.last2014.com/last2014/noticeUwuzu"
|
||||
},
|
||||
"keywords": [
|
||||
"uwuzu",
|
||||
"bot",
|
||||
"cron",
|
||||
"notice",
|
||||
"mail",
|
||||
"weather",
|
||||
"time",
|
||||
"timenotice",
|
||||
"notice"
|
||||
"earthquake",
|
||||
"command",
|
||||
"commands"
|
||||
],
|
||||
"author": {
|
||||
"name": "Last2014",
|
||||
"url": "https://last2014.com",
|
||||
"email": "info@last2014.com"
|
||||
},
|
||||
"license": "ISC",
|
||||
"contributors": [],
|
||||
"license": "Apache-2.0",
|
||||
"type": "module",
|
||||
"dependencies": {
|
||||
"@types/date-fns": "^2.5.3",
|
||||
"@types/dotenv": "^6.1.1",
|
||||
"@types/node": "^24.0.7",
|
||||
"@types/node-cron": "^3.0.11",
|
||||
"@types/nodemailer": "^6.4.17",
|
||||
"@types/ws": "^8.18.1",
|
||||
"child_process": "^1.0.2",
|
||||
"date-fns": "^4.1.0",
|
||||
"dotenv": "^17.0.0",
|
||||
"fs": "^0.0.1-security",
|
||||
"node-cron": "^4.1.1",
|
||||
"tsx": "^4.20.3",
|
||||
"nodemailer": "^7.0.4",
|
||||
"typescript": "^5.8.3",
|
||||
"ws": "^8.18.3"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/node": "^24.0.7",
|
||||
"@types/ws": "^8.18.1"
|
||||
"tsx": "^4.20.3"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,8 @@
|
||||
import * as fs from "fs";
|
||||
|
||||
const version = JSON.parse(fs.readFileSync("package.json", "utf-8")).version;
|
||||
|
||||
export default function asciiArt() {
|
||||
console.log(fs.readFileSync("asciiart.txt", "utf-8").replace(/(\r?\n)$/, ''));
|
||||
console.log(`${version}\n`);
|
||||
}
|
||||
@@ -0,0 +1,14 @@
|
||||
import { existsSync, writeFileSync } from "fs";
|
||||
|
||||
const initialData = {} as
|
||||
{ [key: string]: string | undefined };
|
||||
|
||||
export default function BirthdayDataSet() {
|
||||
if (!existsSync("data/birthdays.json")) {
|
||||
writeFileSync(
|
||||
"data/birthdays.json",
|
||||
JSON.stringify(initialData),
|
||||
"utf-8",
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,56 @@
|
||||
import { readFileSync } from "fs";
|
||||
import { isSameDay, format, differenceInYears } from "date-fns/fp";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function birthdayNotice() {
|
||||
// 読み込み
|
||||
const birthdays: { [key: string]: string | undefined } =
|
||||
JSON.parse(readFileSync("data/birthdays.json", "utf-8"));
|
||||
|
||||
// 配列化
|
||||
const birthdaysIndex: string[] = Object.entries(birthdays)
|
||||
.map(([key, value]) => value)
|
||||
.filter(value => value !== undefined) as string[];
|
||||
|
||||
// 初期値
|
||||
const resultInitial: string = `
|
||||
【今日誕生日の人】\n`;
|
||||
|
||||
let result = resultInitial;
|
||||
|
||||
for (let i = 0; i < Object.keys(birthdays).length; i++) {
|
||||
const birthday = format(birthdaysIndex[i], "yyyy/MM/dd")
|
||||
|
||||
if (isSameDay(birthday, new Date())) {
|
||||
const age = differenceInYears(new Date(), birthday);
|
||||
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/users/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
userid: Object.keys(birthdays)[i],
|
||||
}),
|
||||
});
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
result+= `${res.username}さん(${age}歳)\n`
|
||||
}
|
||||
}
|
||||
|
||||
if (result === resultInitial) {
|
||||
return;
|
||||
}
|
||||
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: result,
|
||||
}),
|
||||
});
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
console.log("誕生日お知らせ:", res);
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
import { unlinkSync } from "fs";
|
||||
|
||||
export default function logsDelete() {
|
||||
console.log("ログを削除中します");
|
||||
|
||||
try {
|
||||
unlinkSync("logs/boot.json");
|
||||
unlinkSync("logs/version.txt");
|
||||
|
||||
console.log("ログファイルを削除しました");
|
||||
console.log("----------------");
|
||||
} catch (err) {
|
||||
console.log("ログファイルの削除中にエラーが発生しました:\n", err);
|
||||
process.exit();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,7 @@
|
||||
import logsDelete from "./logsDel.js";
|
||||
import packageLockJsonDelete from "./packageLockDel.js";
|
||||
import npmInstall from "./npmInstall.js";
|
||||
|
||||
logsDelete();
|
||||
packageLockJsonDelete();
|
||||
npmInstall();
|
||||
@@ -0,0 +1,23 @@
|
||||
import { execSync } from "child_process";
|
||||
|
||||
export default function npmInstall() {
|
||||
// npm install実行
|
||||
console.log("npm installを実行します");
|
||||
|
||||
try {
|
||||
const npmInstall = execSync("npm install");
|
||||
|
||||
console.log("----");
|
||||
console.log("$ npm install");
|
||||
console.log(npmInstall.toString());
|
||||
console.log("----");
|
||||
|
||||
console.log("npm installを実行しました");
|
||||
} catch (err) {
|
||||
console.log("npm installの実行中にエラーが発生しました:\n", err);
|
||||
process.exit();
|
||||
}
|
||||
|
||||
console.log("初期化が完了しました");
|
||||
process.exit();
|
||||
}
|
||||
@@ -0,0 +1,15 @@
|
||||
import { unlinkSync } from "fs";
|
||||
|
||||
export default function packageLockJsonDelete() {
|
||||
console.log("package-lock.jsonを削除します");
|
||||
|
||||
try {
|
||||
unlinkSync("package-lock.json");
|
||||
|
||||
console.log("package-lock.jsonを削除しました");
|
||||
console.log("----------------");
|
||||
} catch (err) {
|
||||
console.log("package-lock.jsonの削除中にエラーが発生しました:\n", err);
|
||||
process.exit();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,88 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { readFileSync, writeFileSync, existsSync } from "fs";
|
||||
import { parse, isValid } from 'date-fns/fp';
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
function normalizedString(Str: string) {
|
||||
return Str.replace(/[\u3000-\u303F]+/g, ' ')
|
||||
.replace(/[\uFF01-\uFF0F]+/g, '0-9')
|
||||
.replace(/[\u3001-\u3002]+/g, '/');
|
||||
}
|
||||
|
||||
function isValidDateString(dateString: string) {
|
||||
const normalizedStr = normalizedString(dateString);
|
||||
|
||||
const regex = /^\d{4}\/\d{2}\/\d{2}$/;
|
||||
if (!regex.test(normalizedStr)) {
|
||||
return false;
|
||||
}
|
||||
|
||||
const parseString = parse(new Date(), 'yyyy/MM/dd');
|
||||
return isValid(parseString(normalizedStr));
|
||||
}
|
||||
|
||||
export default function Birthday(data: ueuse) {
|
||||
// 読み込み
|
||||
const birthdays: { [key: string]: string | undefined } =
|
||||
JSON.parse(readFileSync("data/birthdays.json", "utf-8"));
|
||||
|
||||
if (
|
||||
(data.abi === "none" ||
|
||||
data.abi === "") &&
|
||||
birthdays[data.account.userid] === undefined
|
||||
) {
|
||||
Reply(`
|
||||
追記に誕生日を入力してください
|
||||
(このユーズはもう利用できません。他のユーズで\`/birthday\`をまたご利用ください。)
|
||||
`, data.uniqid);
|
||||
return;
|
||||
}
|
||||
|
||||
if (
|
||||
data.abi === "delete" &&
|
||||
birthdays[data.account.userid] !== undefined
|
||||
) {
|
||||
birthdays[data.account.userid] = undefined;
|
||||
writeFileSync(
|
||||
"data/birthdays.json",
|
||||
JSON.stringify(birthdays),
|
||||
"utf-8",
|
||||
);
|
||||
|
||||
Reply(`
|
||||
誕生日のデータを削除しました
|
||||
`, data.uniqid);
|
||||
return;
|
||||
}
|
||||
|
||||
if (
|
||||
data.abi === "delete" &&
|
||||
birthdays[data.account.userid] === undefined
|
||||
) {
|
||||
Reply(`
|
||||
誕生日のデータが存在しないため削除できません
|
||||
`, data.uniqid);
|
||||
return;
|
||||
}
|
||||
|
||||
if (!isValidDateString(data.abi)) {
|
||||
Reply(`
|
||||
誕生日の形式が違います。
|
||||
yyyy/MM/ddの形式で入力してください。
|
||||
スラッシュ・数字は全角での使用が可能です。
|
||||
(このユーズはもう利用できません。他のユーズで\`/birthday\`をまたご利用ください。)
|
||||
`, data.uniqid);
|
||||
return;
|
||||
}
|
||||
|
||||
birthdays[data.account.userid] = normalizedString(data.abi);
|
||||
writeFileSync(
|
||||
"data/birthdays.json",
|
||||
JSON.stringify(birthdays),
|
||||
"utf-8",
|
||||
);
|
||||
|
||||
Reply(`
|
||||
${data.account.username}さんの誕生日を${normalizedString(data.abi)}に設定しました
|
||||
`, data.uniqid);
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import config from "../../config.js";
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
export default async function Follow(data: ueuse) {
|
||||
const followReq = await fetch(`https://${config.uwuzu.host}/api/users/follow`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
userid: data.account.userid,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
const followRes = await followReq.json();
|
||||
|
||||
console.log("フォロー: ", followRes);
|
||||
|
||||
|
||||
const notice = await Reply(`
|
||||
${data.account.username}さんをフォローしました
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("フォロー通知: ", notice);
|
||||
}
|
||||
@@ -0,0 +1,82 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { readFileSync } from "fs";
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
const helpsMin = {
|
||||
"info": "このBOTについての概要を返信するコマンドです。",
|
||||
"help": "コマンドの概要を返信します。追記に\`/\`抜きのコマンド名を入力することでそのコマンドの詳細(フル)を返信します。",
|
||||
"follow": "コマンド送信者をフォローします。",
|
||||
"unfollow": "コマンド送信者をフォロー解除します。",
|
||||
"weather": "天気を返信します。",
|
||||
"report": "運営者に不具合などを報告します。",
|
||||
"birthday": "誕生日を設定・削除できます。",
|
||||
"legal privacy": "プライバシーポリシーを返信します。",
|
||||
} as { [key: string]: string };
|
||||
|
||||
const helpsFull = {
|
||||
"info": `
|
||||
このBOTについての概要を返信するコマンドです。
|
||||
バージョン、開発者などが確認できます。
|
||||
`,
|
||||
"help": `
|
||||
このコマンドです。コマンドの概要を返信します。
|
||||
追記に\`/\`抜きのコマンド名を入力することでそのコマンドの詳細(フル)を返信します。
|
||||
`,
|
||||
"follow": `
|
||||
コマンドを送信したユーザーをフォローします。
|
||||
既にフォローされているユーザーも使用できます。
|
||||
`,
|
||||
"unfollow": `
|
||||
コマンドを送信したユーザーをフォロー解除します。
|
||||
既にフォローされていないユーザーも使用できます。
|
||||
`,
|
||||
"weather": `
|
||||
天気を返信します。
|
||||
毎日7:00の天気を再投稿するわけではなく、
|
||||
再取得して返信します。
|
||||
`,
|
||||
"report": `
|
||||
不具合などを運営者にメールで報告できます。
|
||||
運営者によって有効化されていないと使用できません。
|
||||
\`/report\`を使用してそのユーズの追記に内容を入力することで使用できます。
|
||||
`,
|
||||
"birthday": `
|
||||
誕生日を設定できます。
|
||||
設定された誕生日の7:00に祝われます。
|
||||
追記にyyyy/MM/ddの形式で誕生日を入力することで誕生日を設定できます。
|
||||
また、追記に\`delete\`と入力することで誕生日のデータを削除できます。
|
||||
`,
|
||||
"legal privacy": `
|
||||
プライバシーポリシーを返信します。
|
||||
`,
|
||||
} as { [key: string]: string };
|
||||
|
||||
export default async function Help(data: ueuse) {
|
||||
const packageJson = JSON.parse(readFileSync("package.json", "utf-8"));
|
||||
|
||||
if (
|
||||
data.abi === "none" ||
|
||||
data.abi === ""
|
||||
) {
|
||||
const helpMsg =
|
||||
Object.entries(helpsMin)
|
||||
.map(([command, message]) =>
|
||||
`\`/${command}\`:${message}`
|
||||
).join('\n');
|
||||
|
||||
const ueuse = await Reply(`
|
||||
${helpMsg}
|
||||
BOTの概要は\`/info\`をご利用ください。
|
||||
Wikiを見る:${packageJson.repository.url}/wiki
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("ヘルプ:", ueuse);
|
||||
} else {
|
||||
const ueuse = await Reply(`
|
||||
${helpsFull[data.abi]}
|
||||
機能を見る:${packageJson.repository.url}/wiki
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("ヘルプ:", ueuse);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,70 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { readFileSync } from "fs";
|
||||
import { Reply } from "./main.js";
|
||||
import config from "../../config.js";
|
||||
|
||||
export default async function Info(data: ueuse) {
|
||||
const packageJson = JSON.parse(readFileSync("package.json", "utf-8"));
|
||||
const releaseUrl = `${packageJson.repository.url}/releases/tag/${packageJson.tag}`;
|
||||
|
||||
let editor = "";
|
||||
|
||||
if (packageJson.author.name !== "Last2014") {
|
||||
editor = `\nEdited by ${packageJson.author.name}`;
|
||||
}
|
||||
|
||||
let adminMail;
|
||||
|
||||
if (
|
||||
config.admin.showMail &&
|
||||
config.emergency.mail.to !== undefined
|
||||
) {
|
||||
adminMail = config.emergency.mail.to;
|
||||
} else if (
|
||||
config.admin.showMail &&
|
||||
config.emergency.mail.to === undefined
|
||||
) {
|
||||
adminMail = "未設定";
|
||||
} else {
|
||||
adminMail = "非公開";
|
||||
}
|
||||
|
||||
let isReport;
|
||||
|
||||
if (config.emergency.report) {
|
||||
isReport = "有効";
|
||||
} else {
|
||||
isReport = "無効";
|
||||
}
|
||||
|
||||
const ueuse = await Reply(`
|
||||
【BOTについて】
|
||||
このBOTはオープンソースソフトウェアであるnoticeUwuzuを利用して運営されています。
|
||||
noticeUwuzuはApache License 2.0によって保護されています。
|
||||
ライセンスに違反して使用した場合は著作権法違反となります。
|
||||
バージョン:${packageJson.version}
|
||||
リリース詳細:${releaseUrl}
|
||||
|
||||
【運営者情報】
|
||||
運営者名:${config.admin.name}
|
||||
メールアドレス:${adminMail}
|
||||
報告機能(\`/report\`):${isReport}
|
||||
|
||||
|
||||
【関連コマンド】
|
||||
コマンドのヘルプをお探しですか?
|
||||
\`/help\`をご利用ください。
|
||||
|
||||
運営者へ報告が必要ですか?
|
||||
\`/report\`をご利用ください。
|
||||
|
||||
プライバシーポリシーをお探しですか?
|
||||
\`/legal privacy\`をご利用ください。
|
||||
|
||||
|
||||
【クレジット】
|
||||
Created by Last2014${editor}
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("概要:", ueuse);
|
||||
}
|
||||
@@ -0,0 +1,7 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { Reply } from "../main.js";
|
||||
import config from "../../../config.js";
|
||||
|
||||
export default function PrivacyPolicy(data: ueuse) {
|
||||
Reply(config.legal.privacy, data.uniqid);
|
||||
}
|
||||
@@ -0,0 +1,7 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { Reply } from "../main.js";
|
||||
import config from "../../../config.js";
|
||||
|
||||
export default function Terms(data: ueuse) {
|
||||
Reply(config.legal.terms, data.uniqid);
|
||||
}
|
||||
@@ -0,0 +1,145 @@
|
||||
import * as fs from "fs";
|
||||
import config from "../../config.js";
|
||||
import type { ueuse } from "types/types.js";
|
||||
|
||||
const initialFile: Array<string> = [];
|
||||
|
||||
// コマンド読み込み
|
||||
import Info from "./info.js";
|
||||
import Follow from "./follow.js";
|
||||
import UnFollow from "./unfollow.js";
|
||||
import Weather from "./weather.js";
|
||||
import Help from "./help.js";
|
||||
import Report from "./report.js";
|
||||
import Birthday from "./birthday.js";
|
||||
import Terms from "./legal/terms.js"
|
||||
import PrivacyPolicy from "./legal/privacy.js";
|
||||
|
||||
// 初期化
|
||||
if (!fs.existsSync("logs/alreadyCommands.json")) {
|
||||
fs.writeFileSync(
|
||||
"logs/alreadyCommands.json",
|
||||
JSON.stringify(initialFile),
|
||||
"utf-8",
|
||||
);
|
||||
}
|
||||
|
||||
// 対応済みユーズ一覧
|
||||
const alreadyCommands: Array<string> = JSON.parse(fs.readFileSync("logs/alreadyCommands.json", "utf-8"));
|
||||
|
||||
function cutAfterChar(str: string, char: string) {
|
||||
const index = str.indexOf(char);
|
||||
|
||||
if (index === -1) {
|
||||
return "";
|
||||
}
|
||||
|
||||
return str.substring(index + 1);
|
||||
}
|
||||
|
||||
export async function Reply(text: string, reply: string) {
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: text,
|
||||
replyid: reply,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
function alreadyAdd(data: string) {
|
||||
alreadyCommands[alreadyCommands.length] = data;
|
||||
|
||||
fs.writeFileSync(
|
||||
"logs/alreadyCommands.json",
|
||||
JSON.stringify(alreadyCommands),
|
||||
"utf-8",
|
||||
);
|
||||
}
|
||||
|
||||
export default async function Commands() {
|
||||
const mentionsReq = await fetch(
|
||||
`https://${config.uwuzu.host}/api/ueuse/mentions`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
}),
|
||||
cache: "no-store",
|
||||
}
|
||||
);
|
||||
|
||||
const mentions: Array<ueuse> = await mentionsReq.json();
|
||||
|
||||
console.log("----------------");
|
||||
console.log("コマンド処理");
|
||||
|
||||
for (let i = 0; i < mentions.length; i++) {
|
||||
const data = mentions[i];
|
||||
|
||||
// 除外ユーズ
|
||||
if (alreadyCommands.indexOf(data.uniqid) !== -1) {
|
||||
break;
|
||||
}
|
||||
|
||||
if (
|
||||
data.text.charAt(0) === "!" ||
|
||||
data.text.charAt(0) === "!" ||
|
||||
data.abi === "ignore"
|
||||
) {
|
||||
break;
|
||||
}
|
||||
|
||||
// コマンド処理
|
||||
console.log("--------");
|
||||
|
||||
const commandName = cutAfterChar(data.text, "/");
|
||||
|
||||
alreadyAdd(data.uniqid);
|
||||
|
||||
switch (commandName) {
|
||||
case "":
|
||||
break;
|
||||
case "info":
|
||||
Info(data);
|
||||
break;
|
||||
case "help":
|
||||
Help(data);
|
||||
break;
|
||||
case "legal terms":
|
||||
Terms(data);
|
||||
break;
|
||||
case "legal privacy":
|
||||
PrivacyPolicy(data);
|
||||
break;
|
||||
case "report":
|
||||
Report(data);
|
||||
break;
|
||||
case "follow":
|
||||
Follow(data);
|
||||
break;
|
||||
case "unfollow":
|
||||
UnFollow(data);
|
||||
break;
|
||||
case "weather":
|
||||
Weather(data);
|
||||
break;
|
||||
case "birthday":
|
||||
Birthday(data);
|
||||
break;
|
||||
default:
|
||||
const reply = await Reply(`
|
||||
不明なコマンドです。
|
||||
コマンド実行を除外する場合は1文字目に\`!\`を入れてください。
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("未対応コマンド: ", reply);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,65 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import { Reply } from "./main.js";
|
||||
import config from "../../config.js";
|
||||
import sendMail from "../../src/mailer.js";
|
||||
|
||||
export default async function Report(data: ueuse) {
|
||||
if (
|
||||
data.abi === "none" ||
|
||||
data.abi === ""
|
||||
) {
|
||||
console.log("報告(内容なし):", await Reply(`
|
||||
追記に内容を記入してください。
|
||||
(このユーズはもう利用できません。他のユーズで\`/report\`をまたご利用ください。)
|
||||
`, data.uniqid));
|
||||
return;
|
||||
}
|
||||
|
||||
if (!config.emergency.mail.function) {
|
||||
console.log("報告(メールオフ):", await Reply(`
|
||||
BOTの運営者によってメール送信機能が無効化されています。
|
||||
そのため報告機能はご利用いただけません。
|
||||
`, data.uniqid));
|
||||
return;
|
||||
}
|
||||
|
||||
if (!config.emergency.report) {
|
||||
console.log("報告(機能オフ):", await Reply(`
|
||||
BOTの運営者によって報告機能が無効化されています。
|
||||
そのため報告機能はご利用いただけません。
|
||||
`, data.uniqid));
|
||||
return;
|
||||
}
|
||||
|
||||
try {
|
||||
sendMail({
|
||||
to: config.emergency.mail.to,
|
||||
subject: "【報告】BOT利用者からの報告",
|
||||
text: `
|
||||
※noticeUwuzu自動送信によるメールです
|
||||
【報告】
|
||||
BOT管理者さん、noticeUwuzu自動送信メールです。
|
||||
@${data.account.userid}@${config.uwuzu.host}から/reportコマンドを利用した報告がありました。
|
||||
報告元ユーズ:https://${config.uwuzu.host}/!${data.uniqid}
|
||||
下記が内容となります。
|
||||
${data.abi}
|
||||
`,
|
||||
});
|
||||
|
||||
console.log("報告(完了):", await Reply(`
|
||||
報告が完了しました。
|
||||
運営者は報告者、ユーズのURL、内容を確認できます。
|
||||
場合によっては運営者、BOTからブロックされる可能性があります。
|
||||
`, data.uniqid));
|
||||
|
||||
return;
|
||||
} catch (err) {
|
||||
console.log("/reportエラー:", err);
|
||||
|
||||
console.log("報告(エラー):", await Reply(`
|
||||
報告に失敗しました。
|
||||
`, data.uniqid));
|
||||
|
||||
return;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,25 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import config from "../../config.js";
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
export default async function UnFollow(data: ueuse) {
|
||||
const unfollowReq = await fetch(`https://${config.uwuzu.host}/api/users/unfollow`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
userid: data.account.userid,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
const unfollowRes = await unfollowReq.json();
|
||||
|
||||
console.log("フォロー解除: ", unfollowRes);
|
||||
|
||||
|
||||
const notice = await Reply(`
|
||||
${data.account.username}さんをフォロー解除しました
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("フォロー解除通知: ", notice);
|
||||
}
|
||||
@@ -0,0 +1,6 @@
|
||||
import { weatherReply } from "../weatherNotice.js";
|
||||
import { ueuse } from "types/types.js";
|
||||
|
||||
export default function Weather(data: ueuse) {
|
||||
weatherReply(data.uniqid);
|
||||
}
|
||||
+347
-95
@@ -1,11 +1,11 @@
|
||||
import WebSocket from "ws";
|
||||
import * as dotenv from "dotenv";
|
||||
import sendMail from "../src/mailer.js";
|
||||
|
||||
dotenv.config();
|
||||
import config from "../config.js";
|
||||
|
||||
class P2PEarthquakeClient {
|
||||
private ws: WebSocket | null = null;
|
||||
private reconnectInterval: number = 5000;
|
||||
private reconnectInterval: number = config.earthquake.reconnectTimes;
|
||||
private reconnectTimer: NodeJS.Timeout | null = null;
|
||||
private isConnecting: boolean = false;
|
||||
|
||||
@@ -18,13 +18,13 @@ class P2PEarthquakeClient {
|
||||
if (this.isConnecting) return;
|
||||
|
||||
this.isConnecting = true;
|
||||
console.log("P2P地震情報に接続中");
|
||||
console.log("地震情報サーバーに接続中");
|
||||
|
||||
try {
|
||||
this.ws = new WebSocket("wss://api.p2pquake.net/v2/ws");
|
||||
this.ws = new WebSocket(config.earthquake.websocketUrl);
|
||||
|
||||
this.ws.on("open", () => {
|
||||
console.log("P2P地震情報に接続しました");
|
||||
console.log("地震情報サーバーに接続しました");
|
||||
this.isConnecting = false;
|
||||
|
||||
if (this.reconnectTimer) {
|
||||
@@ -37,13 +37,13 @@ class P2PEarthquakeClient {
|
||||
try {
|
||||
const message = JSON.parse(data.toString());
|
||||
this.handleMessage(message);
|
||||
} catch (error) {
|
||||
console.error("メッセージのパースに失敗:", error);
|
||||
} catch (err) {
|
||||
console.error(`メッセージのパースでエラーが発生: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
this.ws.on("close", (code: number, reason: Buffer) => {
|
||||
console.log(`接続が閉じられました: ${code} - ${reason.toString()}`);
|
||||
console.log(`切断されました: ${code} - ${reason.toString()}`);
|
||||
this.isConnecting = false;
|
||||
this.scheduleReconnect();
|
||||
});
|
||||
@@ -61,33 +61,28 @@ class P2PEarthquakeClient {
|
||||
}
|
||||
|
||||
private handleMessage(message: any): void {
|
||||
switch (message.code) {
|
||||
case 551: // 地震情報
|
||||
console.log("地震情報を受信しました");
|
||||
this.executeEventFunc(message);
|
||||
break;
|
||||
case 554: // 緊急地震速報
|
||||
console.log("緊急地震速報を受信しました");
|
||||
this.executeEventFunc(message);
|
||||
break;
|
||||
case 555: // 震度情報
|
||||
console.log("震度情報を受信しました");
|
||||
this.executeEventFunc(message);
|
||||
break;
|
||||
default:
|
||||
console.log(`その他の情報 (コード: ${message.code})`);
|
||||
break;
|
||||
}
|
||||
}
|
||||
console.log("----------------");
|
||||
|
||||
private executeEventFunc(earthquakeInfo: any): void {
|
||||
event(earthquakeInfo);
|
||||
const supportCode: Array<number> = [
|
||||
551,
|
||||
552,
|
||||
556,
|
||||
];
|
||||
|
||||
if (supportCode.indexOf(message.code) !== -1) {
|
||||
event(message);
|
||||
} else {
|
||||
console.log(`未対応の情報を受信しました(コード: ${message.code})`);
|
||||
console.log("受信メッセージ:", message);
|
||||
}
|
||||
}
|
||||
|
||||
private scheduleReconnect(): void {
|
||||
if (this.reconnectTimer) return;
|
||||
|
||||
console.log("地震情報サーバーから切断されました");
|
||||
console.log(`${this.reconnectInterval / 1000}秒後に再接続を試みます`);
|
||||
|
||||
this.reconnectTimer = setTimeout(() => {
|
||||
this.reconnectTimer = null;
|
||||
this.connect();
|
||||
@@ -97,7 +92,7 @@ class P2PEarthquakeClient {
|
||||
private setupCleanup(): void {
|
||||
const cleanup = () => {
|
||||
this.stop();
|
||||
process.exit(0);
|
||||
process.exit();
|
||||
};
|
||||
|
||||
process.on("SIGINT", cleanup);
|
||||
@@ -117,11 +112,9 @@ class P2PEarthquakeClient {
|
||||
}
|
||||
}
|
||||
|
||||
// 地名オブジェクトマッピング
|
||||
// 地名マッピング
|
||||
async function areaMap(): Promise<Record<number, string>> {
|
||||
const res = await fetch(
|
||||
"https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv",
|
||||
);
|
||||
const res = await fetch(config.earthquake.areasCsvUrl);
|
||||
|
||||
const text = await res.text();
|
||||
|
||||
@@ -142,112 +135,371 @@ async function areaMap(): Promise<Record<number, string>> {
|
||||
return map;
|
||||
}
|
||||
|
||||
// 地震発生
|
||||
// 情報受信
|
||||
async function event(earthquakeInfo: any): Promise<void> {
|
||||
console.log(JSON.stringify(earthquakeInfo));
|
||||
console.log("受信メッセージ:", earthquakeInfo);
|
||||
// ----処理----
|
||||
|
||||
// 緊急地震速報の場合
|
||||
if (earthquakeInfo.code === 554) {
|
||||
if (earthquakeInfo.code === 556) {
|
||||
console.log("緊急地震速報を受信しました");
|
||||
|
||||
// 地震詳細
|
||||
let descriptionEarthquake: string = "";
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.description !== "" ||
|
||||
earthquakeInfo.earthquake.description !== undefined
|
||||
) {
|
||||
descriptionEarthquake = `この地震について:${earthquakeInfo.earthquake.description}`;
|
||||
}
|
||||
|
||||
// 発令詳細
|
||||
let description: string = "";
|
||||
|
||||
if (
|
||||
earthquakeInfo.comments.freeFormComment !== "" ||
|
||||
earthquakeInfo.comments.freeFormComment !== undefined
|
||||
) {
|
||||
description = `この発令について:${earthquakeInfo.comments.freeFormComment}`;
|
||||
}
|
||||
|
||||
// テスト・訓練
|
||||
let test: string = "";
|
||||
|
||||
if (earthquakeInfo.test !== undefined) {
|
||||
test = "この情報にテスト・訓練かの情報はありません";
|
||||
} else if (earthquakeInfo.test) {
|
||||
test = "これはテスト、あるいは訓練です";
|
||||
} else if (earthquakeInfo.test === false) {
|
||||
test = "これはテスト・訓練ではありません";
|
||||
}
|
||||
|
||||
// 対象地域
|
||||
let areas: string = "";
|
||||
|
||||
if (earthquakeInfo.areas !== undefined) {
|
||||
const areaNames: Array<string> = Array.from(
|
||||
new Set(
|
||||
earthquakeInfo.areas.map((point: any) => point.name).filter(Boolean),
|
||||
),
|
||||
);
|
||||
areas = `対象地域:${areaNames.join("・")}`;
|
||||
}
|
||||
|
||||
// 速報取り消し
|
||||
let cancelled: string = "";
|
||||
|
||||
if (earthquakeInfo.cancelled) {
|
||||
cancelled = "※以下の緊急地震速報が取り消されました※";
|
||||
}
|
||||
|
||||
// マグニチュード
|
||||
let magnitude: string = "マグニチュード:";
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude != -1 ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude === undefined
|
||||
) {
|
||||
magnitude += "マグニチュードの情報はありません";
|
||||
} else {
|
||||
magnitude += `M${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
|
||||
}
|
||||
|
||||
ueuse(`
|
||||
==地震情報==
|
||||
【緊急地震速報】
|
||||
${cancelled}
|
||||
時刻:${earthquakeInfo.time}
|
||||
${descriptionEarthquake}
|
||||
${description}
|
||||
${test}
|
||||
${areas}
|
||||
`);
|
||||
}
|
||||
|
||||
// 地震情報
|
||||
else if (earthquakeInfo.code === 551) {
|
||||
console.log("地震発生情報を受信しました");
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.maxScale !== undefined &&
|
||||
earthquakeInfo.earthquake.maxScale < config.earthquake.maxScaleMin
|
||||
) {
|
||||
console.log("最低震度に満たしていないため投稿されませんでした");
|
||||
return;
|
||||
}
|
||||
|
||||
// 国内津波
|
||||
let domesticTsunami;
|
||||
|
||||
if (earthquakeInfo.earthquake.domesticTsunami === "None") {
|
||||
domesticTsunami = "この地震による国内の津波の心配はありません";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "Unknown") {
|
||||
const TsunamiMessages = {
|
||||
"None": "この地震による国内の津波の心配はありません",
|
||||
"Unknown": "この地震による国内の津波情報はありません",
|
||||
"Checking": "この地震による国内の津波情報を調査中です",
|
||||
"NonEffective": "この地震による国内の津波影響は若干の海面変動が予想されますが被害の心配はありません",
|
||||
"Watch": "この地震により国内で津波注意報が発令しています",
|
||||
"Warning": "この地震による国内の津波予報があります",
|
||||
} as { [key: string]: string };
|
||||
|
||||
if (earthquakeInfo.earthquake.domesticTsunami === undefined) {
|
||||
domesticTsunami = "この地震による国内の津波情報はありません";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "Checking") {
|
||||
domesticTsunami = "この地震による国内の津波情報を調査中です";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "NonEffective") {
|
||||
domesticTsunami =
|
||||
"この地震による国内の津波影響は若干の海面変動が予想されますが被害の心配はありません";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "Watch") {
|
||||
domesticTsunami = "この地震により国内で津波注意報が発令しています";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "Warning") {
|
||||
domesticTsunami = "この地震による国内の津波予報があります";
|
||||
} else {
|
||||
domesticTsunami = "この地震による国内の津波情報はありません";
|
||||
domesticTsunami = TsunamiMessages[earthquakeInfo.earthquake.domesticTsunami];
|
||||
}
|
||||
|
||||
let maxScale;
|
||||
// 最大震度
|
||||
let maxScale: string = "最大深度:";
|
||||
|
||||
if (earthquakeInfo.earthquake.maxScale === -1) {
|
||||
maxScale = "最大震度情報なし";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 10) {
|
||||
maxScale = "震度1";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 20) {
|
||||
maxScale = "震度2";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 30) {
|
||||
maxScale = "震度3";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 40) {
|
||||
maxScale = "震度4";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 45) {
|
||||
maxScale = "震度5弱";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 50) {
|
||||
maxScale = "震度5強";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 55) {
|
||||
maxScale = "震度6弱";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 60) {
|
||||
maxScale = "震度6強";
|
||||
} else if (earthquakeInfo.earthquake.maxScale === 70) {
|
||||
maxScale = "震度7";
|
||||
const maxScales = {
|
||||
10: "震度1",
|
||||
20: "震度2",
|
||||
30: "震度3",
|
||||
40: "震度4",
|
||||
45: "震度5弱",
|
||||
50: "震度5強",
|
||||
55: "震度6弱",
|
||||
60: "震度6強",
|
||||
70: "震度7",
|
||||
} as { [key: number]: string };
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.maxScale == -1 ||
|
||||
earthquakeInfo.earthquake.maxScale === undefined
|
||||
) {
|
||||
maxScale = "最大震度:不明";
|
||||
} else {
|
||||
maxScale = `最大震度:${maxScales[earthquakeInfo.earthquake.maxScale]}`;
|
||||
}
|
||||
|
||||
// 警告
|
||||
if (
|
||||
earthquakeInfo.earthquake.maxScale !== undefined &&
|
||||
earthquakeInfo.earthquake.maxScale >= 60 &&
|
||||
config.emergency.function
|
||||
) {
|
||||
console.log("----------------");
|
||||
|
||||
console.log("震度6強以上の地震を受信しました");
|
||||
console.log("サーバーがダウンする可能性があります");
|
||||
|
||||
// メール送信
|
||||
if (config.emergency.function) {
|
||||
sendMail({
|
||||
to: config.emergency.mail.to,
|
||||
subject: "【警告】震度6強以上の地震を受信しました",
|
||||
text: `
|
||||
※noticeUwuzu自動送信によるメールです
|
||||
【警告】
|
||||
BOT管理者さん、noticeUwuzu自動送信メールです。
|
||||
震度6強以上の地震を受信したため警告メールが送信されました。
|
||||
物理、システム的にサーバーがダウンする可能性があります。
|
||||
ご自身の身をお守りください。
|
||||
`
|
||||
});
|
||||
|
||||
console.log("管理者へ警告メールを送信しました");
|
||||
}
|
||||
|
||||
console.log("----------------");
|
||||
}
|
||||
|
||||
// 対象地域
|
||||
let areas;
|
||||
|
||||
if (earthquakeInfo.points !== undefined) {
|
||||
const areaNames: Array<string> = Array.from(
|
||||
new Set(
|
||||
earthquakeInfo.points.map((point: any) => point.addr).filter(Boolean),
|
||||
),
|
||||
);
|
||||
areas = `対象地域:${areaNames.join("・")}`;
|
||||
} else {
|
||||
areas = "対象地域:不明";
|
||||
}
|
||||
|
||||
// 詳細
|
||||
let description;
|
||||
|
||||
if (
|
||||
earthquakeInfo.comments.freeFormComment !== "" &&
|
||||
earthquakeInfo.comments.freeFormComment !== undefined
|
||||
) {
|
||||
description = `この地震について:${earthquakeInfo.comments.freeFormComment}`;
|
||||
} else {
|
||||
description = "";
|
||||
}
|
||||
|
||||
// 深さ
|
||||
let depth;
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.hypocenter.depth !== null ||
|
||||
earthquakeInfo.earthquake.hypocenter.depth !== undefined
|
||||
) {
|
||||
if (earthquakeInfo.earthquake.hypocenter.depth === 0) {
|
||||
depth = "深さ:ごく浅い";
|
||||
} else if (earthquakeInfo.earthquake.hypocenter.depth === -1) {
|
||||
depth = "深さ:不明";
|
||||
} else {
|
||||
depth = `深さ:${String(earthquakeInfo.earthquake.hypocenter.depth)}km`;
|
||||
}
|
||||
} else {
|
||||
depth = "深さ:不明";
|
||||
}
|
||||
|
||||
// マグニチュード
|
||||
let magnitude;
|
||||
|
||||
if(
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== null ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== undefined
|
||||
) {
|
||||
if (earthquakeInfo.earthquake.hypocenter.magnitude === -1) {
|
||||
magnitude = "マグニチュード:不明";
|
||||
} else {
|
||||
magnitude = `マグニチュード:M${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
|
||||
}
|
||||
} else {
|
||||
magnitude = "マグニチュード:不明";
|
||||
}
|
||||
|
||||
ueuse(`
|
||||
==地震情報==
|
||||
【地域情報更新】
|
||||
【地震発生】
|
||||
時刻:${earthquakeInfo.time}
|
||||
最大深度:${maxScale}
|
||||
${description}
|
||||
${magnitude}
|
||||
${depth}
|
||||
${maxScale}
|
||||
${areas}
|
||||
国内の津波:${domesticTsunami}
|
||||
`);
|
||||
}
|
||||
} else if (earthquakeInfo.code === 552) {
|
||||
console.log("津波予報情報を受信しました");
|
||||
|
||||
// 地域情報更新の場合
|
||||
else if (earthquakeInfo.code === 555) {
|
||||
// 対象地域マッピング
|
||||
const areaMaps: any = await areaMap();
|
||||
// 予報取り消し
|
||||
if (earthquakeInfo.cancelled) {
|
||||
ueuse(`
|
||||
==地震情報==
|
||||
【津波予報】
|
||||
※津波予報が取り消されました※
|
||||
時刻:${earthquakeInfo.time}
|
||||
`);
|
||||
|
||||
const areaNames: Array<string> = Array.from(
|
||||
new Set(
|
||||
earthquakeInfo.areas.map((a: any) => {
|
||||
areaMaps[a.id].filter(Boolean);
|
||||
}),
|
||||
),
|
||||
);
|
||||
return;
|
||||
}
|
||||
|
||||
const result = areaNames.join("・");
|
||||
|
||||
ueuse(`
|
||||
let result: string = `
|
||||
==地震情報==
|
||||
【地域情報更新】
|
||||
【津波予報】
|
||||
時刻:${earthquakeInfo.time}
|
||||
対象地域:${result}
|
||||
`);
|
||||
\n
|
||||
`;
|
||||
|
||||
for (let i = 0; i < earthquakeInfo.areas.length; i++) {
|
||||
const data = earthquakeInfo.areas[i];
|
||||
|
||||
// 種類
|
||||
const gradeMessages = {
|
||||
"MajorWarning": "大津波警報",
|
||||
"Warning": "津波警報",
|
||||
"Watch": "津波注意報",
|
||||
"Unknown": "不明",
|
||||
} as { [key: string]: string };
|
||||
|
||||
let grade;
|
||||
|
||||
if (data.grade === undefined) {
|
||||
grade = "予報種類:不明";
|
||||
} else {
|
||||
grade = `予報種類:${gradeMessages[data.grade]}`;
|
||||
}
|
||||
|
||||
// 直後襲来
|
||||
let immediate;
|
||||
|
||||
if (data.immediate === undefined) {
|
||||
immediate = "津波の襲来が直後かの情報がありません";
|
||||
} else if (data.immediate) {
|
||||
immediate = "### 津波が直ちに襲来します";
|
||||
} else if (!data.immediate) {
|
||||
immediate = "津波は直ちには襲来しません";
|
||||
} else {
|
||||
immediate = "津波の襲来が直後かの情報がありません";
|
||||
}
|
||||
|
||||
// 第1波
|
||||
let firstHeight;
|
||||
|
||||
if (data.firstHeight === undefined) {
|
||||
firstHeight = "第1波の情報がありません";
|
||||
} else if (
|
||||
data.firstHeight.arrivalTime === undefined &&
|
||||
data.firstHeight.condition === undefined
|
||||
) {
|
||||
firstHeight = "第1波の情報がありません";
|
||||
} else {
|
||||
let arrivalTime;
|
||||
|
||||
if (data.arrivalTime === undefined) {
|
||||
arrivalTime = "不明";
|
||||
} else {
|
||||
arrivalTime = data.arrivalTime;
|
||||
}
|
||||
|
||||
let condition;
|
||||
|
||||
if (data.condition === undefined) {
|
||||
condition = "不明";
|
||||
} else {
|
||||
condition = data.condition;
|
||||
}
|
||||
|
||||
firstHeight = `
|
||||
第1波到達予想時刻:${arrivalTime}
|
||||
第1波の状態:${condition}
|
||||
`
|
||||
}
|
||||
|
||||
// 予想高さ
|
||||
let maxHeight;
|
||||
|
||||
if (data.maxHeight.description === undefined) {
|
||||
maxHeight = "津波の高さ(予想):不明";
|
||||
} else {
|
||||
maxHeight = `津波の高さ(予想):${data.maxHeight.description}`;
|
||||
}
|
||||
|
||||
result = `
|
||||
【${data.name}】
|
||||
${grade}
|
||||
${immediate}
|
||||
${firstHeight}
|
||||
${maxHeight}\n\n
|
||||
`;
|
||||
}
|
||||
|
||||
ueuse(result);
|
||||
}
|
||||
}
|
||||
|
||||
async function ueuse(text: string) {
|
||||
const res = await fetch(`https://${process.env.SERVER}/api/ueuse/create`, {
|
||||
const res = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: process.env.TOKEN,
|
||||
token: config.uwuzu.apiToken,
|
||||
text: text,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
const resData = await res.json();
|
||||
|
||||
console.log(JSON.stringify(resData));
|
||||
console.log(`地震情報投稿:${JSON.stringify(resData)}`);
|
||||
}
|
||||
|
||||
export default function earthquake(): void {
|
||||
export default function earthquakeNotice(): void {
|
||||
console.log("地震情報サーバーに接続します");
|
||||
const client = new P2PEarthquakeClient();
|
||||
client.start();
|
||||
|
||||
@@ -1,42 +0,0 @@
|
||||
import * as dotenv from "dotenv";
|
||||
|
||||
import type * as types from "../types";
|
||||
|
||||
dotenv.config();
|
||||
|
||||
export default async function followBack() {
|
||||
// フォロワーを取得
|
||||
const resMe = await fetch(
|
||||
`https://${process.env.SERVER}/api/me?token=${process.env.TOKEN}`,
|
||||
{
|
||||
method: "GET",
|
||||
// uwuzu.netで/api/meのPOSTが死んでいるため簡易的にGET
|
||||
},
|
||||
);
|
||||
|
||||
const meData: types.meApi = await resMe.json();
|
||||
|
||||
console.log(meData);
|
||||
|
||||
const followers: Array<string> = meData.follower;
|
||||
|
||||
// フォロー
|
||||
for (let i = 0; i < followers.length; i++) {
|
||||
const followerItem = followers[i];
|
||||
|
||||
const resFollow = await fetch(
|
||||
`https://${process.env.SERVER}/api/users/follow`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: process.env.TOKEN,
|
||||
userid: followerItem,
|
||||
}),
|
||||
},
|
||||
);
|
||||
|
||||
const followData: types.followApi = await resFollow.json();
|
||||
|
||||
console.log(JSON.stringify(followData));
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,60 @@
|
||||
import * as fs from "fs";
|
||||
import { isAfter } from "date-fns";
|
||||
|
||||
import config from "../config.js";
|
||||
import sendMail from "../src/mailer.js";
|
||||
|
||||
export default function successExit() {
|
||||
// 初期化
|
||||
if (!fs.existsSync("logs/boot.json")) {
|
||||
fs.writeFileSync("logs/boot.json", JSON.stringify({
|
||||
start: new Date(),
|
||||
stop: "",
|
||||
}), "utf-8");
|
||||
}
|
||||
|
||||
const iolog = JSON.parse(fs.readFileSync("logs/boot.json", "utf-8"));
|
||||
|
||||
if (config.emergency.function) {
|
||||
// 前回の終了確認
|
||||
const start = iolog.start;
|
||||
const stop = iolog.stop;
|
||||
|
||||
if (isAfter(start, stop)) {
|
||||
console.log("前回の終了が適切でない可能性があります");
|
||||
|
||||
if (config.emergency.mail.function) {
|
||||
sendMail({
|
||||
to: config.emergency.mail.to,
|
||||
subject: "【警告】前回終了が不適切な可能性",
|
||||
text: `
|
||||
※noticeUwuzu自動送信によるメールです。
|
||||
【警告】
|
||||
BOT管理者さん、noticeUwuzu自動送信メールです。
|
||||
BOTの前回終了で不適切なデータを検出しました。
|
||||
これは適切な終了時にはデータを残しデータがない場合に送信されます。
|
||||
電源を強制的に遮断するなどの行為による可能性があります。
|
||||
その場合は今後やめ、OSからのシャットダウンを使用してください。
|
||||
BOTのプログラムが破損していないかご確認ください。
|
||||
`
|
||||
});
|
||||
}
|
||||
|
||||
console.log("----------------");
|
||||
}
|
||||
}
|
||||
|
||||
// 起動時に起動時刻を保存
|
||||
iolog.start = new Date();
|
||||
fs.writeFileSync("logs/boot.json", JSON.stringify(iolog), "utf-8");
|
||||
|
||||
// 終了時に終了時刻を保存
|
||||
process.on("exit", () => {
|
||||
const iolog = JSON.parse(fs.readFileSync("logs/boot.json", "utf-8"));
|
||||
iolog.stop = new Date();
|
||||
|
||||
fs.writeFileSync("logs/boot.json", JSON.stringify(iolog), "utf-8");
|
||||
});
|
||||
}
|
||||
|
||||
successExit();
|
||||
+39
-19
@@ -1,27 +1,47 @@
|
||||
import * as dotenv from "dotenv";
|
||||
import { format } from "date-fns";
|
||||
|
||||
import type * as types from "../types";
|
||||
|
||||
dotenv.config();
|
||||
import type * as types from "types/types";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function timeNotice() {
|
||||
// 現在時刻を取得
|
||||
const now = format(new Date(), "HH:mm");
|
||||
// 停止時間
|
||||
// 時刻取得
|
||||
const start = config.time.stopTimes.start;
|
||||
const stop = config.time.stopTimes.stop;
|
||||
|
||||
// 投稿
|
||||
const resUeuse = await fetch(
|
||||
`https://${process.env.SERVER}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: process.env.TOKEN,
|
||||
text: `${now}になりました`,
|
||||
}),
|
||||
},
|
||||
);
|
||||
// 現在の時間を取得
|
||||
const nowHour = new Date().getHours();
|
||||
|
||||
const ueuseData: types.ueuseCreateApi = await resUeuse.json();
|
||||
// 停止時刻内かどうかの判定
|
||||
let inRange: boolean = false;
|
||||
|
||||
console.log(JSON.stringify(ueuseData));
|
||||
if (start < stop) {
|
||||
inRange = nowHour >= start && nowHour < stop;
|
||||
} else {
|
||||
inRange = nowHour >= start || nowHour < stop;
|
||||
}
|
||||
|
||||
if (inRange) {
|
||||
console.log("----------------");
|
||||
console.log("時報休止期間のため投稿されませんでした");
|
||||
return;
|
||||
} else {
|
||||
// 投稿
|
||||
const resUeuse = await fetch(
|
||||
`https://${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `${format(new Date(), "HH:mm")}になりました`,
|
||||
}),
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
const ueuseData: types.ueuseCreateApi = await resUeuse.json();
|
||||
|
||||
console.log("----------------");
|
||||
console.log(`時報投稿:${JSON.stringify(ueuseData)}`);
|
||||
}
|
||||
}
|
||||
|
||||
+88
-87
@@ -1,125 +1,126 @@
|
||||
import * as dotenv from "dotenv";
|
||||
import { cityList } from "../src/weatherId.js";
|
||||
import type * as types from "../types";
|
||||
|
||||
dotenv.config();
|
||||
import type * as types from "types/types.js";
|
||||
|
||||
import config from "../config.js";
|
||||
|
||||
export async function weatherNotice() {
|
||||
console.log("----------------");
|
||||
|
||||
export default async function weatherNotice() {
|
||||
// 仮投稿
|
||||
const resUeuse = await fetch(
|
||||
`https://${process.env.SERVER}/api/ueuse/create`,
|
||||
`https://${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: process.env.TOKEN,
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
本日の天気
|
||||
※タイムラインが埋まるため返信に記載しています
|
||||
`,
|
||||
}),
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
const ueuseData: types.ueuseCreateApi = await resUeuse.json();
|
||||
|
||||
console.log(JSON.stringify(ueuseData));
|
||||
console.log(`天気仮投稿:${JSON.stringify(ueuseData)}`);
|
||||
|
||||
// 3分割処理
|
||||
weatherReply(ueuseData.uniqid);
|
||||
}
|
||||
|
||||
export async function weatherReply(uniqid: string) {
|
||||
// インデックス
|
||||
const splitCount = config.weather.splitCount;
|
||||
const total = cityList.length;
|
||||
const firstLength = Math.trunc(total / 3);
|
||||
const secondLength = Math.trunc((total - firstLength) / 2);
|
||||
const thirdLength = total - firstLength - secondLength;
|
||||
const chunkSizes = Array(splitCount).fill(0).map((_, i) =>
|
||||
Math.floor((total + i) / splitCount)
|
||||
);
|
||||
|
||||
// インデックス作成
|
||||
const firstStart = 0;
|
||||
const firstEnd = firstStart + firstLength;
|
||||
const secondStart = firstEnd;
|
||||
const secondEnd = secondStart + secondLength;
|
||||
const thirdStart = secondEnd;
|
||||
const thirdEnd = total;
|
||||
// 分割インデックス
|
||||
let start = 0;
|
||||
const ranges = chunkSizes.map(size => {
|
||||
const range = [start, start + size];
|
||||
start += size;
|
||||
return range;
|
||||
});
|
||||
|
||||
let weatherResults = ["", "", ""];
|
||||
// 配列作成
|
||||
const weatherResults = Array(splitCount).fill("");
|
||||
|
||||
// 投稿1
|
||||
for (let i = firstStart; i < firstEnd; i++) {
|
||||
const res = await fetch(
|
||||
`https://weather.tsukumijima.net/api/forecast/city/${cityList[i]}`,
|
||||
);
|
||||
const data = await res.json();
|
||||
const today = data.forecasts[0];
|
||||
// 天気取得
|
||||
for (let chunkIndex = 0; chunkIndex < splitCount; chunkIndex++) {
|
||||
const [chunkStart, chunkEnd] = ranges[chunkIndex];
|
||||
|
||||
const weather = today.telop ?? "取得できませんでした";
|
||||
const maxTemp = today.temperature.max?.celsius ?? "取得できませんでした";
|
||||
const minTemp = today.temperature.min?.celsius ?? "取得できませんでした";
|
||||
const chanceOfRain = data.chanceOfRain?.["T06_12"] ?? "取得できませんでした";
|
||||
for (let i = chunkStart; i < chunkEnd; i++) {
|
||||
const res = await fetch(
|
||||
`https://weather.tsukumijima.net/api/forecast/city/${cityList[i]}`,
|
||||
);
|
||||
|
||||
weatherResults[0] += `
|
||||
【${data.location.city}】\n
|
||||
天気:${weather}\n
|
||||
最高気温:${maxTemp}℃\n
|
||||
最低気温:${minTemp}℃\n
|
||||
降水確率:${chanceOfRain}\n
|
||||
`;
|
||||
const data = await res.json();
|
||||
const today = data.forecasts[0];
|
||||
|
||||
// 天気
|
||||
const weather = today.telop ?? "取得できませんでした";
|
||||
|
||||
// 最高気温
|
||||
let maxTemp: string;
|
||||
|
||||
if (today.temperature.max.celsius !== null) {
|
||||
maxTemp = `${today.temperature.max.celsius}℃`;
|
||||
} else {
|
||||
maxTemp = "取得できませんでした";
|
||||
}
|
||||
|
||||
// 最低気温
|
||||
let minTemp: string;
|
||||
|
||||
if (today.temperature.min.celsius !== null) {
|
||||
minTemp = `${today.temperature.min.celsius}℃`;
|
||||
} else {
|
||||
minTemp = "取得できませんでした";
|
||||
}
|
||||
|
||||
// 降水確率
|
||||
let chanceOfRain: string;
|
||||
|
||||
if (
|
||||
today.chanceOfRain.T06_12 !== null ||
|
||||
today.chanceOfRain.T06_12 !== "--%"
|
||||
) {
|
||||
chanceOfRain = today.chanceOfRain.T06_12;
|
||||
} else {
|
||||
chanceOfRain = "取得できませんでした";
|
||||
}
|
||||
|
||||
weatherResults[chunkIndex] += `
|
||||
【${data.location.city}】
|
||||
天気:${weather}
|
||||
最高気温:${maxTemp}
|
||||
最低気温:${minTemp}
|
||||
降水確率:${chanceOfRain}
|
||||
`;
|
||||
}
|
||||
}
|
||||
|
||||
// 投稿2
|
||||
for (let i = secondStart; i < secondEnd; i++) {
|
||||
const res = await fetch(
|
||||
`https://weather.tsukumijima.net/api/forecast/city/${cityList[i]}`,
|
||||
);
|
||||
const data = await res.json();
|
||||
const today = data.forecasts[0];
|
||||
|
||||
const weather = today.telop ?? "取得できませんでした";
|
||||
const maxTemp = today.temperature.max?.celsius ?? "取得できませんでした";
|
||||
const minTemp = today.temperature.min?.celsius ?? "取得できませんでした";
|
||||
const chanceOfRain = data.chanceOfRain?.["T06_12"] ?? "取得できませんでした";
|
||||
|
||||
weatherResults[1] += `
|
||||
【${data.location.city}】\n
|
||||
天気:${weather}\n
|
||||
最高気温:${maxTemp}℃\n
|
||||
最低気温:${minTemp}℃\n
|
||||
降水確率:${chanceOfRain}\n
|
||||
`;
|
||||
}
|
||||
|
||||
// 投稿3
|
||||
for (let i = thirdStart; i < thirdEnd; i++) {
|
||||
const res = await fetch(
|
||||
`https://weather.tsukumijima.net/api/forecast/city/${cityList[i]}`,
|
||||
);
|
||||
const data = await res.json();
|
||||
const today = data.forecasts[0];
|
||||
|
||||
const weather = today.telop ?? "取得できませんでした";
|
||||
const maxTemp = today.temperature.max?.celsius ?? "取得できませんでした";
|
||||
const minTemp = today.temperature.min?.celsius ?? "取得できませんでした";
|
||||
const chanceOfRain = data.chanceOfRain?.["T06_12"] ?? "取得できませんでした";
|
||||
|
||||
weatherResults[2] += `
|
||||
【${data.location.city}】\n
|
||||
天気:${weather}\n
|
||||
最高気温:${maxTemp}℃\n
|
||||
最低気温:${minTemp}℃\n
|
||||
降水確率:${chanceOfRain}\n
|
||||
`;
|
||||
}
|
||||
|
||||
// 3分割投稿
|
||||
for (let i = 0; i < 3; i++) {
|
||||
// 分割投稿
|
||||
for (let i = 0; i < splitCount; i++) {
|
||||
const resReply = await fetch(
|
||||
`https://${process.env.SERVER}/api/ueuse/create`,
|
||||
`https://${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: process.env.TOKEN,
|
||||
token: config.uwuzu.apiToken,
|
||||
text: weatherResults[i],
|
||||
replyid: ueuseData.uniqid
|
||||
replyid: uniqid,
|
||||
}),
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
const replyData: types.ueuseCreateApi = await resReply.json();
|
||||
console.log(JSON.stringify(replyData));
|
||||
|
||||
console.log(`天気返信:${JSON.stringify(replyData)}`);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -0,0 +1,52 @@
|
||||
import config from "../config.js";
|
||||
import * as nodemailer from "nodemailer";
|
||||
|
||||
import type SMTPTransport from "nodemailer/lib/smtp-transport";
|
||||
|
||||
export interface EmailMessage {
|
||||
to: string | string[];
|
||||
subject: string;
|
||||
text?: string;
|
||||
html?: string;
|
||||
}
|
||||
|
||||
async function createTransporter() {
|
||||
const transporter = nodemailer.createTransport({
|
||||
host: config.emergency.mail.host,
|
||||
port: config.emergency.mail.port,
|
||||
secure: config.emergency.mail.secure,
|
||||
auth: {
|
||||
user: config.emergency.mail.user,
|
||||
pass: config.emergency.mail.password,
|
||||
},
|
||||
} as SMTPTransport.Options);
|
||||
|
||||
// 接続テスト
|
||||
try {
|
||||
await transporter.verify();
|
||||
console.log("SMTPサーバーに接続できました");
|
||||
} catch (error) {
|
||||
console.error("SMTP接続テストに失敗:", error);
|
||||
throw error;
|
||||
}
|
||||
|
||||
return transporter;
|
||||
}
|
||||
|
||||
export default async function sendMail(message: EmailMessage): Promise<void> {
|
||||
try {
|
||||
const transporter = await createTransporter();
|
||||
|
||||
await transporter.sendMail({
|
||||
from: config.emergency.mail.user,
|
||||
to: Array.isArray(message.to) ? message.to.join(",") : message.to,
|
||||
subject: message.subject,
|
||||
text: message.text,
|
||||
html: message.html,
|
||||
});
|
||||
console.log("メール送信成功");
|
||||
} catch (error) {
|
||||
console.error("メール送信に失敗しました:", error);
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
+5
-4
@@ -1,7 +1,7 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "es2022",
|
||||
"module": "ES2022",
|
||||
"target": "ES2024",
|
||||
"module": "ESNext",
|
||||
"moduleResolution": "bundler",
|
||||
"outDir": "./dist",
|
||||
"esModuleInterop": true,
|
||||
@@ -17,6 +17,7 @@
|
||||
"paths": {
|
||||
"ws": ["./node_modules/ws/index.js"],
|
||||
"@types/ws": ["./node_modules/@types/ws/index.d.ts"]
|
||||
}
|
||||
}
|
||||
},
|
||||
"removeComments": true,
|
||||
},
|
||||
}
|
||||
|
||||
Vendored
+62
@@ -0,0 +1,62 @@
|
||||
interface earthquakeTypes {
|
||||
reconnectTimes: number;
|
||||
websocketUrl: string;
|
||||
areasCsvUrl: string;
|
||||
maxScaleMin: number;
|
||||
}
|
||||
|
||||
interface weatherTypes {
|
||||
splitCount: number;
|
||||
}
|
||||
|
||||
interface stopsTypes {
|
||||
start: number;
|
||||
stop: number;
|
||||
}
|
||||
|
||||
interface timeTypes {
|
||||
stopTimes: stopsTypes;
|
||||
}
|
||||
|
||||
interface emergencyMailTypes {
|
||||
function: boolean;
|
||||
host: string;
|
||||
port: number;
|
||||
user: string;
|
||||
password: string;
|
||||
secure: boolean;
|
||||
to: string | string[];
|
||||
}
|
||||
|
||||
interface emergencyTypes {
|
||||
function: boolean;
|
||||
mail: emergencyMailTypes;
|
||||
report: boolean;
|
||||
}
|
||||
|
||||
interface legalTypes {
|
||||
terms: string;
|
||||
privacy: string;
|
||||
}
|
||||
|
||||
interface adminTypes {
|
||||
name: string;
|
||||
showMail: boolean;
|
||||
}
|
||||
|
||||
interface uwuzuTypes {
|
||||
apiToken: string;
|
||||
clientToken?: string;
|
||||
host: string;
|
||||
}
|
||||
|
||||
export interface configTypes {
|
||||
time: timeTypes,
|
||||
earthquake: earthquakeTypes;
|
||||
weather: weatherTypes;
|
||||
|
||||
emergency: emergencyTypes;
|
||||
legal: legalTypes;
|
||||
admin: adminTypes;
|
||||
uwuzu: uwuzuTypes;
|
||||
}
|
||||
Vendored
+24
-2
@@ -12,9 +12,9 @@ export interface meApi {
|
||||
user_icon: string;
|
||||
user_header: string;
|
||||
registered_date: string;
|
||||
followee: Array;
|
||||
followee: Array<string>;
|
||||
followee_cnt: number;
|
||||
follower: Array;
|
||||
follower: Array<string>;
|
||||
follower_cnt: number;
|
||||
ueuse_cnt: number;
|
||||
isBot: Boolean;
|
||||
@@ -23,6 +23,28 @@ export interface meApi {
|
||||
language: String;
|
||||
}
|
||||
|
||||
export interface ueuse {
|
||||
uniqid: string;
|
||||
text: string;
|
||||
account: {
|
||||
username: string;
|
||||
userid: string;
|
||||
user_icon: string;
|
||||
user_header: string;
|
||||
};
|
||||
photo1: Base64URLString;
|
||||
photo2: Base64URLString;
|
||||
photo3: Base64URLString;
|
||||
photo4: Base64URLString;
|
||||
video1: Base64URLString;
|
||||
favorite: Array<string>;
|
||||
favorite_cnt: string;
|
||||
datetime: string;
|
||||
abi: string;
|
||||
abidatetime: string;
|
||||
nsfw: boolean;
|
||||
}
|
||||
|
||||
export interface ueuseCreateApi {
|
||||
uniqid: string;
|
||||
userid: string;
|
||||
Reference in New Issue
Block a user