server.js

var express = require('express');
var path = require('path');
var fs = require("fs");
var bodyParser = require('body-parser');
var port = process.env.PORT || process.env.VCAP_APP_PORT || '4000';
var nano = require('nano')('http://localhost:'+port);var app = express();
var axios = require("axios");
const BusinessNetworkConnection = require('composer-client').BusinessNetworkConnection;
const rp = require('request-promise');

var cloudantUserName = "97db821e-87a4-4507-b8ee-fcc95b72b447-bluemix";
var cloudantPassword = "ae34609f865eac5720a3e08c9c0208840a9418090a98f9a4c1fcb9fa5573040b";
var dbCredentials_url = "https://"+cloudantUserName+":"+cloudantPassword+"@"+cloudantUserName+".cloudant.com"; // Set this to your own account

//Initialize the library with my account
var cloudant = require('cloudant')(dbCredentials_url);
var dbForLogin = cloudant.db.use("deathclaim");
var dbForTxFlow = cloudant.db.use("deathclaim-tx-flow");
const accountSid = 'AC19cc0b94578878d44c6b86aa726d6b2a';
const authToken = '8e799f98253d6382a9acb984149a7dc7';
const client = require('twilio')(accountSid, authToken);


app.use(bodyParser.json());

app.use(bodyParser.urlencoded({
    extended: true
}));

app.use('/', express.static(__dirname + '/login'));

app.get('/', function(req, res) {
    console.log("Open index page");
    res.sendFile(path.join(__dirname + '/index.html'));
});


app.use('/', express.static(__dirname + '/loginSuccess'));
app.use('/', express.static(__dirname + '/registration'));

app.listen(port);
console.log("server is up on port : "+port);

var pid = { name: 'pid', type: 'json', index: { fields: ['pid'] } };

dbForTxFlow.index(pid, function(er, response) {
  if(er)
    console.log('Error creating index on pid : ' + er);
  else
    console.log('Index creation result on pid : ' + response.result);
}); 


app.post('/getTxData',function (req,res){

 var id = req.body.pid;
	
	
dbForTxFlow.find({ selector: { pid:id } }, function(err, result) {
	 if (!err) {
                     res.json({
               			 success: true,
	        	        record: result
		            });
                } else {
                    res.json({
                                 success: false,
                                 record: err
                            });
                } 
 });
});


function submitTxFlowData(data){

	   // var dateString = Date();
           // dateString = new Date(dateString).toUTCString();
           // data.timestamp = dateString.split(' ').slice(0, 5).join(' ');
	    data.timestamp = Date.now();	
	 
            
	    dbForTxFlow.insert(data, function(err, data) {
                if (!err) {
                    console.log("Transaction inserted into database");
                } else {
                    console.log("error while inserting");
                }
            });			
}

app.post('/verifyBeneficiary', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };
	

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Beneficiary/'+req.body.bid;

   verifyBeneficiary(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                record: data.response
            });
	console.log(data);	
        } else res.json({
            success: false,
            message: data
        });
    });


});

var verifyBeneficiary = async (url, headers) => {
    try {
        var Beneficiary = await axios.get(url, headers);

        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: Beneficiary.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error.toString()
        });
    }
}


app.post('/searchPatient', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Patientform/'+req.body.pid;
	
	
   searchPatient(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                record: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var searchPatient = async (url, headers) => {
    try {
        var Paitent = await axios.get(url, headers);

        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: Paitent.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error.data
        });
    }
}


app.get('/getAllBeneficiary', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Beneficiary';

    getAllBeneficiary(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                beneficiaryDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllBeneficiary = async (url, headers) => {
    try {
        var allBeneficiary = await axios.get(url, headers);
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: allBeneficiary.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}



app.post('/getAllCertprovider', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Certprovider';

    getAllCertprovider(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                certproviderDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllCertprovider = async (url, headers) => {
    try {
        var certprovider = await axios.get(url, headers);
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: certprovider.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/getAllFuneralhome', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Funeralhome';

    getAllFuneralhome(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                funeralhomeDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllFuneralhome = async (url, headers) => {
    try {
        var funeralhome = await axios.get(url, headers);
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: funeralhome.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/getAllHospital', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Hospital';

    getAllHospital(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                hospitalDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllHospital = async (url, headers) => {
    try {
        var hospital = await axios.get(url, headers);
       
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: hospital.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/getAllInsurer', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Insurer';

    getAllInsurer(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                insurerDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllInsurer = async (url, headers) => {
    try {
        var insurer = await axios.get(url, headers);
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: insurer.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/getAllPatientform', function (req, res) {

    var data = {};

    var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

    var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Patientform';

    getAllPatientform(url, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                patientDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var getAllPatientform = async (url, headers) => {
    try {
        var patient = await axios.get(url, headers);
        console.log("Data fetched succesfully");
        return ({
            success: true,
            response: patient.data
        });
    } catch (error) {
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/addDeathRecord', function (req, res) {

  var reqdata = req.body; 

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.PatientRegistration';

    addDeathRecord(url, reqdata, headers).then(function (data) {
        if (data.success) {
	
	    // submitting tx into database

	    data.response.pid = data.response.patientform.pid;
	    submitTxFlowData(data.response);
	
            res.json({
                success: true,
                deathRecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });


});

var addDeathRecord = async (url, data, headers) => {
    
   try {
        var deathRecord = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: deathRecord.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/VerifyandNotifyBeneficiary', function (req, res) {

  var reqdata = req.body;
  var bcontact  = reqdata.bcontactno;
  var paitentfrom = reqdata.patientform.split("#");;
  var pid = paitentfrom[1]; 

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.VerifyandNotifyBeneficiary';

    VerifyandNotifyBeneficiary(url, reqdata, headers).then(function (data) {
        if (data.success) {
	
	    client.messages.create({
                                from: '+12512740095',
                                body: 'Dear Benificiary,for Paitent-'+pid+' please login to portal select funeral home and start death registration process. URL http://ec2-54-205-134-49.compute-1.amazonaws.com:4000',
                                to: bcontact}).then(message => console.log(message.sid));

	   	
            // inserting tx into database  
            data.response.pid = data.response.patientform.split("#")[1]; 
	    submitTxFlowData(data.response);   
	
            res.json({
                success: true,
                verifyandNotifyBeneficiaryRecordDetails: data.response
            });
	
        } else res.json({
            success: false,
            message: data
        });
    });
});

var VerifyandNotifyBeneficiary = async (url, data, headers) => {

   try {
        var verifyandNotifyBeneficiaryRecord = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: verifyandNotifyBeneficiaryRecord.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/Beneficiaryupdate', function (req, res) {

  var reqdata = req.body;

  console.log(reqdata);

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.Beneficiaryupdate';

    Beneficiaryupdate(url, reqdata, headers).then(function (data) {
        if (data.success) {
		
            // inserting tx into database
            data.response.pid = data.response.patientform.split("#")[1];
            submitTxFlowData(data.response);
	
            res.json({
                success: true,
                RecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var Beneficiaryupdate = async (url, data, headers) => {

   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/requestcert', function (req, res) {

  var reqdata = req.body;

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.requestcert';

    requestcert(url, reqdata, headers).then(function (data) {
        if (data.success) {
		
	    // inserting tx into database
            data.response.pid = data.response.patientform.split("#")[1];
            submitTxFlowData(data.response);
	
            res.json({
                success: true,
                RecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var requestcert = async (url, data, headers) => {

   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/providecert' , function (req, res) {

  var reqdata = req.body;

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.providecert';

    providecert(url, reqdata, headers).then(function (data) {
        if (data.success) {

	    // inserting tx into database
            data.response.pid = data.response.patientform.split("#")[1];
            submitTxFlowData(data.response);
	
            res.json({
                success: true,
                RecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var providecert = async (url, data, headers) => {

   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        console.log(error);
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/claiminitiation' , function (req, res) {

  var reqdata = req.body;

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.claiminitiation';

    requestcert(url, reqdata, headers).then(function (data) {
        if (data.success) {
	   

	  // inserting tx into database
            data.response.pid = data.response.patientform.split("#")[1];
            submitTxFlowData(data.response);


            res.json({
                success: true,
                RecordDetails: data.response
            });
	console.log(data);
        } else res.json({
            success: false,
            message: data
        });
    });
});

var claiminitiation = async (url, data, headers) => {

   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/addParticipants' , function (req, res) {

  var reqdata = req.body.data;
  var url  = req.body.url;

  var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

 addParticipants(url, reqdata, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                RecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var addParticipants = async (url, data, headers) => {
   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/getPolicyDetails' , function (req, res) {

   var id = req.body.data; 
  
   dbForLogin.get(id,function(err, body) {
        console.log("erorr : "+err);
        if (!err) {

                res.send ({
                    "status": 200,
                    "message": 'Success',
                    "bid":body.benificiary_id,
                    "bname": body.benificiary_name,
		    "bcontact": body.benificiary_contactNo,
		    "bemail": body.benificiary_emailId
                });

        } else {
           res.send({
			"status":404,
			"data":err
		});
        }
    });
   
});



app.post('/BeneficiaryIdProofupdate', function (req, res) {

  var reqdata = req.body;

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.updateBenificiaryIdentityProof';

 	BeneficiaryIdProofupdate(url, reqdata, headers).then(function (data) {
        if (data.success) {
            res.json({
                success: true,
                RecordDetails: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var BeneficiaryIdProofupdate = async (url, data, headers) => {
   try {
        var Record = await axios.post(url,data);
        console.log("Data post succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}

app.post('/getHistory', function (req, res) {

  var reqdata = req.body;
console.log(reqdata);

   var headers = {
        headers: {
            'Content-Type': 'application/x-www-form-urlencoded'
        }
    };

  var url = 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.HistoryQuery';

        getHistory(url, reqdata, headers).then(function (data) {
//	console.log(data);
        if (data.success) {
            res.json({
                success: true,
                getHistory: data.response
            });
        } else res.json({
            success: false,
            message: data
        });
    });
});

var getHistory = async (url, data, headers) => {
   try {
        var Record = await axios.post(url,data);
        console.log("Get History  succesfully");
        return ({
            success: true,
            response: Record.data
        });
    } catch(error){
        return ({
            success: false,
            message: error
        });
    }
}


app.post('/history', async function (req,res){
	
	var obj = req.body;

        //var obj = JSON.parse(obj);

        console.log(obj);

    //You can do ANYTHING HERE eg.
        var options = {
        method: 'POST',
        uri: 'http://ec2-54-205-134-49.compute-1.amazonaws.com:8080/api/org.aetna.insurance.HistoryQuery',
        body: obj,
        json: true
    };

try {
    let results = await rp(options);

    console.log("Return value from REST API is " + results);
    console.log(`PARTICIPANT HISTORY for Asset ID:  ${results[0]} is: `);
    console.log("=============================================");

    for (const part of results) {
         console.log(`${part.pid}` );
    }
   }
catch(err)
{
        console.log("----------------"+err);
}

});