1 var express = require('express');
2 var router = express.Router();
3 var exec = require('child_process').exec;
4 var util = require('util');
5 var fs = require('fs.extra');
6 var dbRoutes = require('./dbRoutes');
7 var csp = require('./csp');
8 var multer = require('multer');
9 var bodyParser = require('body-parser');
10 var sax = require('sax'),strict=true,parser = sax.parser(strict);
11 var async = require('async');
12 var l_ = require('lodash');
13 var dateFormat = require('dateformat');
14 var properties = require(process.env.SDNC_CONFIG_DIR + '/admportal.json');
15 var vnf = require('./vnf');
16 var network = require('./network');
17 var moment = require('moment');
21 // pass host, username and password to ODL
22 // target host for ODL request
23 var username = properties.odlUser;
24 var password = properties.odlPasswd;
25 var auth = 'Basic ' + new Buffer(username + ':' + password).toString('base64');
26 var host = properties.odlHost;
27 var port = properties.odlPort;
29 var header = {'Host': host, 'Authorization': auth, 'Content-Type': 'application/json'};
34 rejectUnauthorized:false,
38 // Connection to OpenDaylight
39 Odl = require('./Odl');
42 var unixTime = moment().unix();
43 var storage = multer.diskStorage({
44 destination: function (req, file, cb) {
45 cb(null, process.cwd() + '/uploads/')
47 filename: function (req, file, cb) {
48 cb(null, unixTime + "." + file.originalname )
54 fileFilter: function(req,file,cb) {
55 var type = file.mimetype;
56 if ( type.indexOf('ms-excel') == -1 ) {
57 return cb(null,false);
63 router.post('/uploadVnfCsv', csp.checkAuth, dbRoutes.checkDB, upload.array('filename'), function(req, res)
65 console.log('files:'+ JSON.stringify(req.files,null,4));
68 var msgArray = new Array();
69 var privilegeObj = req.session.loggedInAdmin;
71 var privilegeObj = req.session.loggedInAdmin;
74 tasks.push ( function(callback) { vnf.go(req,res,callback,''); } );
75 tasks.push ( function(arg1,arg2,callback) { formatVnfInsertStatement(arg1,arg2,req,res,callback); } );
76 tasks.push( function(arg1, callback) { dbRoutes.addRow(arg1,req,res,callback); } );
77 async.waterfall(tasks, function(err,result)
81 dbRoutes.getVnfData(req,res,{code:'failure', msg:msgArray},privilegeObj);
85 //logger.debug('Successfully uploaded ' + req.session.worksheetFilename);
86 msgArray.push('Successfully uploaded file.' );
87 dbRoutes.getVnfData(req,res,{code:'success', msg:msgArray},privilegeObj);
94 router.post('/uploadNetworkCsv', csp.checkAuth, dbRoutes.checkDB, upload.array('filename'), function(req, res)
96 console.log('files:'+ JSON.stringify(req.files,null,4));
99 var msgArray = new Array();
100 var privilegeObj = req.session.loggedInAdmin;
102 var privilegeObj = req.session.loggedInAdmin;
105 tasks.push ( function(callback) { network.go(req,res,callback,''); } );
106 tasks.push ( function(arg1,arg2,callback) { formatNetworkInsertStatement(arg1,arg2,req,res,callback); } );
107 tasks.push( function(arg1, callback) { dbRoutes.addRow(arg1,req,res,callback); } );
108 async.waterfall(tasks, function(err,result)
112 dbRoutes.getVnfNetworkData(req,res,{code:'failure', msg:msgArray},privilegeObj);
116 //logger.debug('Successfully uploaded ' + req.session.worksheetFilename);
117 msgArray.push('Successfully uploaded file.' );
118 dbRoutes.getVnfNetworkData(req,res,{code:'success', msg:msgArray},privilegeObj);
126 function formatVnfInsertStatement(content,filename,req,res,callback)
128 //var newstr = JSON.stringify(content).replace(/\\\"/g,'\\\\\\"');
129 //var ins_str = newstr.replace("\r\n ", "\\r\\n");
130 var newstr = JSON.stringify(content);
131 var enc_str = encodeURI(newstr);
132 var sql = "INSERT INTO PRE_LOAD_VNF_DATA "
133 + "(filename,preload_data) VALUES ("
134 + "'"+ filename + "',"
135 + "'" + enc_str + "')";
140 function formatNetworkInsertStatement(content,filename,req,res,callback)
142 var newstr = JSON.stringify(content);
143 var enc_str = encodeURI(newstr);
144 var sql = "INSERT INTO PRE_LOAD_VNF_NETWORK_DATA "
145 + "(filename,preload_data) VALUES ("
146 + "'"+ filename + "',"
147 + "'" + enc_str + "')";
154 module.exports = router;