Compare commits
2 Commits
c4e0d2763b
...
8b15157c81
| Author | SHA1 | Date | |
|---|---|---|---|
| 8b15157c81 | |||
| bd2c86658c |
+1
-1
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "earthquake-bot-for-mtweet",
|
"name": "earthquake-bot-for-mtweet",
|
||||||
"version": "1.0.0",
|
"version": "1.0.1",
|
||||||
"type": "module",
|
"type": "module",
|
||||||
"main": "dist/index.js",
|
"main": "dist/index.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { readFileSync, writeFileSync } from "node:fs";
|
import { readFileSync } from "node:fs";
|
||||||
import sharp from "sharp";
|
import sharp from "sharp";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -54,20 +54,7 @@ if (config.earthquake?.useHistoryData) {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
const id = message.id ?? message._id;
|
|
||||||
const mem = Memory.memory;
|
|
||||||
if (mem.processedInfo.includes(id) && !config.debug) {
|
|
||||||
console.log("重複した地震情報:", message.id);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
processMessage(message);
|
processMessage(message);
|
||||||
|
|
||||||
if (!config.debug) {
|
|
||||||
const mem = Memory.memory;
|
|
||||||
mem.processedInfo = mem.processedInfo.concat([id]);
|
|
||||||
Memory.memory = mem;
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+1
-41
@@ -1,7 +1,5 @@
|
|||||||
import { schedule } from "node-cron";
|
|
||||||
import { readFileSync } from "node:fs";
|
import { readFileSync } from "node:fs";
|
||||||
import config from "@/lib/config";
|
import config from "@/lib/config";
|
||||||
import { initData } from "@/lib/memory";
|
|
||||||
import { styleText } from "node:util";
|
import { styleText } from "node:util";
|
||||||
import { Worker } from "node:worker_threads";
|
import { Worker } from "node:worker_threads";
|
||||||
|
|
||||||
@@ -18,9 +16,7 @@ try {
|
|||||||
}
|
}
|
||||||
console.log();
|
console.log();
|
||||||
|
|
||||||
await initData();
|
new Worker(`${import.meta.dirname}/earthquake/index.js`);
|
||||||
|
|
||||||
new Worker(`${import.meta.dirname}/feature/earthquake/index.js`);
|
|
||||||
|
|
||||||
console.log("Botが起動しました");
|
console.log("Botが起動しました");
|
||||||
} catch (err: any) {
|
} catch (err: any) {
|
||||||
@@ -28,40 +24,4 @@ try {
|
|||||||
? err.message
|
? err.message
|
||||||
: err);
|
: err);
|
||||||
process.exit(1);
|
process.exit(1);
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
schedule("0 * * * *", async () => {
|
|
||||||
new Worker(`${import.meta.dirname}/feature/time/index.js`);
|
|
||||||
});
|
|
||||||
|
|
||||||
schedule("0 7 * * *", async () => {
|
|
||||||
new Worker(`${import.meta.dirname}/feature/weatherNotice.js`, {
|
|
||||||
workerData: "scheduledWeatherNotice",
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
schedule("0 18 * * *", async () => {
|
|
||||||
new Worker(`${import.meta.dirname}/feature/weatherNotice.js`, {
|
|
||||||
workerData: "scheduledWeatherNoticeTomorrow",
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
schedule(`*/${config.command.interval} * * * *`, async () => {
|
|
||||||
new Worker(`${import.meta.dirname}/feature/command/index.js`);
|
|
||||||
});
|
|
||||||
|
|
||||||
let hnyWorker: Worker | undefined = undefined;
|
|
||||||
|
|
||||||
schedule("57 59 23 31 12 *", () => {
|
|
||||||
hnyWorker = new Worker(`${import.meta.dirname}/feature/hnyNotice.js`);
|
|
||||||
});
|
|
||||||
|
|
||||||
schedule("0 0 0 1 1 *", () => {
|
|
||||||
hnyWorker?.postMessage("");
|
|
||||||
});
|
|
||||||
} catch (err: any) {
|
|
||||||
console.error("message" in err
|
|
||||||
? err.message
|
|
||||||
: err);
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user