HORIZON PROJECT

var agent = require('../modules/agent_module');

//#region [ variable ]

var httpServer = require('socket.io');

var io;

var mySocket = {};

// 소켓의 정보

var socketInfo  = function(){

    id = '',

    name = ''

};

var socketArray = [];   // 소켓들을 저장하고 있을 배열

//#endregion

//#region [ method ]

mySocket.setSocket = function(server){

    io = new httpServer(server);

    io.on('connection', function(client){

        console.log('---------------------- connect | id : ' + client.id);

        client.emit('data');    // 상대방 data event 호출

        // 서버는 이쪽 이벤트를 실행해준다.

        client.on('web', function(data){

            console.log('------------------ web name : ' + data);

            // 소켓을 정의 해준다.

            var tmpSocket = new socketInfo();

            tmpSocket.id = client.id;

            tmpSocket.name = data.name;

            socketArray.push(tmpSocket);    // 소켓 배열에 넣어준다.

        });

        // 클라는 이쪽 이벤트를 실행해준다.

        client.on('agent', function(data){

            console.log('------------------ agent name : ' + data);

            // agent 가 연결이 되었을때의 함수.

            agent.connect(data, function(data, result){

                if(checkServerLive())

                    mySocket.serverEmit('agent_connect', result);

            });              

            var tmpSocket = new socketInfo();

            tmpSocket.id = client.id;

            tmpSocket.name = data;

            socketArray.push(tmpSocket);    // 소켓 배열에 넣어준다.

        });

        client.on('state', function(data){

            console.log('---------------------------state : ' + data);

            var info = findSocketInfo(client.id);

            if(info!=null){

                // 서버는 이 이벤트를 실행할 수 없기때문에 if 문을 생략한다.

                agent.stateChange(info.name, data, function(err, result){

                    if(!err){

                        console.log('성공적인 state 변경');

                    }

                });

            }

        });

        // 연결이 끊겼을 경우 실행해준다.

        client.on('disconnect', function(){

            console.log('------------------- disconnect | id : ' + client.id);

            var info = findSocketInfo(client.id);

            if(info!=null){

                if(info.name == 'server' ){

                } else {

                    // TODO : db 의 정보도 변경해줘야한다.

                    agent.disconnect(info.name, function(err, result){

                        if(err == null&& result != null){

                        }

                    });

                    agent.getOne(info.name, function(err, result){

                        if(!err){

                            if(result){

                                if(serverSocket != null)

                                    mySocket.serverEmit('agent_disconnect', result);

                            }

                        }

                    });

                }

            }

            var locate = socketArray.indexOf(client.id);

            socketArray.splice(locate, 1);

        });

    });

    //setInterval(intervalFunc, 6000);

};

// 현재 서버가 살아 있는지 판별한다.

var checkServerLive = function(){

    for( var i = 0 ; i < socketArray.length; i++){

        if(socketArray[i].name == 'server'){

            return true;

        }

    }

    return false;

}

// socketId 로 소켓의 정보를 찾아온다.

var findSocketInfo = function(socketId){

    for( var i = 0 ; i < socketArray.length; i++){

        if(socketArray[i].id == socketId){

            return socketArray[i];

        }

    }

    return null;

}

var findSocketInfoInMac = function(mac){

    for( var i = 0 ; i < socketArray.length; i++){

        if(socketArray[i].name == mac){

            return socketArray[i];

        }

    }

    return null;

}

mySocket.agentEmit = function(methodName){

    for(var i = 0; i < socketArray.length; i++){

        socketArray[i].emit(methodName);

    }

};

mySocket.serverEmit = function(methodName, result){

    serverSocket.emit(methodName, result);

};

mySocket.modifyData = function(contentsName){

    console.log('업데이트 할것이 있습니다.');

    agent.FindAgentForContentName(contentsName, function(err, result){

        if(err==null&&result!=null){

            for(var i = 0 ; i< result.length; i++){

                var socket = findSocketInfoInMac(result[i].mac);

                socket.emit('update', result[i]);

            }

        }

    });

};

function intervalFunc(){

    io.emit('name');

};

//#endregion

module.exports = mySocket;