97 lines
1.7 KiB
JavaScript
97 lines
1.7 KiB
JavaScript
|
var _ = require("lodash");
|
||
|
|
var net = require("net");
|
||
|
|
var Network = require("./models/network");
|
||
|
|
var slate = require("slate-irc");
|
||
|
|
var tls = require("tls");
|
||
|
|
|
||
|
|
module.exports = Client;
|
||
|
|
|
||
|
|
var id = 0;
|
||
|
|
var events = [
|
||
|
|
"errors",
|
||
|
|
"join",
|
||
|
|
"kick",
|
||
|
|
"mode",
|
||
|
|
"motd",
|
||
|
|
"message",
|
||
|
|
"names",
|
||
|
|
"nick",
|
||
|
|
"notice",
|
||
|
|
"part",
|
||
|
|
"quit",
|
||
|
|
"topic",
|
||
|
|
"welcome",
|
||
|
|
"whois"
|
||
|
|
];
|
||
|
|
|
||
|
|
function Client(attr) {
|
||
|
|
_.merge(this, _.extend({
|
||
|
|
id: id++,
|
||
|
|
networks: [],
|
||
|
|
keepAlive: false,
|
||
|
|
sockets: null
|
||
|
|
}, attr));
|
||
|
|
}
|
||
|
|
|
||
|
|
Client.prototype.emit = function(event, data) {
|
||
|
|
if (this.sockets !== null) {
|
||
|
|
this.sockets.in(this.id).emit(event, data);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.find = function(id) {
|
||
|
|
var network = null;
|
||
|
|
var chan = null;
|
||
|
|
for (var i in this.networks) {
|
||
|
|
var n = this.networks[i];
|
||
|
|
chan = _.find(n.channels, {id: id});
|
||
|
|
if (chan) {
|
||
|
|
network = n;
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
if (network && chan) {
|
||
|
|
return {
|
||
|
|
network: network,
|
||
|
|
chan: chan
|
||
|
|
};
|
||
|
|
} else {
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
Client.prototype.connect = function(args) {
|
||
|
|
var client = this;
|
||
|
|
var options = {
|
||
|
|
host: args.host,
|
||
|
|
port: args.port || 6667
|
||
|
|
};
|
||
|
|
|
||
|
|
var stream = args.tls ? tls.connect(options) : net.connect(options);
|
||
|
|
stream.on("error", function(e) {
|
||
|
|
console.log(e);
|
||
|
|
});
|
||
|
|
|
||
|
|
var irc = slate(stream);
|
||
|
|
irc.nick("shout");
|
||
|
|
irc.user("shout", "Shout User");
|
||
|
|
|
||
|
|
var network = new Network({
|
||
|
|
host: options.host,
|
||
|
|
irc: irc
|
||
|
|
});
|
||
|
|
|
||
|
|
client.networks.push(network);
|
||
|
|
client.emit("network", {
|
||
|
|
network: network
|
||
|
|
});
|
||
|
|
|
||
|
|
events.forEach(function(plugin) {
|
||
|
|
require("./plugins/irc-events/" + plugin).apply(client, [irc, network]);
|
||
|
|
});
|
||
|
|
|
||
|
|
irc.on("welcome", function() {
|
||
|
|
irc.join("#shout-test");
|
||
|
|
});
|
||
|
|
};
|