Compare commits
5 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dc67845bc8 | |||
| 50db83cc8c | |||
| d7a5d8a43e | |||
| 1c10aeb9e4 | |||
| 081d1eca6e |
@@ -4,7 +4,7 @@ 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
|
||||
|
||||
http://www.apache.org/licenses/LICENSE-2.0
|
||||
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,
|
||||
|
||||
@@ -1,21 +1,37 @@
|
||||
# uwuzuお知らせBOT
|
||||
# noticeUwuzu
|
||||
|
||||
# uwuzuお知らせBOTについて
|
||||
# Overview
|
||||
|
||||
uwuzuで動作するお知らせBOTです。
|
||||
Automatic notification bot for uwuzu
|
||||
|
||||
# 設定
|
||||
examples/config.tsをプロジェクトルートへ移動し各設定を更新してください。
|
||||
# Functions
|
||||
|
||||
# サーバー起動
|
||||
- Time notification
|
||||
- Earthquake information notification
|
||||
- Earthquake Early Warning
|
||||
- Earthquake occurs
|
||||
- Tsunami forecast
|
||||
- Weather notification
|
||||
- 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がインストールされている必要があります。
|
||||
|
||||
# ライセンス
|
||||
Apache 2.0 License
|
||||
# License
|
||||
[Apache 2.0 License](https://www.apache.org/licenses/LICENSE-2.0)
|
||||
|
||||
+3
-6
@@ -3,7 +3,7 @@ import config from "../config.js";
|
||||
|
||||
export default async function APICheck() {
|
||||
try {
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/me`, {
|
||||
const req = await fetch(`https://${config.uwuzu.host}/api/me/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
@@ -12,15 +12,12 @@ export default async function APICheck() {
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
if (
|
||||
res.isBot === undefined ||
|
||||
res.isBot === null
|
||||
) {
|
||||
if (res.error_code !== undefined) {
|
||||
console.log(styleText("red", "APIトークンあるいはuwuzuサーバーホストが無効です"));
|
||||
process.exit();
|
||||
}
|
||||
|
||||
if (!res.isBot) {
|
||||
if (res.isBot === false) {
|
||||
setTimeout(() => {
|
||||
console.log(styleText("yellow", "使用するアカウントでBOTフラグが設定されていません"));
|
||||
}, 1500);
|
||||
|
||||
@@ -9,33 +9,33 @@ import * as cron from "node-cron";
|
||||
|
||||
// 機能読み込み
|
||||
import timeNotice from "./scripts/timeNotice.js";
|
||||
import weatherNotice from "./scripts/weatherNotice.js";
|
||||
import { weatherNotice } from "./scripts/weatherNotice.js";
|
||||
import earthquakeNotice from "./scripts/earthquakeNotice.js";
|
||||
import Commands from "scripts/commands/main.js";
|
||||
|
||||
// アスキーアート読み込み
|
||||
// その他機能
|
||||
import asciiArt from "./scripts/asciiart.js";
|
||||
asciiArt();
|
||||
|
||||
// フォロー機能読み込み
|
||||
import follows from "./scripts/follow/main.js";
|
||||
|
||||
// 正常終了確認読み込み
|
||||
import successExit from "./scripts/successExit.js";
|
||||
successExit();
|
||||
|
||||
// 地震情報観測開始
|
||||
earthquakeNotice();
|
||||
|
||||
// 時報・フォローバック(毎時)
|
||||
// 時報(1時間/1回)
|
||||
cron.schedule("0 * * * *", () => {
|
||||
timeNotice();
|
||||
follows();
|
||||
});
|
||||
|
||||
// 天気お知らせ(毎日7:01)
|
||||
cron.schedule("1 7 * * *", () => {
|
||||
// コマンド(10分/1回)
|
||||
cron.schedule('*/10 * * * *', () => {
|
||||
Commands();
|
||||
});
|
||||
|
||||
// 天気お知らせ(毎日7:00)
|
||||
cron.schedule("0 7 * * *", () => {
|
||||
weatherNotice();
|
||||
});
|
||||
|
||||
// コンソールで表示
|
||||
// 起動表示
|
||||
console.log("BOTサーバーが起動しました");
|
||||
|
||||
+6
-4
@@ -1,13 +1,14 @@
|
||||
{
|
||||
"name": "notice-uwuzu",
|
||||
"version": "v6.0.1@uwuzu1.5.4",
|
||||
"description": "uwuzu Notice Bot",
|
||||
"version": "v7.0(unconfirmed)@uwuzu1.5.4",
|
||||
"description": "Notice Bot for uwuzu",
|
||||
"main": "dist/main.js",
|
||||
"scripts": {
|
||||
"start": "node .",
|
||||
"build": "tsc",
|
||||
"main": "tsc && node .",
|
||||
"dev": "tsx main.ts"
|
||||
"dev": "tsx main.ts",
|
||||
"clean": "tsc && node dist/scripts/clean/main.js"
|
||||
},
|
||||
"keywords": [
|
||||
"uwuzu",
|
||||
@@ -28,10 +29,11 @@
|
||||
"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/node": "^24.0.7",
|
||||
"@types/ws": "^8.18.1",
|
||||
"child_process": "^1.0.2",
|
||||
"date-fns": "^4.1.0",
|
||||
"fs": "^0.0.1-security",
|
||||
"node-cron": "^4.1.1",
|
||||
|
||||
@@ -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,32 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import config from "../../config.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,
|
||||
}),
|
||||
});
|
||||
|
||||
const followRes = await followReq.json();
|
||||
|
||||
console.log("フォロー: ", followRes);
|
||||
|
||||
|
||||
const noticeReq = await fetch(`https://${config.uwuzu.host}/api/ueuse/create/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
${data.account.username}さんをフォローしました
|
||||
`,
|
||||
replyid: data.uniqid,
|
||||
}),
|
||||
});
|
||||
|
||||
const noticeRes = await noticeReq.json();
|
||||
|
||||
console.log("フォロー通知: ", noticeRes);
|
||||
}
|
||||
@@ -0,0 +1,114 @@
|
||||
import * as fs from "fs";
|
||||
import config from "../../config.js";
|
||||
import type { ueuse } from "types/types.js";
|
||||
|
||||
const initialFile: Array<string> = [];
|
||||
|
||||
// コマンド読み込み
|
||||
import Follow from "./follow.js";
|
||||
import UnFollow from "./unfollow.js";
|
||||
import Weather from "./weather.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("alreadyCommands.json", "utf-8"));
|
||||
|
||||
function cutAfterChar(str: string, char: string) {
|
||||
const index = str.indexOf(char);
|
||||
|
||||
if (index === -1) {
|
||||
return "";
|
||||
}
|
||||
|
||||
return str.substring(index + 1);
|
||||
}
|
||||
|
||||
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,
|
||||
}),
|
||||
});
|
||||
|
||||
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 mentions: Array<ueuse> = await (await fetch(
|
||||
`https://${config.uwuzu.host}/api/ueuse/mentions/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
}),
|
||||
}
|
||||
)).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) === "!") {
|
||||
break;
|
||||
}
|
||||
|
||||
// コマンド処理
|
||||
console.log("--------");
|
||||
|
||||
const commandName = cutAfterChar(data.text, "/");
|
||||
|
||||
switch (commandName) {
|
||||
case "follow":
|
||||
alreadyAdd(data.uniqid);
|
||||
Follow(data);
|
||||
break;
|
||||
case "unfollow":
|
||||
alreadyAdd(data.uniqid);
|
||||
UnFollow(data);
|
||||
break;
|
||||
case "weather":
|
||||
alreadyAdd(data.uniqid);
|
||||
Weather(data);
|
||||
break;
|
||||
default:
|
||||
alreadyAdd(data.uniqid);
|
||||
|
||||
const reply = await Reply(`
|
||||
不明なコマンドです。
|
||||
コマンド実行を除外する場合は1文字目に\`!\`を入れてください。
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("未対応コマンド: ", reply);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,31 @@
|
||||
import { ueuse } from "types/types.js";
|
||||
import config from "../../config.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,
|
||||
}),
|
||||
});
|
||||
|
||||
const unfollowRes = await unfollowReq.json();
|
||||
|
||||
console.log("フォロー解除: ", unfollowRes);
|
||||
|
||||
const noticeReq = await fetch(`https://${config.uwuzu.host}/api/ueuse/create/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
${data.account.username}さんをフォロー解除しました
|
||||
`,
|
||||
replyid: data.uniqid,
|
||||
}),
|
||||
});
|
||||
|
||||
const noticeRes = await noticeReq.json();
|
||||
|
||||
console.log("フォロー解除通知: ", noticeRes);
|
||||
}
|
||||
@@ -0,0 +1,6 @@
|
||||
import { weatherReply } from "scripts/weatherNotice";
|
||||
import { ueuse } from "types/types.js";
|
||||
|
||||
export default function Weather(data: ueuse) {
|
||||
weatherReply(data.uniqid);
|
||||
}
|
||||
+179
-76
@@ -2,6 +2,7 @@ import WebSocket from "ws";
|
||||
import sendMail from "../src/mailer.js";
|
||||
|
||||
import config from "../config.js";
|
||||
import { max } from "date-fns/fp";
|
||||
|
||||
class P2PEarthquakeClient {
|
||||
private ws: WebSocket | null = null;
|
||||
@@ -37,8 +38,8 @@ class P2PEarthquakeClient {
|
||||
try {
|
||||
const message = JSON.parse(data.toString());
|
||||
this.handleMessage(message);
|
||||
} catch (error) {
|
||||
console.error("メッセージのパースに失敗:", error);
|
||||
} catch (err) {
|
||||
console.error(`メッセージのパースでエラーが発生: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
@@ -63,23 +64,18 @@ class P2PEarthquakeClient {
|
||||
private handleMessage(message: any): void {
|
||||
console.log("----------------");
|
||||
|
||||
switch (message.code) {
|
||||
case 551: // 地震情報
|
||||
console.log("地震情報を受信しました");
|
||||
this.executeEventFunc(message);
|
||||
break;
|
||||
case 554: // 緊急地震速報
|
||||
console.log("緊急地震速報を受信しました");
|
||||
this.executeEventFunc(message);
|
||||
break;
|
||||
default:
|
||||
console.log(`未対応の情報を受信しました(コード: ${message.code})`);
|
||||
break;
|
||||
}
|
||||
}
|
||||
const supportCode: Array<number> = [
|
||||
551,
|
||||
552,
|
||||
556,
|
||||
];
|
||||
|
||||
private executeEventFunc(earthquakeInfo: any): void {
|
||||
event(earthquakeInfo);
|
||||
if (supportCode.indexOf(message.code) !== -1) {
|
||||
event(message);
|
||||
} else {
|
||||
console.log(`未対応の情報を受信しました(コード: ${message.code})`);
|
||||
console.log(`受信メッセージ:${message}`);
|
||||
}
|
||||
}
|
||||
|
||||
private scheduleReconnect(): void {
|
||||
@@ -87,6 +83,7 @@ class P2PEarthquakeClient {
|
||||
|
||||
console.log("地震情報サーバーから切断されました");
|
||||
console.log(`${this.reconnectInterval / 1000}秒後に再接続を試みます`);
|
||||
|
||||
this.reconnectTimer = setTimeout(() => {
|
||||
this.reconnectTimer = null;
|
||||
this.connect();
|
||||
@@ -96,7 +93,7 @@ class P2PEarthquakeClient {
|
||||
private setupCleanup(): void {
|
||||
const cleanup = () => {
|
||||
this.stop();
|
||||
process.exit(0);
|
||||
process.exit();
|
||||
};
|
||||
|
||||
process.on("SIGINT", cleanup);
|
||||
@@ -116,7 +113,7 @@ class P2PEarthquakeClient {
|
||||
}
|
||||
}
|
||||
|
||||
// 地名オブジェクトマッピング
|
||||
// 地名マッピング
|
||||
async function areaMap(): Promise<Record<number, string>> {
|
||||
const res = await fetch(config.earthquake.areasCsvUrl);
|
||||
|
||||
@@ -141,12 +138,13 @@ async function areaMap(): Promise<Record<number, string>> {
|
||||
|
||||
// 情報受信
|
||||
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 = "";
|
||||
|
||||
@@ -223,28 +221,7 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
|
||||
// 地震情報
|
||||
else if (earthquakeInfo.code === 551) {
|
||||
// 国内津波
|
||||
let domesticTsunami;
|
||||
|
||||
if (earthquakeInfo.earthquake.domesticTsunami === undefined) {
|
||||
domesticTsunami = "この地震による国内の津波情報はありません";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "None") {
|
||||
domesticTsunami = "この地震による国内の津波の心配はありません";
|
||||
} else if (earthquakeInfo.earthquake.domesticTsunami === "Unknown") {
|
||||
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 = "この地震による国内の津波予報があります";
|
||||
}
|
||||
|
||||
// 最大震度
|
||||
let maxScale: string = "最大深度:";
|
||||
console.log("地震発生情報を受信しました");
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.maxScale !== undefined &&
|
||||
@@ -254,29 +231,46 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
// 国内津波
|
||||
let domesticTsunami;
|
||||
|
||||
const TsunamiMessages = {
|
||||
"None": "この地震による国内の津波の心配はありません",
|
||||
"Unknown": "この地震による国内の津波情報はありません",
|
||||
"Checking": "この地震による国内の津波情報を調査中です",
|
||||
"NonEffective": "この地震による国内の津波影響は若干の海面変動が予想されますが被害の心配はありません",
|
||||
"Watch": "この地震により国内で津波注意報が発令しています",
|
||||
"Warning": "この地震による国内の津波予報があります",
|
||||
} as { [key: string]: string };
|
||||
|
||||
if (earthquakeInfo.earthquake.domesticTsunami === undefined) {
|
||||
domesticTsunami = "この地震による国内の津波情報はありません";
|
||||
} else {
|
||||
domesticTsunami = TsunamiMessages[earthquakeInfo.earthquake.domesticTsunami];
|
||||
}
|
||||
|
||||
// 最大震度
|
||||
let maxScale: string = "最大深度:";
|
||||
|
||||
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 == -1 ||
|
||||
earthquakeInfo.earthquake.maxScale === undefined
|
||||
) {
|
||||
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";
|
||||
maxScale = "最大震度:不明";
|
||||
} else {
|
||||
maxScale = `最大震度:${maxScales[earthquakeInfo.earthquake.maxScale]}`;
|
||||
}
|
||||
|
||||
// 警告
|
||||
@@ -312,7 +306,7 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
}
|
||||
|
||||
// 対象地域
|
||||
let areas: string = "";
|
||||
let areas;
|
||||
|
||||
if (earthquakeInfo.points !== undefined) {
|
||||
const areaNames: Array<string> = Array.from(
|
||||
@@ -324,7 +318,7 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
}
|
||||
|
||||
// 詳細
|
||||
let description: string = "";
|
||||
let description;
|
||||
|
||||
if (
|
||||
earthquakeInfo.comments.freeFormComment !== "" &&
|
||||
@@ -334,29 +328,33 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
}
|
||||
|
||||
// 深さ
|
||||
let depth: string = "";
|
||||
let depth;
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.hypocenter.depth !== null ||
|
||||
earthquakeInfo.earthquake.hypocenter.depth !== undefined ||
|
||||
earthquakeInfo.earthquake.hypocenter.depth != -1
|
||||
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`;
|
||||
}
|
||||
}
|
||||
|
||||
// マグニチュード
|
||||
let magnitude: string = "";
|
||||
let magnitude;
|
||||
|
||||
if(
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== null ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== undefined ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude != -1
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== undefined
|
||||
) {
|
||||
magnitude = `マグニチュード:M${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
|
||||
if (earthquakeInfo.earthquake.hypocenter.magnitude === -1) {
|
||||
depth = "マグニチュード:不明";
|
||||
} else {
|
||||
magnitude = `マグニチュード:M${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
|
||||
}
|
||||
}
|
||||
|
||||
ueuse(`
|
||||
@@ -370,11 +368,116 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
${areas}
|
||||
国内の津波:${domesticTsunami}
|
||||
`);
|
||||
} else if (earthquakeInfo.code === 552) {
|
||||
console.log("津波予報情報を受信しました");
|
||||
|
||||
// 予報取り消し
|
||||
if (earthquakeInfo.cancelled) {
|
||||
ueuse(`
|
||||
==地震情報==
|
||||
【津波予報】
|
||||
※津波予報が取り消されました※
|
||||
時刻:${earthquakeInfo.time}
|
||||
`);
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
let result: string = `
|
||||
==地震情報==
|
||||
【津波予報】
|
||||
時刻:${earthquakeInfo.time}
|
||||
\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 = "津波は直ちには襲来しません";
|
||||
}
|
||||
|
||||
// 第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://${config.uwuzu.host}/api/ueuse/create`, {
|
||||
console.log(text);
|
||||
/*const res = await fetch(`https://${config.uwuzu.host}/api/ueuse/create/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
@@ -384,7 +487,7 @@ async function ueuse(text: string) {
|
||||
|
||||
const resData = await res.json();
|
||||
|
||||
console.log(`地震情報投稿:${JSON.stringify(resData)}`);
|
||||
console.log(`地震情報投稿:${JSON.stringify(resData)}`);*/
|
||||
}
|
||||
|
||||
export default function earthquakeNotice(): void {
|
||||
|
||||
@@ -1,42 +0,0 @@
|
||||
import type * as types from "types/types";
|
||||
|
||||
import config from "../../config.js";
|
||||
|
||||
export default async function followBack() {
|
||||
console.log("----------------");
|
||||
|
||||
// フォロワーを取得
|
||||
const resMe = await fetch(
|
||||
`https://${config.uwuzu.host}/api/me?token=${config.uwuzu.apiToken}`,
|
||||
{
|
||||
method: "GET",
|
||||
// uwuzu v1.5.4で/api/meのPOSTが死んでいるため簡易的にGET
|
||||
},
|
||||
);
|
||||
|
||||
const meData: types.meApi = await resMe.json();
|
||||
|
||||
console.log(`BOTプロフィール:${JSON.stringify(meData)}`);
|
||||
|
||||
const followers: Array<string> = meData.follower;
|
||||
|
||||
// フォロー
|
||||
for (let i = 0; i < followers.length; i++) {
|
||||
const followerItem = followers[i];
|
||||
|
||||
const resFollow = await fetch(
|
||||
`https://${config.uwuzu.host}/api/users/follow`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
userid: followerItem,
|
||||
}),
|
||||
},
|
||||
);
|
||||
|
||||
const followData: types.followApi = await resFollow.json();
|
||||
|
||||
console.log(`フォロー:${JSON.stringify(followData)}`);
|
||||
}
|
||||
}
|
||||
@@ -1,7 +0,0 @@
|
||||
import followBack from "./follow.js";
|
||||
import unFollowBack from "./unfollow.js";
|
||||
|
||||
export default function follows() {
|
||||
unFollowBack();
|
||||
followBack();
|
||||
}
|
||||
@@ -1,27 +0,0 @@
|
||||
import config from "../../config.js";
|
||||
import { meApi } from "types/types.js";
|
||||
|
||||
export default async function unFollowBack() {
|
||||
const profile: meApi = await
|
||||
(await fetch(`https://${config.uwuzu.host}/api/me`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
})
|
||||
})).json();
|
||||
|
||||
profile.followee.forEach(async (followUser: string) => {
|
||||
if (
|
||||
profile.follower[followUser] === undefined ||
|
||||
profile.follower[followUser] === null
|
||||
) {
|
||||
await fetch(`https://${config.uwuzu.host}/api/users/unfollow`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
userId: followUser,
|
||||
}),
|
||||
})
|
||||
}
|
||||
});
|
||||
}
|
||||
@@ -4,7 +4,7 @@ import type * as types from "types/types.js";
|
||||
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function weatherNotice() {
|
||||
export async function weatherNotice() {
|
||||
console.log("----------------");
|
||||
|
||||
// 仮投稿
|
||||
@@ -26,7 +26,10 @@ export default async function weatherNotice() {
|
||||
|
||||
console.log(`天気仮投稿:${JSON.stringify(ueuseData)}`);
|
||||
|
||||
weatherReply(ueuseData.uniqid);
|
||||
}
|
||||
|
||||
export async function weatherReply(uniqid: string) {
|
||||
// インデックス
|
||||
const splitCount = config.weather.splitCount;
|
||||
const total = cityList.length;
|
||||
@@ -109,13 +112,13 @@ export default async function weatherNotice() {
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: weatherResults[i],
|
||||
replyid: ueuseData.uniqid
|
||||
replyid: uniqid,
|
||||
}),
|
||||
},
|
||||
);
|
||||
|
||||
const replyData: types.ueuseCreateApi = await resReply.json();
|
||||
|
||||
console.log(`天気投稿:${JSON.stringify(replyData)}`);
|
||||
console.log(`天気返信:${JSON.stringify(replyData)}`);
|
||||
}
|
||||
}
|
||||
|
||||
+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
+1
-1
@@ -35,7 +35,7 @@ interface emergencyTypes {
|
||||
|
||||
interface uwuzuTypes {
|
||||
apiToken: string;
|
||||
clientToken:? string;
|
||||
clientToken?: string;
|
||||
host: string;
|
||||
}
|
||||
|
||||
|
||||
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