HORIZON PROJECT

var express = require('express');

var mongoose = require('mongoose');

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

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

//#region [ database ]

var agentSchema = mongoose.Schema({

    mac: String,       // 맥

    ip: String,        // 아이피

    state: String,    // 상태 / play | down | ready

    contents: String,  // 컨텐츠

    connect: String,

    lastUpdateDate: String,

    files: [],

    updatafiles: [],

    deletefiles: [],

    starts: [],

    parameters: []

});

//var agentModel = mongoose.model('agent', agentSchema); // agent model 정의

var agentContorl = {};

agentContorl.createCollection = function(err){

    console.log('[Agent] createcollection 호출');

    if(err) {

        console.log('[Agent] createcollection err : ' + err);

    } else {

        console.log('[Agent] collection 생성 성공');

    }

};

agentContorl.test = function(){

    console.log('agent test');

}

//#endregion

//#region [ variable ]

var collectionName = 'agent';

//#endregion

//#region [ API ]

const router = express.Router();

// udp로 받은 신호를 반환해주는 post

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

    console.log('[agent] agent 등록 시도');

    dbCenter.findClient(collectionName, req.body.mac, function(err, result){

        if(err){

            console.log('[agent find] err : ' + err.toString());

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

            res.end();

            return;

        } else {

            if(result){

                console.log('[agent find] 결과를 찾았습니다.');

                dbCenter.findAll('contents', function(err, docs){

                    if(err){

                        console.log('[agent][getAll] err : ' + err.toSring());

                    } else {

                        console.log('[agent][getAll] 전체 데이터 호출 성공');

                        console.log(docs);

                        result.files = docs[0].files;

                        console.log(result.files);

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

                        res.end();

                    }

                });

            } else {

                console.log('[agent find] 결과가 없습니다. 새로운 것입니다.');

                dbCenter.add(collectionName, req.body, function(err){

                    if(err){

                        console.log('[agent add] err : ' + err.toString());

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

                        res.end();

                        return;

                    } else {

                        console.log('[agent add] 성공');

                        res.send({'result':req.body});

                        res.end();

                    }

                });

            }

        }

    });

});

// 전체 조회

router.get('/', function(req, res){

    console.log('[agent] 전체조회 호출'); 

    dbCenter.findAll(collectionName, function(err, docs){

        if(err){

            console.log('[agent][getAll] err : ' + err.toSring());

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

            res.end();

        } else {

            console.log('[agent][getAll] 전체 데이터 호출 성공');

            res.send(docs);

            res.end();

        }

    });

});

// 특정 정보로 조회

router.get('/:mac', function(req, res){

    console.log('[agent] get/:mac'); 

});

// 수정

router.put('/:mac', function(req, res){

    console.log('[agent] put/:' + req.params.mac);

    dbCenter.findClient(collectionName, req.params.mac, function(err, result){

        if(err){

            console.log('[agent put] err : ' + err.toString());

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

            res.end();

        } else {

            if(result){

                console.log('[agent put] 결과를 찾았습니다.');

                console.log('result : ' + JSON.stringify(result));

                console.log(req.body);

                // 바뀔 데이터

                var setdata = {};

                setdata.contents = req.body.contents;

                setdata.files = req.body.files;

                setdata.starts = req.body.starts;

                setdata.parameters = req.body.parameters;

                setdata.lastUpdateDate = req.body.lastUpdateDate;

                setdata.updateFiles = req.body.updataFiles;

                setdata.deleteFiles = req.body.deleteFiles;

                dbCenter.modifiy(collectionName, result, setdata, function(err, result){

                    if(err){

                        console.log('[agnet put] : err : ' + err.toString());

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

                        res.end();

                    } else {

                        mySocket.modifyData(result);

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

                        res.end();

                    }

                });

            } else {

                console.log('[agent put] 결과를 찾지못했습니다.');

                res.send({'result':'not found'});

                res.end();

            }

        }

    });

});

// 삭제

router.delete('/:mac', function(req, res){

    console.log('[agent delete/:mac');

});

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

    console.log('req : ' + req.body._ip );

    //var agentModel = mongoose.model('agent', agentSchema); // agent model 정의

    var agentModel ;

    dbCenter.findAll(agentModel, function(err, docs){

        if(err){

            console.log('[agent][getAll] err : ' + err.toString());

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

            res.end();

        } else {

            console.log('[agent][getAll] 전체 데이터 호출 성공');

            res.send(docs);

            res.end();

        }

    });

});

//#endregion

exports.default = router;