HORIZON PROJECT

var mongoose = require('mongoose');

var fs = require('fs');

var mongod = require('mongod');

var express = require('express');

var MongoClient = require('mongodb').MongoClient;

var router = express.Router();

// Client 스키마 정의

var clientSchema = mongoose.Schema({

    _ip: String,

    _mac: String,

    _registerd: String

});

var ClientModel;

var dbCenter = {};

//#region [ Variable ]

var dbo;

//#endregion

//#region [ USED ]

// db에 connect 가 시도되며 url 의 database 가 없다면 자동으로 생성하게 된다.

dbCenter.connect = function(url, callback){

    console.log('[dbCenter] connect 호출');

    MongoClient.connect(url, function(err, db){

        if( err ){

            callback(err);

            throw err;

        } else {

            dbo = db.db('horizon');

            callback(null);

            //db.close(); // ? : 꼭 마지막에 close 를 해줘야 하는지는 아직 판단 하지 못했음.00

        }

     });

};

// db 검색

dbCenter.findClient = function(collectionName, key, callback){

    console.log('[dbCenter] findClient 호출');

    dbo.collection(collectionName).findOne({mac: key}, function(err, result){

        if(err){

            callback(err, null);

        } else{

            if(result){

                callback(null, result);

            } else {

                callback(null, null);

            }

        }

    });

};

// db 검색

dbCenter.findContents = function(collectionName, key, callback){

    console.log('[dbCenter] findContents 호출');

    dbo.collection(collectionName).findOne({name: key}, function(err, result){

        if(err){

            callback(err, null);

        } else{

            if(result){

                callback(null, result);

            } else {

                callback(null, null);

            }

        }

    });

};

// db 추가 | 콜렉션의 이름 | req.body | 검색하고자 하는 키 | 콜백

dbCenter.add = function(collectionName, data, callback){

    console.log('[dbCenter] add 호출');

    dbo.collection(collectionName).insertOne(data, function(err, res){

        if(err){

            callback(err);

        } else {

            callback(null);

        }

    });

};

// db 전체 검색

dbCenter.findAll = function(collectionName, callback){

    console.log('[dbCenter] findall 호출');

    dbo.collection(collectionName).find({}).toArray(function(err, result){

        if(err){

            callback(err, null);

        } else {

            callback(null, result);

        }

    });

};

dbCenter.findSome = function(collectionName, callback){

    console.log('[dbCenter] findSome 호출');

}

dbCenter.modifiy = function(collectionName, orgdata, setdata ,callback){

    console.log('[dbCenter] modifiy 호출');

    dbo.collection(collectionName).updateOne(orgdata, {$set:setdata}, function(err, res){

        if(err){

            callback(err, null);

        } else{

            callback(null, res);

        }

    });

};

//#endregion

exports.default = router;

module.exports = dbCenter;