HORIZON PROJECT

var express = require('express');

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

var path = require('path');

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

var cors = require('cors');

var multer = require('multer');

var rmdir = require('rmdir');

var fs = require('fs');

var multiparty = require('multiparty');

var mongoose = require('mongoose');

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

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

var localPath = 'D:/00.FAMOZ/16.CMS/02.SVN/Repository/Horizon/HServer/00.Server/00.Program/uploads';

//#region [ database ]

var contentSchema = function(){

    name: String;    // 프로젝트 이름

    files: [];       // 파일들의 정보

    lastUpdateDate: Date;    // 마지막 업데이트 날짜

    updateFiles: [];

    deleteFiles: [];

};

//#endregion

//#region [ variable ]

var collectionName = 'contents';

//#endregion

//#region [ API ]

const router = express.Router();

// content 등록

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

    console.log('[content] post');

    var form = new multiparty.Form();       // 멀티파티폼의 설정

    form.maxFields = 100000;

    var contentsName;    // 프로젝트의 이름을 저장해줄 변수

    // get field name & value

    form.on('field',function(name, value){

        console.log('normal field / name = '+name+' , value = '+ value);

        var parseData =  JSON.parse(value); // value 값을 파싱해준다.

        var saveData = new contentSchema;   // 저장할 데이터를 만든다.

        saveData.name = parseData.name;     // 프로젝트 이름 설정

        saveData.files = parseData.files;   // 파일들 설정

        saveData.lastUpdateDate = Date.now();   // 업데이트 시간 설정

        saveData.updateFiles = [];

        saveData.deleteFiles= [];

        contentsName = name; // 현재 프로젝트 네임을 설정해준다. 최상위 폴더가 된다.

        // 추가해준다. 무조건 첫번째 등록을 가정하고 중복 검사를 하지 않는다.

        dbCenter.add(collectionName, saveData, function(err){

            if(err){

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

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

                // res.end();

                return;

            } else {

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

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

                // res.end();

            }

        });

    });

    // file upload handling

    form.on('part',function(part){

         var filename;

         var size;

         if (part.filename) {

               filename = part.filename;

               size = part.byteCount;

         }else{

               part.resume();

         }

         var filePath = part.name;

         //console.log('filename : ' + filename);

         //console.log('filepath : ' + filePath);

         var tmpPath = filePath.substring(0, filePath.length - filename.length);

         //console.log('tmppath : ' + tmpPath);

         var savePath = localPath + '/' + contentsName;

         if(!fs.existsSync(savePath))

         {

            fs.mkdirSync(savePath);

         }

         while(true){

            var firstIndex = filePath.indexOf('/');

            if( firstIndex == -1 ) break;

            //console.log('firstIndex : ' + firstIndex);

            var tmpString = tmpPath.substring(firstIndex + 1, filePath.length);

            //console.log('tmpString : ' + tmpString);

            var secondIndex = tmpString.indexOf('/');

            if(secondIndex == -1) break;

            var resultString = tmpPath.substring(firstIndex, secondIndex + 1);

            //console.log('result : ' + resultString);

            savePath = savePath + resultString;

            if(!fs.existsSync(savePath))

            {

               fs.mkdirSync(savePath);

            }

            tmpPath = tmpPath.substring(secondIndex + 1, tmpPath.length);

            //console.log('aaaaaa : ' + tmpPath);

         }

         //console.log("Write Streaming file :"+filename);

         var writeStream = fs.createWriteStream(savePath + '/' + filename);

         writeStream.filename = filename;

         part.pipe(writeStream);

         part.on('data',function(chunk){

               //console.log(filename+' read '+chunk.length + 'bytes');

         });

         part.on('end',function(){

               //console.log(filename+' Part read complete');

               writeStream.end();

         });

    });

    // all uploads are completed

    form.on('close',function(){

        res.status(200).send('Upload complete');

    });

    // track progress

    form.on('progress',function(byteRead,byteExpected){

         //console.log(' Reading total  '+byteRead+'/'+byteExpected);

    });

    form.parse(req);

});

// 전체 조회

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

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

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

        if(err){

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

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

            res.end();

        } else {

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

            res.send(docs);

            res.end();

        }

    });

});

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

});

// 수정

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

    console.log('[content] put/file ' + req.params.name);

    var form = new multiparty.Form();       // 멀티파티폼의 설정

    form.maxFields = 100000;

    var contentsName = req.params.name;    // 프로젝트의 이름을 저장해줄 변수

    var saveData = new contentSchema;   // 저장할 데이터를 만든다.

    var isFound = false;

    // 만약 projectName 으로 된 폴더가 있다면.

    if(fs.existsSync(localPath+ '/' + contentsName + '/')){

        console.log('폴더를 찾았습니다.');

        isFound = true;

    } else {

        console.log('폴더를 찾지 못했습니다.');

    }

    if(isFound){

        rmdir('uploads/' + contentsName, function(err, dirs, files){

            if(err){

                console.log(err);

            } else{

                console.log(' 폴더가 삭제되었습니다. ');

                form.parse(req);

            }

        });

        // fs.unlink(localPath+ '/' + contentsName + '/' + 'qwe/', (err) =>{

        //     if(err) {

        //         console.log('err : ' + err.toString());

        //         return;

        //     }

        //     console.log(contentsName + ' 폴더가 삭제되었습니다. ');

        //     return;

        //     form.parse(req);

        // });

    }

    // get field name & value

    form.on('field',function(name, value){

        console.log('normal field / name = '+name+' , value = '+value);

        var parseData =  JSON.parse(value); // value 값을 파싱해준다.

        saveData.name = parseData.name;

        saveData.files = parseData.files;

        saveData.lastUpdateDate = Date.now();

        saveData.updateFiles = [];

        saveData.deleteFiles = [];

    });

    // file upload handling

    form.on('part',function(part){

         var filename;

         var size;

         if (part.filename) {

               filename = part.filename;

               size = part.byteCount;

         }else{

               part.resume();

         }

         var filePath = part.name;

         //console.log('filename : ' + filename);

         //console.log('filepath : ' + filePath);

         var tmpPath = filePath.substring(0, filePath.length - filename.length);

         //console.log('tmppath : ' + tmpPath);

         var savePath = localPath + '/' + contentsName;

         if(!fs.existsSync(savePath))

         {

            fs.mkdirSync(savePath);

         }

         while(true){

            var firstIndex = filePath.indexOf('/');

            if( firstIndex == -1 ) break;

            //console.log('firstIndex : ' + firstIndex);

            var tmpString = tmpPath.substring(firstIndex + 1, filePath.length);

            //console.log('tmpString : ' + tmpString);

            var secondIndex = tmpString.indexOf('/');

            if(secondIndex == -1) break;

            var resultString = tmpPath.substring(firstIndex, secondIndex + 1);

            //console.log('result : ' + resultString);

            savePath = savePath + resultString;

            if(!fs.existsSync(savePath))

            {

               fs.mkdirSync(savePath);

            }

            tmpPath = tmpPath.substring(secondIndex + 1, tmpPath.length);

            //console.log('aaaaaa : ' + tmpPath);

         }

         //console.log("Write Streaming file :"+filename);

         var writeStream = fs.createWriteStream(savePath + '/' + filename);

         writeStream.filename = filename;

         part.pipe(writeStream);

         part.on('data',function(chunk){

               //console.log(filename+' read '+chunk.length + 'bytes');

         });

         part.on('end',function(){

               //console.log(filename+' Part read complete');

               writeStream.end();

         });

    });

    // all uploads are completed

    form.on('close',function(){

        res.status(200).send('Upload complete');

        dbCenter.findContents(collectionName, req.params.name, function(err, result){

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

                console.log(result);

                ArrayClear(result.updateFiles);

                ArrayClear(result.deleteFiles);

                compareFiles(result, saveData); // 파일을 비교해서 업데이트 파일과 딜리트 파일을 찾아준다.

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

                    if(err){

                        console.log(err.toString());

                    } else {

                        if(result != null){

                            console.log('[contents] 수정 완료');

                            // 콘텐츠 수정 완료 후에는 에이전트에게 업데이트 된걸 비교해서 넣어줘야한다.

                            mySocket.modifyData(contentsName);   // 소켓으로 현재 프로젝트 이름을 가지고 있는 agent 들에게 업데이트 할 것이 있다고 알려준다.

                        }

                    }

                });

            }

        });

    });

    // track progress

    form.on('progress',function(byteRead,byteExpected){

         //console.log(' Reading total  '+byteRead+'/'+byteExpected);

    });

});

// 특정 정보로 조회

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

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

});

// 삭제

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

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

});

// 파일 비교 모듈

var compareFiles = function(orgData, newData){

    var orgFiles = orgData.files;

    var newFiles = newData.files;

    console.log('orgfiles: ' + orgData);

    console.log('newFiles: ' + newFiles);

    // 오리지널 파일들 순환

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

        var isDeleteFile = true;   // 지워야 할 파일인지 판별해주는 변수 | 새로운 파일들을 다 순환해도 같은 이름의 파일이 없으면 지워야 할 파일이 된다.

        // 새로운 파일들 순환

        for(var q = 0; q < newFiles.length; q++){

            if(orgFiles[i].name == newFiles[q].name){

                isDeleteFile = false;

                if(orgFiles[i].size != newFiles[q].size || orgFiles[i].lastModified != newFiles[q].lastModified){

                    newData.updateFiles.push(newFiles[q]);

                }

            }

        }

        if(isDeleteFile){

            newData.deleteFiles.push(orgFiles[i]);

        }

    }

};

var ArrayClear = function(array){

    console.log(array);

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

        array.pop();

    }

}

//#endregion

exports.default = router;