[SDNGC-XXXX] fixing sql connection leak

was not cleaning up sql connections during checkDB, removed call to checkDB, redundant

Change-Id: I3d4a10cb7b743eb68a1969c1719c376829bc27c3
Signed-off-by: Al Rotundo <arotundo@att.com>

Former-commit-id: d9b6e415838e94bf485c01a3f5d6aaa841e37c45

1 files changed, 594 insertions, 0 deletions

diff --git a/admportal/server/router/routes/OdlInterface.js b/admportal/server/router/routes/OdlInterface.js
new file mode 100755
index 00000000..1fc615c4
--- /dev/null
+++ b/admportal/server/router/routes/OdlInterface.js
@@ -0,0 +1,594 @@
+// OdlInterface.js
+var https = require('https');
+var http = require('http');
+var properties = require(process.env.SDNC_CONFIG_DIR + '/admportal.json');
+
+
+var OdlInterface = function() {
+    // Call ODL page
+    //  get(uri,res)
+    //  post(uri,data, res)
+
+	var _healthcheck = function(options, callback)
+	{
+		// Setup request to ODL side
+		console.log('options:' + JSON.stringify(options,null,2));
+		var request = https.request(options, function(response) {
+			
+			var response_str = '';
+	    	// Read the response from ODL side
+	    	response.on('data', function(chunk) {
+				response_str += chunk;
+	    	});
+			
+			response.on('end', function() 
+			{
+				//logger.debug(response_str);
+				if(response.statusCode == 200)
+				{
+					console.log('200 OK');
+					callback(null, response_str);
+					return;
+				}
+				else{
+					console.log('not ok status=' + response.statusCode);
+					callback(response_str, 'statusCode=' + response.statusCode + '\n' + response_str);
+					return;
+				}
+			});
+		});
+		request.end()
+
+		request.on('error', function(err) {
+			console.error('err:' + err);
+			callback(err, err);
+			return;
+		});
+	}
+
+    var _get = function(uri,options,callback,req,res) 
+	{
+
+		options.method = "GET";
+		options.path = uri;
+
+		// Setup request to ODL side
+		console.log('options:' + JSON.stringify(options,null,2));
+		var request = https.request(options, function(response) {
+	    	// console.dir(response);
+  	    	console.log('STATUS: ' + response.statusCode);
+	    	var response_str = '';
+	    	// Read the response from ODL side
+	    	response.on('data', function(chunk) {
+				response_str += chunk;
+	    	});
+
+	    	response.on('end', function() 
+			{
+				console.log(response_str);
+
+				if(response.statusCode == 200)
+				{
+				// make sure response starts with JSON string
+        		if (response_str && response_str.indexOf('{') == 0) {
+            		//console.log("response: ", result);
+						
+					req.session.l3sdnPageInfo = undefined;
+					var x=0;
+					var pageList = [];
+					var obj_rows = [];
+					var rows = [];
+					var robj = JSON.parse(response_str);
+
+					if ( typeof robj['services']['layer3-service-list'] != 'undefined' )
+					{
+						for( var i=0; i<robj['services']['layer3-service-list'].length; i++)
+						{
+							obj_rows.push( robj['services']['layer3-service-list'][i] );
+						}
+					}
+					else
+					{
+            			res.render('pages/err', {result:{code:'failure', msg:'no data Error: ' + String(err)}, header:process.env.MAIN_MENU});
+						callback(null,response_str,res);
+						return;
+					}
+ 
+        			var rows = [];
+					var l3sdnPageInfo =
+        			{
+            			'totalRows'   : obj_rows.length,
+            			'pageSize'    : 18,
+            			'pageCount'   : parseInt(obj_rows.length/18),
+            			'currentPage' : 1
+        			}
+
+					while (obj_rows.length > 0){
+            			pageList.push(obj_rows.splice(0,l3sdnPageInfo.pageSize));
+        			}
+					l3sdnPageInfo.rows = pageList[0]; // first page
+					l3sdnPageInfo.pages = pageList; // all pages
+
+
+					req.session.l3sdnPageInfo = l3sdnPageInfo;
+					var privObj = req.session.loggedInAdmin;
+
+            		res.render('odl/listWklst', 
+					{
+            			pageInfo  : l3sdnPageInfo,
+            			result    : {code:'', msg:''},
+						privilege : privObj, header:process.env.MAIN_MENU
+    				});
+
+
+        		} else {
+            		res.render('pages/err', {result:{code:'failure', msg:'no data Error: ' + String(err)}, header:process.env.MAIN_MENU});
+        		}
+	        	callback(null, response_str, res);
+			}
+			else
+			{
+				callback(response_str,response_str,res);
+				//res.render('pages/err', {result:{code:'failure', msg:'Failed to retrieve worklist. ' + response_str}});
+			}
+	    	});
+		});
+
+		request.end()
+
+		request.on('error', function(err) {
+	    	callback(err,null, res);
+		});
+    }
+
+    var _getid = function(uri,options,res) {
+	options.method = "GET";
+	options.path = uri;
+
+	// Setup request to ODL side
+	var request = https.request(options, function(response) {
+	    // console.dir(response);
+  	    //console.log('STATUS: ' + response.statusCode);
+	    var response_str = '';
+	    // Read the response from ODL side
+	    response.on('data', function(chunk) {
+			response_str += chunk;
+	    });
+
+	    response.on('end', function() {
+			if(response.statusCode == 200){
+				if(response_str){
+					//console.log("response: ", response_str);
+					res.render('odl/view', {response_obj: JSON.parse(response_str), header:process.env.MAIN_MENU});
+				}
+				else{
+					//console.log("no data");
+					res.render('pages/err', {result:{code:'failure', msg:'Failed to retrieve worklist'}, header:process.env.MAIN_MENU});
+				}
+			}
+			else {
+				//console.log("bad status code:", response.statusCode);
+				res.render('pages/err', {result:{code:'failure', msg:'Failed to retrieve worklist. Status Code:' + response.statusCode}, header:process.env.MAIN_MENU});
+			}
+	    });
+	});
+
+	request.end()
+
+	request.on('error', function(err) {
+		//console.log(err);
+		res.render('pages/err', {result:{code:'failure', msg:'Failed to get worklist item. ' + String(err)}, header:process.env.MAIN_MENU});
+	});
+    }
+
+	var _getvrlan = function(uri,options,callback) {
+    options.method = "GET";
+    options.path = uri;
+
+
+	//callback(null,'');	
+    // Setup request to ODL side
+    var request = https.request(options, function(response) {
+        // console.dir(response);
+        //console.log('STATUS: ' + response.statusCode);
+        var response_str = '';
+        // Read the response from ODL side
+        response.on('data', function(chunk) {
+            response_str += chunk;
+        });
+
+
+        response.on('end', function() {
+            if(response.statusCode == 200){
+                if(response_str){
+					callback(null,response_str);
+					return;
+                }
+                else{
+					callback('err','no data');
+					return;
+                }
+            }
+            else {
+				callback('error',response.statusCode);
+				return;
+            }
+        });
+    });
+
+    request.end()
+
+    request.on('error', function(err) {
+		callback(err,String(err));
+		return;
+    });
+    }
+
+
+	var _getvnf = function(uri,options,req,res) {
+    options.method = "GET";
+    options.path = uri;
+
+    // Setup request to ODL side
+    var request = https.request(options, function(response) {
+        // console.dir(response);
+        //console.log('STATUS: ' + response.statusCode);
+        var response_str = '';
+        // Read the response from ODL side
+        response.on('data', function(chunk) {
+            response_str += chunk;
+        });
+
+        response.on('end', function() {
+            if(response.statusCode == 200){
+                if(response_str){
+                    //console.log("response: ", response_str);
+                    res.render('odl/viewvnf', { vnf_obj: JSON.parse(response_str),
+											   request_id: req.query['request'], header:process.env.MAIN_MENU });
+                }
+                else{
+                    //console.log("no data");
+					res.render('pages/err', {result:{code:'failure', msg:'Failed to retrieve worklist item.'}, header:process.env.MAIN_MENU});
+                }
+            }
+            else {
+                //console.log("bad status code:", response.statusCode);
+				res.render('pages/err', {result:{code:'failure', msg:'Failed to retrieve worklist. Status Code:' + response.statusCode}, header:process.env.MAIN_MENU});
+            }
+        });
+    });
+
+    request.end()
+
+    request.on('error', function(err) {
+        //console.log(err);
+        res.render('pages/err', {result:{code:'failure', msg:'Failed getting VNF information. Error: '+ String(err)}, header:process.env.MAIN_MENU});
+    });
+    }
+
+	var _getPreloadVnfData = function(uri,options,res,callback) {
+
+    options.method = "GET";
+    options.path = uri;
+
+
+    // Setup request to ODL side
+	var protocol;
+	if ( process.env.NODE_ENV != 'production' ){
+    	protocol = http;
+	}else{
+    	protocol = https;
+	}
+
+console.log('NODE_ENV:' + process.env.NODE_ENV);
+console.log('GET: ' + JSON.stringify(options,null,4));
+
+    var request = protocol.request(options, function(response) {
+
+        var response_str = '';
+
+        // Read the response from ODL side
+        response.on('data', function(chunk) {
+            response_str += chunk;
+        });
+
+        response.on('end', function() {
+console.log('response_str: ' + response_str);
+console.log('response.statusCode: ' + response.statusCode);
+            if(response.statusCode == 200){
+                if(response_str){
+						callback(null,response_str);
+						return;
+				}
+                else{
+					callback('Error - No data returned.');
+					return;
+                }
+            }
+            else {
+				if ( response.statusCode == 404 )
+				{
+					callback('HTTP Status Code:' + response.statusCode + '.  Not Found.');
+					return;
+				}
+				else if ( response_str.length > 0 )
+				{
+					callback('HTTP Status Code:' + response.statusCode + '.  ' + response_str);
+					return;
+				}
+				else
+				{
+					callback('HTTP Status Code:' + response.statusCode + '.  No data returned.');
+					return;
+				}
+            }
+        });
+    });
+
+    request.end()
+
+    request.on('error', function(err) {
+		callback(err);
+		return;
+    });
+    }
+
+var _getClusterStatus = function(options,callback) {
+    //options.method = "GET";
+    //options.path = uri;
+
+    console.log('URI='+options.path);
+
+    // Setup request to ODL side
+    var protocol = properties.odlProtocol;
+console.log('protocol=' + protocol);
+    if ( protocol == 'http' || protocol == 'HTTP' )
+    {
+console.log('http request');
+	var request = http.request(options, function(response) {
+        	var response_str = '';
+
+        	// Read the response from ODL side
+        	response.on('data', function(chunk) {
+            		response_str += chunk;
+        	});
+
+
+        	response.on('end', function() {
+console.log('HTTP StatusCode='+response.statusCode);
+            		if(response.statusCode == 200){
+                		if(response_str){
+console.log('response_str='+response_str);
+                    			callback(null,JSON.parse(response_str));
+                    			return;
+                		}
+                		else{
+                    			callback(null,'no data');
+                    			return;
+                		}
+            		}
+            		else {
+                		callback(null,response.statusCode);
+                		return;
+            		}
+        	});
+    		});
+
+    	request.end()
+
+    	request.on('error', function(err) {
+        	callback(null,String(err));
+        	return;
+    	});
+    }
+    else {
+	var request = https.request(options, function(response) {
+                var response_str = '';
+
+                // Read the response from ODL side
+                response.on('data', function(chunk) {
+                        response_str += chunk;
+                });
+
+
+                response.on('end', function() {
+                        if(response.statusCode == 200){
+                                if(response_str){
+console.log('response_str='+response_str);
+                                        callback(null,JSON.parse(response_str));
+                                        return;
+                                }
+                                else{
+                                        callback(null,'no data');
+                                        return;
+                                }
+                        }
+                        else {
+                                callback(null,response.statusCode);
+                                return;
+                        }
+                });
+                });
+
+        request.end()
+
+        request.on('error', function(err) {
+                callback(null,String(err));
+                return;
+        });
+    }
+}
+
+    var _delete = function(uri,options,res,callback) {
+		options.method = 'DELETE';
+		options.path = uri;
+
+
+        // Setup request to ODL side
+        //var request = https.request(options, function(response) {
+        var request = http.request(options, function(response) {
+            //console.log('STATUS: ' + response.statusCode);
+            var response_str = '';
+            // Read the response from ODL side
+            response.on('data', function(chunk) {
+                response_str += chunk;
+            });
+
+            response.on('end', function() {
+				if(response.statusCode == 200){
+                    callback(null);
+                    return;
+                }
+                else {
+                    callback('Error:' + response_str);
+                    return;
+                }
+            });
+        });
+		request.on('error', function(err) {
+	    	callback(err);
+			return;
+		});
+        request.end()
+    }
+
+    var _post = function(uri,options,data,res,callback)
+	{
+		options.method = 'POST';
+		options.path = uri;
+
+
+		// Setup request to ODL side
+		var protocol;
+		//if ( process.env.NODE_ENV != 'production' ){
+    		protocol = http;
+		//}else{
+    		//protocol = https;
+		//}
+		var request = protocol.request(options, function(response)
+		{
+	    	var response_str = '';
+	    	// Read the response from ODL side
+	    	response.on('data', function(chunk) {
+				response_str += chunk;
+                //logger.debug('chunk:' + chunk);
+	    	});
+
+	    	// end of request, check response
+	    	response.on('end', function() {
+				console.log('post status code:'+response.statusCode);
+				if(response.statusCode == 200 ){
+                    try {
+				        var respObj = JSON.parse(response_str);
+                        console.log('response_str.length:' + response_str.length);
+					    if(response_str){
+	        			    console.log("post response-code:" + respObj['output']['response-code']);
+						
+                    	    if ( respObj['output']['response-code'] == 200 ){
+                        	    callback(null,response_str);
+                        	    return;
+                    	    }else{
+                        	    callback('Error - response-code:' + respObj['output']['response-code'] + '  response-message:' + respObj['output']['response-message']);
+                        	    return;
+                    	    }
+					    }else{
+						    // success
+	            		    callback(null);
+						    return;
+					    }
+                    }
+                    catch (error) {
+                        callback('Error parsing response: ' + error);
+                        return;
+                    }
+				}
+            	else {
+				    var respObj = null; 
+                    if ( response_str.length > 0 ) {
+                        console.log('response_str:' + response_str);
+				        try {
+                            respObj = JSON.parse(response_str);
+                            if ( typeof respObj['errors'] != 'undefined' )
+					        {
+                                console.log('Error' + JSON.stringify(respObj));
+						        if ( typeof respObj['errors']['error'][0]['error-message'] != 'undefined' )
+						        {
+							        callback('HTTP Status Code:' + response.statusCode + '. Message:' 
+								        + respObj['errors']['error'][0]['error-message']);
+                			        return;
+						        }
+						        else
+						        {
+							        callback('Error - HTTP Status Code:' + response.statusCode + '.');
+                			        return;
+						        }
+					        }
+					        else
+					        {
+						        callback('Error - HTTP Status Code:' + response.statusCode + '.');
+                		        return;
+					        }
+                        }
+                        catch (error) {
+						    callback('Error - HTTP Status Code:' + response.statusCode + '.');
+                		    return;
+                        }
+                    }
+                    else{
+						callback('Error - HTTP Status Code:' + response.statusCode + '.');
+                		return;
+					}
+            	}
+	    	});
+		});
+
+		request.on('error', function(err) {
+	    	callback(err);
+			return;
+		});
+
+    	request.write(data);
+		request.end()
+    }
+
+    var _postSubnetAllocated = function(uri,options,data,callback,res) {
+        options.method = 'POST';
+        options.path = uri;
+
+        // Setup request to ODL side
+        var request = https.request(options, function(response) {
+        var response_str = '';
+        // Read the response from ODL side
+        response.on('data', function(chunk) {
+        response_str += chunk;
+        });
+
+        // end of request, check response
+        response.on('end', function() {
+            //console.log("post: response: " + response_str);
+             callback(response_str,null,res);
+        });
+    });
+    request.on('error', function(err) {
+        callback(err,null, res);
+    });
+    request.write(data);
+    request.end()
+    }
+
+    return {
+	GetClusterStatus: _getClusterStatus,
+	Get: _get,
+	GetID: _getid,
+	GetVNF: _getvnf,
+	GetVRlan: _getvrlan,
+	GetPreloadVnfData: _getPreloadVnfData,
+	Post: _post,
+	PostSubnetAllocated: _postSubnetAllocated,
+	Delete: _delete,
+	Healthcheck: _healthcheck
+    };
+}();
+
+module.exports = OdlInterface;
+