HORIZON PROJECT

/* TODO LIST

1. UDP 부분

    1) UDP 에서 연결된 장치 전체에 신호 던져주기.

    2) 던져 주는 신호 등록해 둬서 서버에서 언제든지 호출 할 수 있게 해주기.

    3) 주기적으로 던져주기.

    4) 웹에서는 연결된 것들 다 찾아노는 이벤트 만들어두기

    5) 클라에서는 정보 요청 하는 것들 찾아보기

2. FTP 부분

*/

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 database;

var UserSchema;

var UserModel;

// mongoose 접속과 schema 에 관련된 내용이 있다.

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

var app = express();

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

// public 폴더 오픈

app.use('/public', static(path.join(__dirname,'public')));

// upload 폴더 오픈

app.use('/uploads', static(path.join(__dirname, 'uploads')));

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

}));

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

app.use(cors());

// multer 미들웨어 사용 : 미들웨어 사용 순서 중요 body-parser -> multer -> router

// 파일 제한 10개 , 1G

var storage = multer.diskStorage({

   destination: function(req, file, callback){

       // uploads 폴더로 destination 을 정해준다.

       callback(null, 'uploads');

   },

    filename: function (req, file, callback){

        //callback(null, file.originalname + Date.now() + '.png')

        var extension = path.extname(file.originalname);

        var basename = path.basename(file.originalname, extension);

        callback(null, basename + Date.now() + extension);

    }

});

var upload = multer({

    storage: storage,

    limits: {

        // 한번에 업로드 할 수 있는 최대 파일 갯수

        files: 10,

        // 한버넹 업로드 할 수 있는 최대 파일 용량

        rileSize: 1024*1024*1024

    }

});

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

var router = express.Router();

// ▼ DB 접속 관련 함수 ▼////////////////////////////////////////////////////////////////////

// ▲ DB 접속 관련 함수 ▲////////////////////////////////////////////////////////////////////

// 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();

       }

   });

});

// ▼ 클라이언트에 대한 것들 ▼////////////////////////////////////////////////////////////////////

// 연결된 모든 클라이언트를 가져올 것이다.

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

     dbCenter.data_All(function(err, users){

         if(err){

         } else {

             res.send(users);

             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('/',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') + ')');

    dbCenter.db_Connect(function(err){

        if(err){

        } else {

        }

    });

});

// socket.io 사용

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

var connectPage;

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

    console.log('없는 장치를 검색하는 페이지에 접근함.');

    connectPage = client;

    //client.emit('test',);

    io.emit('test');

    //client.on('event', function(data){});

    //client.on('disconnect', function(){});

});