Compare commits
34 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 97af8da4dd | |||
| a83054f5ce | |||
| bbf2d66b57 | |||
| db719b8312 | |||
| 2966eee889 | |||
| db5e174dd4 | |||
| 2b53b8cd3d | |||
| d20f630e1b | |||
| 644ba912b1 | |||
| 1ff4b2c429 | |||
| 0a3bb241a6 | |||
| f14999be13 | |||
| 6ec9831ed4 | |||
| 718e97ed45 | |||
| f6f7030d8c | |||
| a2576f961b | |||
| 844a9cd058 | |||
| 2a30fdf1e9 | |||
| dc67845bc8 | |||
| 50db83cc8c | |||
| d7a5d8a43e | |||
| 1c10aeb9e4 | |||
| 081d1eca6e | |||
| 0e9c8f8225 | |||
| 724e18ba3b | |||
| 3955d91978 | |||
| d28ca6ce4c | |||
| ad0d975a12 | |||
| 7f07710d23 | |||
| 3b58e7ee2d | |||
| 22ec582e0a | |||
| 05194ad7b8 | |||
| ef374b1639 | |||
| 563d70aacd |
LFS
BIN
Binary file not shown.
@@ -3,5 +3,3 @@
|
||||
/node_modules/
|
||||
/package-lock.json
|
||||
/config.ts
|
||||
|
||||
log*
|
||||
|
||||
@@ -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,36 +1,45 @@
|
||||
# uwuzuお知らせBOT
|
||||
# noticeUwuzu
|
||||
|
||||
# uwuzuお知らせBOTについて
|
||||
# Overview
|
||||
|
||||
uwuzuで動作するお知らせBOTです。
|
||||
Automatic notification bot for uwuzu
|
||||
|
||||
# 設定
|
||||
examples/config.tsをプロジェクトルートへ移動し各設定を更新してください。
|
||||
# Functions
|
||||
|
||||
## 設定項目
|
||||
time.stopTimes.start: 時報休止期間の開始時刻(HH)
|
||||
time.stopTimes.stop: 時報休止期間の停止時刻(HH)
|
||||
- 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
|
||||
- Make it a quote
|
||||
- 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
|
||||
|
||||
earthquake.reconnectTimes:地震情報のWebSocketが切断されたときに自動再接続する時間(ミリ秒)
|
||||
earthquake.websocketUrl:地震情報のWebSocket接続先URL
|
||||
earthquake.areasCsvUrl:地域情報のデータベース(CSV)ファイルのURL
|
||||
earthquake.maxScaleMin: 地震発生投稿の最低震度(10-70)
|
||||
earthquake.rateLimit: 地域情報更新のレート制限(分)
|
||||
# Config
|
||||
An example configuration file is available in `examples/config.ts`.
|
||||
|
||||
weather.splitCount:天気お知らせの返信の分割数(4分割を推奨)
|
||||
# Start the server
|
||||
|
||||
apiToken:BOTアカウントのAPIキー
|
||||
uwuzuServer:使用するuwuzuサーバーのホスト名(uwuzu.netなど)
|
||||
|
||||
# サーバー起動
|
||||
|
||||
```
|
||||
```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)
|
||||
|
||||
+5
-5
@@ -1,5 +1,5 @@
|
||||
# # ##### ####### ### ##### ####### # # # # # # ###### # #
|
||||
## # # # # # ## # # # # # # # # # # #
|
||||
# ## # # # # # # ###### # # # # # # # # ## # #
|
||||
# ## # # # # ## # # # # # # # # # #
|
||||
# # ##### # ### ##### ####### ###### # # ###### ###### #######
|
||||
# # ###### ##### ### ###### ####### # # # # # # ###### # #
|
||||
## # # # # # # # # # # # # # # # # #
|
||||
# ## # # # # # # ####### # # # # # # # # ## # #
|
||||
# ## # # # # # # # # # # # # # # #
|
||||
# # ###### # ### ###### ####### ###### # # ###### ###### ######
|
||||
|
||||
@@ -0,0 +1,30 @@
|
||||
import { styleText } from "util";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function APICheck() {
|
||||
try {
|
||||
const req = await fetch(`${config.uwuzu.host}/api/me/`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
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,12 @@
|
||||
import config from "../config.js";
|
||||
import { styleText } from "util";
|
||||
|
||||
export default function LegalCheck() {
|
||||
if (
|
||||
config.legal.terms.length <= 50 ||
|
||||
config.legal.terms.length <= 50
|
||||
) {
|
||||
console.log(styleText("red", "利用規約とプライバシーポリシーは50文字以上にしてください。"));
|
||||
process.exit();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,18 @@
|
||||
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";
|
||||
import LegalCheck from "./legal.js";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function Check() {
|
||||
PackagesIsExist();
|
||||
PackagesCheck();
|
||||
ConfigCheck();
|
||||
if (config.debug === undefined) {
|
||||
LegalCheck()
|
||||
}
|
||||
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(`${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
|
||||
+43
-4
@@ -8,7 +8,7 @@ const config: configTypes = {
|
||||
stopTimes: {
|
||||
start: 23, // 開始
|
||||
stop: 6, // 停止
|
||||
}
|
||||
},
|
||||
},
|
||||
// 地震速報設定
|
||||
earthquake: {
|
||||
@@ -16,14 +16,53 @@ const config: configTypes = {
|
||||
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)
|
||||
rateLimit: 30, // 地域情報更新のレート制限(分)
|
||||
},
|
||||
// 天気お知らせ設定
|
||||
weather: {
|
||||
splitCount: 4, // 返信の分割数
|
||||
},
|
||||
// Make it a quote設定
|
||||
miq: true, // 有効/無効
|
||||
|
||||
apiToken: "TOKEN_EXAMPLE", // BOTアカウントのAPIトークン
|
||||
uwuzuServer: "uwuzu.example.com", // uwuzuのサーバー
|
||||
// 緊急時設定
|
||||
emergency: {
|
||||
isEnabled: true, // 緊急時のコンソール表示
|
||||
mail: {
|
||||
isEnabled: 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", // 緊急時メール送信先(配列可)
|
||||
},
|
||||
},
|
||||
// /report設定
|
||||
report: {
|
||||
isEnabled: true, // 有効/無効
|
||||
message: "", // 報告者へのメッセージ
|
||||
},
|
||||
// 規約等
|
||||
legal: {
|
||||
terms: `
|
||||
`, // 利用規約
|
||||
privacy: `
|
||||
`, // プライバシーポリシー
|
||||
},
|
||||
// 管理者情報設定
|
||||
admin: {
|
||||
name: "あどみん", // BOT管理者名
|
||||
showMail: false, // メールアドレスを公開するか(false:非公開/文字列:メールアドレス)
|
||||
panel: { // 管理パネル
|
||||
isEnabled: true, // 有効/無効
|
||||
port: 74919, // 配信ポート
|
||||
},
|
||||
},
|
||||
// uwuzuサーバー設定
|
||||
uwuzu: {
|
||||
apiToken: "TOKEN_EXAMPLE", // APIトークン
|
||||
host: "https://uwuzu.example.com", // サーバーホスト
|
||||
},
|
||||
};
|
||||
|
||||
export default config;
|
||||
|
||||
@@ -0,0 +1,2 @@
|
||||
*
|
||||
!.gitignore
|
||||
@@ -1,33 +1,62 @@
|
||||
// 起動チェック
|
||||
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 { weatherNotice } from "./scripts/weatherNotice.js";
|
||||
import earthquakeNotice from "./scripts/earthquakeNotice.js";
|
||||
import EventDays from "./scripts/eventday.js";
|
||||
import Commands from "./scripts/commands/main.js";
|
||||
|
||||
// アスキーアート読み込み
|
||||
// その他機能
|
||||
import asciiArt from "./scripts/asciiart.js";
|
||||
asciiArt();
|
||||
|
||||
// フォローバック機能読み込み
|
||||
import followBack from "./scripts/followBack.js";
|
||||
import successExit from "./scripts/successExit.js";
|
||||
successExit();
|
||||
|
||||
// 地震情報観測開始
|
||||
earthquakeNotice();
|
||||
|
||||
// 時報・フォローバック(毎時)
|
||||
// 時報(1時間/1回)
|
||||
cron.schedule("0 * * * *", () => {
|
||||
timeNotice();
|
||||
followBack();
|
||||
});
|
||||
|
||||
// 天気お知らせ(毎日7:01)
|
||||
cron.schedule("1 7 * * *", () => {
|
||||
// コマンド(10分/1回)
|
||||
cron.schedule("*/10 * * * *", () => {
|
||||
Commands();
|
||||
});
|
||||
|
||||
// 祝日などお知らせ(毎日0:00)
|
||||
cron.schedule("0 0 * * *", () => {
|
||||
EventDays();
|
||||
});
|
||||
|
||||
// 天気お知らせ(毎日7:00)
|
||||
import { setTimeout } from "timers";
|
||||
cron.schedule("0 7 * * *", () => {
|
||||
setTimeout(() => {
|
||||
weatherNotice();
|
||||
}, 100);
|
||||
});
|
||||
|
||||
// コンソールで表示
|
||||
// 管理パネル
|
||||
import AdminPanel from "./panel/main.js";
|
||||
import { styleText } from "util";
|
||||
(async () => {
|
||||
await AdminPanel();
|
||||
})();
|
||||
|
||||
// 起動表示
|
||||
console.log("BOTサーバーが起動しました");
|
||||
|
||||
import config from "./config.js";
|
||||
if (config.debug !== undefined) {
|
||||
console.log(styleText(["bgRed", "cyan", "bold"], "デバッグモードで起動中"));
|
||||
}
|
||||
|
||||
@@ -0,0 +1,93 @@
|
||||
Copyright 2014-2021 Adobe (http://www.adobe.com/), with Reserved Font Name 'Source'
|
||||
|
||||
This Font Software is licensed under the SIL Open Font License, Version 1.1.
|
||||
This license is copied below, and is also available with a FAQ at:
|
||||
https://openfontlicense.org
|
||||
|
||||
|
||||
-----------------------------------------------------------
|
||||
SIL OPEN FONT LICENSE Version 1.1 - 26 February 2007
|
||||
-----------------------------------------------------------
|
||||
|
||||
PREAMBLE
|
||||
The goals of the Open Font License (OFL) are to stimulate worldwide
|
||||
development of collaborative font projects, to support the font creation
|
||||
efforts of academic and linguistic communities, and to provide a free and
|
||||
open framework in which fonts may be shared and improved in partnership
|
||||
with others.
|
||||
|
||||
The OFL allows the licensed fonts to be used, studied, modified and
|
||||
redistributed freely as long as they are not sold by themselves. The
|
||||
fonts, including any derivative works, can be bundled, embedded,
|
||||
redistributed and/or sold with any software provided that any reserved
|
||||
names are not used by derivative works. The fonts and derivatives,
|
||||
however, cannot be released under any other type of license. The
|
||||
requirement for fonts to remain under this license does not apply
|
||||
to any document created using the fonts or their derivatives.
|
||||
|
||||
DEFINITIONS
|
||||
"Font Software" refers to the set of files released by the Copyright
|
||||
Holder(s) under this license and clearly marked as such. This may
|
||||
include source files, build scripts and documentation.
|
||||
|
||||
"Reserved Font Name" refers to any names specified as such after the
|
||||
copyright statement(s).
|
||||
|
||||
"Original Version" refers to the collection of Font Software components as
|
||||
distributed by the Copyright Holder(s).
|
||||
|
||||
"Modified Version" refers to any derivative made by adding to, deleting,
|
||||
or substituting -- in part or in whole -- any of the components of the
|
||||
Original Version, by changing formats or by porting the Font Software to a
|
||||
new environment.
|
||||
|
||||
"Author" refers to any designer, engineer, programmer, technical
|
||||
writer or other person who contributed to the Font Software.
|
||||
|
||||
PERMISSION & CONDITIONS
|
||||
Permission is hereby granted, free of charge, to any person obtaining
|
||||
a copy of the Font Software, to use, study, copy, merge, embed, modify,
|
||||
redistribute, and sell modified and unmodified copies of the Font
|
||||
Software, subject to the following conditions:
|
||||
|
||||
1) Neither the Font Software nor any of its individual components,
|
||||
in Original or Modified Versions, may be sold by itself.
|
||||
|
||||
2) Original or Modified Versions of the Font Software may be bundled,
|
||||
redistributed and/or sold with any software, provided that each copy
|
||||
contains the above copyright notice and this license. These can be
|
||||
included either as stand-alone text files, human-readable headers or
|
||||
in the appropriate machine-readable metadata fields within text or
|
||||
binary files as long as those fields can be easily viewed by the user.
|
||||
|
||||
3) No Modified Version of the Font Software may use the Reserved Font
|
||||
Name(s) unless explicit written permission is granted by the corresponding
|
||||
Copyright Holder. This restriction only applies to the primary font name as
|
||||
presented to the users.
|
||||
|
||||
4) The name(s) of the Copyright Holder(s) or the Author(s) of the Font
|
||||
Software shall not be used to promote, endorse or advertise any
|
||||
Modified Version, except to acknowledge the contribution(s) of the
|
||||
Copyright Holder(s) and the Author(s) or with their explicit written
|
||||
permission.
|
||||
|
||||
5) The Font Software, modified or unmodified, in part or in whole,
|
||||
must be distributed entirely under this license, and must not be
|
||||
distributed under any other license. The requirement for fonts to
|
||||
remain under this license does not apply to any document created
|
||||
using the Font Software.
|
||||
|
||||
TERMINATION
|
||||
This license becomes null and void if any of the above conditions are
|
||||
not met.
|
||||
|
||||
DISCLAIMER
|
||||
THE FONT SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
||||
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO ANY WARRANTIES OF
|
||||
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT
|
||||
OF COPYRIGHT, PATENT, TRADEMARK, OR OTHER RIGHT. IN NO EVENT SHALL THE
|
||||
COPYRIGHT HOLDER BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
|
||||
INCLUDING ANY GENERAL, SPECIAL, INDIRECT, INCIDENTAL, OR CONSEQUENTIAL
|
||||
DAMAGES, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
||||
FROM, OUT OF THE USE OR INABILITY TO USE THE FONT SOFTWARE OR FROM
|
||||
OTHER DEALINGS IN THE FONT SOFTWARE.
|
||||
Binary file not shown.
LFS
BIN
Binary file not shown.
BIN
Binary file not shown.
LFS
BIN
Binary file not shown.
@@ -0,0 +1,54 @@
|
||||
import express from "express";
|
||||
import * as os from "os";
|
||||
import config from "../config.js";
|
||||
import { NetworkInterfaceDetails } from "types/types";
|
||||
|
||||
// バックエンドルーティング
|
||||
import CommandExecute from "./route/command.js";
|
||||
import ueusePost from "./route/ueuse.js";
|
||||
import WeatherUeuse from "./route/weather.js";
|
||||
import API from "./route/api.js";
|
||||
import Token from "./route/token.js";
|
||||
import Debug from "./route/debug.js";
|
||||
|
||||
export default async function AdminPanel() {
|
||||
// 無効
|
||||
if (!config.admin.panel.isEnabled) {
|
||||
return;
|
||||
}
|
||||
|
||||
// 管理パネル
|
||||
const app = express();
|
||||
const port = config.admin.panel.port;
|
||||
|
||||
// ルーティング
|
||||
app.use(ueusePost);
|
||||
app.use(CommandExecute);
|
||||
app.use(WeatherUeuse);
|
||||
app.use(API);
|
||||
app.use(Token);
|
||||
app.use(Debug);
|
||||
app.use(express.static("panel/public"));
|
||||
|
||||
app.listen(port, () => {
|
||||
console.log(`http://${LocalIP()}:${port} で管理パネルを起動しました`);
|
||||
});
|
||||
}
|
||||
|
||||
function LocalIP() {
|
||||
const interfaces = os.networkInterfaces();
|
||||
|
||||
for (const name in interfaces) {
|
||||
const iface: any = interfaces[name];
|
||||
|
||||
for (const i of iface) {
|
||||
const details: NetworkInterfaceDetails = i;
|
||||
|
||||
if (details.family === 'IPv4' && details.internal !== true) {
|
||||
return details.address;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return "localhost";
|
||||
}
|
||||
@@ -0,0 +1,40 @@
|
||||
<!DOCTYPE html>
|
||||
<html>
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>管理パネル</title>
|
||||
|
||||
<!-- パッケージ -->
|
||||
<script src="https://cdn.jsdelivr.net/npm/@tailwindcss/browser@4"></script>
|
||||
<script src="https://code.iconify.design/iconify-icon/3.0.0/iconify-icon.min.js"></script>
|
||||
<script>
|
||||
import "iconify-icon";
|
||||
</script>
|
||||
</head>
|
||||
<body class="dark:bg-gray-950 dark:text-white text-center">
|
||||
<h1 class="text-4xl font-bold">noticeUwuzu管理パネル</h1>
|
||||
|
||||
<button id="commandExec" class="border rounded-[10px] p-[5px] m-[10px] mt-[20px] cursor-pointer">
|
||||
コマンド実行
|
||||
</button>
|
||||
|
||||
<button id="weatherUeuse" class="border rounded-[10px] p-[5px] m-[10px] mt-[20px] cursor-pointer">
|
||||
天気お知らせ
|
||||
</button>
|
||||
|
||||
<button id="eventdayUeuse" class="border rounded-[10px] p-[5px] m-[10px] mt-[20px] cursor-pointer">
|
||||
祝日等お知らせ
|
||||
</button>
|
||||
|
||||
<button id="ueuse" class="border rounded-[10px] p-[5px] m-[10px] mt-[20px] cursor-pointer">
|
||||
ユーズ投稿
|
||||
</button>
|
||||
|
||||
<button id="api" class="border rounded-[10px] p-[5px] m-[10px] mt-[20px] cursor-pointer">
|
||||
API使用
|
||||
</button>
|
||||
|
||||
<script src="/script.js"></script>
|
||||
</body>
|
||||
</html>
|
||||
@@ -0,0 +1,106 @@
|
||||
document.getElementById("commandExec").addEventListener("click", async () => {
|
||||
const req = await fetch("/actions/command-execute", {
|
||||
method: "POST",
|
||||
});
|
||||
|
||||
const res = await req.text();
|
||||
|
||||
if (res === "Accepted") {
|
||||
alert("コマンド実行を受け付けました");
|
||||
} else {
|
||||
alert(`コマンド実行の要求にエラーが発生しました:${res}`);
|
||||
}
|
||||
});
|
||||
|
||||
document.getElementById("weatherUeuse").addEventListener("click", async () => {
|
||||
const req = await fetch("/actions/weather", {
|
||||
method: "POST",
|
||||
});
|
||||
|
||||
const res = await req.text();
|
||||
|
||||
if (res === "Accepted") {
|
||||
alert("天気お知らせを受け付けました");
|
||||
} else {
|
||||
alert(`天気お知らせの要求にエラーが発生しました:${res}`);
|
||||
}
|
||||
});
|
||||
|
||||
document.getElementById("eventdayUeuse").addEventListener("click", async () => {
|
||||
const req = await fetch("/actions/eventday", {
|
||||
method: "POST",
|
||||
});
|
||||
|
||||
const res = await req.text();
|
||||
|
||||
if (res === "Accepted") {
|
||||
alert("祝日等お知らせを受け付けました");
|
||||
} else {
|
||||
alert(`祝日等お知らせの要求にエラーが発生しました:${res}`);
|
||||
}
|
||||
});
|
||||
|
||||
document.getElementById("ueuse").addEventListener("click", async () => {
|
||||
const text = prompt("ユーズ内容").toLowerCase();
|
||||
|
||||
if (text === "") {
|
||||
alert("ユーズ内容がありません。");
|
||||
return;
|
||||
}
|
||||
|
||||
const nsfw = confirm("NSFWにしますか?");
|
||||
|
||||
const req = await fetch("/actions/ueuse", {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
},
|
||||
body: JSON.stringify({
|
||||
text, text,
|
||||
nsfw: nsfw,
|
||||
}),
|
||||
});
|
||||
|
||||
const res = await req.text();
|
||||
|
||||
if (res === "Success") {
|
||||
alert("ユーズ投稿を受け付けました");
|
||||
} else {
|
||||
alert(`ユーズ投稿の要求にエラーが発生しました:${res}`);
|
||||
}
|
||||
});
|
||||
|
||||
document.getElementById("api").addEventListener("click", async () => {
|
||||
const token = await (await fetch("/actions/token", {
|
||||
method: "GET",
|
||||
})).text();
|
||||
|
||||
const endpoint = prompt("エンドポイント", "/serverinfo-api").toLowerCase();
|
||||
|
||||
if (endpoint === "") {
|
||||
alert("エンドポイントが設定されていません。");
|
||||
return;
|
||||
}
|
||||
|
||||
const body = prompt("body(JSON)", `{"token": "${token}"}`).toLowerCase();
|
||||
|
||||
if (body === "") {
|
||||
alert("bodyが設定されていません。");
|
||||
return;
|
||||
}
|
||||
|
||||
const req = await fetch("/actions/api", {
|
||||
method: "POST",
|
||||
headers: {
|
||||
"Content-Type": "application/json",
|
||||
},
|
||||
body: JSON.stringify({
|
||||
endpoint: endpoint,
|
||||
body: JSON.parse(body),
|
||||
}),
|
||||
});
|
||||
|
||||
const res = await req.text();
|
||||
|
||||
alert(res);
|
||||
});
|
||||
@@ -0,0 +1,34 @@
|
||||
import express from "express";
|
||||
const API = express.Router();
|
||||
|
||||
import config from "../../config.js";
|
||||
|
||||
API.use(express.json());
|
||||
API.use(express.urlencoded({ extended: true }));
|
||||
|
||||
API.post("/actions/api", async (req, res, next) => {
|
||||
const endpoint = req.body.endpoint;
|
||||
const body = req.body.body;
|
||||
|
||||
try {
|
||||
const apiReq = await fetch(`${config.uwuzu.host}/api${endpoint}`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify(body),
|
||||
});
|
||||
|
||||
const apiRes = await apiReq.json();
|
||||
|
||||
res.status(200)
|
||||
.send(apiRes);
|
||||
} catch(err) {
|
||||
res.status(500)
|
||||
.send(`Error: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
API.get("/actions/api", (req, res) => {
|
||||
res.status(501)
|
||||
.send("POST Only");
|
||||
});
|
||||
|
||||
export default API;
|
||||
@@ -0,0 +1,25 @@
|
||||
import express from "express";
|
||||
const CommandExecute = express.Router();
|
||||
|
||||
import Commands from "../../scripts/commands/main.js";
|
||||
|
||||
CommandExecute.post("/actions/command-execute", (req, res) => {
|
||||
try {
|
||||
(async () => {
|
||||
await Commands();
|
||||
})();
|
||||
|
||||
res.status(202)
|
||||
.send("Accepted");
|
||||
} catch(err) {
|
||||
res.status(500)
|
||||
.send(`Error: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
CommandExecute.get("/actions/command-execute", (req, res) => {
|
||||
res.status(501)
|
||||
.send("POST Only");
|
||||
});
|
||||
|
||||
export default CommandExecute;
|
||||
@@ -0,0 +1,24 @@
|
||||
import express from "express";
|
||||
const Debug = express.Router();
|
||||
|
||||
import config from "../../config.js";
|
||||
|
||||
Debug.post("/actions/debug", (req, res, next) => {
|
||||
res.status(501)
|
||||
.send("GET Only");
|
||||
});
|
||||
|
||||
Debug.get("/actions/debug", (req, res) => {
|
||||
let debug;
|
||||
|
||||
if (config.debug === undefined) {
|
||||
debug = false;
|
||||
} else {
|
||||
debug = true;
|
||||
}
|
||||
|
||||
res.status(200)
|
||||
.send(debug);
|
||||
});
|
||||
|
||||
export default Debug;
|
||||
@@ -0,0 +1,25 @@
|
||||
import express from "express";
|
||||
const EventdayUeuse = express.Router();
|
||||
|
||||
import EventDays from "../../scripts/eventday.js";
|
||||
|
||||
EventdayUeuse.post("/actions/eventday", (req, res) => {
|
||||
try {
|
||||
(async () => {
|
||||
await EventDays();
|
||||
})();
|
||||
|
||||
res.status(202)
|
||||
.send("Accepted");
|
||||
} catch(err) {
|
||||
res.status(500)
|
||||
.send(`Error: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
EventdayUeuse.get("/actions/eventday", (req, res) => {
|
||||
res.status(501)
|
||||
.send("POST Only");
|
||||
});
|
||||
|
||||
export default EventdayUeuse;
|
||||
@@ -0,0 +1,16 @@
|
||||
import express from "express";
|
||||
const Token = express.Router();
|
||||
|
||||
import config from "../../config.js";
|
||||
|
||||
Token.post("/actions/token", (req, res, next) => {
|
||||
res.status(501)
|
||||
.send("GET Only");
|
||||
});
|
||||
|
||||
Token.get("/actions/token", (req, res) => {
|
||||
res.status(200)
|
||||
.send(config.uwuzu.apiToken);
|
||||
});
|
||||
|
||||
export default Token;
|
||||
@@ -0,0 +1,44 @@
|
||||
import express from "express";
|
||||
const ueusePost = express.Router();
|
||||
|
||||
import config from "../../config.js";
|
||||
|
||||
ueusePost.use(express.json());
|
||||
ueusePost.use(express.urlencoded({ extended: true }));
|
||||
|
||||
ueusePost.post("/actions/ueuse", async (req, res, next) => {
|
||||
const text = req.body.text;
|
||||
const nsfw = req.body.nsfw;
|
||||
|
||||
try {
|
||||
const ueuseReq = await fetch(`${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
${text}
|
||||
|
||||
このユーズはnoticeUwuzuの管理パネルから投稿されました
|
||||
`,
|
||||
nsfw: nsfw,
|
||||
}),
|
||||
});
|
||||
|
||||
const ueuseRes = await ueuseReq.json();
|
||||
|
||||
console.log(`ユーズ(管理パネル):${JSON.stringify(ueuseRes)}`);
|
||||
|
||||
res.status(200)
|
||||
.send("Success");
|
||||
} catch(err) {
|
||||
res.status(500)
|
||||
.send(`Error: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
ueusePost.get("/actions/ueuse", (req, res) => {
|
||||
res.status(501)
|
||||
.send("POST Only");
|
||||
});
|
||||
|
||||
export default ueusePost;
|
||||
@@ -0,0 +1,25 @@
|
||||
import express from "express";
|
||||
const WeatherUeuse = express.Router();
|
||||
|
||||
import { weatherNotice } from "../../scripts/weatherNotice.js";
|
||||
|
||||
WeatherUeuse.post("/actions/weather", (req, res) => {
|
||||
try {
|
||||
(async () => {
|
||||
await weatherNotice();
|
||||
})();
|
||||
|
||||
res.status(202)
|
||||
.send("Accepted");
|
||||
} catch(err) {
|
||||
res.status(500)
|
||||
.send(`Error: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
WeatherUeuse.get("/actions/weather", (req, res) => {
|
||||
res.status(501)
|
||||
.send("POST Only");
|
||||
});
|
||||
|
||||
export default WeatherUeuse;
|
||||
+4
-1
@@ -1,5 +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"));
|
||||
console.log(fs.readFileSync("asciiart.txt", "utf-8").replace(/(\r?\n)$/, ''));
|
||||
console.log(`${version}\n`);
|
||||
}
|
||||
|
||||
@@ -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,25 @@
|
||||
import { ueuse } from "types/types";
|
||||
import config from "../../config.js";
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
export default async function Follow(data: ueuse) {
|
||||
const followReq = await fetch(`${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);
|
||||
}
|
||||
BIN
Binary file not shown.
@@ -0,0 +1,65 @@
|
||||
import { ueuse } from "types/types";
|
||||
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 === false) {
|
||||
adminMail = "非公開";
|
||||
} else {
|
||||
adminMail = config.admin.showMail;
|
||||
}
|
||||
|
||||
let isReport;
|
||||
|
||||
if (config.report.isEnabled) {
|
||||
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 terms\`をご利用ください。
|
||||
|
||||
プライバシーポリシーをお探しですか?
|
||||
\`/legal privacy\`をご利用ください。
|
||||
|
||||
|
||||
【クレジット】
|
||||
Created by Last2014${editor}
|
||||
`, data.uniqid);
|
||||
|
||||
console.log("概要:", ueuse);
|
||||
}
|
||||
@@ -0,0 +1,7 @@
|
||||
import { ueuse } from "types/types";
|
||||
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";
|
||||
import { Reply } from "../main.js";
|
||||
import config from "../../../config.js";
|
||||
|
||||
export default function Terms(data: ueuse) {
|
||||
Reply(config.legal.terms, data.uniqid);
|
||||
}
|
||||
BIN
Binary file not shown.
BIN
Binary file not shown.
@@ -0,0 +1,74 @@
|
||||
import { ueuse } from "types/types";
|
||||
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.isEnabled) {
|
||||
console.log("報告(重要通知オフ):", await Reply(`
|
||||
BOTの運営者によって重要通知が無効化されています。
|
||||
そのため報告機能はご利用いただけません。
|
||||
`, data.uniqid));
|
||||
return;
|
||||
}
|
||||
|
||||
if (!config.emergency.mail.isEnabled) {
|
||||
console.log("報告(メールオフ):", await Reply(`
|
||||
BOTの運営者によってメール送信機能が無効化されています。
|
||||
そのため報告機能はご利用いただけません。
|
||||
`, data.uniqid));
|
||||
return;
|
||||
}
|
||||
|
||||
if (!config.report.isEnabled) {
|
||||
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コマンドを利用した報告がありました。
|
||||
報告元ユーズ:${config.uwuzu.host}/!${data.uniqid}
|
||||
下記が内容となります。
|
||||
${data.abi}
|
||||
`,
|
||||
});
|
||||
|
||||
console.log("報告(完了):", await Reply(`
|
||||
報告が完了しました。
|
||||
運営者は報告者、ユーズのURL、内容を確認できます。
|
||||
--運営者からのメッセージ--
|
||||
${config.report.message}
|
||||
`, 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";
|
||||
import config from "../../config.js";
|
||||
import { Reply } from "./main.js";
|
||||
|
||||
export default async function UnFollow(data: ueuse) {
|
||||
const unfollowReq = await fetch(`${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";
|
||||
|
||||
export default function Weather(data: ueuse) {
|
||||
weatherReply(data.uniqid);
|
||||
}
|
||||
+232
-116
@@ -1,10 +1,8 @@
|
||||
import WebSocket from "ws";
|
||||
import { differenceInMinutes, subMinutes } from "date-fns";
|
||||
import sendMail from "../src/mailer.js";
|
||||
|
||||
import config from "../config.js";
|
||||
|
||||
let rateLimit: Date | null = null;
|
||||
|
||||
class P2PEarthquakeClient {
|
||||
private ws: WebSocket | null = null;
|
||||
private reconnectInterval: number = config.earthquake.reconnectTimes;
|
||||
@@ -39,8 +37,8 @@ class P2PEarthquakeClient {
|
||||
try {
|
||||
const message = JSON.parse(data.toString());
|
||||
this.handleMessage(message);
|
||||
} catch (error) {
|
||||
console.error("メッセージのパースに失敗:", error);
|
||||
} catch (err) {
|
||||
console.error(`メッセージのパースでエラーが発生: ${err}`);
|
||||
}
|
||||
});
|
||||
|
||||
@@ -65,27 +63,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;
|
||||
case 555: // 地域情報更新情報
|
||||
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 {
|
||||
@@ -93,6 +82,7 @@ class P2PEarthquakeClient {
|
||||
|
||||
console.log("地震情報サーバーから切断されました");
|
||||
console.log(`${this.reconnectInterval / 1000}秒後に再接続を試みます`);
|
||||
|
||||
this.reconnectTimer = setTimeout(() => {
|
||||
this.reconnectTimer = null;
|
||||
this.connect();
|
||||
@@ -102,7 +92,7 @@ class P2PEarthquakeClient {
|
||||
private setupCleanup(): void {
|
||||
const cleanup = () => {
|
||||
this.stop();
|
||||
process.exit(0);
|
||||
process.exit();
|
||||
};
|
||||
|
||||
process.on("SIGINT", cleanup);
|
||||
@@ -122,7 +112,7 @@ class P2PEarthquakeClient {
|
||||
}
|
||||
}
|
||||
|
||||
// 地名オブジェクトマッピング
|
||||
// 地名マッピング
|
||||
async function areaMap(): Promise<Record<number, string>> {
|
||||
const res = await fetch(config.earthquake.areasCsvUrl);
|
||||
|
||||
@@ -147,41 +137,48 @@ 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 = "";
|
||||
|
||||
if (earthquakeInfo.earthquake.description !== "") {
|
||||
if (
|
||||
earthquakeInfo.earthquake.description !== "" ||
|
||||
earthquakeInfo.earthquake.description !== undefined
|
||||
) {
|
||||
descriptionEarthquake = `この地震について:${earthquakeInfo.earthquake.description}`;
|
||||
}
|
||||
|
||||
// 発令詳細
|
||||
let description: string = "";
|
||||
|
||||
if (earthquakeInfo.comments.freeFormComment !== "") {
|
||||
if (
|
||||
earthquakeInfo.comments.freeFormComment !== "" ||
|
||||
earthquakeInfo.comments.freeFormComment !== undefined
|
||||
) {
|
||||
description = `この発令について:${earthquakeInfo.comments.freeFormComment}`;
|
||||
}
|
||||
|
||||
// テスト・訓練
|
||||
let test: string = "";
|
||||
|
||||
if (earthquakeInfo.test) {
|
||||
if (earthquakeInfo.test !== undefined) {
|
||||
test = "この情報にテスト・訓練かの情報はありません";
|
||||
} else if (earthquakeInfo.test) {
|
||||
test = "これはテスト、あるいは訓練です";
|
||||
} else if (earthquakeInfo.test === false) {
|
||||
test = "これはテスト・訓練ではありません";
|
||||
} else {
|
||||
test = "この情報にテスト・訓練かの情報はありません";
|
||||
}
|
||||
|
||||
// 対象地域
|
||||
let areas: string = "";
|
||||
|
||||
if (earthquakeInfo.areas !== null) {
|
||||
if (earthquakeInfo.areas !== undefined) {
|
||||
const areaNames: Array<string> = Array.from(
|
||||
new Set(
|
||||
earthquakeInfo.areas.map((point: any) => point.name).filter(Boolean),
|
||||
@@ -201,8 +198,8 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
let magnitude: string = "マグニチュード:";
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== -1 ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude === null
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude != -1 ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude === undefined
|
||||
) {
|
||||
magnitude += "マグニチュードの情報はありません";
|
||||
} else {
|
||||
@@ -223,100 +220,148 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
|
||||
// 地震情報
|
||||
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: string = "最大深度:";
|
||||
|
||||
if (earthquakeInfo.earthquake.maxScale < config.earthquake.maxScaleMin) {
|
||||
console.log("最低震度に満たしていないため投稿されませんでした");
|
||||
return;
|
||||
}
|
||||
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 === null
|
||||
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]}`;
|
||||
}
|
||||
|
||||
// 警告
|
||||
if (
|
||||
earthquakeInfo.earthquake.maxScale !== undefined &&
|
||||
earthquakeInfo.earthquake.maxScale >= 60 &&
|
||||
config.emergency.isEnabled
|
||||
) {
|
||||
console.log("----------------");
|
||||
|
||||
console.log("震度6強以上の地震を受信しました");
|
||||
console.log("サーバーがダウンする可能性があります");
|
||||
|
||||
// メール送信
|
||||
if (config.emergency.isEnabled) {
|
||||
sendMail({
|
||||
to: config.emergency.mail.to,
|
||||
subject: "【警告】震度6強以上の地震を受信しました",
|
||||
text: `
|
||||
※noticeUwuzu自動送信によるメールです
|
||||
【警告】
|
||||
BOT管理者さん、noticeUwuzu自動送信メールです。
|
||||
震度6強以上の地震を受信したため警告メールが送信されました。
|
||||
物理、システム的にサーバーがダウンする可能性があります。
|
||||
ご自身の身をお守りください。
|
||||
`
|
||||
});
|
||||
|
||||
console.log("管理者へ警告メールを送信しました");
|
||||
}
|
||||
|
||||
console.log("----------------");
|
||||
}
|
||||
|
||||
// 対象地域
|
||||
let areas: string = "";
|
||||
let areas;
|
||||
|
||||
if (earthquakeInfo.points !== null) {
|
||||
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: string = "";
|
||||
let description;
|
||||
|
||||
if (earthquakeInfo.comments.freeFormComment !== "") {
|
||||
if (
|
||||
earthquakeInfo.comments.freeFormComment !== "" &&
|
||||
earthquakeInfo.comments.freeFormComment !== undefined
|
||||
) {
|
||||
description = `この地震について:${earthquakeInfo.comments.freeFormComment}`;
|
||||
} else {
|
||||
description = "";
|
||||
}
|
||||
|
||||
// 深さ
|
||||
let depth: string = "";
|
||||
let depth;
|
||||
|
||||
if (
|
||||
earthquakeInfo.earthquake.hypocenter.depth !== null ||
|
||||
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 = `深さ:${earthquakeInfo.hypocenter.depth}km`;
|
||||
depth = `深さ:${String(earthquakeInfo.earthquake.hypocenter.depth)}km`;
|
||||
}
|
||||
} else {
|
||||
depth = "深さ:不明";
|
||||
}
|
||||
|
||||
// マグニチュード
|
||||
let magnitude: string = "";
|
||||
let magnitude;
|
||||
|
||||
if(
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== null ||
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== -1
|
||||
earthquakeInfo.earthquake.hypocenter.magnitude !== undefined
|
||||
) {
|
||||
magnitude = `マグニチュード:${earthquakeInfo.earthquake.hypocenter.magnitude}`;
|
||||
if (earthquakeInfo.earthquake.hypocenter.magnitude === -1) {
|
||||
magnitude = "マグニチュード:不明";
|
||||
} else {
|
||||
magnitude = `マグニチュード:M${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
|
||||
}
|
||||
} else {
|
||||
magnitude = "マグニチュード:不明";
|
||||
}
|
||||
|
||||
ueuse(`
|
||||
@@ -330,52 +375,123 @@ async function event(earthquakeInfo: any): Promise<void> {
|
||||
${areas}
|
||||
国内の津波:${domesticTsunami}
|
||||
`);
|
||||
}
|
||||
} else if (earthquakeInfo.code === 552) {
|
||||
console.log("津波予報情報を受信しました");
|
||||
|
||||
// 地域情報更新の場合
|
||||
else if (earthquakeInfo.code === 555) {
|
||||
if (rateLimit === null) {
|
||||
rateLimit = subMinutes(new Date(), 15);
|
||||
}
|
||||
|
||||
// 対象地域マッピング
|
||||
const areaMaps: any = await areaMap();
|
||||
|
||||
const areaNames: Array<string> = Array.from(
|
||||
new Set(
|
||||
earthquakeInfo.areas
|
||||
.map((i: any) => {
|
||||
return areaMaps[i.id];
|
||||
})
|
||||
.filter(Boolean),
|
||||
),
|
||||
);
|
||||
|
||||
const areas = areaNames.join("・");
|
||||
|
||||
if (Math.abs(differenceInMinutes(rateLimit, new Date())) >= config.earthquake.rateLimit) {
|
||||
// 予報取り消し
|
||||
if (earthquakeInfo.cancelled) {
|
||||
ueuse(`
|
||||
==地震情報==
|
||||
【地域情報更新】
|
||||
【津波予報】
|
||||
※津波予報が取り消されました※
|
||||
時刻:${earthquakeInfo.time}
|
||||
対象地域:${areas}
|
||||
`);
|
||||
|
||||
rateLimit = new Date();
|
||||
} else {
|
||||
console.log("レート制限に満たしていないため投稿されませんでした");
|
||||
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 = "津波は直ちには襲来しません";
|
||||
} 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://${config.uwuzuServer}/api/ueuse/create`, {
|
||||
const res = await fetch(`${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.apiToken,
|
||||
token: config.uwuzu.apiToken,
|
||||
text: text,
|
||||
}),
|
||||
cache: "no-store",
|
||||
});
|
||||
|
||||
const resData = await res.json();
|
||||
|
||||
@@ -0,0 +1,30 @@
|
||||
import { format } from "date-fns";
|
||||
import eventdays from "./eventdayData.js";
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function EventDays() {
|
||||
const now = format(new Date(), "MM/dd");
|
||||
|
||||
for (let i = 0; i < Object.keys(eventdays).length; i++) {
|
||||
const day = Object.keys(eventdays)[i];
|
||||
const value = Object.values(eventdays)[i];
|
||||
const name = value.name;
|
||||
const message = value.message;
|
||||
|
||||
if (day === now) {
|
||||
const req = await fetch(`${config.uwuzu.host}/api/ueuse/create`, {
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.uwuzu.apiToken,
|
||||
text:
|
||||
`今日は${name}です
|
||||
${message}`,
|
||||
}),
|
||||
});
|
||||
|
||||
const res = await req.json();
|
||||
|
||||
console.log("祝日等ユーズ:", res);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,70 @@
|
||||
interface eventdaysValue {
|
||||
name: string;
|
||||
message: string;
|
||||
}
|
||||
|
||||
const eventdays = {
|
||||
"01/01": {
|
||||
name: "元日",
|
||||
message: "はい年越した瞬間地球にいなかった~",
|
||||
},
|
||||
"02/11": {
|
||||
name: "建国記念日",
|
||||
message: "建国記念日とかいう強制休暇",
|
||||
},
|
||||
"04/29": {
|
||||
name: "昭和の日",
|
||||
message: "平成の日は???",
|
||||
},
|
||||
"05/03": {
|
||||
name: "憲法記念日",
|
||||
message: "憲法決めた日とか祝日じゃなくていいだろ",
|
||||
},
|
||||
"05/04": {
|
||||
name: "みどりの日",
|
||||
message:
|
||||
`なんだよみどりの日って
|
||||
単色全部作れよ`,
|
||||
},
|
||||
"05/05": {
|
||||
name: "こどもの日",
|
||||
message: "こどもの日あるならおとなの日もあっていいだろ",
|
||||
},
|
||||
"07/07": {
|
||||
name: "七夕",
|
||||
message:
|
||||
`祭りでも行っとけ
|
||||
どーせ開発者のLast2014は家でサーバーいじってるから`,
|
||||
},
|
||||
"08/11": {
|
||||
name: "山の日",
|
||||
message:
|
||||
`空の日と山の日も作れよ
|
||||
水の循環に重要な3つ`,
|
||||
},
|
||||
"11/03": {
|
||||
name: "文化の日",
|
||||
message: "ネットミームできるたびに休みになればいいのになぁ...",
|
||||
},
|
||||
"11/23": {
|
||||
name: "勤労感謝の日",
|
||||
message: "学生は神!!",
|
||||
},
|
||||
"12/24": {
|
||||
name: "クリスマスイブ",
|
||||
message:
|
||||
`リア充爆破します
|
||||
by 開発者`,
|
||||
},
|
||||
"12/25": {
|
||||
name: "クリスマス",
|
||||
message: `リア充爆破します(2回目)
|
||||
by 開発者`,
|
||||
},
|
||||
"12/31": {
|
||||
name: "大晦日",
|
||||
message: "大掃除!!大掃除!!",
|
||||
},
|
||||
} as { [key: string]: eventdaysValue };
|
||||
|
||||
export default eventdays;
|
||||
@@ -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.uwuzuServer}/api/me?token=${config.apiToken}`,
|
||||
{
|
||||
method: "GET",
|
||||
// uwuzu v1.5.4で/api/meのPOSTが死んでいるため簡易的にGET
|
||||
},
|
||||
);
|
||||
|
||||
const meData: types.meApi = await resMe.json();
|
||||
|
||||
console.log(`BOTプロフィール:${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.uwuzuServer}/api/users/follow`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.apiToken,
|
||||
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.isEnabled) {
|
||||
// 前回の終了確認
|
||||
const start = iolog.start;
|
||||
const stop = iolog.stop;
|
||||
|
||||
if (isAfter(start, stop)) {
|
||||
console.log("前回の終了が適切でない可能性があります");
|
||||
|
||||
if (config.emergency.mail.isEnabled) {
|
||||
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();
|
||||
+21
-22
@@ -3,46 +3,45 @@ import { format } from "date-fns";
|
||||
import type * as types from "types/types";
|
||||
import config from "../config.js";
|
||||
|
||||
|
||||
// 停止時間
|
||||
// 時刻取得
|
||||
const start = config.time.stopTimes.start;
|
||||
const stop = config.time.stopTimes.stop;
|
||||
|
||||
// 現在の時間を取得
|
||||
const nowHour = new Date().getHours();
|
||||
|
||||
// 停止時刻内かどうかの判定
|
||||
let inRange: boolean = false;
|
||||
|
||||
if (start < stop) {
|
||||
inRange = nowHour >= start && nowHour < stop;
|
||||
} else {
|
||||
inRange = nowHour >= start || nowHour < stop;
|
||||
}
|
||||
|
||||
|
||||
export default async function timeNotice() {
|
||||
console.log("----------------");
|
||||
// 停止時間
|
||||
// 時刻取得
|
||||
const start = config.time.stopTimes.start;
|
||||
const stop = config.time.stopTimes.stop;
|
||||
|
||||
// 現在の時間を取得
|
||||
const nowHour = new Date().getHours();
|
||||
|
||||
// 停止時刻内かどうかの判定
|
||||
let inRange: boolean = false;
|
||||
|
||||
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.uwuzuServer}/api/ueuse/create`,
|
||||
`${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.apiToken,
|
||||
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)}`);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,24 +1,25 @@
|
||||
import { cityList } from "../src/weatherId.js";
|
||||
|
||||
import type * as types from "types/types.js";
|
||||
import type * as types from "types/types";
|
||||
|
||||
import config from "../config.js";
|
||||
|
||||
export default async function weatherNotice() {
|
||||
export async function weatherNotice() {
|
||||
console.log("----------------");
|
||||
|
||||
// 仮投稿
|
||||
const resUeuse = await fetch(
|
||||
`https://${config.uwuzuServer}/api/ueuse/create`,
|
||||
`${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.apiToken,
|
||||
token: config.uwuzu.apiToken,
|
||||
text: `
|
||||
本日の天気
|
||||
※タイムラインが埋まるため返信に記載しています
|
||||
`,
|
||||
}),
|
||||
cache: "no-store",
|
||||
},
|
||||
);
|
||||
|
||||
@@ -26,7 +27,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;
|
||||
@@ -103,19 +107,20 @@ export default async function weatherNotice() {
|
||||
// 分割投稿
|
||||
for (let i = 0; i < splitCount; i++) {
|
||||
const resReply = await fetch(
|
||||
`https://${config.uwuzuServer}/api/ueuse/create`,
|
||||
`${config.uwuzu.host}/api/ueuse/create`,
|
||||
{
|
||||
method: "POST",
|
||||
body: JSON.stringify({
|
||||
token: config.apiToken,
|
||||
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,64 @@
|
||||
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() {
|
||||
if (
|
||||
config.emergency.isEnabled &&
|
||||
config.emergency.mail.isEnabled
|
||||
) {
|
||||
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> {
|
||||
if (
|
||||
config.emergency.isEnabled &&
|
||||
config.emergency.mail.isEnabled
|
||||
) {
|
||||
try {
|
||||
const transporter: any = 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;
|
||||
}
|
||||
} else {
|
||||
return;
|
||||
}
|
||||
}
|
||||
+6
-5
@@ -1,8 +1,8 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "es2022",
|
||||
"module": "ES2022",
|
||||
"moduleResolution": "bundler",
|
||||
"target": "ES2024",
|
||||
"module": "ESNext",
|
||||
"moduleResolution": "node",
|
||||
"outDir": "./dist",
|
||||
"esModuleInterop": true,
|
||||
"allowSyntheticDefaultImports": true,
|
||||
@@ -17,6 +17,7 @@
|
||||
"paths": {
|
||||
"ws": ["./node_modules/ws/index.js"],
|
||||
"@types/ws": ["./node_modules/@types/ws/index.d.ts"]
|
||||
}
|
||||
}
|
||||
},
|
||||
"removeComments": true,
|
||||
},
|
||||
}
|
||||
|
||||
Vendored
+61
-3
@@ -3,7 +3,6 @@ interface earthquakeTypes {
|
||||
websocketUrl: string;
|
||||
areasCsvUrl: string;
|
||||
maxScaleMin: number;
|
||||
rateLimit: number;
|
||||
}
|
||||
|
||||
interface weatherTypes {
|
||||
@@ -19,11 +18,70 @@ interface timeTypes {
|
||||
stopTimes: stopsTypes;
|
||||
}
|
||||
|
||||
interface emergencyMailFullTypes {
|
||||
isEnabled: true;
|
||||
host: string;
|
||||
port: number;
|
||||
user: string;
|
||||
password: string;
|
||||
secure: boolean;
|
||||
to: string | string[];
|
||||
}
|
||||
|
||||
interface emergencyMailMinTypes {
|
||||
isEnabled: false;
|
||||
mail: undefined;
|
||||
}
|
||||
|
||||
interface emergencyFullTypes {
|
||||
isEnabled: true;
|
||||
mail: emergencyMailFullTypes | emergemcyMailMinTypes;
|
||||
}
|
||||
|
||||
interface emergencyMinTypes {
|
||||
isEnabled: false;
|
||||
}
|
||||
|
||||
interface reportTypes {
|
||||
isEnabled: boolean;
|
||||
message: string;
|
||||
}
|
||||
|
||||
interface legalTypes {
|
||||
terms: string;
|
||||
privacy: string;
|
||||
}
|
||||
|
||||
interface PanelFullTypes {
|
||||
isEnabled: true;
|
||||
port: number;
|
||||
}
|
||||
|
||||
interface PanelMinTypes {
|
||||
isEnabled: false;
|
||||
}
|
||||
|
||||
interface adminTypes {
|
||||
name: string;
|
||||
showMail: string | false;
|
||||
panel: PanelFullTypes | PanelMinTypes;
|
||||
}
|
||||
|
||||
interface uwuzuTypes {
|
||||
apiToken: string;
|
||||
host: string;
|
||||
}
|
||||
|
||||
export interface configTypes {
|
||||
time: timeTypes,
|
||||
earthquake: earthquakeTypes;
|
||||
weather: weatherTypes;
|
||||
miq: boolean;
|
||||
|
||||
apiToken: string;
|
||||
uwuzuServer: string;
|
||||
emergency: emergencyFullTypes | emergencyMinTypes;
|
||||
report: reportTypes;
|
||||
legal: legalTypes;
|
||||
admin: adminTypes;
|
||||
uwuzu: uwuzuTypes;
|
||||
debug?: true;
|
||||
}
|
||||
|
||||
Vendored
+33
-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,31 @@ export interface meApi {
|
||||
language: String;
|
||||
}
|
||||
|
||||
export interface ueuse {
|
||||
uniqid: string;
|
||||
replyid: string;
|
||||
reuseid: string;
|
||||
text: string;
|
||||
account: {
|
||||
username: string;
|
||||
userid: string;
|
||||
user_icon: string;
|
||||
user_header: string;
|
||||
is_bot: boolean;
|
||||
};
|
||||
photo1: string;
|
||||
photo2: string;
|
||||
photo3: string;
|
||||
photo4: string;
|
||||
video1: string;
|
||||
favorite: Array<string>;
|
||||
favorite_cnt: string;
|
||||
datetime: string;
|
||||
abi: string;
|
||||
abidatetime: string;
|
||||
nsfw: boolean;
|
||||
}
|
||||
|
||||
export interface ueuseCreateApi {
|
||||
uniqid: string;
|
||||
userid: string;
|
||||
@@ -31,3 +56,9 @@ export interface ueuseCreateApi {
|
||||
export interface followApi {
|
||||
userid: string;
|
||||
}
|
||||
|
||||
export interface NetworkInterfaceDetails {
|
||||
family: string;
|
||||
internal: boolean;
|
||||
address: string;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user