HORIZON PROJECT

var express = require('express');

var http = require('http');

var static = require('serve-static');

var path = require('path');

var bodyParser = require('body-parser');

var cookieParser = require('cookie-parser');

var expressSession = require('express-session');

var expressErrorHandler = require('express-error-handler');

var multer = require('multer'); 

var fs = require('fs');

var cors = require('cors'); // 다중 서버 접속 지원

var udp =require('./udp_modules/udpMulticast');

var dbCenter = require('./db_modules/dbCenter');

var mySocket = require('./socket.io_modules/mySocket');

//var user = require('./routers/user');   // 사용자 관리 라우터

var agent = require('./routers/agent');

var contents = require('./routers/contents');

var app = express();

app.set('port', process.env.PORT || 3000);

app.use('/public', static(path.join(__dirname,'public')));  // public 폴더 오픈

app.use('/uploads', static(path.join(__dirname, 'uploads'))); // upload 폴더 오픈

app.use(bodyParser.urlencoded({ extended: true })); 

//app.use(bodyParser.urlencoded({extended:false}));

app.use(bodyParser.json());

app.use(cookieParser());

app.use(expressSession({

    secret:'my key',    

    resave:true,

    saveUninitialized:true

}));

app.use(cors()); // 클라이언트에서 ajax로 요청했을 때 cors(다중 서버 접속)지원

// 이 코드 아래로 부터 라우터 등록

var router = express.Router();

// DB Create 요청

router.route('/DB/Create').post(function(req, res){

    console.log('/DB/Create : call');

    dbCenter.createDB(req.body, function(err){

       if( err ){

           var resultString = err.toString();

           console.log(resultString);

           res.send({'result':resultString});

           res.end();

       } else {

           console.log('DB/Create : Success');

           res.send({'result':resultString});

           res.end();

       }

   });

});

// Client 에서 udp를 받게되면 post로 쏴준다.

router.route('/clients/attendance').post(function(req, res){    

    //console.dir(req);

    dbCenter.data_Set(req, function(err){

        if(err){

            res.json({"result":'fail'});

            res.end();

        } else {

            // 페이지에 새로고침을 요청하는 명령어를 날린다.

            io.emit('test');

            res.json({"result":'success'});

            res.end();

        }

    });

});

//app.use('/dbCenter', dbCenter.default);

//app.use('/user', user.default); // 사용자 관리 라우터 등록

app.use('/agent', agent.default);

app.use('/contents', contents.default);

app.use('/',router);

// var errorHandler = expressErrorHandler({

//     static: {

//         '404':'./public/404.html'

//     }

// });

// app.use(expressErrorHandler.httpError(404));

// app.use(errorHandler);

//var udpMulticast = require('./udpMulticast');

// 비동기 함수로 udp 멀티캐스트 주기적으로 전송

// ms 단위로 재 전송 시간 설정

var reSendTime = 1000;

let asyncUdpSend = (massage)=> new Promise((resolve)=>{

   setTimeout(()=>{

       console.log(massage);

       udpMulticast.send();

       resolve(asyncUdpSend(massage));

   }, reSendTime) ;

});

async function asyncMain(){

    asyncUdpSend('upd send');

};

// http 웹 서버를 실행 합니다.

var server = http.createServer(app).listen(app.get('port'), function(){ 

    console.log('웹 서버가 실행 되었습니다. (포트 : ' + app.get('port') + ')');

    var url = "mongodb://localhost:27017/horizon";

    dbCenter.connect(url, function(err){

        if(err){

            console.log("[createServer] 최초 db 연결 실패. err : " + err.toString());

        } else{

            console.log('[createServer] dbServer 연결 성공');

            udp.send(); // UDP 를 쏘기 시작한다.

            mySocket.setSocket(server);

        }

    });

});