app.js

var express = require('express');
var app = express();
var server = require('http').Server(app);
var io = require('socket.io')(server);

var serverConfig = require('./public/config').serverConfig;

var Game = require('./public/tdGame/Game');
var Rooms = require('./public/tdGame/Room');
var Room = Rooms.Room;

var utils = require('./public/utils');

io.on('connection', function (socket) {
    var clientIp = socket.request.connection.remoteAddress;
    console.log('New connection from ' + clientIp);

    socket.on('newRoom', function(data) {
        var roomName = data['name'];
        var userInfo = data['userInfo'];
        var msg = {code:0,msg:'failed'};
        if(!Room.isRoomExisted(roomName)){
            utils.clearSocketsByRoomName(io,roomName);
            socket.roomName = roomName;
            socket.role = 'master';
            socket.join(roomName);            

            var game = new Game(io,roomName);
            game.addPlayer(userInfo);
            msg = Room.createRoom(roomName,game);
            if(msg.code==1){
                msg = {code:1,userInfos:game.userInfos};
            }
        }
        socket.emit('roomInfo', msg);
    });

    socket.on('getRooms', function() {
        // TODO 数据格式需要改动
        var msg = {'ret': 1, 'data': Room.getRooms()};
        socket.emit('getRooms', msg);
    });
    
    socket.on('joinRoom', function (data) {
        var roomName = data.roomId;
        var userInfo = data.userInfo;
        var msg = {code:0,msg:'failed'};

        if(!Room.isRoomExisted(roomName) || Room.isRoomFull(roomName)){
            socket.emit('joinRoom', msg);
        }else{
            socket.roomName = roomName;
            socket.role = 'challenger';
            socket.join(roomName);

            var game = Room.getRoom(roomName);            
            game.addPlayer(userInfo);
            msg = {code:1,userInfos:game.userInfos};
            game.broadcastMsg('roomInfo', msg);
        }

    });

    socket.on('deleteRoom', function () {
        var roomName = socket.roomName;
        var msg = {code:0,msg:'failed'};

        if(!Room.isRoomExisted(roomName)){
            socket.emit('deleteRoom', msg);
        }else{
            var game = Room.getRoom(roomName);
            game.broadcastMsg('deleteRoom',{code:1,msg:'success'}); 
            Room.deleteRoom(roomName);           
            utils.clearSocketsByRoomName(io,roomName);
        }
    });

    socket.on('startGame', function() {
        var roomName = socket.roomName;
        var game = Room.getRoom(roomName); 
        if(game){
            game.startGame();
        }
    });

    socket.on('playAgain', function(data) {
        var roomName = data.roomId;
        var userInfo = data.userInfo;
        var msg = {code:0,msg:'failed'};
        if(!Room.isRoomExisted(roomName)){
            socket.role = 'master';
            socket.roomName = roomName;
            socket.join(roomName);
            userInfo.isMaster = true;

            var game = new Game(io,roomName);
            game.addPlayer(userInfo);
            msg = Room.createRoom(roomName,game);
            if(msg.code === 1){
                msg.userInfos = game.userInfos;
                msg.msg = 'success';
            }
        }else if(!Room.isRoomFull(roomName)){
            socket.role = 'challenger';
            socket.roomName = roomName;
            socket.join(roomName);
            userInfo['isMaster'] = false;

            var game = Room.getRoom(roomName);            
            game.addPlayer(userInfo);
            msg ={code:1,msg:'success',userInfos:game.userInfos};
            game.broadcastMsg('playAgain',msg);
            return;
        }
        socket.emit('playAgain', msg);
    });

    socket.on('KeyUp', function (keyCode) {
        var game = Room.getRoom(socket.roomName);
        if(game){
            if (socket.role === 'master') {
                game.stopARoleByKeyCode(keyCode,game.roleArr[0]);
            } else {
                game.stopARoleByKeyCode(keyCode,game.roleArr[1]);
            }
        }
    });

    socket.on('KeyDown', function (keyCode) {
        var game = Room.getRoom(socket.roomName);
        if (game) {
            if (socket.role === 'master') {
                game.moveARoleByKeyCode(keyCode,game.roleArr[0]);
            } else {
                game.moveARoleByKeyCode(keyCode,game.roleArr[1]);
            }
        }
    });

    socket.on('MoveByAngle', function (angle) {
        var game = Room.getRoom(socket.roomName);
        if (game) {
            if (socket.role === 'master') {
                game.moveARoleByAngle(angle,game.roleArr[0]);
            } else {
                game.moveARoleByAngle(angle,game.roleArr[1]);
            }
        }
    });

    socket.on('TouchEnd', function () {
        var game = Room.getRoom(socket.roomName);
        if(game){
            if (socket.role === 'master') {
                game.stopAMobileRole(game.roleArr[0]);
            } else {
                game.stopAMobileRole(game.roleArr[1]);
            }
        }
    });

    socket.on('disconnect', function(){
        var game = Room.getRoom(socket.roomName);
        if(game){
            game.broadcastMsg('deleteRoom',{code:1,msg:'success'});
            game.stopGame(socket.role);
        }
    })

    socket.on('error',function(){
        console.log('server websocket error');
    })

});

server.listen(4000, function(){
    console.log('App listening at http://%s:%s', serverConfig.host, serverConfig.port);
});