Compare commits
8 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e3451323f3 | |||
| 8be3684a78 | |||
| 600626d071 | |||
| 5c0c34bbb4 | |||
| 88bd2e88a5 | |||
| 7c7dfdcf3c | |||
| dd70fe5494 | |||
| 73091bb92f |
@@ -1,10 +1,19 @@
|
|||||||
import type { configTypes } from "types/config";
|
import type { configTypes } from "types/config";
|
||||||
|
|
||||||
|
// READMEの設定項目を参照
|
||||||
const config: configTypes = {
|
const config: configTypes = {
|
||||||
|
time: {
|
||||||
|
stopTimes: {
|
||||||
|
start: new Date("23:00"),
|
||||||
|
stop: new Date("6:00"),
|
||||||
|
}
|
||||||
|
},
|
||||||
earthquake: {
|
earthquake: {
|
||||||
reconnectTimes: 5000,
|
reconnectTimes: 5000,
|
||||||
websocketUrl: "wss://api.p2pquake.net/v2/ws",
|
websocketUrl: "wss://api.p2pquake.net/v2/ws",
|
||||||
areasCsvUrl: "https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv",
|
areasCsvUrl: "https://raw.githubusercontent.com/p2pquake/epsp-specifications/master/epsp-area.csv",
|
||||||
|
maxScaleMax: 30,
|
||||||
|
rateLimit: 30,
|
||||||
},
|
},
|
||||||
weather: {
|
weather: {
|
||||||
splitCount: 4,
|
splitCount: 4,
|
||||||
|
|||||||
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "noticeuwuzu",
|
"name": "noticeuwuzu",
|
||||||
"version": "v3.5.1@uwuzu1.5.4",
|
"version": "v4.0@uwuzu1.5.4",
|
||||||
"description": "uwuzu Notice Bot",
|
"description": "uwuzu Notice Bot",
|
||||||
"main": "dist/main.js",
|
"main": "dist/main.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
@@ -1,7 +1,10 @@
|
|||||||
import WebSocket from "ws";
|
import WebSocket from "ws";
|
||||||
|
import { differenceInMinutes } from "date-fns";
|
||||||
|
|
||||||
import config from "../config.js";
|
import config from "../config.js";
|
||||||
|
|
||||||
|
let rateLimit: Date;
|
||||||
|
|
||||||
class P2PEarthquakeClient {
|
class P2PEarthquakeClient {
|
||||||
private ws: WebSocket | null = null;
|
private ws: WebSocket | null = null;
|
||||||
private reconnectInterval: number = config.earthquake.reconnectTimes;
|
private reconnectInterval: number = config.earthquake.reconnectTimes;
|
||||||
@@ -178,12 +181,9 @@ async function event(earthquakeInfo: any): Promise<void> {
|
|||||||
if (earthquakeInfo.areas !== null) {
|
if (earthquakeInfo.areas !== null) {
|
||||||
const areaNames: Array<string> = Array.from(
|
const areaNames: Array<string> = Array.from(
|
||||||
new Set(
|
new Set(
|
||||||
earthquakeInfo.areas.map((i: any) => {
|
earthquakeInfo.areas.map((point: any) => point.name).filter(Boolean),
|
||||||
earthquakeInfo.areas[i].name.filter(Boolean);
|
|
||||||
}),
|
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
|
|
||||||
areas = `対象地域:${areaNames.join("・")}`;
|
areas = `対象地域:${areaNames.join("・")}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -243,6 +243,10 @@ async function event(earthquakeInfo: any): Promise<void> {
|
|||||||
// 最大震度
|
// 最大震度
|
||||||
let maxScale: string = "最大深度:";
|
let maxScale: string = "最大深度:";
|
||||||
|
|
||||||
|
if (earthquakeInfo.earthquake.maxScale < config.earthquake.maxScaleMax) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if (
|
if (
|
||||||
earthquakeInfo.earthquake.maxScale === -1 ||
|
earthquakeInfo.earthquake.maxScale === -1 ||
|
||||||
earthquakeInfo.earthquake.maxScale === null
|
earthquakeInfo.earthquake.maxScale === null
|
||||||
@@ -273,9 +277,10 @@ async function event(earthquakeInfo: any): Promise<void> {
|
|||||||
|
|
||||||
if (earthquakeInfo.points !== null) {
|
if (earthquakeInfo.points !== null) {
|
||||||
const areaNames: Array<string> = Array.from(
|
const areaNames: Array<string> = Array.from(
|
||||||
new Set(earthquakeInfo.points.map((i: any) => i.addr).filter(Boolean)),
|
new Set(
|
||||||
|
earthquakeInfo.points.map((point: any) => point.addr).filter(Boolean),
|
||||||
|
),
|
||||||
);
|
);
|
||||||
|
|
||||||
areas = `対象地域:${areaNames.join("・")}`;
|
areas = `対象地域:${areaNames.join("・")}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -286,11 +291,37 @@ async function event(earthquakeInfo: any): Promise<void> {
|
|||||||
description = `この地震について:${earthquakeInfo.comments.freeFormComment}`;
|
description = `この地震について:${earthquakeInfo.comments.freeFormComment}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 深さ
|
||||||
|
let depth: string = "";
|
||||||
|
|
||||||
|
if (
|
||||||
|
earthquakeInfo.earthquake.hypocenter.depth !== null ||
|
||||||
|
earthquakeInfo.earthquake.hypocenter.depth !== -1
|
||||||
|
) {
|
||||||
|
if (earthquakeInfo.earthquake.hypocenter.depth === 0) {
|
||||||
|
depth = "深さ:ごく浅い";
|
||||||
|
} else {
|
||||||
|
depth = `深さ:${earthquakeInfo.hypocenter.depth}km`;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// マグニチュード
|
||||||
|
let magnitude: string = "";
|
||||||
|
|
||||||
|
if(
|
||||||
|
earthquakeInfo.earthquake.hypocenter.magnitude !== null ||
|
||||||
|
earthquakeInfo.earthquake.hypocenter.magnitude !== -1
|
||||||
|
) {
|
||||||
|
magnitude = `マグニチュード:${earthquakeInfo.earthquake.hypocenter.magnitude}`;
|
||||||
|
}
|
||||||
|
|
||||||
ueuse(`
|
ueuse(`
|
||||||
==地震情報==
|
==地震情報==
|
||||||
【地震発生】
|
【地震発生】
|
||||||
時刻:${earthquakeInfo.time}
|
時刻:${earthquakeInfo.time}
|
||||||
${description}
|
${description}
|
||||||
|
${magnitude}
|
||||||
|
${depth}
|
||||||
${maxScale}
|
${maxScale}
|
||||||
${areas}
|
${areas}
|
||||||
国内の津波:${domesticTsunami}
|
国内の津波:${domesticTsunami}
|
||||||
@@ -299,25 +330,35 @@ async function event(earthquakeInfo: any): Promise<void> {
|
|||||||
|
|
||||||
// 地域情報更新の場合
|
// 地域情報更新の場合
|
||||||
else if (earthquakeInfo.code === 555) {
|
else if (earthquakeInfo.code === 555) {
|
||||||
|
if (rateLimit === null) {
|
||||||
|
rateLimit = new Date();
|
||||||
|
}
|
||||||
|
|
||||||
// 対象地域マッピング
|
// 対象地域マッピング
|
||||||
const areaMaps: any = await areaMap();
|
const areaMaps: any = await areaMap();
|
||||||
|
|
||||||
const areaNames: Array<string> = Array.from(
|
const areaNames: Array<string> = Array.from(
|
||||||
new Set(
|
new Set(
|
||||||
earthquakeInfo.areas.map((i: any) => {
|
earthquakeInfo.areas
|
||||||
areaMaps[i.id].filter(Boolean);
|
.map((i: any) => {
|
||||||
}),
|
return areaMaps[i.id];
|
||||||
|
})
|
||||||
|
.filter(Boolean),
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
|
|
||||||
const areas = areaNames.join("・");
|
const areas = areaNames.join("・");
|
||||||
|
|
||||||
|
if (differenceInMinutes(rateLimit, new Date()) >= config.earthquake.rateLimit) {
|
||||||
ueuse(`
|
ueuse(`
|
||||||
==地震情報==
|
==地震情報==
|
||||||
【地域情報更新】
|
【地域情報更新】
|
||||||
時刻:${earthquakeInfo.time}
|
時刻:${earthquakeInfo.time}
|
||||||
対象地域:${areas}
|
対象地域:${areas}
|
||||||
`);
|
`);
|
||||||
|
|
||||||
|
rateLimit = new Date();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+18
-5
@@ -1,13 +1,25 @@
|
|||||||
import { format } from "date-fns";
|
import { format, isAfter, isBefore } from "date-fns";
|
||||||
|
|
||||||
import type * as types from "types/types";
|
import type * as types from "types/types";
|
||||||
|
|
||||||
import config from "../config.js";
|
import config from "../config.js";
|
||||||
|
|
||||||
export default async function timeNotice() {
|
// 時刻取得
|
||||||
// 現在時刻を取得
|
const now = new Date();
|
||||||
const now = format(new Date(), "HH:mm");
|
const start = config.time.stopTimes.start;
|
||||||
|
const stop = config.time.stopTimes.stop;
|
||||||
|
|
||||||
|
// 停止時刻外
|
||||||
|
let inRange: Boolean = false;
|
||||||
|
|
||||||
|
if (isBefore(start, stop)) {
|
||||||
|
inRange = isAfter(now, start) && isBefore(now, stop);
|
||||||
|
} else {
|
||||||
|
inRange = isAfter(now, start) || isBefore(now, stop);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
export default async function timeNotice() {
|
||||||
|
if (inRange === false) {
|
||||||
// 投稿
|
// 投稿
|
||||||
const resUeuse = await fetch(
|
const resUeuse = await fetch(
|
||||||
`https://${config.uwuzuServer}/api/ueuse/create`,
|
`https://${config.uwuzuServer}/api/ueuse/create`,
|
||||||
@@ -24,3 +36,4 @@ export default async function timeNotice() {
|
|||||||
|
|
||||||
console.log(JSON.stringify(ueuseData));
|
console.log(JSON.stringify(ueuseData));
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -83,7 +83,7 @@ export default async function weatherNotice() {
|
|||||||
today.chanceOfRain.T06_12 !== null ||
|
today.chanceOfRain.T06_12 !== null ||
|
||||||
today.chanceOfRain.T06_12 !== "--%"
|
today.chanceOfRain.T06_12 !== "--%"
|
||||||
) {
|
) {
|
||||||
chanceOfRain = `${today.chanceOfRain.T06_12}%`;
|
chanceOfRain = today.chanceOfRain.T06_12;
|
||||||
} else {
|
} else {
|
||||||
chanceOfRain = "取得できませんでした";
|
chanceOfRain = "取得できませんでした";
|
||||||
}
|
}
|
||||||
|
|||||||
Vendored
+12
@@ -2,13 +2,25 @@ interface earthquakeTypes {
|
|||||||
reconnectTimes: number;
|
reconnectTimes: number;
|
||||||
websocketUrl: string;
|
websocketUrl: string;
|
||||||
areasCsvUrl: string;
|
areasCsvUrl: string;
|
||||||
|
maxScaleMax: number;
|
||||||
|
rateLimit: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
interface weatherTypes {
|
interface weatherTypes {
|
||||||
splitCount: number;
|
splitCount: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
interface stopsTypes {
|
||||||
|
start: Date;
|
||||||
|
stop: Date;
|
||||||
|
}
|
||||||
|
|
||||||
|
interface timeTypes {
|
||||||
|
stopTimes: stopsTypes;
|
||||||
|
}
|
||||||
|
|
||||||
export interface configTypes {
|
export interface configTypes {
|
||||||
|
time: timeTypes,
|
||||||
earthquake: earthquakeTypes;
|
earthquake: earthquakeTypes;
|
||||||
weather: weatherTypes;
|
weather: weatherTypes;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user