rewrite trigger system

This commit is contained in:
Flummi
2019-08-19 01:28:01 +00:00
parent 22d79eed18
commit 3a751f2e52
30 changed files with 536 additions and 570 deletions

View File

@@ -1,12 +1,12 @@
import logger from "./inc/log";
import _fs from "fs";
import { read, cfg } from "./inc/cfg";
import { default as config } from "../cfg/config.json";
import triggers from "./inc/trigger";
import events from "./inc/events";
import cuffeo from "cuffeo";
const fs = _fs.promises;
const timeout = 1000;
(async () => {
await read(); // read and parse config from database
@@ -24,6 +24,35 @@ import cuffeo from "cuffeo";
bot: new cuffeo(config.clients)
};
triggers.forEach(mod => mod(self));
events.forEach(event => event(self));
console.time("loading");
const modules = {
events: (await fs.readdir("./src/inc/events")).filter(f => f.endsWith(".mjs")),
trigger: (await fs.readdir("./src/inc/trigger")).filter(f => f.endsWith(".mjs"))
};
console.timeLog("loading", "directories");
const blah = (await Promise.all(Object.entries(modules).map(async ([dir, mods]) => ({
[dir]: (await Promise.all(mods.map(async mod => {
const res = await Promise.race([
(await import(`./inc/${dir}/${mod}`)).default(self),
new Promise((_, rej) => setTimeout(() => rej(false), timeout))
]);
console.timeLog("loading", `${dir}/${mod}`);
return res;
}))).flat(2)
})))).reduce((a, b) => ({...a, ...b}));
blah.events.forEach(event => {
console.timeLog("loading", `registering event > ${event.name}`);
self.bot.on(event.listener, event.f);
});
blah.trigger.forEach(trigger => {
console.timeLog("loading", `registering trigger > ${trigger.name}`);
self._trigger.set(trigger.name, new self.trigger(trigger));
});
console.timeEnd("loading");
})();