keinBot/cuffeo
2
2
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix mod loading race condition

Browse Source
This commit is contained in:
Flummi 2021-01-25 20:16:14 +01:00
parent 77dd49bc2c
commit 388f4a80f1
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/clients/irc.mjs
View File

@ -55,6 +55,17 @@ export default class irc extends EventEmitter {
channel: new Map(), channel: new Map(),
user: new Map() user: new Map()
}; };
return (async () => {
const dir = (await fs.readdir(`${__dirname}/irc`)).filter(f => f.endsWith(".mjs"));
await Promise.all(dir.map(async mod => {
return (await import(`${__dirname}/irc/${mod}`)).default(this);
}));
this.connect();
return this;
})();
}
connect() {
this.socket = (this.options.ssl ? tls : net).connect({ this.socket = (this.options.ssl ? tls : net).connect({
host: this.options.host, host: this.options.host,
port: this.options.port, port: this.options.port,
@ -73,11 +84,6 @@ export default class irc extends EventEmitter {
this._cmd.get(cmd.command)(cmd); this._cmd.get(cmd.command)(cmd);
}) })
}); });
return (async () => {
(await fs.readdir(`${__dirname}/irc`)).filter(f => f.endsWith(".mjs")).forEach(async mod => (await import(`./irc/${mod}`)).default(this));
return this;
})();
} }
send(data) { send(data) {
this.socket.write(`${data}\n`); this.socket.write(`${data}\n`);