Compare commits

..

No commits in common. "main" and "v7.1.1" have entirely different histories.
main ... v7.1.1

38 changed files with 163 additions and 1066 deletions

View File

@ -12,13 +12,6 @@ Automatic notification bot for uwuzu
- Earthquake occurs - Earthquake occurs
- Tsunami forecast - Tsunami forecast
- Weather notification - Weather notification
- Commands that users can use freely
- About BOT
- Command Help
- Report to the operator
- Follow back
- Unfollow
- Weather Repost
- Startup requirements check - Startup requirements check
- Check package existence - Check package existence
- Required package version check - Required package version check

View File

@ -3,12 +3,11 @@ import config from "../config.js";
export default async function APICheck() { export default async function APICheck() {
try { try {
const req = await fetch(`${config.uwuzu.host}/api/me/`, { const req = await fetch(`https://${config.uwuzu.host}/api/me/`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
}), })
cache: "no-store",
}); });
const res = await req.json(); const res = await req.json();

View File

@ -1,12 +0,0 @@
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();
}
}

View File

@ -3,16 +3,11 @@ import PackagesCheck from "./packages.js";
import ConfigCheck from "./config.js"; import ConfigCheck from "./config.js";
import APICheck from "./api.js"; import APICheck from "./api.js";
import VersionCheck from "./version.js"; import VersionCheck from "./version.js";
import LegalCheck from "./legal.js";
import config from "../config.js";
export default async function Check() { export default async function Check() {
PackagesIsExist(); PackagesIsExist();
PackagesCheck(); PackagesCheck();
ConfigCheck(); ConfigCheck();
if (config.debug === undefined) {
LegalCheck()
}
await APICheck(); await APICheck();
await VersionCheck(); await VersionCheck();
} }

View File

@ -1,41 +1,35 @@
import * as fs from "fs";
import config from "../config.js"; import config from "../config.js";
import { readFileSync, writeFileSync, existsSync } from "fs";
export default async function VersionCheck() { export default async function VersionCheck() {
const packageJson = JSON.parse(readFileSync("package.json", "utf-8")); const nowVersion: string = JSON.parse(fs.readFileSync("package.json", "utf-8")).version;
// 初期化 // 初期化
if (!existsSync("logs/version.txt")) { if (!fs.existsSync("logs/version.txt")) {
writeFileSync( fs.writeFileSync(
"logs/version.txt", "logs/version.txt",
packageJson.version, nowVersion,
"utf-8", "utf-8",
); );
} }
// 最終起動バージョン取得 // 最終起動バージョン取得
const oldVersion = readFileSync("logs/version.txt", "utf-8"); const oldVersion = fs.readFileSync("logs/version.txt", "utf-8");
if (oldVersion !== packageJson.version) { if (oldVersion !== nowVersion) {
try { try {
writeFileSync( fs.writeFileSync(
"logs/version.txt", "logs/version.txt",
packageJson.version, nowVersion,
"utf-8", "utf-8",
); );
const releaseUrl = `${packageJson.repository.url}/releases/tag/${packageJson.tag}`; await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
await fetch(`${config.uwuzu.host}/api/ueuse/create`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
text: ` text: `${nowVersion}にBOTがアップデートされました`,
${packageJson.version}BOTがアップデートされました
${releaseUrl}
`,
}), }),
cache: "no-store",
}); });
} catch (err) { } catch (err) {
console.log("アップデート通知にエラーが発生しました: ", err); console.log("アップデート通知にエラーが発生しました: ", err);

2
data/.gitignore vendored
View File

@ -1,2 +0,0 @@
*
!.gitignore

View File

@ -17,16 +17,15 @@ const config: configTypes = {
areasCsvUrl: "https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv", // 対象地域CSVファイルのURL areasCsvUrl: "https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv", // 対象地域CSVファイルのURL
maxScaleMin: 30, // 地震発生の際の最低震度(10-70) maxScaleMin: 30, // 地震発生の際の最低震度(10-70)
}, },
// 天気お知らせ設定
weather: { weather: {
splitCount: 4, // 返信の分割数 splitCount: 4, // 返信の分割数
}, },
// 緊急時設定 // 緊急時設定
emergency: { emergency: {
isEnabled: true, // 緊急時のコンソール表示 function: true, // 緊急時のコンソール表示
mail: { mail: {
isEnabled: true, // 緊急時のメール送信 function: true, // 緊急時のメール送信
host: "smtp.example.com", // SMTPサーバー host: "smtp.example.com", // SMTPサーバー
port: 465, // SMTPポート port: 465, // SMTPポート
user: "mailUser@example.com", // BOTメール送信元 user: "mailUser@example.com", // BOTメール送信元
@ -35,31 +34,10 @@ const config: configTypes = {
to: "admin@noticeuwuzu.example.com", // 緊急時メール送信先(配列可) 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: { uwuzu: {
apiToken: "TOKEN_EXAMPLE", // APIトークン apiToken: "TOKEN_EXAMPLE",
host: "https://uwuzu.example.com", // サーバーホスト clientToken: "TOKEN_EXAMPLE",
host: "uwuzu.example.com",
}, },
}; };

23
main.ts
View File

@ -11,7 +11,6 @@ import * as cron from "node-cron";
import timeNotice from "./scripts/timeNotice.js"; 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 earthquakeNotice from "./scripts/earthquakeNotice.js";
import EventDays from "./scripts/eventday.js";
import Commands from "./scripts/commands/main.js"; import Commands from "./scripts/commands/main.js";
// その他機能 // その他機能
@ -29,34 +28,14 @@ cron.schedule("0 * * * *", () => {
}); });
// コマンド(10分/1回) // コマンド(10分/1回)
cron.schedule("*/10 * * * *", () => { cron.schedule('*/10 * * * *', () => {
Commands(); Commands();
}); });
// 祝日などお知らせ(毎日0:00)
cron.schedule("0 0 * * *", () => {
EventDays();
});
// 天気お知らせ(毎日7:00) // 天気お知らせ(毎日7:00)
import { setTimeout } from "timers";
cron.schedule("0 7 * * *", () => { cron.schedule("0 7 * * *", () => {
setTimeout(() => {
weatherNotice(); weatherNotice();
}, 100);
}); });
// 管理パネル
import AdminPanel from "./panel/main.js";
import { styleText } from "util";
(async () => {
await AdminPanel();
})();
// 起動表示 // 起動表示
console.log("BOTサーバーが起動しました"); console.log("BOTサーバーが起動しました");
import config from "./config.js";
if (config.debug !== undefined) {
console.log(styleText(["bgRed", "cyan", "bold"], "デバッグモードで起動中"));
}

View File

@ -1,7 +1,6 @@
{ {
"name": "notice-uwuzu", "name": "notice-uwuzu",
"version": "v8.1.2@uwuzu1.6.1", "version": "v7.1.1(LTS)@uwuzu1.5.4",
"tag": "v8.1.2",
"description": "Notice Bot for uwuzu", "description": "Notice Bot for uwuzu",
"main": "dist/main.js", "main": "dist/main.js",
"scripts": { "scripts": {
@ -11,46 +10,35 @@
"dev": "tsx main.ts", "dev": "tsx main.ts",
"clean": "tsc && node dist/scripts/clean/main.js" "clean": "tsc && node dist/scripts/clean/main.js"
}, },
"repository": {
"type": "git",
"url": "https://gitea.last2014.com/last2014/noticeUwuzu"
},
"keywords": [ "keywords": [
"uwuzu", "uwuzu",
"bot", "bot",
"cron", "cron",
"notice", "notice",
"mail",
"weather", "weather",
"time", "time",
"earthquake", "earthquake"
"command",
"commands"
], ],
"author": { "author": {
"name": "Last2014", "name": "Last2014",
"url": "https://last2014.com", "url": "https://last2014.com",
"email": "info@last2014.com" "email": "info@last2014.com"
}, },
"contributors": [],
"license": "Apache-2.0", "license": "Apache-2.0",
"type": "module", "type": "module",
"dependencies": { "dependencies": {
"@types/date-fns": "^2.5.3", "@types/date-fns": "^2.5.3",
"@types/dotenv": "^6.1.1", "@types/dotenv": "^6.1.1",
"@types/express": "^5.0.3",
"@types/node": "^24.0.7", "@types/node": "^24.0.7",
"@types/node-cron": "^3.0.11", "@types/node-cron": "^3.0.11",
"@types/nodemailer": "^6.4.17", "@types/nodemailer": "^6.4.17",
"@types/ws": "^8.18.1", "@types/ws": "^8.18.1",
"child_process": "^1.0.2", "child_process": "^1.0.2",
"date-fns": "^4.1.0", "date-fns": "^4.1.0",
"express": "^5.1.0",
"fs": "^0.0.1-security", "fs": "^0.0.1-security",
"node-cron": "^4.1.1", "node-cron": "^4.1.1",
"nodemailer": "^7.0.4", "nodemailer": "^7.0.4",
"timers": "^0.1.1", "typescript": "^5.8.3",
"typescript": "^5.9.2",
"ws": "^8.18.3" "ws": "^8.18.3"
}, },
"devDependencies": { "devDependencies": {

View File

@ -1,54 +0,0 @@
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";
}

View File

@ -1,40 +0,0 @@
<!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>

View File

@ -1,106 +0,0 @@
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);
});

View File

@ -1,34 +0,0 @@
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;

View File

@ -1,25 +0,0 @@
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;

View File

@ -1,24 +0,0 @@
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;

View File

@ -1,25 +0,0 @@
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;

View File

@ -1,16 +0,0 @@
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;

View File

@ -1,44 +0,0 @@
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;

View File

@ -1,25 +0,0 @@
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;

View File

@ -1,15 +1,13 @@
import { ueuse } from "types/types"; import { ueuse } from "types/types.js";
import config from "../../config.js"; import config from "../../config.js";
import { Reply } from "./main.js";
export default async function Follow(data: ueuse) { export default async function Follow(data: ueuse) {
const followReq = await fetch(`${config.uwuzu.host}/api/users/follow`, { const followReq = await fetch(`https://${config.uwuzu.host}/api/users/follow`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
userid: data.account.userid, userid: data.account.userid,
}), }),
cache: "no-store",
}); });
const followRes = await followReq.json(); const followRes = await followReq.json();
@ -17,9 +15,18 @@ export default async function Follow(data: ueuse) {
console.log("フォロー: ", followRes); console.log("フォロー: ", followRes);
const notice = await Reply(` const noticeReq = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
method: "POST",
body: JSON.stringify({
token: config.uwuzu.apiToken,
text: `
${data.account.username} ${data.account.username}
`, data.uniqid); `,
replyid: data.uniqid,
}),
});
console.log("フォロー通知: ", notice); const noticeRes = await noticeReq.json();
console.log("フォロー通知: ", noticeRes);
} }

View File

@ -1,79 +0,0 @@
import { ueuse } from "types/types";
import { readFileSync } from "fs";
import { Reply } from "./main.js";
const helpsMin = {
"info": "このBOTについての概要を返信するコマンドです。",
"help": "コマンドの概要を返信します。追記に\`/\`抜きのコマンド名を入力することでそのコマンドの詳細(フル)を返信します。",
"follow": "コマンド送信者をフォローします。",
"unfollow": "コマンド送信者をフォロー解除します。",
"weather": "天気を返信します。",
"report": "運営者に不具合などを報告します。",
"legal terms": "利用規約を返信します。",
"legal privacy": "プライバシーポリシーを返信します。",
} as { [key: string]: string };
const helpsFull = {
"info": `
BOTについての概要を返信するコマンドです
`,
"help": `
\`/\`抜きのコマンド名を入力することでそのコマンドの詳細(フル)を返信します。
`,
"follow": `
使
`,
"unfollow": `
使
`,
"weather": `
毎日7:00の天気を再投稿するわけではなく
`,
"report": `
使
\`/report\`を使用してそのユーズの追記に内容を入力することで使用できます。
`,
"legal terms": `
`,
"legal privacy": `
`,
} as { [key: string]: string };
export default async function Help(data: ueuse) {
const packageJson = JSON.parse(readFileSync("package.json", "utf-8"));
if (
data.abi === "none" ||
data.abi === ""
) {
const helpMsg =
Object.entries(helpsMin)
.map(([command, message]) =>
`\`/${command}\`${message}`
).join('\n');
const ueuse = await Reply(`
${helpMsg}
BOTの概要は\`/info\`をご利用ください。
Wikiを見る${packageJson.repository.url}/wiki
`, data.uniqid);
console.log("ヘルプ:", ueuse);
} else {
const ueuse = await Reply(`
${helpsFull[data.abi]}
${packageJson.repository.url}/wiki
`, data.uniqid);
console.log("ヘルプ:", ueuse);
}
}

View File

@ -1,65 +0,0 @@
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);
}

View File

@ -1,7 +0,0 @@
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);
}

View File

@ -1,7 +0,0 @@
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);
}

View File

@ -1,30 +1,25 @@
import * as fs from "fs"; import * as fs from "fs";
import config from "../../config.js"; import config from "../../config.js";
import type { ueuse } from "types/types"; import type { ueuse } from "types/types.js";
const initialFile: Array<string> = []; const initialFile: Array<string> = [];
// コマンド読み込み // コマンド読み込み
import Info from "./info.js";
import Follow from "./follow.js"; import Follow from "./follow.js";
import UnFollow from "./unfollow.js"; import UnFollow from "./unfollow.js";
import Weather from "./weather.js"; import Weather from "./weather.js";
import Help from "./help.js";
import Report from "./report.js";
import Terms from "./legal/terms.js"
import PrivacyPolicy from "./legal/privacy.js";
// 初期化 // 初期化
if (!fs.existsSync("data/alreadyCommands.json")) { if (!fs.existsSync("logs/alreadyCommands.json")) {
fs.writeFileSync( fs.writeFileSync(
"data/alreadyCommands.json", "logs/alreadyCommands.json",
JSON.stringify(initialFile), JSON.stringify(initialFile),
"utf-8", "utf-8",
); );
} }
// 対応済みユーズ一覧 // 対応済みユーズ一覧
const alreadyCommands: Array<string> = JSON.parse(fs.readFileSync("data/alreadyCommands.json", "utf-8")); const alreadyCommands: Array<string> = JSON.parse(fs.readFileSync("logs/alreadyCommands.json", "utf-8"));
function cutAfterChar(str: string, char: string) { function cutAfterChar(str: string, char: string) {
const index = str.indexOf(char); const index = str.indexOf(char);
@ -36,15 +31,14 @@ function cutAfterChar(str: string, char: string) {
return str.substring(index + 1); return str.substring(index + 1);
} }
export async function Reply(text: string, reply: string) { async function Reply(text: string, reply: string) {
const req = await fetch(`${config.uwuzu.host}/api/ueuse/create`, { const req = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
text: text, text: text,
replyid: reply, replyid: reply,
}), }),
cache: "no-store",
}); });
const res = await req.json(); const res = await req.json();
@ -56,7 +50,7 @@ function alreadyAdd(data: string) {
alreadyCommands[alreadyCommands.length] = data; alreadyCommands[alreadyCommands.length] = data;
fs.writeFileSync( fs.writeFileSync(
"data/alreadyCommands.json", "logs/alreadyCommands.json",
JSON.stringify(alreadyCommands), JSON.stringify(alreadyCommands),
"utf-8", "utf-8",
); );
@ -64,38 +58,28 @@ function alreadyAdd(data: string) {
export default async function Commands() { export default async function Commands() {
const mentionsReq = await fetch( const mentionsReq = await fetch(
`${config.uwuzu.host}/api/ueuse/mentions`, { `https://${config.uwuzu.host}/api/ueuse/mentions`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
}), }),
cache: "no-store",
} }
); );
const mentions: { [key: string]: ueuse } = await mentionsReq.json(); const mentions: Array<ueuse> = await mentionsReq.json();
console.log("----------------"); console.log("----------------");
console.log("コマンド処理"); console.log("コマンド処理");
for (const key in mentions) { for (let i = 0; i < mentions.length; i++) {
if (mentions.hasOwnProperty(key)) { const data = mentions[i];
const data = mentions[key];
// 除外ユーズ // 除外ユーズ
if (data.text === undefined) {
break;
}
if (alreadyCommands.indexOf(data.uniqid) !== -1) { if (alreadyCommands.indexOf(data.uniqid) !== -1) {
break; break;
} }
if ( if (data.text.charAt(0) === "!") {
data.text.charAt(0) === "!" ||
data.text.charAt(0) === "" ||
data.abi === "ignore"
) {
break; break;
} }
@ -104,36 +88,22 @@ export default async function Commands() {
const commandName = cutAfterChar(data.text, "/"); const commandName = cutAfterChar(data.text, "/");
alreadyAdd(data.uniqid);
switch (commandName) { switch (commandName) {
case "":
break;
case "info":
Info(data);
break;
case "help":
Help(data);
break;
case "legal terms":
Terms(data);
break;
case "legal privacy":
PrivacyPolicy(data);
break;
case "report":
Report(data);
break;
case "follow": case "follow":
alreadyAdd(data.uniqid);
Follow(data); Follow(data);
break; break;
case "unfollow": case "unfollow":
alreadyAdd(data.uniqid);
UnFollow(data); UnFollow(data);
break; break;
case "weather": case "weather":
alreadyAdd(data.uniqid);
Weather(data); Weather(data);
break; break;
default: default:
alreadyAdd(data.uniqid);
const reply = await Reply(` const reply = await Reply(`
1\`!\`を入れてください。 1\`!\`を入れてください。
@ -143,5 +113,4 @@ export default async function Commands() {
break; break;
} }
} }
}
} }

View File

@ -1,74 +0,0 @@
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;
}
}

View File

@ -1,25 +1,31 @@
import { ueuse } from "types/types"; import { ueuse } from "types/types.js";
import config from "../../config.js"; import config from "../../config.js";
import { Reply } from "./main.js";
export default async function UnFollow(data: ueuse) { export default async function UnFollow(data: ueuse) {
const unfollowReq = await fetch(`${config.uwuzu.host}/api/users/unfollow`, { const unfollowReq = await fetch(`https://${config.uwuzu.host}/api/users/unfollow`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
userid: data.account.userid, userid: data.account.userid,
}), }),
cache: "no-store",
}); });
const unfollowRes = await unfollowReq.json(); const unfollowRes = await unfollowReq.json();
console.log("フォロー解除: ", unfollowRes); console.log("フォロー解除: ", unfollowRes);
const noticeReq = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
const notice = await Reply(` method: "POST",
body: JSON.stringify({
token: config.uwuzu.apiToken,
text: `
${data.account.username} ${data.account.username}
`, data.uniqid); `,
replyid: data.uniqid,
}),
});
console.log("フォロー解除通知: ", notice); const noticeRes = await noticeReq.json();
console.log("フォロー解除通知: ", noticeRes);
} }

View File

@ -1,5 +1,5 @@
import { weatherReply } from "../weatherNotice.js"; import { weatherReply } from "../weatherNotice.js";
import { ueuse } from "types/types"; import { ueuse } from "types/types.js";
export default function Weather(data: ueuse) { export default function Weather(data: ueuse) {
weatherReply(data.uniqid); weatherReply(data.uniqid);

View File

@ -73,7 +73,7 @@ class P2PEarthquakeClient {
event(message); event(message);
} else { } else {
console.log(`未対応の情報を受信しました(コード: ${message.code})`); console.log(`未対応の情報を受信しました(コード: ${message.code})`);
console.log("受信メッセージ:", message); console.log(`受信メッセージ:${message}`);
} }
} }
@ -137,7 +137,7 @@ async function areaMap(): Promise<Record<number, string>> {
// 情報受信 // 情報受信
async function event(earthquakeInfo: any): Promise<void> { async function event(earthquakeInfo: any): Promise<void> {
console.log("受信メッセージ:", earthquakeInfo); console.log(`受信メッセージ:${earthquakeInfo}`);
// ----処理---- // ----処理----
// 緊急地震速報の場合 // 緊急地震速報の場合
@ -276,7 +276,7 @@ async function event(earthquakeInfo: any): Promise<void> {
if ( if (
earthquakeInfo.earthquake.maxScale !== undefined && earthquakeInfo.earthquake.maxScale !== undefined &&
earthquakeInfo.earthquake.maxScale >= 60 && earthquakeInfo.earthquake.maxScale >= 60 &&
config.emergency.isEnabled config.emergency.function
) { ) {
console.log("----------------"); console.log("----------------");
@ -284,7 +284,7 @@ async function event(earthquakeInfo: any): Promise<void> {
console.log("サーバーがダウンする可能性があります"); console.log("サーバーがダウンする可能性があります");
// メール送信 // メール送信
if (config.emergency.isEnabled) { if (config.emergency.function) {
sendMail({ sendMail({
to: config.emergency.mail.to, to: config.emergency.mail.to,
subject: "【警告】震度6強以上の地震を受信しました", subject: "【警告】震度6強以上の地震を受信しました",
@ -314,8 +314,6 @@ async function event(earthquakeInfo: any): Promise<void> {
), ),
); );
areas = `対象地域:${areaNames.join("・")}`; areas = `対象地域:${areaNames.join("・")}`;
} else {
areas = "対象地域:不明";
} }
// 詳細 // 詳細
@ -326,8 +324,6 @@ async function event(earthquakeInfo: any): Promise<void> {
earthquakeInfo.comments.freeFormComment !== undefined earthquakeInfo.comments.freeFormComment !== undefined
) { ) {
description = `この地震について:${earthquakeInfo.comments.freeFormComment}`; description = `この地震について:${earthquakeInfo.comments.freeFormComment}`;
} else {
description = "";
} }
// 深さ // 深さ
@ -344,8 +340,6 @@ async function event(earthquakeInfo: any): Promise<void> {
} else { } else {
depth = `深さ:${String(earthquakeInfo.earthquake.hypocenter.depth)}km`; depth = `深さ:${String(earthquakeInfo.earthquake.hypocenter.depth)}km`;
} }
} else {
depth = "深さ:不明";
} }
// マグニチュード // マグニチュード
@ -356,12 +350,10 @@ async function event(earthquakeInfo: any): Promise<void> {
earthquakeInfo.earthquake.hypocenter.magnitude !== undefined earthquakeInfo.earthquake.hypocenter.magnitude !== undefined
) { ) {
if (earthquakeInfo.earthquake.hypocenter.magnitude === -1) { if (earthquakeInfo.earthquake.hypocenter.magnitude === -1) {
magnitude = "マグニチュード:不明"; depth = "マグニチュード:不明";
} else { } else {
magnitude = `マグニチュードM${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`; magnitude = `マグニチュードM${String(earthquakeInfo.earthquake.hypocenter.magnitude)}`;
} }
} else {
magnitude = "マグニチュード:不明";
} }
ueuse(` ueuse(`
@ -425,8 +417,6 @@ async function event(earthquakeInfo: any): Promise<void> {
immediate = "### 津波が直ちに襲来します"; immediate = "### 津波が直ちに襲来します";
} else if (!data.immediate) { } else if (!data.immediate) {
immediate = "津波は直ちには襲来しません"; immediate = "津波は直ちには襲来しません";
} else {
immediate = "津波の襲来が直後かの情報がありません";
} }
// 第1波 // 第1波
@ -485,13 +475,12 @@ async function event(earthquakeInfo: any): Promise<void> {
} }
async function ueuse(text: string) { async function ueuse(text: string) {
const res = await fetch(`${config.uwuzu.host}/api/ueuse/create`, { const res = await fetch(`https://${config.uwuzu.host}/api/ueuse/create`, {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
text: text, text: text,
}), }),
cache: "no-store",
}); });
const resData = await res.json(); const resData = await res.json();

View File

@ -1,30 +0,0 @@
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);
}
}
}

View File

@ -1,70 +0,0 @@
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;

View File

@ -1,5 +1,5 @@
import * as fs from "fs"; import * as fs from "fs";
import { isAfter } from "date-fns"; import { isBefore } from "date-fns/fp";
import config from "../config.js"; import config from "../config.js";
import sendMail from "../src/mailer.js"; import sendMail from "../src/mailer.js";
@ -15,15 +15,15 @@ export default function successExit() {
const iolog = JSON.parse(fs.readFileSync("logs/boot.json", "utf-8")); const iolog = JSON.parse(fs.readFileSync("logs/boot.json", "utf-8"));
if (config.emergency.isEnabled) { if (config.emergency.function) {
// 前回の終了確認 // 前回の終了確認
const start = iolog.start; const start = iolog.start;
const stop = iolog.stop; const stop = iolog.stop;
if (isAfter(start, stop)) { if (isBefore(start, stop)) {
console.log("前回の終了が適切でない可能性があります"); console.log("前回の終了が適切でない可能性があります");
if (config.emergency.mail.isEnabled) { if (config.emergency.mail.function) {
sendMail({ sendMail({
to: config.emergency.mail.to, to: config.emergency.mail.to,
subject: "【警告】前回終了が不適切な可能性", subject: "【警告】前回終了が不適切な可能性",

View File

@ -28,14 +28,13 @@ export default async function timeNotice() {
} else { } else {
// 投稿 // 投稿
const resUeuse = await fetch( const resUeuse = await fetch(
`${config.uwuzu.host}/api/ueuse/create`, `https://${config.uwuzu.host}/api/ueuse/create`,
{ {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
token: config.uwuzu.apiToken, token: config.uwuzu.apiToken,
text: `${format(new Date(), "HH:mm")}になりました`, text: `${format(new Date(), "HH:mm")}になりました`,
}), }),
cache: "no-store",
}, },
); );

View File

@ -1,6 +1,6 @@
import { cityList } from "../src/weatherId.js"; import { cityList } from "../src/weatherId.js";
import type * as types from "types/types"; import type * as types from "types/types.js";
import config from "../config.js"; import config from "../config.js";
@ -9,7 +9,7 @@ export async function weatherNotice() {
// 仮投稿 // 仮投稿
const resUeuse = await fetch( const resUeuse = await fetch(
`${config.uwuzu.host}/api/ueuse/create`, `https://${config.uwuzu.host}/api/ueuse/create`,
{ {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
@ -19,7 +19,6 @@ export async function weatherNotice() {
`, `,
}), }),
cache: "no-store",
}, },
); );
@ -107,7 +106,7 @@ export async function weatherReply(uniqid: string) {
// 分割投稿 // 分割投稿
for (let i = 0; i < splitCount; i++) { for (let i = 0; i < splitCount; i++) {
const resReply = await fetch( const resReply = await fetch(
`${config.uwuzu.host}/api/ueuse/create`, `https://${config.uwuzu.host}/api/ueuse/create`,
{ {
method: "POST", method: "POST",
body: JSON.stringify({ body: JSON.stringify({
@ -115,7 +114,6 @@ export async function weatherReply(uniqid: string) {
text: weatherResults[i], text: weatherResults[i],
replyid: uniqid, replyid: uniqid,
}), }),
cache: "no-store",
}, },
); );

View File

@ -11,10 +11,6 @@ export interface EmailMessage {
} }
async function createTransporter() { async function createTransporter() {
if (
config.emergency.isEnabled &&
config.emergency.mail.isEnabled
) {
const transporter = nodemailer.createTransport({ const transporter = nodemailer.createTransport({
host: config.emergency.mail.host, host: config.emergency.mail.host,
port: config.emergency.mail.port, port: config.emergency.mail.port,
@ -35,16 +31,11 @@ async function createTransporter() {
} }
return transporter; return transporter;
}
} }
export default async function sendMail(message: EmailMessage): Promise<void> { export default async function sendMail(message: EmailMessage): Promise<void> {
if (
config.emergency.isEnabled &&
config.emergency.mail.isEnabled
) {
try { try {
const transporter: any = await createTransporter(); const transporter = await createTransporter();
await transporter.sendMail({ await transporter.sendMail({
from: config.emergency.mail.user, from: config.emergency.mail.user,
@ -58,7 +49,4 @@ export default async function sendMail(message: EmailMessage): Promise<void> {
console.error("メール送信に失敗しました:", error); console.error("メール送信に失敗しました:", error);
throw error; throw error;
} }
} else {
return;
}
} }

View File

@ -2,7 +2,7 @@
"compilerOptions": { "compilerOptions": {
"target": "ES2024", "target": "ES2024",
"module": "ESNext", "module": "ESNext",
"moduleResolution": "node", "moduleResolution": "bundler",
"outDir": "./dist", "outDir": "./dist",
"esModuleInterop": true, "esModuleInterop": true,
"allowSyntheticDefaultImports": true, "allowSyntheticDefaultImports": true,

57
types/config.d.ts vendored
View File

@ -18,57 +18,24 @@ interface timeTypes {
stopTimes: stopsTypes; stopTimes: stopsTypes;
} }
interface emergencyMailFullTypes { interface emergencyMailTypes {
isEnabled: true; function: Boolean;
host: string; host: string | undefined;
port: number; port: number;
user: string; user: string;
password: string; password: string;
secure: boolean; secure: Boolean;
to: string | string[]; to: string;
} }
interface emergencyMailMinTypes { interface emergencyTypes {
isEnabled: false; function: Boolean;
mail: undefined; mail: emergencyMailTypes;
}
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 { interface uwuzuTypes {
apiToken: string; apiToken: string;
clientToken?: string;
host: string; host: string;
} }
@ -77,10 +44,6 @@ export interface configTypes {
earthquake: earthquakeTypes; earthquake: earthquakeTypes;
weather: weatherTypes; weather: weatherTypes;
emergency: emergencyFullTypes | emergencyMinTypes; emergency: emergencyTypes;
report: reportTypes;
legal: legalTypes;
admin: adminTypes;
uwuzu: uwuzuTypes; uwuzu: uwuzuTypes;
debug?: true;
} }

19
types/types.d.ts vendored
View File

@ -25,21 +25,18 @@ export interface meApi {
export interface ueuse { export interface ueuse {
uniqid: string; uniqid: string;
relpyid: string;
reuseid: string;
text: string; text: string;
account: { account: {
username: string; username: string;
userid: string; userid: string;
user_icon: string; user_icon: string;
user_header: string; user_header: string;
is_bot: boolean;
}; };
photo1: string; photo1: Base64URLString;
photo2: string; photo2: Base64URLString;
photo3: string; photo3: Base64URLString;
photo4: string; photo4: Base64URLString;
video1: string; video1: Base64URLString;
favorite: Array<string>; favorite: Array<string>;
favorite_cnt: string; favorite_cnt: string;
datetime: string; datetime: string;
@ -56,9 +53,3 @@ export interface ueuseCreateApi {
export interface followApi { export interface followApi {
userid: string; userid: string;
} }
export interface NetworkInterfaceDetails {
family: string;
internal: boolean;
address: string;
}