This commit is contained in:
Flummi
2018-03-01 07:02:33 +01:00
parent 95d76163e3
commit a225922753
2 changed files with 44 additions and 51 deletions

View File

@ -3,46 +3,47 @@ import { irc as irclib } from "../clients/irc";
import { tg as tglib } from "../clients/tg";
import { discord as discordlib } from "../clients/discord";
import util from "util";
import EventEmitter from "events";
const clients = [];
const wrapper = function () {
for (let srv in cfg.client) {
if(cfg.client[srv].val.enabled) {
switch (cfg.client[srv].val.type) {
case "irc":
clients.push({
name: cfg.client[srv].val.network,
type: "irc",
client: new irclib(cfg.client[srv].val)
});
break;
case "tg":
clients.push({
name: "tg",
type: "tg",
client: new tglib(cfg.client[srv].val)
});
break;
case "discord":
clients.push({
name: "discord",
type: "discord",
client: new discordlib(cfg.client[srv].val)
});
break;
const wrapper = class wrapper extends EventEmitter {
constructor() {
super();
for (let srv in cfg.client) {
if(cfg.client[srv].val.enabled) {
switch (cfg.client[srv].val.type) {
case "irc":
clients.push({
name: cfg.client[srv].val.network,
type: "irc",
client: new irclib(cfg.client[srv].val)
});
break;
case "tg":
clients.push({
name: "tg",
type: "tg",
client: new tglib(cfg.client[srv].val)
});
break;
case "discord":
clients.push({
name: "discord",
type: "discord",
client: new discordlib(cfg.client[srv].val)
});
break;
}
}
}
}
clients.forEach(client => {
client.client.on("data", e => {
this.emit(e[0], e[1]);
clients.forEach(client => {
client.client.on("data", e => {
this.emit(e[0], e[1]);
});
});
});
}
};
util.inherits(wrapper, EventEmitter);
export { wrapper, clients };