'use strict'; if (!global.window) { global.Random = require("random-js"); require("./util.js"); require("./Callback.js"); require("./Game.js"); require("./Phase.js"); require("./IO.js"); require("./Player.js"); require("./Card.js"); require("./Zone.js"); require("./CardInfo.js"); require("./Timming.js"); require("./Mask.js"); require("./ConstEffect.js"); require("./ConstEffectManager.js"); require("./Effect.js"); require("./EffectManager.js"); require("./Client.js"); require("./Room.js"); require("./RoomManager.js"); } var io; if (global.window) { io = { on: function (name,handler) { io._handler = handler; }, use: function () {} }; global.window.newClient = function () { var win = window.open('./webxoss-client/?local=true'); win.addEventListener('load',function () { var socket = new FakeSocket(win); win.addEventListener('unload',function () { socket._doEmit('disconnect'); }); win.document.title = 'Client' + socket.id; io._handler(socket); }); } } else { var express = require('express'); var compression = require('compression'); var app = express(); var server = require('http').Server(app); app.use(compression()); app.use('/background',express.static(__dirname + '/webxoss-client/images',{ maxAge: '2h' })); app.use('/images',express.static(__dirname + '/webxoss-client/images',{ maxAge: '30d' })); app.use(express.static(__dirname + '/webxoss-client')); io = require('socket.io')(server,{ pingTimeout: 30000, maxHttpBufferSize: 1024*1024, }); var port = 80; process.argv.slice(2).forEach(function (arg) { var match = arg.match(/^port=(\d+)/) if (match) { port = +match[1]; } }); server.listen(port); } var cfg = { MAX_ROOMS: 100, MAX_CLIENTS: 500, MAX_ROOM_NAME_LENGTH: 15, MAX_NICKNAME_LENGTH: 10, MAX_PASSWORD_LENGTH: 15 }; var roomManager = new RoomManager(cfg); var MAX_SOCKETS = 500; // var MAX_SOCKETS_PER_IP = 50; // var ipTable = {}; function getSocketCount () { if (!io.sockets) return 0; return Object.keys(io.sockets.connected).length; } io.use(function (socket,next) { if (getSocketCount() >= MAX_SOCKETS) { next(new Error('MAX_SOCKETS')); return; } // var handshake = socket.request; // var ip = handshake.connection.remoteAddress; // if (!ip) { // next(); // return; // } // if (ip in ipTable) { // if (ipTable[ip] >= MAX_SOCKETS_PER_IP) { // console.log('MAX_SOCKETS_PER_IP: %s',ip); // next(new Error('MAX_SOCKETS_PER_IP')); // return; // } else { // ipTable[ip]++; // } // } else { // ipTable[ip] = 1; // } // socket.on('disconnect',function () { // console.log('disconnect: %s, count: %s',ip,getSocketCount()); // if (ip in ipTable) { // if (ipTable[ip] <= 1) { // delete ipTable[ip]; // } else { // ipTable[ip]--; // } // } // }); next(); }); io.on('connect',function (socket) { if (global.window) { return roomManager.createClient(socket); } var req = socket.request; if (req.connection.destroyed) { console.log('req.connection.destroyed'); return; } var query = require('url').parse(req.url,true).query; // console.log('connect: %s, count: %s',req.connection.remoteAddress,getSocketCount()); // console.log(query.clientId); roomManager.createClient(socket,+query.clientId); // test // socket.on('force disconnect',function () { // socket.disconnect(); // }); // for debug if (typeof process === 'undefined') return; var password = ''; process.argv.slice(2).forEach(function (arg) { var match = arg.match(/^debug_password=(\S+)/) if (match) { password = match[1]; } }); if (!password) return; socket.on('debug',function (psw) { if (psw !== password) return; try { var path = require('path'); var filePath = './debug.js'; delete require.cache[path.resolve(filePath)]; require(filePath); } catch (e) { console.log(e); } }); }); if (!global.window) { exports.roomManager = roomManager; }