Patient data smart contract on Hyperledger-Fabric blockchain development - Sandeep Kanao

Patient data smart contract on Hyperledger-Fabric blockchain development (source code) - Sandeep Kanao


startFabric.sh

#!/bin/bash
#
# Copyright IBM Corp All Rights Reserved
#
# SPDX-License-Identifier: Apache-2.0
#
# Exit on first error
set -e

# don't rewrite paths for Windows Git Bash users
export MSYS_NO_PATHCONV=1
starttime=$(date +%s)
LANGUAGE=${1:-"golang"}
CC_SRC_PATH=github.com/healthdata/go
if [ "$LANGUAGE" = "node" -o "$LANGUAGE" = "NODE" ]; then
 CC_SRC_PATH=/opt/gopath/src/github.com/healthdata/node
fi

# clean the keystore
rm -rf ./hfc-key-store

# launch network; create channel and join peer to channel
cd ../basic-network
./start.sh

# Now launch the CLI container in order to install, instantiate chaincode
# and prime the ledger with our 10 cars
docker-compose -f ./docker-compose.yml up -d cli

docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode install -n healthdata -v 1.1 -p "$CC_SRC_PATH" -l "$LANGUAGE"
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode instantiate -o orderer.example.com:7050 -C mychannel -n healthdata -l "$LANGUAGE" -v 1.1 -c '{"Args":[""]}' -P "OR ('Org1MSP.member','Org2MSP.member')"
sleep 10
docker exec -e "CORE_PEER_LOCALMSPID=Org1MSP" -e "CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp" cli peer chaincode invoke -o orderer.example.com:7050 -C mychannel -n healthdata -c '{"function":"initLedger","Args":[""]}'

printf "\nTotal setup execution time : $(($(date +%s) - starttime)) secs ...\n\n\n"
printf "Start by installing required packages run 'npm install'\n"
printf "Then run 'node enrollAdmin.js', then 'node registerUser'\n\n"
printf "The 'node invoke.js' will fail until it has been updated with valid arguments\n"
printf "The 'node query.js' may be run at anytime once the user has been registered\n\n"

enrolladmin.js

'use strict';
/*
* Copyright IBM Corp All Rights Reserved
*
* SPDX-License-Identifier: Apache-2.0
*/
/*
 * Enroll the admin user
 */

var Fabric_Client = require('fabric-client');
var Fabric_CA_Client = require('fabric-ca-client');

var path = require('path');
var util = require('util');
var os = require('os');

//
var fabric_client = new Fabric_Client();
var fabric_ca_client = null;
var admin_user = null;
var member_user = null;
var store_path = path.join(__dirname, 'hfc-key-store');
console.log(' Store path:'+store_path);

// create the key value store as defined in the fabric-client/config/default.json 'key-value-store' setting
Fabric_Client.newDefaultKeyValueStore({ path: store_path
}).then((state_store) => {
    // assign the store to the fabric client
    fabric_client.setStateStore(state_store);
    var crypto_suite = Fabric_Client.newCryptoSuite();
    // use the same location for the state store (where the users' certificate are kept)
    // and the crypto store (where the users' keys are kept)
    var crypto_store = Fabric_Client.newCryptoKeyStore({path: store_path});
    crypto_suite.setCryptoKeyStore(crypto_store);
    fabric_client.setCryptoSuite(crypto_suite);
    var tlsOptions = {
     trustedRoots: [],
     verify: false
    };
    // be sure to change the http to https when the CA is running TLS enabled
    fabric_ca_client = new Fabric_CA_Client('http://192.168.99.100:7054', tlsOptions , 'ca.example.com', crypto_suite);

    // first check to see if the admin is already enrolled
    return fabric_client.getUserContext('admin', true);
}).then((user_from_store) => {
    if (user_from_store && user_from_store.isEnrolled()) {
        console.log('Successfully loaded admin from persistence');
        admin_user = user_from_store;
        return null;
    } else {
        // need to enroll it with CA server
        return fabric_ca_client.enroll({
          enrollmentID: 'admin',
          enrollmentSecret: 'adminpw'
        }).then((enrollment) => {
          console.log('Successfully enrolled admin user "admin"');
          return fabric_client.createUser(
              {username: 'admin',
                  mspid: 'Org1MSP',
                  cryptoContent: { privateKeyPEM: enrollment.key.toBytes(), signedCertPEM: enrollment.certificate }
              });
        }).then((user) => {
          admin_user = user;
          return fabric_client.setUserContext(admin_user);
        }).catch((err) => {
          console.error('Failed to enroll and persist admin. Error: ' + err.stack ? err.stack : err);
          throw new Error('Failed to enroll admin');
        });
    }
}).then(() => {
    console.log('Assigned the admin user to the fabric client ::' + admin_user.toString());
}).catch((err) => {
    console.error('Failed to enroll admin: ' + err);
});

query.js

'use strict';
/*
* Copyright IBM Corp All Rights Reserved
*
* SPDX-License-Identifier: Apache-2.0
*/
/*
 * Chaincode query
 */

var Fabric_Client = require('fabric-client');
var path = require('path');
var util = require('util');
var os = require('os');

//
var fabric_client = new Fabric_Client();

// setup the fabric network
var channel = fabric_client.newChannel('mychannel');
var peer = fabric_client.newPeer('grpc://192.168.99.100:7051');
channel.addPeer(peer);

//
var member_user = null;
var store_path = path.join(__dirname, 'hfc-key-store');
console.log('Store path:'+store_path);
var tx_id = null;

// create the key value store as defined in the fabric-client/config/default.json 'key-value-store' setting
Fabric_Client.newDefaultKeyValueStore({ path: store_path
}).then((state_store) => {
 // assign the store to the fabric client
 fabric_client.setStateStore(state_store);
 var crypto_suite = Fabric_Client.newCryptoSuite();
 // use the same location for the state store (where the users' certificate are kept)
 // and the crypto store (where the users' keys are kept)
 var crypto_store = Fabric_Client.newCryptoKeyStore({path: store_path});
 crypto_suite.setCryptoKeyStore(crypto_store);
 fabric_client.setCryptoSuite(crypto_suite);

 // get the enrolled user from persistence, this user will sign all requests
 return fabric_client.getUserContext('user1', true);
}).then((user_from_store) => {
 if (user_from_store && user_from_store.isEnrolled()) {
  console.log('Successfully loaded user1 from persistence');
  member_user = user_from_store;
 } else {
  throw new Error('Failed to get user1.... run registerUser.js');
 }

 // queryCar chaincode function - requires 1 argument, ex: args: ['CAR4'],
 // queryAllCars chaincode function - requires no arguments , ex: args: [''],
 const request = {
  //targets : --- letting this default to the peers assigned to the channel
  chaincodeId: 'healthdata',
  fcn: 'queryPatient',
  args: ['PATIENT1']
 };

 // send the query proposal to the peer
 return channel.queryByChaincode(request);
}).then((query_responses) => {
 console.log("Query has completed, checking results");
 // query_responses could have more than one  results if there multiple peers were used as targets
 if (query_responses && query_responses.length == 1) {
  if (query_responses[0] instanceof Error) {
   console.error("error from query = ", query_responses[0]);
  } else {
   console.log("Response is ", query_responses[0].toString());
  }
 } else {
  console.log("No payloads were returned from query");
 }
}).catch((err) => {
 console.error('Failed to query successfully :: ' + err);
});

registerUser.js

'use strict';
/*
* Copyright IBM Corp All Rights Reserved
*
* SPDX-License-Identifier: Apache-2.0
*/
/*
 * Register and Enroll a user
 */

var Fabric_Client = require('fabric-client');
var Fabric_CA_Client = require('fabric-ca-client');

var path = require('path');
var util = require('util');
var os = require('os');

//
var fabric_client = new Fabric_Client();
var fabric_ca_client = null;
var admin_user = null;
var member_user = null;
var store_path = path.join(__dirname, 'hfc-key-store');
console.log(' Store path:'+store_path);

// create the key value store as defined in the fabric-client/config/default.json 'key-value-store' setting
Fabric_Client.newDefaultKeyValueStore({ path: store_path
}).then((state_store) => {
    // assign the store to the fabric client
    fabric_client.setStateStore(state_store);
    var crypto_suite = Fabric_Client.newCryptoSuite();
    // use the same location for the state store (where the users' certificate are kept)
    // and the crypto store (where the users' keys are kept)
    var crypto_store = Fabric_Client.newCryptoKeyStore({path: store_path});
    crypto_suite.setCryptoKeyStore(crypto_store);
    fabric_client.setCryptoSuite(crypto_suite);
    var tlsOptions = {
     trustedRoots: [],
     verify: false
    };
    // be sure to change the http to https when the CA is running TLS enabled
    fabric_ca_client = new Fabric_CA_Client('http://192.168.99.100:7054', null , '', crypto_suite);

    // first check to see if the admin is already enrolled
    return fabric_client.getUserContext('admin', true);
}).then((user_from_store) => {
    if (user_from_store && user_from_store.isEnrolled()) {
        console.log('Successfully loaded admin from persistence');
        admin_user = user_from_store;
    } else {
        throw new Error('Failed to get admin.... run enrollAdmin.js');
    }

    // at this point we should have the admin user
    // first need to register the user with the CA server
    return fabric_ca_client.register({enrollmentID: 'user1', affiliation: 'org1.department1',role: 'client'}, admin_user);
}).then((secret) => {
    // next we need to enroll the user with CA server
    console.log('Successfully registered user1 - secret:'+ secret);

    return fabric_ca_client.enroll({enrollmentID: 'user1', enrollmentSecret: secret});
}).then((enrollment) => {
  console.log('Successfully enrolled member user "user1" ');
  return fabric_client.createUser(
     {username: 'user1',
     mspid: 'Org1MSP',
     cryptoContent: { privateKeyPEM: enrollment.key.toBytes(), signedCertPEM: enrollment.certificate }
     });
}).then((user) => {
     member_user = user;

     return fabric_client.setUserContext(member_user);
}).then(()=>{
     console.log('User1 was successfully registered and enrolled and is ready to intreact with the fabric network');

}).catch((err) => {
    console.error('Failed to register: ' + err);
 if(err.toString().indexOf('Authorization') > -1) {
  console.error('Authorization failures may be caused by having admin credentials from a previous CA instance.\n' +
  'Try again after deleting the contents of the store directory '+store_path);
 }
});

package.json

{
    "name": "healthdata",
    "version": "1.0.0",
    "private": true,
    "description": "Hyperledger Fabric healthdata Sample Application",
    "main": "healthdata.js",
    "scripts": {
        "test": "echo \"Error: no test specified\" && exit 1"
    },
    "dependencies": {
        "fabric-ca-client": "unstable",
        "fabric-client": "unstable",
        "grpc": "^1.6.0"
    },
    "author": "Sandeep Kanao",
    "license": "Apache-2.0",
    "keywords": [
        "Hyperledger",
        "Fabric",
        "healthdata",
        "Sample",
        "Application"
    ],
    "devDependencies": {
        "lite-server": "^2.3.0"
    }
}

invoke.js

'use strict';
/*
* Copyright IBM Corp All Rights Reserved
*
* SPDX-License-Identifier: Apache-2.0
*/
/*
 * Chaincode Invoke
 */

var Fabric_Client = require('fabric-client');
var path = require('path');
var util = require('util');
var os = require('os');

//
var fabric_client = new Fabric_Client();

// setup the fabric network
var channel = fabric_client.newChannel('mychannel');
var peer = fabric_client.newPeer('grpc://192.168.99.100:7051');
channel.addPeer(peer);
var order = fabric_client.newOrderer('grpc://192.168.99.100:7050')
channel.addOrderer(order);

//
var member_user = null;
var store_path = path.join(__dirname, 'hfc-key-store');
console.log('Store path:'+store_path);
var tx_id = null;

// create the key value store as defined in the fabric-client/config/default.json 'key-value-store' setting
Fabric_Client.newDefaultKeyValueStore({ path: store_path
}).then((state_store) => {
 // assign the store to the fabric client
 fabric_client.setStateStore(state_store);
 var crypto_suite = Fabric_Client.newCryptoSuite();
 // use the same location for the state store (where the users' certificate are kept)
 // and the crypto store (where the users' keys are kept)
 var crypto_store = Fabric_Client.newCryptoKeyStore({path: store_path});
 crypto_suite.setCryptoKeyStore(crypto_store);
 fabric_client.setCryptoSuite(crypto_suite);

 // get the enrolled user from persistence, this user will sign all requests
 return fabric_client.getUserContext('user1', true);
}).then((user_from_store) => {
 if (user_from_store && user_from_store.isEnrolled()) {
  console.log('Successfully loaded user1 from persistence');
  member_user = user_from_store;
 } else {
  throw new Error('Failed to get user1.... run registerUser.js');
 }

 // get a transaction id object based on the current user assigned to fabric client
 tx_id = fabric_client.newTransactionID();
 console.log("Assigning transaction_id: ", tx_id._transaction_id);

 // createCar chaincode function - requires 5 args, ex: args: ['CAR12', 'Honda', 'Accord', 'Black', 'Tom'],
 // changeCarOwner chaincode function - requires 2 args , ex: args: ['CAR10', 'Dave'],
 // must send the proposal to endorsing peers
 var request = {
  //targets: let default to the peer assigned to the client
  chaincodeId: 'healthdata',
  fcn: 'createPatient',
  args: ['Sam22', 'Delhi', '02-01-1933', 'B-', '5555', '01-03-2018', 'xrp'],
  chainId: 'mychannel',
  txId: tx_id
 };

 // send the transaction proposal to the peers
 return channel.sendTransactionProposal(request);
}).then((results) => {
 var proposalResponses = results[0];
 var proposal = results[1];
 let isProposalGood = false;
 if (proposalResponses && proposalResponses[0].response &&
  proposalResponses[0].response.status === 200) {
   isProposalGood = true;
   console.log('Transaction proposal was good');
  } else {
   console.error('Transaction proposal was bad');
  }
 if (isProposalGood) {
  console.log(util.format(
   'Successfully sent Proposal and received ProposalResponse: Status - %s, message - "%s"',
   proposalResponses[0].response.status, proposalResponses[0].response.message));

  // build up the request for the orderer to have the transaction committed
  var request = {
   proposalResponses: proposalResponses,
   proposal: proposal
  };

  // set the transaction listener and set a timeout of 30 sec
  // if the transaction did not get committed within the timeout period,
  // report a TIMEOUT status
  var transaction_id_string = tx_id.getTransactionID(); //Get the transaction ID string to be used by the event processing
  var promises = [];

  var sendPromise = channel.sendTransaction(request);
  promises.push(sendPromise); //we want the send transaction first, so that we know where to check status

  // get an eventhub once the fabric client has a user assigned. The user
  // is required bacause the event registration must be signed
  let event_hub = fabric_client.newEventHub();
  event_hub.setPeerAddr('grpc://192.168.99.100:7053');

  // using resolve the promise so that result status may be processed
  // under the then clause rather than having the catch clause process
  // the status
  let txPromise = new Promise((resolve, reject) => {
   let handle = setTimeout(() => {
    event_hub.disconnect();
    resolve({event_status : 'TIMEOUT'}); //we could use reject(new Error('Trnasaction did not complete within 30 seconds'));
   }, 6000);
   event_hub.connect();
   event_hub.registerTxEvent(transaction_id_string, (tx, code) => {
    // this is the callback for transaction event status
    // first some clean up of event listener
    clearTimeout(handle);
    event_hub.unregisterTxEvent(transaction_id_string);
    event_hub.disconnect();

    // now let the application know what happened
    var return_status = {event_status : code, tx_id : transaction_id_string};
    if (code !== 'VALID') {
     console.error('The transaction was invalid, code = ' + code);
     resolve(return_status); // we could use reject(new Error('Problem with the tranaction, event status ::'+code));
    } else {
     console.log('The transaction has been committed on peer ' + event_hub._ep._endpoint.addr);
     resolve(return_status);
    }
   }, (err) => {
    //this is the callback if something goes wrong with the event registration or processing
    reject(new Error('There was a problem with the eventhub ::'+err));
   });
  });
  promises.push(txPromise);

  return Promise.all(promises);
 } else {
  console.error('Failed to send Proposal or receive valid response. Response null or status is not 200. exiting...');
  throw new Error('Failed to send Proposal or receive valid response. Response null or status is not 200. exiting...');
 }
}).then((results) => {
 console.log('Send transaction promise and event listener promise have completed');
 // check the results in the order the promises were added to the promise all list
 if (results && results[0] && results[0].status === 'SUCCESS') {
  console.log('Successfully sent transaction to the orderer.');
 } else {
  console.error('Failed to order the transaction. Error code: ' + response.status);
 }

 if(results && results[1] && results[1].event_status === 'VALID') {
  console.log('Successfully committed the change to the ledger by the peer');
 } else {
  console.log('Transaction failed to be committed to the ledger due to ::'+results[1].event_status);
 }
}).catch((err) => {
 console.error('Failed to invoke successfully :: ' + err);
});