// 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;