diff options
Diffstat (limited to 'admportal/server/router/routes/OdlInterface.js')
| -rwxr-xr-x | admportal/server/router/routes/OdlInterface.js | 594 |
1 files changed, 0 insertions, 594 deletions
diff --git a/admportal/server/router/routes/OdlInterface.js b/admportal/server/router/routes/OdlInterface.js deleted file mode 100755 index 1fc615c4..00000000 --- a/admportal/server/router/routes/OdlInterface.js +++ /dev/null @@ -1,594 +0,0 @@ -// 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; - |