dgbuilder/red/sla.js

exports.listSLA =  function(settings,req,res) {
try{
	var mysql = require('mysql');

	//console.dir(settings);
 
	var connection = mysql.createConnection(
    	{
      	host     : settings.dbHost,
        port     : settings.dbPort,
        user     : settings.dbUser,
        password : settings.dbPassword,
        database : settings.dbName
       });

        var rows=[];

	var sqlQuery = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
	//console.log("sqlQuery:" + sqlQuery);
         connection.query(sqlQuery, function(err, rows) {
            if(!err) {
                if ( rows.length > 0 )
                {
                        res.send({ 'rows': rows,'dbHost':settings.dbHost } );
                }else{
                        res.send({'rows': [],'dbHost':settings.dbHost});
                }
            } else {
			console.log("error:" + err);
            	    res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
            }
		//console.dir(rows);
		connection.end();
        }); //end query
}catch(error){
	console.log(error);
        res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
}
}

exports.listCurrentDGs =  function(settings,req,res) {
	var _module = req.query.module;
	var rpc = req.query.rpc;
	console.log("_module:" + _module);
	console.log("rpc:" + rpc);
try{
	var mysql = require('mysql');

	//console.dir(settings);
 
	var connection = mysql.createConnection(
    	{
      	host     : settings.dbHost,
        port     : settings.dbPort,
        user     : settings.dbUser,
        password : settings.dbPassword,
        database : settings.dbName
       });

        var rows=[];

	var sqlQuery = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC where module ='" + _module + "' and rpc ='" + rpc + "'";
	console.log("sqlQuery:" + sqlQuery);
         connection.query(sqlQuery, function(err, rows) {
            if(!err) {
                if ( rows.length > 0 )
                {
                        res.send({ 'rows': rows,'dbHost':settings.dbHost } );
                }else{
                        res.send({'rows': [],'dbHost':settings.dbHost});
                }
            } else {
			console.log("error:" + err);
            	    res.send({error: "Connection to DB failed.",'dbHost':settings.dbHost});
            }
		//console.dir(rows);
		connection.end();
        }); //end query
}catch(error){
	console.log(error);
        res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
}
}

exports.activateDG = function(settings,req,res){
	var _module = req.query.module;
	var rpc = req.query.rpc;
	var version = req.query.version;
	var mode = req.query.mode;
	var displayOnlyCurrent = req.query.displayOnlyCurrent;

try{
	var mysql = require('mysql');
 
	var connection = mysql.createConnection(
    	{
      	host     : settings.dbHost,
        port     : settings.dbPort,
        user     : settings.dbUser,
        password : settings.dbPassword,
        database : settings.dbName
       });

        var rows=[];

	var updateStmt = "UPDATE SVC_LOGIC SET active=\'Y\' WHERE module=\'"
                        + _module + "' AND rpc=\'"
                        + rpc + "' AND version=\'"
                        +  version + "' AND mode=\'"
                        +  mode + "'";

         connection.query(updateStmt, function(err, result) {
		var nextUpdateStmt = "UPDATE SVC_LOGIC SET active=\'N\' WHERE module=\'"
                        + _module + "' AND rpc=\'"
                        + rpc + "' AND version !=\'"
                        +  version + "'";
         	connection.query(nextUpdateStmt, function(err, result) {
			var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
			if(displayOnlyCurrent == 'true'){
				query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
					+  _module + "' and rpc=\'" + rpc + "'";
			}
         		connection.query(query, function(err, rows) {
            			if(!err) {
                			if ( rows.length > 0 )
                			{
                        			res.send({ 'rows': rows,'dbHost':settings.dbHost } );
                			}else{
                        			res.send({'rows': [],'dbHost':settings.dbHost});
                			}
            			} else {
            	    			res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
            			}
				connection.end();
        		}); //end query
        	}); //end query
       	}); //end query
}catch(error){
        res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
}
}


exports.deActivateDG = function(settings,req,res){

	var _module = req.query.module;
	var rpc = req.query.rpc;
	var version = req.query.version;
	var mode = req.query.mode;
	var displayOnlyCurrent = req.query.displayOnlyCurrent;

try{
	var mysql = require('mysql');
 
	var connection = mysql.createConnection(
    	{
      	host     : settings.dbHost,
        port     : settings.dbPort,
        user     : settings.dbUser,
        password : settings.dbPassword,
        database : settings.dbName
       });

        var rows=[];

	var updateStmt = "UPDATE SVC_LOGIC SET active=\'N\' WHERE module=\'"
                        + _module + "' AND rpc=\'"
                        + rpc + "' AND version=\'"
                        +  version + "' AND mode=\'"
                        +  mode + "'";

         connection.query(updateStmt, function(err, result) {
		var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
		if(displayOnlyCurrent == 'true'){
			query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
				+  _module + "' and rpc=\'" + rpc + "'";
		}
         	connection.query(query, function(err, rows) {
            	if(!err) {
                	if ( rows.length > 0 )
                	{
                        	res.send({ 'rows': rows,'dbHost':settings.dbHost } );
                	}else{
                        	res.send({'rows': [],'dbHost':settings.dbHost});
                	}
            	} else {
            	    	res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
            	}
		connection.end();
        	}); //end query
       	}); //end query
}catch(error){
        res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
}
}

exports.deleteDG = function(settings,req,res){

	var _module = req.query.module;
	var rpc = req.query.rpc;
	var version = req.query.version;
	var mode = req.query.mode;
	var displayOnlyCurrent = req.query.displayOnlyCurrent;

try{
	var mysql = require('mysql');
 
	var connection = mysql.createConnection(
    	{
      	host     : settings.dbHost,
        port     : settings.dbPort,
        user     : settings.dbUser,
        password : settings.dbPassword,
        database : settings.dbName
       });

        var rows=[];

	var deleteStmt = "DELETE FROM SVC_LOGIC  WHERE module=\'"
                        + _module + "' AND rpc=\'"
                        + rpc + "' AND version=\'"
                        +  version + "' AND mode=\'"
                        +  mode + "'";
	 console.log(deleteStmt);

         connection.query(deleteStmt, function(err, result) {
		var query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC";
		if(displayOnlyCurrent == 'true'){
			query = "SELECT module,rpc,version,mode,active FROM SVC_LOGIC WHERE module=\'"
				+  _module + "' and rpc=\'" + rpc + "'";
		}
         	connection.query(query, function(err, rows) {
            	if(!err) {
                	if ( rows.length > 0 )
                	{
                        	res.send({ 'rows': rows,'dbHost':settings.dbHost } );
                	}else{
                        	res.send({'rows': [],'dbHost':settings.dbHost});
                	}
            	} else {
            	    	res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
            	}
		connection.end();
        	}); //end query
       	}); //end query
}catch(error){
        res.send({'error': "Connection to DB failed.",'dbHost':settings.dbHost});
}
}