Shuo/lib/server.js

97 lines
1.7 KiB
JavaScript

var _ = require("lodash");
var Client = require("./client");
var config = require("../config") || {};
var http = require("connect");
var io = require("socket.io");
var sockets = null;
var clients = [];
var inputs = [
"action",
"connect",
"invite",
"join",
"kick",
"mode",
"msg",
"nick",
"notice",
"part",
"quit",
"raw",
"topic",
"whois"
];
module.exports = function() {
sockets = io(http().use(http.static("client")).listen(config.port || 9000));
sockets.on("connection", function(socket) {
if (config.public) {
auth.call(socket);
} else {
init(socket);
}
});
};
function init(socket, client) {
if (!client) {
socket.emit("auth");
socket.on("auth", auth);
} else {
socket.on("input", function(data) { input(client, data); });
socket.join(client.id);
socket.emit("init", {
networks: client.networks
});
}
}
function auth(data) {
var socket = this;
if (config.public) {
// Temporary:
var client = clients[0];
if (clients.length === 0) {
client = new Client({sockets: sockets});
clients.push(client);
client.connect({
host: "irc.freenode.org"
});
}
init(socket, client);
} else {
if (false) {
// ..
}
}
}
function input(client, data) {
var target = client.find(data.target);
var text = data.text;
if (text.charAt(0) !== "/") {
text = "/say " + text;
}
var args = text.split(" ");
var cmd = args.shift().replace("/", "").toLowerCase();
inputs.forEach(function(plugin) {
try {
var fn = require("./plugins/inputs/" + plugin);
fn.apply(client, [
target.network,
target.chan,
cmd,
args
]);
} catch (err) {
console.log(err.stack);
// ..
}
});
}