Initial commit for OpenECOMP SDN-C OA&M

[sdnc/oam.git] / admportal / server / router / routes / preload.js

diff --git a/admportal/server/router/routes/preload.js b/admportal/server/router/routes/preload.js
new file mode 100644 (file)
index 0000000..1a63ec0
--- /dev/null
+++ b/admportal/server/router/routes/preload.js
@@ -0,0 +1,154 @@
+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
+};
+
+// Connection to OpenDaylight
+Odl = require('./Odl');
+
+// 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, dbRoutes.checkDB, 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, dbRoutes.checkDB, 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;