var express = require('express');
var router = express.Router();
var exec = require('child_process').exec;
var util = require('util');
var fs = require('fs.extra');
var dbRoutes = require('./dbRoutes');
var csp = require('./csp');
var multer = require('multer');
var bodyParser = require('body-parser');
var sax = require('sax'),strict=true,parser = sax.parser(strict);
var async = require('async');
var l_ = require('lodash');
var dateFormat = require('dateformat');
var properties = require(process.env.SDNC_CONFIG_DIR + '/admportal.json');
var vnf = require('./vnf');
var network = require('./network');
var moment = require('moment');



// pass host, username and password to ODL
// target host for ODL request
var username = properties.odlUser;
var password = properties.odlPasswd;
var auth = 'Basic ' + new Buffer(username + ':' + password).toString('base64');
var host = properties.odlHost;
var port = properties.odlPort;

var header = {'Host': host, 'Authorization': auth, 'Content-Type': 'application/json'};
var options = {
        host    : host,
        headers : header,
        port    : port,
        rejectUnauthorized:false,
        strictSSL: false
};

// multer 1.1
var unixTime = moment().unix();
var storage = multer.diskStorage({
  destination: function (req, file, cb) {
    cb(null, process.cwd() + '/uploads/')
  },
  filename: function (req, file, cb) {
    cb(null, unixTime + "." + file.originalname )
  }
});

var upload = multer({
	storage: storage,
	fileFilter: function(req,file,cb) {
		var type = file.mimetype;
		if ( type.indexOf('ms-excel') == -1 ) {
			return cb(null,false);
		}
		cb(null,true);
	}
});

router.post('/uploadVnfCsv', csp.checkAuth, upload.array('filename'), function(req, res)
{
	console.log('files:'+ JSON.stringify(req.files,null,4));

	var tasks = []
    var msgArray = new Array();
    var privilegeObj = req.session.loggedInAdmin;
	
	var privilegeObj = req.session.loggedInAdmin;
	var tasks = [];

	tasks.push ( function(callback) { vnf.go(req,res,callback,''); } );
	tasks.push ( function(arg1,arg2,callback) { formatVnfInsertStatement(arg1,arg2,req,res,callback); } );
    tasks.push( function(arg1, callback) { dbRoutes.addRow(arg1,req,res,callback); } );
	async.waterfall(tasks, function(err,result)
	{	
		 if(err){
         	msgArray.push(err);
            dbRoutes.getVnfData(req,res,{code:'failure', msg:msgArray},privilegeObj);
            return;
        }
        else {
        	//logger.debug('Successfully uploaded ' + req.session.worksheetFilename);
        	msgArray.push('Successfully uploaded file.' );
            dbRoutes.getVnfData(req,res,{code:'success', msg:msgArray},privilegeObj);
            return;
        }
	});

});

router.post('/uploadNetworkCsv', csp.checkAuth, upload.array('filename'), function(req, res)
{
    console.log('files:'+ JSON.stringify(req.files,null,4));

    var tasks = []
    var msgArray = new Array();
    var privilegeObj = req.session.loggedInAdmin;

    var privilegeObj = req.session.loggedInAdmin;
    var tasks = [];

    tasks.push ( function(callback) { network.go(req,res,callback,''); } );
    tasks.push ( function(arg1,arg2,callback) { formatNetworkInsertStatement(arg1,arg2,req,res,callback); } );
    tasks.push( function(arg1, callback) { dbRoutes.addRow(arg1,req,res,callback); } );
    async.waterfall(tasks, function(err,result)
    {
         if(err){
            msgArray.push(err);
            dbRoutes.getVnfNetworkData(req,res,{code:'failure', msg:msgArray},privilegeObj);
            return;
        }
        else {
            //logger.debug('Successfully uploaded ' + req.session.worksheetFilename);
            msgArray.push('Successfully uploaded file.' );
            dbRoutes.getVnfNetworkData(req,res,{code:'success', msg:msgArray},privilegeObj);
            return;
        }
    });

});


function formatVnfInsertStatement(content,filename,req,res,callback)
{
     //var newstr = JSON.stringify(content).replace(/\\\"/g,'\\\\\\"');
     //var ins_str = newstr.replace("\r\n ", "\\r\\n");
     var newstr = JSON.stringify(content);
     var enc_str = encodeURI(newstr);
	 var sql = "INSERT INTO PRE_LOAD_VNF_DATA "
		+ "(filename,preload_data) VALUES ("
		+ "'"+ filename + "',"
		+ "'" + enc_str + "')";

	callback(null,sql);
}

function formatNetworkInsertStatement(content,filename,req,res,callback)
{
     var newstr = JSON.stringify(content);
     var enc_str = encodeURI(newstr);
	 var sql = "INSERT INTO PRE_LOAD_VNF_NETWORK_DATA "
		+ "(filename,preload_data) VALUES ("
		+ "'"+ filename + "',"
		+ "'" + enc_str + "')";

	callback(null,sql);
}



module.exports = router;