var _ = require("lodash"); var Client = require("./client"); var ClientManager = require("./clientManager"); var config = require("../config.json"); var fs = require("fs"); var http = require("connect"); var io = require("socket.io"); var sockets = null; var manager = new ClientManager(); var inputs = [ "action", "connect", "invite", "join", "kick", "mode", "msg", "nick", "notice", "part", "quit", "raw", "topic", "whois" ]; module.exports = function(port, host, isPublic) { config.port = port; config.host = host; config.public = isPublic; var app = http() .use(index) .use(http.static("client")) .use(http.static(process.env.HOME + "/.shout/cache")) .listen(config.port, config.host); sockets = io(app); sockets.on("connect", function(socket) { if (config.public) { auth.call(socket); } else { init(socket); } }); console.log(""); console.log("Shout is now running on host/port " + config.host + ":" + config.port); console.log("Press ctrl-c to stop"); console.log(""); if (!config.public) { manager.loadUsers(sockets); } }; function index(req, res, next) { if (req.url != "/") return next(); return fs.readFile("client/index.html", "utf-8", function(err, file) { var data = _.merge( require("../package.json"), config ); res.end(_.template( file, data )); }); } function init(socket, client) { if (!client) { socket.emit("auth"); socket.on("auth", auth); } else { socket.on( "input", function(data) { input(client, data); } ); socket.on( "showMore", function(data) { showMore(client, data); } ); socket.on( "conn", function(data) { client.connect(data); } ); socket.join(client.id); socket.emit("init", { networks: client.networks }); } } function auth(data) { var socket = this; if (config.public) { var client = new Client(sockets); manager.clients.push(client); socket.on("disconnect", function() { manager.clients = _.without(manager.clients, client); client.quit(); }); init(socket, client); } else { var success = 0; _.each(manager.clients, function(client) { if (client.config.name == data.name && client.config.password == data.password) { init(socket, client); success++; } }); if (!success) { socket.emit("auth"); } } } function input(client, data) { var text = data.text; var target = client.find(data.target); if (text.charAt(0) !== "/") { text = "/say " + text; } var args = text.split(" "); var cmd = args.shift().replace("/", "").toLowerCase(); _.each(inputs, function(plugin) { try { var path = "./plugins/inputs/" + plugin; var fn = require(path); fn.apply(client, [ target.network, target.chan, cmd, args ]); } catch (e) { console.log(path + ": " + e); } }); } function showMore(client, data) { var target = client.find(data.target); if (!target) { return; } var chan = target.chan; var messages = chan.messages.slice(0, chan.messages.length - (data.count || 0)); client.emit("showMore", { chan: chan.id, messages: messages }); }