epistemophiliac/fabric-samples
1
0
Fork 0
mirror of https://github.com/hyperledger/fabric-samples.git synced 2026-06-17 15:35:09 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge "FAB-12322 Update commercial-paper sample"

Browse source
This commit is contained in:
David Enyeart 2018-11-16 22:03:01 +00:00 committed by Gerrit Code Review
commit 4bde7d4e82
47 changed files with 2086 additions and 522 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
commercial-paper/.gitignore vendored Normal file
View file

@ -0,0 +1,8 @@
organization/magnetocorp/application/node_modules/
organization/magnetocorp/contract/node_modules/
organization/magnetocorp/identity/user/
organization/digibank/application/node_modules/
organization/digibank/contract/node_modules/
organization/digibank/identity/user/
package-lock.json
.vscode

76
commercial-paper/application/application.js
View file

@ -1,76 +0,0 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
/*
* This application has 6 basic steps:
* 1. Select an identity from a wallet
* 2. Connect to network gateway
* 3. Access PaperNet network
* 4. Construct request to issue commercial paper
* 5. Submit transaction
* 6. Process response
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const file = require("fs");
const yaml = require('js-yaml');
const { FileSystemWallet, Gateway } = require('fabric-network');
const { CommercialPaper } = require('./paper.js');
// A wallet stores a collection of identities for use
const wallet = new FileSystemWallet('./wallet');
// A gateway defines the peers used to access Fabric networks
const gateway = new Gateway();
// Main try/catch/finally block
try {
// Load connection profile; will be used to locate a gateway
connectionProfile = yaml.safeLoad(file.readFileSync('./gateway/connectionProfile.yaml', 'utf8'));
// Set connection options; use 'admin' identity from application wallet
let connectionOptions = {
identity: 'isabella.the.issuer@magnetocorp.com',
wallet: wallet,
commitTimeout: 100,
strategy: MSPID_SCOPE_ANYFORTX,
commitNotifyStrategy: WAIT_FOR_ALL_CHANNEL_PEER
}
// Connect to gateway using application specified parameters
await gateway.connect(connectionProfile, connectionOptions);
console.log('Connected to Fabric gateway.')
// Get addressability to PaperNet network
const network = await gateway.getNetwork('PaperNet');
// Get addressability to commercial paper contract
const contract = await network.getContract('papercontract', 'org.papernet.commercialpaper');
console.log('Submit commercial paper issue transaction.')
// issue commercial paper
const response = await contract.submitTransaction('issue', 'MagnetoCorp', '00001', '2020-05-31', '2020-11-30', '5000000');
let paper = CommercialPaper.deserialize(response);
console.log(`${paper.issuer} commercial paper : ${paper.paperNumber} successfully issued for value ${paper.faceValue}`);
console.log('Transaction complete.')
} catch (error) {
console.log(`Error processing transaction. ${error}`);
} finally {
// Disconnect from the gateway
console.log('Disconnect from Fabric gateway.')
gateway.disconnect();
}

7
commercial-paper/contract/index.js
View file

@ -1,7 +0,0 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
module.exports.contracts = require('./lib/cpcontract.js');

113
commercial-paper/contract/lib/cpcontract.js
View file

@ -1,113 +0,0 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Smart contract API brought into scope
const {Contract} = require('fabric-contract-api');
// Commercial paper classes brought into scope
const {CommercialPaper, CommercialPaperList} = require('./cpstate.js');
/**
* Define the commercial paper smart contract extending Fabric Contract class
*/
class CommercialPaperContract extends Contract {
/**
* Each smart contract can have a unique namespace; useful when multiple
* smart contracts per file.
* Use transaction context (ctx) to access list of all commercial papers.
*/
constructor() {
super('org.papernet.commercialpaper');
this.setBeforeFn = (ctx)=>{
ctx.cpList = new CommercialPaperList(ctx, 'COMMERCIALPAPER');
return ctx;
};
}
/**
* Issue commercial paper
* @param {TxContext} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} issueDateTime paper issue date
* @param {String} maturityDateTime paper maturity date
* @param {Integer} faceValue face value of paper
*/
async issue(ctx, issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
let cp = new CommercialPaper(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue);
// {issuer:"MagnetoCorp", paperNumber:"00001", "May31 2020", "Nov 30 2020", "5M USD"}
await ctx.cpList.addPaper(cp);
}
/**
* Buy commercial paper
* @param {TxContext} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} currentOwner current owner of paper
* @param {String} newOwner new owner of paper
* @param {Integer} price price paid for this paper
* @param {String} purchaseDateTime time paper was purchased (i.e. traded)
*/
async buy(ctx, issuer, paperNumber, currentOwner, newOwner, price, purchaseDateTime) {
let cpKey = CommercialPaper.createKey(issuer, paperNumber);
let cp = await ctx.cpList.getPaper(cpKey);
if (cp.getOwner() !== currentOwner) {
throw new Error('Paper '+issuer+paperNumber+' is not owned by '+currentOwner);
}
// First buy moves state from ISSUED to TRADING
if (cp.isIssued()) {
cp.setTrading();
}
// Check paper is TRADING, not REDEEMED
if (cp.IsTrading()) {
cp.setOwner(newOwner);
} else {
throw new Error('Paper '+issuer+paperNumber+' is not trading. Current state = '+cp.getCurrentState());
}
await ctx.cpList.updatePaper(cp);
}
/**
* Redeem commercial paper
* @param {TxContext} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} redeemingOwner redeeming owner of paper
* @param {String} redeemDateTime time paper was redeemed
*/
async redeem(ctx, issuer, paperNumber, redeemingOwner, redeemDateTime) {
let cpKey = CommercialPaper.createKey(issuer, paperNumber);
let cp = await ctx.cpList.getPaper(cpKey);
// Check paper is TRADING, not REDEEMED
if (cp.IsRedeemed()) {
throw new Error('Paper '+issuer+paperNumber+' already redeemed');
}
// Verify that the redeemer owns the commercial paper before redeeming it
if (cp.getOwner() === redeemingOwner) {
cp.setOwner(cp.getIssuer());
cp.setRedeemed();
} else {
throw new Error('Redeeming owner does not own paper'+issuer+paperNumber);
}
await ctx.cpList.updatePaper(cp);
}
}
module.exports = CommericalPaperContract;

148
commercial-paper/contract/lib/cpstate.js
View file

@ -1,148 +0,0 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Helpful utilities class
const Utils = require('./utils.js');
// Enumeration of commercial paper state values
const cpState = {
ISSUED: 1,
TRADING: 2,
REDEEMED: 3
};
/**
* CommercialPaper class defines a commercial paper state
*/
class CommercialPaper {
/**
* Construct a commercial paper. Initial state is issued.
*/
constructor(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
this.issuer = issuer;
this.paperNumber = paperNumber;
this.owner = issuer;
this.issueDateTime = issueDateTime;
this.maturityDateTime = maturityDateTime;
this.faceValue = faceValue;
this.currentState = cpState.ISSUED;
this.key = CommercialPaper.createKey(issuer, paperNumber);
}
/**
* The commercial paper is uniquely identified by its key.
* The key is a simple composite of issuer and paper number as strings.
*/
static createKey(issuer, paperNumber) {
return JSON.stringify(issuer) + JSON.stringify(paperNumber);
}
/**
* Basic getters and setters
*/
getKey() {
return this.key;
}
getIssuer() {
return this.issuer;
}
setIssuer(newIssuer) {
this.issuer = newIssuer;
}
getOwner() {
return this.owner;
}
setOwner(newOwner) {
this.owner = newOwner;
}
/**
* Useful methods to encapsulate commercial paper states
*/
setTrading() {
this.currentState = cpState.TRADING;
}
setRedeemed() {
this.currentState = cpState.REDEEMED;
}
isTrading() {
return this.currentState === cpState.TRADING;
}
isRedeemed() {
return this.currentState === cpState.REDEEMED;
}
}
/**
* CommercialPaperList provides a virtual container to access all
* commercial papers. Each paper has unique key which associates it
* with the container, rather than the container containing a link to
* the paper. This is important in Fabric becuase it minimizes
* collisions for parallel transactions on different papers.
*/
class CommercialPaperList {
/**
* For this sample, it is sufficient to create a commercial paper list
* using a fixed container prefix. The transaction context is saved to
* access Fabric APIs when required.
*/
constructor(ctx, prefix) {
this.api = ctx.stub;
this.prefix = prefix;
}
/**
* Add a paper to the list. Creates a new state in worldstate with
* appropriate composite key. Note that paper defines its own key.
* Paper object is serialized before writing.
*/
async addPaper(cp) {
let key = this.api.createCompositeKey(this.prefix, [cp.getKey()]);
let data = Utils.serialize(cp);
await this.api.putState(key, data);
}
/**
* Get a paper from the list using issuer and paper number. Forms composite
* keys to retrieve data from world state. State data is deserialized
* into paper object before being returned.
*/
async getPaper(key) {
let key = this.api.createCompositeKey(this.prefix, [key]);
let data = await this.api.getState(key);
let cp = Utils.deserialize(data);
return cp;
}
/**
* Update a paper in the list. Puts the new state in world state with
* appropriate composite key. Note that paper defines its own key.
* Paper object is serialized before writing. Logic is very similar to
* addPaper() but kept separate becuase it is semantically distinct, and
* may change.
*/
async updatePaper(cp) {
let key = this.api.createCompositeKey(this.prefix, [cp.getKey()]);
let data = Utils.serialize(cp);
await this.api.putState(key, data);
}
}
module.exports = {
CommercialPaper,
CommercialPaperList
};

34
commercial-paper/contract/lib/utils.js
View file

@ -1,34 +0,0 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
/**
* Utility class for data, object mapulation, e.g. serialization
*/
class Utils {
/**
* Convert object to buffer containing JSON data serialization
* Typically used before putState() ledger API
* @param {Object} object object to serialize
* @return {buffer} buffer with the data to store
*/
static serialize(object){
return Buffer.from(JSON.stringify(object));
}
/**
* Deserialize object, i.e. Covert serialized data to JSON object
* Typically used after getState() ledger API
* @param {Object} data object to deserialize
* @return {json} json with the data to store
*/
static deserialize(data){
return JSON.parse(data);
}
}
module.exports = Utils;

37
commercial-paper/organization/digibank/application/.eslintrc.js Normal file
View file

@ -0,0 +1,37 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
module.exports = {
env: {
node: true,
mocha: true
},
parserOptions: {
ecmaVersion: 8,
sourceType: 'script'
},
extends: "eslint:recommended",
rules: {
indent: ['error', 4],
'linebreak-style': ['error', 'unix'],
quotes: ['error', 'single'],
semi: ['error', 'always'],
'no-unused-vars': ['error', { args: 'none' }],
'no-console': 'off',
curly: 'error',
eqeqeq: 'error',
'no-throw-literal': 'error',
strict: 'error',
'no-var': 'error',
'dot-notation': 'error',
'no-tabs': 'error',
'no-trailing-spaces': 'error',
'no-use-before-define': 'error',
'no-useless-call': 'error',
'no-with': 'error',
'operator-linebreak': 'error',
yoda: 'error',
'quote-props': ['error', 'as-needed']
}
};

45
commercial-paper/organization/digibank/application/addToWallet.js Normal file
View file

@ -0,0 +1,45 @@
/*
* SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const fs = require('fs');
const { FileSystemWallet, X509WalletMixin } = require('fabric-network');
const path = require('path');
const fixtures = path.resolve(__dirname, '../../../../basic-network');
// A wallet stores a collection of identities
const wallet = new FileSystemWallet('../identity/user/balaji/wallet');
async function main() {
// Main try/catch block
try {
// Identity to credentials to be stored in the wallet
const credPath = path.join(fixtures, '/crypto-config/peerOrganizations/org1.example.com/users/Admin@org1.example.com');
const cert = fs.readFileSync(path.join(credPath, '/msp/signcerts/Admin@org1.example.com-cert.pem')).toString();
const key = fs.readFileSync(path.join(credPath, '/msp/keystore/cd96d5260ad4757551ed4a5a991e62130f8008a0bf996e4e4b84cd097a747fec_sk')).toString();
// Load credentials into wallet
const identityLabel = 'Admin@org1.example.com';
const identity = X509WalletMixin.createIdentity('Org1MSP', cert, key);
await wallet.import(identityLabel, identity);
} catch (error) {
console.log(`Error adding to wallet. ${error}`);
console.log(error.stack);
}
}
main().then(() => {
console.log('done');
}).catch((e) => {
console.log(e);
console.log(e.stack);
process.exit(-1);
});

102
commercial-paper/organization/digibank/application/buy.js Normal file
View file

@ -0,0 +1,102 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
/*
* This application has 6 basic steps:
* 1. Select an identity from a wallet
* 2. Connect to network gateway
* 3. Access PaperNet network
* 4. Construct request to issue commercial paper
* 5. Submit transaction
* 6. Process response
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const fs = require('fs');
const yaml = require('js-yaml');
const { FileSystemWallet, Gateway } = require('fabric-network');
const CommercialPaper = require('../contract/lib/paper.js');
// A wallet stores a collection of identities for use
const wallet = new FileSystemWallet('../identity/user/balaji/wallet');
// Main program function
async function main() {
// A gateway defines the peers used to access Fabric networks
const gateway = new Gateway();
// Main try/catch block
try {
// Specify userName for network access
// const userName = 'isabella.issuer@magnetocorp.com';
const userName = 'Admin@org1.example.com';
// Load connection profile; will be used to locate a gateway
let connectionProfile = yaml.safeLoad(fs.readFileSync('../gateway/networkConnection.yaml', 'utf8'));
// Set connection options; identity and wallet
let connectionOptions = {
identity: userName,
wallet: wallet,
discovery: { enabled:false, asLocalhost: true }
};
// Connect to gateway using application specified parameters
console.log('Connect to Fabric gateway.');
await gateway.connect(connectionProfile, connectionOptions);
// Access PaperNet network
console.log('Use network channel: mychannel.');
const network = await gateway.getNetwork('mychannel');
// Get addressability to commercial paper contract
console.log('Use org.papernet.commercialpaper smart contract.');
const contract = await network.getContract('papercontract', 'org.papernet.commercialpaper');
// buy commercial paper
console.log('Submit commercial paper buy transaction.');
const buyResponse = await contract.submitTransaction('buy', 'MagnetoCorp', '00001', 'MagnetoCorp', 'DigiBank', '4900000', '2020-05-31');
// process response
console.log('Process buy transaction response.');
let paper = CommercialPaper.fromBuffer(buyResponse);
console.log(`${paper.issuer} commercial paper : ${paper.paperNumber} successfully purchased by ${paper.owner}`);
console.log('Transaction complete.');
} catch (error) {
console.log(`Error processing transaction. ${error}`);
console.log(error.stack);
} finally {
// Disconnect from the gateway
console.log('Disconnect from Fabric gateway.')
gateway.disconnect();
}
}
main().then(() => {
console.log('Buy program complete.');
}).catch((e) => {
console.log('Buy program exception.');
console.log(e);
console.log(e.stack);
process.exit(-1);
});

20
commercial-paper/organization/digibank/application/package.json Normal file
View file

@ -0,0 +1,20 @@
{
"name": "nodejs",
"version": "1.0.0",
"description": "",
"main": "buy.js",
"scripts": {
"test": "rm -rf _idwallet && node addToWallet.js && node buy.js"
},
"keywords": [],
"author": "",
"license": "ISC",
"dependencies": {
"fabric-network": "^1.4.0-beta",
"fabric-client": "^1.4.0-beta",
"js-yaml": "^3.12.0"
},
"devDependencies": {
"eslint": "^5.6.0"
}
}

101
commercial-paper/organization/digibank/application/redeem.js Normal file
View file

@ -0,0 +1,101 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
/*
* This application has 6 basic steps:
* 1. Select an identity from a wallet
* 2. Connect to network gateway
* 3. Access PaperNet network
* 4. Construct request to issue commercial paper
* 5. Submit transaction
* 6. Process response
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const fs = require('fs');
const yaml = require('js-yaml');
const { FileSystemWallet, Gateway } = require('fabric-network');
const CommercialPaper = require('../contract/lib/paper.js');
// A wallet stores a collection of identities for use
const wallet = new FileSystemWallet('../identity/user/balaji/wallet');
// Main program function
async function main() {
// A gateway defines the peers used to access Fabric networks
const gateway = new Gateway();
// Main try/catch block
try {
// Specify userName for network access
// const userName = 'isabella.issuer@magnetocorp.com';
const userName = 'Admin@org1.example.com';
// Load connection profile; will be used to locate a gateway
let connectionProfile = yaml.safeLoad(fs.readFileSync('../gateway/networkConnection.yaml', 'utf8'));
// Set connection options; identity and wallet
let connectionOptions = {
identity: userName,
wallet: wallet,
discovery: { enabled:false, asLocalhost: true }
};
// Connect to gateway using application specified parameters
console.log('Connect to Fabric gateway.');
await gateway.connect(connectionProfile, connectionOptions);
// Access PaperNet network
console.log('Use network channel: mychannel.');
const network = await gateway.getNetwork('mychannel');
// Get addressability to commercial paper contract
console.log('Use org.papernet.commercialpaper smart contract.');
const contract = await network.getContract('papercontract', 'org.papernet.commercialpaper');
// redeem commercial paper
console.log('Submit commercial paper redeem transaction.');
const redeemResponse = await contract.submitTransaction('redeem', 'MagnetoCorp', '00001', 'DigiBank', '2020-11-30');
// process response
console.log('Process redeem transaction response.');
let paper = CommercialPaper.fromBuffer(redeemResponse);
console.log(`${paper.issuer} commercial paper : ${paper.paperNumber} successfully redeemed with ${paper.owner}`);
console.log('Transaction complete.');
} catch (error) {
console.log(`Error processing transaction. ${error}`);
console.log(error.stack);
} finally {
// Disconnect from the gateway
console.log('Disconnect from Fabric gateway.')
gateway.disconnect();
}
}
main().then(() => {
console.log('Redeem program complete.');
}).catch((e) => {
console.log('Redeem program exception.');
console.log(e);
console.log(e.stack);
process.exit(-1);
});

38
commercial-paper/organization/digibank/configuration/cli/docker-compose.yml Normal file
View file

@ -0,0 +1,38 @@
#
# Copyright IBM Corp All Rights Reserved
#
# SPDX-License-Identifier: Apache-2.0
#
version: '2'
networks:
basic:
external:
name: net_basic
services:
cliDigiBank:
container_name: cliDigiBank
image: hyperledger/fabric-tools
tty: true
environment:
- GOPATH=/opt/gopath
- CORE_VM_ENDPOINT=unix:///host/var/run/docker.sock
- CORE_LOGGING_LEVEL=info
- CORE_PEER_ID=cli
- CORE_PEER_ADDRESS=peer0.org1.example.com:7051
- CORE_PEER_LOCALMSPID=Org1MSP
- CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp
- CORE_CHAINCODE_KEEPALIVE=10
working_dir: /opt/gopath/src/github.com/hyperledger/fabric/peer
command: /bin/bash
volumes:
- /var/run/:/host/var/run/
- ./../../../../organization/digibank:/opt/gopath/src/github.com/
- ./../../../../../basic-network/crypto-config:/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/
networks:
- basic
#depends_on:
# - orderer.example.com
# - peer0.org1.example.com
# - couchdb

25
commercial-paper/organization/digibank/configuration/cli/monitordocker.sh Executable file
View file

@ -0,0 +1,25 @@
#!/bin/bash
# This script uses the logspout and http stream tools to let you watch the docker containers
# in action.
#
# More information at https://github.com/gliderlabs/logspout/tree/master/httpstream
if [ -z "$1" ]; then
DOCKER_NETWORK=basicnetwork_basic
else
DOCKER_NETWORK="$1"
fi
echo Starting monitoring on all containers on the network ${DOCKER_NETWORK}
docker kill logspout 2> /dev/null 1>&2 || true
docker rm logspout 2> /dev/null 1>&2 || true
docker run -d --name="logspout" \
--volume=/var/run/docker.sock:/var/run/docker.sock \
--publish=127.0.0.1:8000:80 \
--network ${DOCKER_NETWORK} \
gliderlabs/logspout
sleep 3
curl http://127.0.0.1:8000/logs

0
commercial-paper/contract/.editorconfig → commercial-paper/organization/digibank/contract/.editorconfig
View file

0
commercial-paper/contract/.eslintignore → commercial-paper/organization/digibank/contract/.eslintignore
View file

0
commercial-paper/contract/.eslintrc.js → commercial-paper/organization/digibank/contract/.eslintrc.js
View file

0
commercial-paper/contract/.npmignore → commercial-paper/organization/digibank/contract/.npmignore
View file

8
commercial-paper/organization/digibank/contract/index.js Normal file
View file

@ -0,0 +1,8 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
const cpcontract = require('./lib/papercontract.js');
module.exports.contracts = [cpcontract];

98
commercial-paper/organization/digibank/contract/ledger-api/state.js Normal file
View file

@ -0,0 +1,98 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
/**
* State class. States have a class, unique key, and a lifecycle current state
* the current state is determined by the specific subclass
*/
class State {
/**
* @param {String|Object} class An indentifiable class of the instance
* @param {keyParts[]} elements to pull together to make a key for the objects
*/
constructor(stateClass, keyParts) {
this.class = stateClass;
this.key = State.makeKey(keyParts);
this.currentState = null;
}
getClass() {
return this.class;
}
getKey() {
return this.key;
}
getSplitKey(){
return State.splitKey(this.key);
}
getCurrentState(){
return this.currentState;
}
serialize() {
return State.serialize(this);
}
/**
* Convert object to buffer containing JSON data serialization
* Typically used before putState()ledger API
* @param {Object} JSON object to serialize
* @return {buffer} buffer with the data to store
*/
static serialize(object) {
return Buffer.from(JSON.stringify(object));
}
/**
* Deserialize object into one of a set of supported JSON classes
* i.e. Covert serialized data to JSON object
* Typically used after getState() ledger API
* @param {data} data to deserialize into JSON object
* @param (supportedClasses) the set of classes data can be serialized to
* @return {json} json with the data to store
*/
static deserialize(data, supportedClasses) {
let json = JSON.parse(data.toString());
let objClass = supportedClasses[json.class];
if (!objClass) {
throw new Error(`Unknown class of ${json.class}`);
}
let object = new (objClass)(json);
return object;
}
/**
* Deserialize object into specific object class
* Typically used after getState() ledger API
* @param {data} data to deserialize into JSON object
* @return {json} json with the data to store
*/
static deserializeClass(data, objClass) {
let json = JSON.parse(data.toString());
let object = new (objClass)(json);
return object;
}
/**
* Join the keyParts to make a unififed string
* @param (String[]) keyParts
*/
static makeKey(keyParts) {
return keyParts.map(part => JSON.stringify(part)).join(':');
}
static splitKey(key){
return key.split(':');
}
}
module.exports = State;

54
commercial-paper/contract/lib/ledgerutils.js → commercial-paper/organization/digibank/contract/ledger-api/statelist.js
View file

@ -3,32 +3,7 @@ SPDX-License-Identifier: Apache-2.0
*/
'use strict';
/**
* Utility class for data, object mapulation, e.g. serialization
*/
class Utils {
/**
* Convert object to buffer containing JSON data serialization
* Typically used before putState()ledger API
* @param {Object} JSON object to serialize
* @return {buffer} buffer with the data to store
*/
static serialize(object) {
return Buffer.from(JSON.stringify(object));
}
/**
* Deserialize object, i.e. Covert serialized data to JSON object
* Typically used after getState() ledger API
* @param {data} data to deserialize into JSON object
* @return {json} json with the data to store
*/
static deserialize(data) {
return JSON.parse(data);
}
}
const State = require('./state.js');
/**
* StateList provides a named virtual container for a set of ledger states.
@ -44,6 +19,8 @@ class StateList {
constructor(ctx, listName) {
this.ctx = ctx;
this.name = listName;
this.supportedClasses = {};
}
/**
@ -52,8 +29,8 @@ class StateList {
* State object is serialized before writing.
*/
async addState(state) {
let key = this.ctx.stub.createCompositeKey(this.name, [state.getKey()]);
let data = Utils.serialize(state);
let key = this.ctx.stub.createCompositeKey(this.name, state.getSplitKey());
let data = State.serialize(state);
await this.ctx.stub.putState(key, data);
}
@ -62,10 +39,10 @@ class StateList {
* keys to retrieve state from world state. State data is deserialized
* into JSON object before being returned.
*/
async getState([keys]) {
let key = this.ctx.stub.createCompositeKey(this.name, [keys]);
let data = await this.ctx.stub.getState(key);
let state = Utils.deserialize(data);
async getState(key) {
let ledgerKey = this.ctx.stub.createCompositeKey(this.name, State.splitKey(key));
let data = await this.ctx.stub.getState(ledgerKey);
let state = State.deserialize(data, this.supportedClasses);
return state;
}
@ -76,13 +53,16 @@ class StateList {
* addState() but kept separate becuase it is semantically distinct.
*/
async updateState(state) {
let key = this.ctx.stub.createCompositeKey(this.name, [state.getKey()]);
let data = Utils.serialize(state);
let key = this.ctx.stub.createCompositeKey(this.name, state.getSplitKey());
let data = State.serialize(state);
await this.ctx.stub.putState(key, data);
}
/** Stores the class for future deserialization */
use(stateClass) {
this.supportedClasses[stateClass.getClass()] = stateClass;
}
}
module.exports = {
StateList
};
module.exports = StateList;

67
commercial-paper/contract/lib/paper.js → commercial-paper/organization/digibank/contract/lib/paper.js
View file

@ -4,6 +4,9 @@ SPDX-License-Identifier: Apache-2.0
'use strict';
// Utility class for ledger state
const State = require('./../ledger-api/state.js');
// Enumerate commercial paper state values
const cpState = {
ISSUED: 1,
@ -11,45 +14,15 @@ const cpState = {
REDEEMED: 3
};
/**
* State class. States have a type, unique key, and a lifecycle current state
*/
class State {
constructor(type, [keyParts]) {
this.type = JSON.stringify(type);
this.key = makeKey([keyParts]);
this.currentState = null;
}
getType() {
return this.type;
}
static makeKey([keyParts]) {
return keyParts.map(part => JSON.stringify(part)).join('');
}
getKey() {
return this.key;
}
}
/**
* CommercialPaper class extends State class
* Class will be used by application and smart contract to define a paper
*/
class CommercialPaper extends State {
constructor(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
super(`org.papernet.commercialpaper`, [issuer, paperNumber]);
this.issuer = issuer;
this.paperNumber = paperNumber;
this.owner = issuer;
this.issueDateTime = issueDateTime;
this.maturityDateTime = maturityDateTime;
this.faceValue = faceValue;
constructor(obj) {
super(CommercialPaper.getClass(), [obj.issuer, obj.paperNumber]);
Object.assign(this, obj);
}
/**
@ -98,20 +71,32 @@ class CommercialPaper extends State {
return this.currentState === cpState.REDEEMED;
}
/**
* Serialize/deserialize commercial paper
**/
static fromBuffer(buffer) {
return CommercialPaper.deserialize(Buffer.from(JSON.parse(buffer)));
}
serialize() {
toBuffer() {
return Buffer.from(JSON.stringify(this));
}
/**
* Deserialize a state data to commercial paper
* @param {Buffer} data to form back into the object
*/
static deserialize(data) {
return Object.create(new CommercialPaper, JSON.parse(data));
return State.deserializeClass(data, CommercialPaper);
}
/**
* Factory method to create a commercial paper object
*/
static createInstance(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
return new CommercialPaper({ issuer, paperNumber, issueDateTime, maturityDateTime, faceValue });
}
static getClass() {
return 'org.papernet.commercialpaper';
}
}
module.exports = {
CommercialPaper,
};
module.exports = CommercialPaper;

102
commercial-paper/contract/lib/papercontract.js → commercial-paper/organization/digibank/contract/lib/papercontract.js
View file

@ -8,25 +8,25 @@ SPDX-License-Identifier: Apache-2.0
const { Contract, Context } = require('fabric-contract-api');
// PaperNet specifc classes
const { CommercialPaper } = require('./paper.js');
// Utility classes
const { StateList } = require('./ledgerutils.js');
const CommercialPaper = require('./paper.js');
const PaperList = require('./paperlist.js');
/**
* Define custom context for commercial paper by extending Fabric Context class
* A custom context provides easy access to list of all commercial papers
*/
class CommericalPaperContext extends Context {
class CommercialPaperContext extends Context {
constructor() {
// All papers held ins a list of Fabric states
this.cpList = new StateList(this, 'org.papernet.commercialpaperlist');
super();
// All papers are held in a list of papers
this.paperList = new PaperList(this);
}
}
/**
* Define commercial paper smart contract by extending Fabric Contract class
*
*/
class CommercialPaperContract extends Contract {
@ -35,20 +35,27 @@ class CommercialPaperContract extends Contract {
super('org.papernet.commercialpaper');
}
// This method is called when a smart contract is instantiated
// Often used to set up the ledger main transactions are called
instantiate() {
/**
* Define a custom context for commercial paper
*/
createContext() {
return new CommercialPaperContext();
}
// A custom context provides easy access to the list of commercial papers
createContext() {
return new CommericalPaperContext();
/**
* Instantiate to perform any setup of the ledger that might be required.
* @param {Context} ctx the transaction context
*/
async instantiate(ctx) {
// No implementation required with this example
// It could be where data migration is performed, if necessary
console.log('Instantiate the contract');
}
/**
* Issue commercial paper
* @param {TxContext} ctx the transaction context
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} issueDateTime paper issue date
@ -57,20 +64,26 @@ class CommercialPaperContract extends Contract {
*/
async issue(ctx, issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
let cp = new CommercialPaper(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue);
// create an instance of the paper
let paper = CommercialPaper.createInstance(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue);
// Smart contract, rather than paper, moves paper into ISSUED state
cp.setIssued();
paper.setIssued();
// Newly issued paper is owned by the issuer
paper.setOwner(issuer);
// Add the paper to the list of all similar commercial papers in the ledger world state
await ctx.cpList.addState(cp);
await ctx.paperList.addPaper(paper);
return cp.serialize();
// Must return a serialized paper to caller of smart contract
return paper.toBuffer();
}
/**
* Buy commercial paper
* @param {TxContext} ctx the transaction context
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} currentOwner current owner of paper
@ -80,31 +93,36 @@ class CommercialPaperContract extends Contract {
*/
async buy(ctx, issuer, paperNumber, currentOwner, newOwner, price, purchaseDateTime) {
let cpKey = CommercialPaper.makeKey([issuer, paperNumber]);
// Retrieve the current paper using key fields provided
let paperKey = CommercialPaper.makeKey([issuer, paperNumber]);
let paper = await ctx.paperList.getPaper(paperKey);
let cp = await ctx.cpList.getState(cpKey);
if (cp.getOwner() !== currentOwner) {
// Validate current owner
if (paper.getOwner() !== currentOwner) {
throw new Error('Paper ' + issuer + paperNumber + ' is not owned by ' + currentOwner);
}
// First buy moves state from ISSUED to TRADING
if (cp.isIssued()) {
cp.setTrading();
if (paper.isIssued()) {
paper.setTrading();
}
// Check paper is not already REDEEMED
if (cp.IsTrading()) {
cp.setOwner(newOwner);
if (paper.isTrading()) {
paper.setOwner(newOwner);
} else {
throw new Error('Paper ' + issuer + paperNumber + ' is not trading. Current state = ' + cp.getCurrentState());
}
await ctx.cpList.updateState(cp);
return cp.deserialize();
// Update the paper
await ctx.paperList.updatePaper(paper);
return paper.toBuffer();
}
/**
* Redeem commercial paper
* @param {TxContext} ctx the transaction context
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} redeemingOwner redeeming owner of paper
@ -112,27 +130,27 @@ class CommercialPaperContract extends Contract {
*/
async redeem(ctx, issuer, paperNumber, redeemingOwner, redeemDateTime) {
let cpKey = CommercialPaper.makeKey([issuer, paperNumber]);
let paperKey = CommercialPaper.makeKey([issuer, paperNumber]);
let cp = await ctx.cpList.getState(cpKey);
let paper = await ctx.paperList.getPaper(paperKey);
// Check paper is TRADING, not REDEEMED
if (cp.IsRedeemed()) {
// Check paper is not REDEEMED
if (paper.isRedeemed()) {
throw new Error('Paper ' + issuer + paperNumber + ' already redeemed');
}
// Verify that the redeemer owns the commercial paper before redeeming it
if (cp.getOwner() === redeemingOwner) {
cp.setOwner(cp.getIssuer());
cp.setRedeemed();
if (paper.getOwner() === redeemingOwner) {
paper.setOwner(paper.getIssuer());
paper.setRedeemed();
} else {
throw new Error('Redeeming owner does not own paper' + issuer + paperNumber);
}
await ctx.cpList.updateState(cp);
return cp.serialize();
await ctx.paperList.updatePaper(paper);
return paper.toBuffer();
}
}
module.exports = CommericalPaperContract;
module.exports = CommercialPaperContract;

33
commercial-paper/organization/digibank/contract/lib/paperlist.js Normal file
View file

@ -0,0 +1,33 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Utility class for collections of ledger states -- a state list
const StateList = require('./../ledger-api/statelist.js');
const CommercialPaper = require('./paper.js');
class PaperList extends StateList {
constructor(ctx) {
super(ctx, 'org.papernet.commercialpaperlist');
this.use(CommercialPaper);
}
async addPaper(paper) {
return this.addState(paper);
}
async getPaper(paperKey) {
return this.getState(paperKey);
}
async updatePaper(paper) {
return this.updateState(paper);
}
}
module.exports = PaperList;

20
commercial-paper/contract/package.json → commercial-paper/organization/digibank/contract/package.json
View file

@ -1,7 +1,8 @@
{
"name": "smart-contract",
"name": "papernet-js",
"version": "0.0.1",
"description": "Smart Contract",
"description": "Papernet Contract",
"main": "index.js",
"engines": {
"node": ">=8",
"npm": ">=5"
@ -9,22 +10,25 @@
"scripts": {
"lint": "eslint .",
"pretest": "npm run lint",
"test": "nyc mocha --recursive",
"start": "startChaincode"
"test": "nyc mocha test --recursive",
"start": "fabric-chaincode-node start",
"mocha": "mocha test --recursive"
},
"engineStrict": true,
"author": "Anthony ODowd",
"author": "hyperledger",
"license": "Apache-2.0",
"dependencies": {
"fabric-shim": "unstable",
"fabric-contract-api": "unstable"
"fabric-contract-api": "^1.4.0-snapshot.17",
"fabric-shim": "^1.4.0-snapshot.27"
},
"devDependencies": {
"chai": "^4.1.2",
"chai-as-promised": "^7.1.1",
"eslint": "^4.19.1",
"mocha": "^5.2.0",
"nyc": "^12.0.2",
"sinon": "^6.0.0"
"sinon": "^6.0.0",
"sinon-chai": "^3.2.0"
},
"nyc": {
"exclude": [

0
commercial-paper/contract/test/contract.js → commercial-paper/organization/digibank/contract/test/contract.js
View file

129
commercial-paper/organization/digibank/gateway/networkConnection.yaml Normal file
View file

@ -0,0 +1,129 @@
---
#
# The network connection profile provides client applications the information about the target
# blockchain network that are necessary for the applications to interact with it. These are all
# knowledge that must be acquired from out-of-band sources. This file provides such a source.
#
name: "basic-network"
#
# Any properties with an "x-" prefix will be treated as application-specific, exactly like how naming
# in HTTP headers or swagger properties work. The SDK will simply ignore these fields and leave
# them for the applications to process. This is a mechanism for different components of an application
# to exchange information that are not part of the standard schema described below. In particular,
# the "x-type" property with the "hlfv1" value example below is used by Hyperledger Composer to
# determine the type of Fabric networks (v0.6 vs. v1.0) it needs to work with.
#
x-type: "hlfv1"
#
# Describe what the target network is/does.
#
description: "The basic network"
#
# Schema version of the content. Used by the SDK to apply the corresponding parsing rules.
#
version: "1.0"
#
# [Optional]. But most apps would have this section so that channel objects can be constructed
# based on the content below. If an app is creating channels, then it likely will not need this
# section.
#
channels:
# name of the channel
mychannel:
# Required. list of orderers designated by the application to use for transactions on this
# channel. This list can be a result of access control ("org1" can only access "ordererA"), or
# operational decisions to share loads from applications among the orderers. The values must
# be "names" of orgs defined under "organizations/peers"
orderers:
- orderer.example.com
# Required. list of peers from participating orgs
peers:
peer0.org1.example.com:
# [Optional]. will this peer be sent transaction proposals for endorsement? The peer must
# have the chaincode installed. The app can also use this property to decide which peers
# to send the chaincode install request. Default: true
endorsingPeer: true
# [Optional]. will this peer be sent query proposals? The peer must have the chaincode
# installed. The app can also use this property to decide which peers to send the
# chaincode install request. Default: true
chaincodeQuery: true
# [Optional]. will this peer be sent query proposals that do not require chaincodes, like
# queryBlock(), queryTransaction(), etc. Default: true
ledgerQuery: true
# [Optional]. will this peer be the target of the SDK's listener registration? All peers can
# produce events but the app typically only needs to connect to one to listen to events.
# Default: true
eventSource: true
#
# list of participating organizations in this network
#
organizations:
Org1:
mspid: Org1MSP
peers:
- peer0.org1.example.com
# [Optional]. Certificate Authorities issue certificates for identification purposes in a Fabric based
# network. Typically certificates provisioning is done in a separate process outside of the
# runtime network. Fabric-CA is a special certificate authority that provides a REST APIs for
# dynamic certificate management (enroll, revoke, re-enroll). The following section is only for
# Fabric-CA servers.
certificateAuthorities:
- ca-org1
#
# List of orderers to send transaction and channel create/update requests to. For the time
# being only one orderer is needed. If more than one is defined, which one get used by the
# SDK is implementation specific. Consult each SDK's documentation for its handling of orderers.
#
orderers:
orderer.example.com:
url: grpc://localhost:7050
# these are standard properties defined by the gRPC library
# they will be passed in as-is to gRPC client constructor
grpcOptions:
ssl-target-name-override: orderer.example.com
#
# List of peers to send various requests to, including endorsement, query
# and event listener registration.
#
peers:
peer0.org1.example.com:
# this URL is used to send endorsement and query requests
url: grpc://localhost:7051
grpcOptions:
ssl-target-name-override: peer0.org1.example.com
request-timeout: 120001
# Fabric-CA is a special kind of Certificate Authority provided by Hyperledger Fabric which allows
# certificate management to be done via REST APIs. Application may choose to use a standard
# Certificate Authority instead of Fabric-CA, in which case this section would not be specified.
#
certificateAuthorities:
ca-org1:
url: http://localhost:7054
# the properties specified under this object are passed to the 'http' client verbatim when
# making the request to the Fabric-CA server
httpOptions:
verify: false
# Fabric-CA supports dynamic user enrollment via REST APIs. A "root" user, a.k.a registrar, is
# needed to enroll and invoke new users.
registrar:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-org1

32
commercial-paper/application/gateway/connectionProfile.yaml → commercial-paper/organization/digibank/gateway/papernetConnection.yaml
View file

@ -4,7 +4,7 @@
# blockchain network that are necessary for the applications to interact with it. These are all
# knowledge that must be acquired from out-of-band sources. This file provides such a source.
#
name: "global-trade-network"
name: "finance-networks"
#
# Any properties with an "x-" prefix will be treated as application-specific, exactly like how naming
@ -19,7 +19,7 @@ x-type: "hlfv1"
#
# Describe what the target network is/does.
#
description: "The network to be in if you want to stay in the global trade business"
description: "A gateway connection file for the PaperNet networks"
#
# Schema version of the content. Used by the SDK to apply the corresponding parsing rules.
@ -59,13 +59,13 @@ version: "1.0"
#
channels:
# name of the channel
PaperNet:
papernet:
# Required. list of orderers designated by the application to use for transactions on this
# channel. This list can be a result of access control ("org1" can only access "ordererA"), or
# operational decisions to share loads from applications among the orderers. The values must
# be "names" of orgs defined under "organizations/peers"
orderers:
- orderer.example.com
- orderer.magnetocorp.com
# Required. list of peers from participating orgs
peers:
@ -119,7 +119,7 @@ organizations:
# dynamic certificate management (enroll, revoke, re-enroll). The following section is only for
# Fabric-CA servers.
certificateAuthorities:
- ca-org1
- ca-magnetocorp
# [Optional]. If the application is going to make requests that are reserved to organization
# administrators, including creating/updating channels, installing/instantiating chaincodes, it
@ -129,9 +129,9 @@ organizations:
# this way. The SDK should allow applications to set the org admin identity via APIs, and only use
# this route as an alternative when it exists.
adminPrivateKey:
path: test/fixtures/channel/crypto-config/peerOrganizations/org1.example.com/users/Admin@org1.example.com/keystore/9022d671ceedbb24af3ea69b5a8136cc64203df6b9920e26f48123fcfcb1d2e9_sk
path: commercial-paper/organization/magnetocorp/users/Admin@magnetocorp/keystore/9022d671ceedbb24af3ea69b5a8136cc64203df6b9920e26f48123fcfcb1d2e9_sk
signedCert:
path: test/fixtures/channel/crypto-config/peerOrganizations/org1.example.com/users/Admin@org1.example.com/signcerts/Admin@org1.example.com-cert.pem
path: comercial-paper/organization/magnetocorp/users/Admin@magnetocorp.com/signcerts/Admin@magnetocorp.com-cert.pem
# the profile will contain public information about organizations other than the one it belongs to.
# These are necessary information to make transaction lifecycles work, including MSP IDs and
@ -143,11 +143,11 @@ organizations:
peers:
- peer1.digibank.com
certificateAuthorities:
- ca-org2
- ca-digibank
adminPrivateKey:
path: test/fixtures/channel/crypto-config/peerOrganizations/org2.example.com/users/Admin@org2.example.com/keystore/5a983ddcbefe52a7f9b8ee5b85a590c3e3a43c4ccd70c7795bec504e7f74848d_sk
path: commercial-paper/organization/digibank/users/Admin@digibank.com/keystore/5a983ddcbefe52a7f9b8ee5b85a590c3e3a43c4ccd70c7795bec504e7f74848d_sk
signedCert:
path: test/fixtures/channel/crypto-config/peerOrganizations/org2.example.com/users/Admin@org2.example.com/signcerts/Admin@org2.example.com-cert.pem
path: commercial-paper/organization/digibank/users/Admin@digibank.com/signcerts/Admin@digibank.com-cert.pem
#
# List of orderers to send transaction and channel create/update requests to. For the time
@ -155,7 +155,7 @@ organizations:
# SDK is implementation specific. Consult each SDK's documentation for its handling of orderers.
#
orderers:
orderer.example.com:
orderer.magnetocorp.com:
url: grpcs://localhost:7050
# these are standard properties defined by the gRPC library
@ -164,7 +164,7 @@ orderers:
ssl-target-name-override: orderer.example.com
tlsCACerts:
path: test/fixtures/channel/crypto-config/ordererOrganizations/example.com/orderers/orderer.example.com/tlscacerts/example.com-cert.pem
path: comercial-paper/organization/magnetocorp/orderer/orderer.magnetocorp.com/tlscacerts/example.com-cert.pem
#
# List of peers to send various requests to, including endorsement, query
@ -202,7 +202,7 @@ certificateAuthorities:
httpOptions:
verify: false
tlsCACerts:
path: test/fixtures/channel/crypto-config/peerOrganizations/org1.example.com/ca/org1.example.com-cert.pem
path: commercial-paper/organization/magnetocorp/ca/magnetocorp.com-cert.pem
# Fabric-CA supports dynamic user enrollment via REST APIs. A "root" user, a.k.a registrar, is
# needed to enroll and invoke new users.
@ -210,16 +210,16 @@ certificateAuthorities:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-org1
caName: ca-magnetocorp
ca-org2:
url: https://localhost:8054
httpOptions:
verify: false
tlsCACerts:
path: test/fixtures/channel/crypto-config/peerOrganizations/org2.example.com/ca/org2.example.com-cert.pem
path: commercial-paper/organization/digibank/ca/digibank.com-cert.pem
registrar:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-org2
caName: ca-digibank

37
commercial-paper/organization/magnetocorp/application/.eslintrc.js Normal file
View file

@ -0,0 +1,37 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
module.exports = {
env: {
node: true,
mocha: true
},
parserOptions: {
ecmaVersion: 8,
sourceType: 'script'
},
extends: "eslint:recommended",
rules: {
indent: ['error', 4],
'linebreak-style': ['error', 'unix'],
quotes: ['error', 'single'],
semi: ['error', 'always'],
'no-unused-vars': ['error', { args: 'none' }],
'no-console': 'off',
curly: 'error',
eqeqeq: 'error',
'no-throw-literal': 'error',
strict: 'error',
'no-var': 'error',
'dot-notation': 'error',
'no-tabs': 'error',
'no-trailing-spaces': 'error',
'no-use-before-define': 'error',
'no-useless-call': 'error',
'no-with': 'error',
'operator-linebreak': 'error',
yoda: 'error',
'quote-props': ['error', 'as-needed']
}
};

45
commercial-paper/organization/magnetocorp/application/addToWallet.js Normal file
View file

@ -0,0 +1,45 @@
/*
* SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const fs = require('fs');
const { FileSystemWallet, X509WalletMixin } = require('fabric-network');
const path = require('path');
const fixtures = path.resolve(__dirname, '../../../../basic-network');
// A wallet stores a collection of identities
const wallet = new FileSystemWallet('../identity/user/isabella/wallet');
async function main() {
// Main try/catch block
try {
// Identity to credentials to be stored in the wallet
const credPath = path.join(fixtures, '/crypto-config/peerOrganizations/org1.example.com/users/User1@org1.example.com');
const cert = fs.readFileSync(path.join(credPath, '/msp/signcerts/User1@org1.example.com-cert.pem')).toString();
const key = fs.readFileSync(path.join(credPath, '/msp/keystore/c75bd6911aca808941c3557ee7c97e90f3952e379497dc55eb903f31b50abc83_sk')).toString();
// Load credentials into wallet
const identityLabel = 'User1@org1.example.com';
const identity = X509WalletMixin.createIdentity('Org1MSP', cert, key);
await wallet.import(identityLabel, identity);
} catch (error) {
console.log(`Error adding to wallet. ${error}`);
console.log(error.stack);
}
}
main().then(() => {
console.log('done');
}).catch((e) => {
console.log(e);
console.log(e.stack);
process.exit(-1);
});

102
commercial-paper/organization/magnetocorp/application/issue.js Normal file
View file

@ -0,0 +1,102 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
/*
* This application has 6 basic steps:
* 1. Select an identity from a wallet
* 2. Connect to network gateway
* 3. Access PaperNet network
* 4. Construct request to issue commercial paper
* 5. Submit transaction
* 6. Process response
*/
'use strict';
// Bring key classes into scope, most importantly Fabric SDK network class
const fs = require('fs');
const yaml = require('js-yaml');
const { FileSystemWallet, Gateway } = require('fabric-network');
const CommercialPaper = require('../contract/lib/paper.js');
// A wallet stores a collection of identities for use
//const wallet = new FileSystemWallet('../user/isabella/wallet');
const wallet = new FileSystemWallet('../identity/user/isabella/wallet');
// Main program function
async function main() {
// A gateway defines the peers used to access Fabric networks
const gateway = new Gateway();
// Main try/catch block
try {
// Specify userName for network access
// const userName = 'isabella.issuer@magnetocorp.com';
const userName = 'User1@org1.example.com';
// Load connection profile; will be used to locate a gateway
let connectionProfile = yaml.safeLoad(fs.readFileSync('../gateway/networkConnection.yaml', 'utf8'));
// Set connection options; identity and wallet
let connectionOptions = {
identity: userName,
wallet: wallet,
discovery: { enabled:false, asLocalhost: true }
};
// Connect to gateway using application specified parameters
console.log('Connect to Fabric gateway.');
await gateway.connect(connectionProfile, connectionOptions);
// Access PaperNet network
console.log('Use network channel: mychannel.');
const network = await gateway.getNetwork('mychannel');
// Get addressability to commercial paper contract
console.log('Use org.papernet.commercialpaper smart contract.');
const contract = await network.getContract('papercontract', 'org.papernet.commercialpaper');
// issue commercial paper
console.log('Submit commercial paper issue transaction.');
const issueResponse = await contract.submitTransaction('issue', 'MagnetoCorp', '00001', '2020-05-31', '2020-11-30', '5000000');
// process response
console.log('Process issue transaction response.');
let paper = CommercialPaper.fromBuffer(issueResponse);
console.log(`${paper.issuer} commercial paper : ${paper.paperNumber} successfully issued for value ${paper.faceValue}`);
console.log('Transaction complete.');
} catch (error) {
console.log(`Error processing transaction. ${error}`);
console.log(error.stack);
} finally {
// Disconnect from the gateway
console.log('Disconnect from Fabric gateway.')
gateway.disconnect();
}
}
main().then(() => {
console.log('Issue program complete.');
}).catch((e) => {
console.log('Issue program exception.');
console.log(e);
console.log(e.stack);
process.exit(-1);
});

20
commercial-paper/organization/magnetocorp/application/package.json Normal file
View file

@ -0,0 +1,20 @@
{
"name": "nodejs",
"version": "1.0.0",
"description": "",
"main": "issue.js",
"scripts": {
"test": "rm -rf _idwallet && node addToWallet.js && node issue.js"
},
"keywords": [],
"author": "",
"license": "ISC",
"dependencies": {
"fabric-network": "^1.4.0-beta",
"fabric-client": "^1.4.0-beta",
"js-yaml": "^3.12.0"
},
"devDependencies": {
"eslint": "^5.6.0"
}
}

38
commercial-paper/organization/magnetocorp/configuration/cli/docker-compose.yml Normal file
View file

@ -0,0 +1,38 @@
#
# Copyright IBM Corp All Rights Reserved
#
# SPDX-License-Identifier: Apache-2.0
#
version: '2'
networks:
basic:
external:
name: net_basic
services:
cliMagnetoCorp:
container_name: cliMagnetoCorp
image: hyperledger/fabric-tools
tty: true
environment:
- GOPATH=/opt/gopath
- CORE_VM_ENDPOINT=unix:///host/var/run/docker.sock
- CORE_LOGGING_LEVEL=info
- CORE_PEER_ID=cli
- CORE_PEER_ADDRESS=peer0.org1.example.com:7051
- CORE_PEER_LOCALMSPID=Org1MSP
- CORE_PEER_MSPCONFIGPATH=/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/peerOrganizations/org1.example.com/users/Admin@org1.example.com/msp
- CORE_CHAINCODE_KEEPALIVE=10
working_dir: /opt/gopath/src/github.com/hyperledger/fabric/peer
command: /bin/bash
volumes:
- /var/run/:/host/var/run/
- ./../../../../organization/magnetocorp:/opt/gopath/src/github.com/
- ./../../../../../basic-network/crypto-config:/opt/gopath/src/github.com/hyperledger/fabric/peer/crypto/
networks:
- basic
#depends_on:
# - orderer.example.com
# - peer0.org1.example.com
# - couchdb

25
commercial-paper/organization/magnetocorp/configuration/cli/monitordocker.sh Executable file
View file

@ -0,0 +1,25 @@
#!/bin/bash
# This script uses the logspout and http stream tools to let you watch the docker containers
# in action.
#
# More information at https://github.com/gliderlabs/logspout/tree/master/httpstream
if [ -z "$1" ]; then
DOCKER_NETWORK=basicnetwork_basic
else
DOCKER_NETWORK="$1"
fi
echo Starting monitoring on all containers on the network ${DOCKER_NETWORK}
docker kill logspout 2> /dev/null 1>&2 || true
docker rm logspout 2> /dev/null 1>&2 || true
docker run -d --name="logspout" \
--volume=/var/run/docker.sock:/var/run/docker.sock \
--publish=127.0.0.1:8000:80 \
--network ${DOCKER_NETWORK} \
gliderlabs/logspout
sleep 3
curl http://127.0.0.1:8000/logs

16
commercial-paper/organization/magnetocorp/contract/.editorconfig Executable file
View file

@ -0,0 +1,16 @@
#
# SPDX-License-Identifier: Apache-2.0
#
root = true
[*]
indent_style = space
indent_size = 4
end_of_line = lf
charset = utf-8
trim_trailing_whitespace = true
insert_final_newline = true
[*.md]
trim_trailing_whitespace = false

5
commercial-paper/organization/magnetocorp/contract/.eslintignore Normal file
View file

@ -0,0 +1,5 @@
#
# SPDX-License-Identifier: Apache-2.0
#
coverage

37
commercial-paper/organization/magnetocorp/contract/.eslintrc.js Normal file
View file

@ -0,0 +1,37 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
module.exports = {
env: {
node: true,
mocha: true
},
parserOptions: {
ecmaVersion: 8,
sourceType: 'script'
},
extends: "eslint:recommended",
rules: {
indent: ['error', 4],
'linebreak-style': ['error', 'unix'],
quotes: ['error', 'single'],
semi: ['error', 'always'],
'no-unused-vars': ['error', { args: 'none' }],
'no-console': 'off',
curly: 'error',
eqeqeq: 'error',
'no-throw-literal': 'error',
strict: 'error',
'no-var': 'error',
'dot-notation': 'error',
'no-tabs': 'error',
'no-trailing-spaces': 'error',
'no-use-before-define': 'error',
'no-useless-call': 'error',
'no-with': 'error',
'operator-linebreak': 'error',
yoda: 'error',
'quote-props': ['error', 'as-needed']
}
};

77
commercial-paper/organization/magnetocorp/contract/.npmignore Normal file
View file

@ -0,0 +1,77 @@
#
# SPDX-License-Identifier: Apache-2.0
#
# Logs
logs
*.log
npm-debug.log*
yarn-debug.log*
yarn-error.log*
# Runtime data
pids
*.pid
*.seed
*.pid.lock
# Directory for instrumented libs generated by jscoverage/JSCover
lib-cov
# Coverage directory used by tools like istanbul
coverage
# nyc test coverage
.nyc_output
# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
.grunt
# Bower dependency directory (https://bower.io/)
bower_components
# node-waf configuration
.lock-wscript
# Compiled binary addons (https://nodejs.org/api/addons.html)
build/Release
# Dependency directories
node_modules/
jspm_packages/
# TypeScript v1 declaration files
typings/
# Optional npm cache directory
.npm
# Optional eslint cache
.eslintcache
# Optional REPL history
.node_repl_history
# Output of 'npm pack'
*.tgz
# Yarn Integrity file
.yarn-integrity
# dotenv environment variables file
.env
# parcel-bundler cache (https://parceljs.org/)
.cache
# next.js build output
.next
# nuxt.js build output
.nuxt
# vuepress build output
.vuepress/dist
# Serverless directories
.serverless

8
commercial-paper/organization/magnetocorp/contract/index.js Normal file
View file

@ -0,0 +1,8 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
const cpcontract = require('./lib/papercontract.js');
module.exports.contracts = [cpcontract];

98
commercial-paper/organization/magnetocorp/contract/ledger-api/state.js Normal file
View file

@ -0,0 +1,98 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
/**
* State class. States have a class, unique key, and a lifecycle current state
* the current state is determined by the specific subclass
*/
class State {
/**
* @param {String|Object} class An indentifiable class of the instance
* @param {keyParts[]} elements to pull together to make a key for the objects
*/
constructor(stateClass, keyParts) {
this.class = stateClass;
this.key = State.makeKey(keyParts);
this.currentState = null;
}
getClass() {
return this.class;
}
getKey() {
return this.key;
}
getSplitKey(){
return State.splitKey(this.key);
}
getCurrentState(){
return this.currentState;
}
serialize() {
return State.serialize(this);
}
/**
* Convert object to buffer containing JSON data serialization
* Typically used before putState()ledger API
* @param {Object} JSON object to serialize
* @return {buffer} buffer with the data to store
*/
static serialize(object) {
return Buffer.from(JSON.stringify(object));
}
/**
* Deserialize object into one of a set of supported JSON classes
* i.e. Covert serialized data to JSON object
* Typically used after getState() ledger API
* @param {data} data to deserialize into JSON object
* @param (supportedClasses) the set of classes data can be serialized to
* @return {json} json with the data to store
*/
static deserialize(data, supportedClasses) {
let json = JSON.parse(data.toString());
let objClass = supportedClasses[json.class];
if (!objClass) {
throw new Error(`Unknown class of ${json.class}`);
}
let object = new (objClass)(json);
return object;
}
/**
* Deserialize object into specific object class
* Typically used after getState() ledger API
* @param {data} data to deserialize into JSON object
* @return {json} json with the data to store
*/
static deserializeClass(data, objClass) {
let json = JSON.parse(data.toString());
let object = new (objClass)(json);
return object;
}
/**
* Join the keyParts to make a unififed string
* @param (String[]) keyParts
*/
static makeKey(keyParts) {
return keyParts.map(part => JSON.stringify(part)).join(':');
}
static splitKey(key){
return key.split(':');
}
}
module.exports = State;

68
commercial-paper/organization/magnetocorp/contract/ledger-api/statelist.js Normal file
View file

@ -0,0 +1,68 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
const State = require('./state.js');
/**
* StateList provides a named virtual container for a set of ledger states.
* Each state has a unique key which associates it with the container, rather
* than the container containing a link to the state. This minimizes collisions
* for parallel transactions on different states.
*/
class StateList {
/**
* Store Fabric context for subsequent API access, and name of list
*/
constructor(ctx, listName) {
this.ctx = ctx;
this.name = listName;
this.supportedClasses = {};
}
/**
* Add a state to the list. Creates a new state in worldstate with
* appropriate composite key. Note that state defines its own key.
* State object is serialized before writing.
*/
async addState(state) {
let key = this.ctx.stub.createCompositeKey(this.name, state.getSplitKey());
let data = State.serialize(state);
await this.ctx.stub.putState(key, data);
}
/**
* Get a state from the list using supplied keys. Form composite
* keys to retrieve state from world state. State data is deserialized
* into JSON object before being returned.
*/
async getState(key) {
let ledgerKey = this.ctx.stub.createCompositeKey(this.name, State.splitKey(key));
let data = await this.ctx.stub.getState(ledgerKey);
let state = State.deserialize(data, this.supportedClasses);
return state;
}
/**
* Update a state in the list. Puts the new state in world state with
* appropriate composite key. Note that state defines its own key.
* A state is serialized before writing. Logic is very similar to
* addState() but kept separate becuase it is semantically distinct.
*/
async updateState(state) {
let key = this.ctx.stub.createCompositeKey(this.name, state.getSplitKey());
let data = State.serialize(state);
await this.ctx.stub.putState(key, data);
}
/** Stores the class for future deserialization */
use(stateClass) {
this.supportedClasses[stateClass.getClass()] = stateClass;
}
}
module.exports = StateList;

102
commercial-paper/organization/magnetocorp/contract/lib/paper.js Normal file
View file

@ -0,0 +1,102 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Utility class for ledger state
const State = require('./../ledger-api/state.js');
// Enumerate commercial paper state values
const cpState = {
ISSUED: 1,
TRADING: 2,
REDEEMED: 3
};
/**
* CommercialPaper class extends State class
* Class will be used by application and smart contract to define a paper
*/
class CommercialPaper extends State {
constructor(obj) {
super(CommercialPaper.getClass(), [obj.issuer, obj.paperNumber]);
Object.assign(this, obj);
}
/**
* Basic getters and setters
*/
getIssuer() {
return this.issuer;
}
setIssuer(newIssuer) {
this.issuer = newIssuer;
}
getOwner() {
return this.owner;
}
setOwner(newOwner) {
this.owner = newOwner;
}
/**
* Useful methods to encapsulate commercial paper states
*/
setIssued() {
this.currentState = cpState.ISSUED;
}
setTrading() {
this.currentState = cpState.TRADING;
}
setRedeemed() {
this.currentState = cpState.REDEEMED;
}
isIssued() {
return this.currentState === cpState.ISSUED;
}
isTrading() {
return this.currentState === cpState.TRADING;
}
isRedeemed() {
return this.currentState === cpState.REDEEMED;
}
static fromBuffer(buffer) {
return CommercialPaper.deserialize(Buffer.from(JSON.parse(buffer)));
}
toBuffer() {
return Buffer.from(JSON.stringify(this));
}
/**
* Deserialize a state data to commercial paper
* @param {Buffer} data to form back into the object
*/
static deserialize(data) {
return State.deserializeClass(data, CommercialPaper);
}
/**
* Factory method to create a commercial paper object
*/
static createInstance(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
return new CommercialPaper({ issuer, paperNumber, issueDateTime, maturityDateTime, faceValue });
}
static getClass() {
return 'org.papernet.commercialpaper';
}
}
module.exports = CommercialPaper;

156
commercial-paper/organization/magnetocorp/contract/lib/papercontract.js Normal file
View file

@ -0,0 +1,156 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Fabric smart contract classes
const { Contract, Context } = require('fabric-contract-api');
// PaperNet specifc classes
const CommercialPaper = require('./paper.js');
const PaperList = require('./paperlist.js');
/**
* A custom context provides easy access to list of all commercial papers
*/
class CommercialPaperContext extends Context {
constructor() {
super();
// All papers are held in a list of papers
this.paperList = new PaperList(this);
}
}
/**
* Define commercial paper smart contract by extending Fabric Contract class
*
*/
class CommercialPaperContract extends Contract {
constructor() {
// Unique namespace when multiple contracts per chaincode file
super('org.papernet.commercialpaper');
}
/**
* Define a custom context for commercial paper
*/
createContext() {
return new CommercialPaperContext();
}
/**
* Instantiate to perform any setup of the ledger that might be required.
* @param {Context} ctx the transaction context
*/
async instantiate(ctx) {
// No implementation required with this example
// It could be where data migration is performed, if necessary
console.log('Instantiate the contract');
}
/**
* Issue commercial paper
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} issueDateTime paper issue date
* @param {String} maturityDateTime paper maturity date
* @param {Integer} faceValue face value of paper
*/
async issue(ctx, issuer, paperNumber, issueDateTime, maturityDateTime, faceValue) {
// create an instance of the paper
let paper = CommercialPaper.createInstance(issuer, paperNumber, issueDateTime, maturityDateTime, faceValue);
// Smart contract, rather than paper, moves paper into ISSUED state
paper.setIssued();
// Newly issued paper is owned by the issuer
paper.setOwner(issuer);
// Add the paper to the list of all similar commercial papers in the ledger world state
await ctx.paperList.addPaper(paper);
// Must return a serialized paper to caller of smart contract
return paper.toBuffer();
}
/**
* Buy commercial paper
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} currentOwner current owner of paper
* @param {String} newOwner new owner of paper
* @param {Integer} price price paid for this paper
* @param {String} purchaseDateTime time paper was purchased (i.e. traded)
*/
async buy(ctx, issuer, paperNumber, currentOwner, newOwner, price, purchaseDateTime) {
// Retrieve the current paper using key fields provided
let paperKey = CommercialPaper.makeKey([issuer, paperNumber]);
let paper = await ctx.paperList.getPaper(paperKey);
// Validate current owner
if (paper.getOwner() !== currentOwner) {
throw new Error('Paper ' + issuer + paperNumber + ' is not owned by ' + currentOwner);
}
// First buy moves state from ISSUED to TRADING
if (paper.isIssued()) {
paper.setTrading();
}
// Check paper is not already REDEEMED
if (paper.isTrading()) {
paper.setOwner(newOwner);
} else {
throw new Error('Paper ' + issuer + paperNumber + ' is not trading. Current state = ' +paper.getCurrentState());
}
// Update the paper
await ctx.paperList.updatePaper(paper);
return paper.toBuffer();
}
/**
* Redeem commercial paper
*
* @param {Context} ctx the transaction context
* @param {String} issuer commercial paper issuer
* @param {Integer} paperNumber paper number for this issuer
* @param {String} redeemingOwner redeeming owner of paper
* @param {String} redeemDateTime time paper was redeemed
*/
async redeem(ctx, issuer, paperNumber, redeemingOwner, redeemDateTime) {
let paperKey = CommercialPaper.makeKey([issuer, paperNumber]);
let paper = await ctx.paperList.getPaper(paperKey);
// Check paper is not REDEEMED
if (paper.isRedeemed()) {
throw new Error('Paper ' + issuer + paperNumber + ' already redeemed');
}
// Verify that the redeemer owns the commercial paper before redeeming it
if (paper.getOwner() === redeemingOwner) {
paper.setOwner(paper.getIssuer());
paper.setRedeemed();
} else {
throw new Error('Redeeming owner does not own paper' + issuer + paperNumber);
}
await ctx.paperList.updatePaper(paper);
return paper.toBuffer();
}
}
module.exports = CommercialPaperContract;

33
commercial-paper/organization/magnetocorp/contract/lib/paperlist.js Normal file
View file

@ -0,0 +1,33 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
// Utility class for collections of ledger states -- a state list
const StateList = require('./../ledger-api/statelist.js');
const CommercialPaper = require('./paper.js');
class PaperList extends StateList {
constructor(ctx) {
super(ctx, 'org.papernet.commercialpaperlist');
this.use(CommercialPaper);
}
async addPaper(paper) {
return this.addState(paper);
}
async getPaper(paperKey) {
return this.getState(paperKey);
}
async updatePaper(paper) {
return this.updateState(paper);
}
}
module.exports = PaperList;

49
commercial-paper/organization/magnetocorp/contract/package.json Normal file
View file

@ -0,0 +1,49 @@
{
"name": "papernet-js",
"version": "0.0.1",
"description": "Papernet Contract",
"main": "index.js",
"engines": {
"node": ">=8",
"npm": ">=5"
},
"scripts": {
"lint": "eslint .",
"pretest": "npm run lint",
"test": "nyc mocha test --recursive",
"start": "fabric-chaincode-node start",
"mocha": "mocha test --recursive"
},
"engineStrict": true,
"author": "hyperledger",
"license": "Apache-2.0",
"dependencies": {
"fabric-contract-api": "^1.4.0-snapshot.17",
"fabric-shim": "^1.4.0-snapshot.27"
},
"devDependencies": {
"chai": "^4.1.2",
"chai-as-promised": "^7.1.1",
"eslint": "^4.19.1",
"mocha": "^5.2.0",
"nyc": "^12.0.2",
"sinon": "^6.0.0",
"sinon-chai": "^3.2.0"
},
"nyc": {
"exclude": [
"coverage/**",
"test/**"
],
"reporter": [
"text-summary",
"html"
],
"all": true,
"check-coverage": true,
"statements": 100,
"branches": 100,
"functions": 100,
"lines": 100
}
}

41
commercial-paper/organization/magnetocorp/contract/test/contract.js Normal file
View file

@ -0,0 +1,41 @@
/*
SPDX-License-Identifier: Apache-2.0
*/
'use strict';
const Chaincode = require('../lib/chaincode');
const { Stub } = require('fabric-shim');
require('chai').should();
const sinon = require('sinon');
describe('Chaincode', () => {
describe('#Init', () => {
it('should work', async () => {
const cc = new Chaincode();
const stub = sinon.createStubInstance(Stub);
stub.getFunctionAndParameters.returns({ fcn: 'initFunc', params: [] });
const res = await cc.Init(stub);
res.status.should.equal(Stub.RESPONSE_CODE.OK);
});
});
describe('#Invoke', async () => {
it('should work', async () => {
const cc = new Chaincode();
const stub = sinon.createStubInstance(Stub);
stub.getFunctionAndParameters.returns({ fcn: 'initFunc', params: [] });
let res = await cc.Init(stub);
res.status.should.equal(Stub.RESPONSE_CODE.OK);
stub.getFunctionAndParameters.returns({ fcn: 'invokeFunc', params: [] });
res = await cc.Invoke(stub);
res.status.should.equal(Stub.RESPONSE_CODE.OK);
});
});
});

129
commercial-paper/organization/magnetocorp/gateway/networkConnection.yaml Normal file
View file

@ -0,0 +1,129 @@
---
#
# The network connection profile provides client applications the information about the target
# blockchain network that are necessary for the applications to interact with it. These are all
# knowledge that must be acquired from out-of-band sources. This file provides such a source.
#
name: "basic-network"
#
# Any properties with an "x-" prefix will be treated as application-specific, exactly like how naming
# in HTTP headers or swagger properties work. The SDK will simply ignore these fields and leave
# them for the applications to process. This is a mechanism for different components of an application
# to exchange information that are not part of the standard schema described below. In particular,
# the "x-type" property with the "hlfv1" value example below is used by Hyperledger Composer to
# determine the type of Fabric networks (v0.6 vs. v1.0) it needs to work with.
#
x-type: "hlfv1"
#
# Describe what the target network is/does.
#
description: "The basic network"
#
# Schema version of the content. Used by the SDK to apply the corresponding parsing rules.
#
version: "1.0"
#
# [Optional]. But most apps would have this section so that channel objects can be constructed
# based on the content below. If an app is creating channels, then it likely will not need this
# section.
#
channels:
# name of the channel
mychannel:
# Required. list of orderers designated by the application to use for transactions on this
# channel. This list can be a result of access control ("org1" can only access "ordererA"), or
# operational decisions to share loads from applications among the orderers. The values must
# be "names" of orgs defined under "organizations/peers"
orderers:
- orderer.example.com
# Required. list of peers from participating orgs
peers:
peer0.org1.example.com:
# [Optional]. will this peer be sent transaction proposals for endorsement? The peer must
# have the chaincode installed. The app can also use this property to decide which peers
# to send the chaincode install request. Default: true
endorsingPeer: true
# [Optional]. will this peer be sent query proposals? The peer must have the chaincode
# installed. The app can also use this property to decide which peers to send the
# chaincode install request. Default: true
chaincodeQuery: true
# [Optional]. will this peer be sent query proposals that do not require chaincodes, like
# queryBlock(), queryTransaction(), etc. Default: true
ledgerQuery: true
# [Optional]. will this peer be the target of the SDK's listener registration? All peers can
# produce events but the app typically only needs to connect to one to listen to events.
# Default: true
eventSource: true
#
# list of participating organizations in this network
#
organizations:
Org1:
mspid: Org1MSP
peers:
- peer0.org1.example.com
# [Optional]. Certificate Authorities issue certificates for identification purposes in a Fabric based
# network. Typically certificates provisioning is done in a separate process outside of the
# runtime network. Fabric-CA is a special certificate authority that provides a REST APIs for
# dynamic certificate management (enroll, revoke, re-enroll). The following section is only for
# Fabric-CA servers.
certificateAuthorities:
- ca-org1
#
# List of orderers to send transaction and channel create/update requests to. For the time
# being only one orderer is needed. If more than one is defined, which one get used by the
# SDK is implementation specific. Consult each SDK's documentation for its handling of orderers.
#
orderers:
orderer.example.com:
url: grpc://localhost:7050
# these are standard properties defined by the gRPC library
# they will be passed in as-is to gRPC client constructor
grpcOptions:
ssl-target-name-override: orderer.example.com
#
# List of peers to send various requests to, including endorsement, query
# and event listener registration.
#
peers:
peer0.org1.example.com:
# this URL is used to send endorsement and query requests
url: grpc://localhost:7051
grpcOptions:
ssl-target-name-override: peer0.org1.example.com
request-timeout: 120001
# Fabric-CA is a special kind of Certificate Authority provided by Hyperledger Fabric which allows
# certificate management to be done via REST APIs. Application may choose to use a standard
# Certificate Authority instead of Fabric-CA, in which case this section would not be specified.
#
certificateAuthorities:
ca-org1:
url: http://localhost:7054
# the properties specified under this object are passed to the 'http' client verbatim when
# making the request to the Fabric-CA server
httpOptions:
verify: false
# Fabric-CA supports dynamic user enrollment via REST APIs. A "root" user, a.k.a registrar, is
# needed to enroll and invoke new users.
registrar:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-org1

225
commercial-paper/organization/magnetocorp/gateway/papernetConnection.yaml Normal file
View file

@ -0,0 +1,225 @@
---
#
# The network connection profile provides client applications the information about the target
# blockchain network that are necessary for the applications to interact with it. These are all
# knowledge that must be acquired from out-of-band sources. This file provides such a source.
#
name: "finance-networks"
#
# Any properties with an "x-" prefix will be treated as application-specific, exactly like how naming
# in HTTP headers or swagger properties work. The SDK will simply ignore these fields and leave
# them for the applications to process. This is a mechanism for different components of an application
# to exchange information that are not part of the standard schema described below. In particular,
# the "x-type" property with the "hlfv1" value example below is used by Hyperledger Composer to
# determine the type of Fabric networks (v0.6 vs. v1.0) it needs to work with.
#
x-type: "hlfv1"
#
# Describe what the target network is/does.
#
description: "A gateway connection file for the PaperNet networks"
#
# Schema version of the content. Used by the SDK to apply the corresponding parsing rules.
#
version: "1.0"
#
# The client section is SDK-specific. The sample below is for the node.js SDK
#
#client:
# Which organization does this application instance belong to? The value must be the name of an org
# defined under "organizations"
#organization: Org1
# Some SDKs support pluggable KV stores, the properties under "credentialStore"
# are implementation specific
#credentialStore:
# [Optional]. Specific to FileKeyValueStore.js or similar implementations in other SDKs. Can be others
# if using an alternative impl. For instance, CouchDBKeyValueStore.js would require an object
# here for properties like url, db name, etc.
#path: "/tmp/hfc-kvs"
# [Optional]. Specific to the CryptoSuite implementation. Software-based implementations like
# CryptoSuite_ECDSA_AES.js in node SDK requires a key store. PKCS#11 based implementations does
# not.
#cryptoStore:
# Specific to the underlying KeyValueStore that backs the crypto key store.
#path: "/tmp/hfc-cvs"
# [Optional]. Specific to Composer environment
#wallet: wallet-name
#
# [Optional]. But most apps would have this section so that channel objects can be constructed
# based on the content below. If an app is creating channels, then it likely will not need this
# section.
#
channels:
# name of the channel
papernet:
# Required. list of orderers designated by the application to use for transactions on this
# channel. This list can be a result of access control ("org1" can only access "ordererA"), or
# operational decisions to share loads from applications among the orderers. The values must
# be "names" of orgs defined under "organizations/peers"
orderers:
- orderer.magnetocorp.com
# Required. list of peers from participating orgs
peers:
peer1.magnetocorp.com:
# [Optional]. will this peer be sent transaction proposals for endorsement? The peer must
# have the chaincode installed. The app can also use this property to decide which peers
# to send the chaincode install request. Default: true
endorsingPeer: true
# [Optional]. will this peer be sent query proposals? The peer must have the chaincode
# installed. The app can also use this property to decide which peers to send the
# chaincode install request. Default: true
chaincodeQuery: true
# [Optional]. will this peer be sent query proposals that do not require chaincodes, like
# queryBlock(), queryTransaction(), etc. Default: true
ledgerQuery: true
# [Optional]. will this peer be the target of the SDK's listener registration? All peers can
# produce events but the app typically only needs to connect to one to listen to events.
# Default: true
eventSource: true
peer2.digibank.com:
endorsingPeer: true
chaincodeQuery: false
ledgerQuery: true
eventSource: true
# [Optional]. what chaincodes are expected to exist on this channel? The application can use
# this information to validate that the target peers are in the expected state by comparing
# this list with the query results of getInstalledChaincodes() and getInstantiatedChaincodes()
chaincodes:
# the format follows the "cannonical name" of chaincodes by fabric code
- example02:v1
- marbles:1.0
#
# list of participating organizations in this network
#
organizations:
Org1:
mspid: magnetocorpMSP
peers:
- peer1.magnetocorp.com
# [Optional]. Certificate Authorities issue certificates for identification purposes in a Fabric based
# network. Typically certificates provisioning is done in a separate process outside of the
# runtime network. Fabric-CA is a special certificate authority that provides a REST APIs for
# dynamic certificate management (enroll, revoke, re-enroll). The following section is only for
# Fabric-CA servers.
certificateAuthorities:
- ca-magnetocorp
# [Optional]. If the application is going to make requests that are reserved to organization
# administrators, including creating/updating channels, installing/instantiating chaincodes, it
# must have access to the admin identity represented by the private key and signing certificate.
# Both properties can be the PEM string or local path to the PEM file. Note that this is mainly for
# convenience in development mode, production systems should not expose sensitive information
# this way. The SDK should allow applications to set the org admin identity via APIs, and only use
# this route as an alternative when it exists.
adminPrivateKey:
path: commercial-paper/organization/magnetocorp/users/Admin@magnetocorp/keystore/9022d671ceedbb24af3ea69b5a8136cc64203df6b9920e26f48123fcfcb1d2e9_sk
signedCert:
path: comercial-paper/organization/magnetocorp/users/Admin@magnetocorp.com/signcerts/Admin@magnetocorp.com-cert.pem
# the profile will contain public information about organizations other than the one it belongs to.
# These are necessary information to make transaction lifecycles work, including MSP IDs and
# peers with a public URL to send transaction proposals. The file will not contain private
# information reserved for members of the organization, such as admin key and certificate,
# fabric-ca registrar enroll ID and secret, etc.
Org2:
mspid: digibankMSP
peers:
- peer1.digibank.com
certificateAuthorities:
- ca-digibank
adminPrivateKey:
path: commercial-paper/organization/digibank/users/Admin@digibank.com/keystore/5a983ddcbefe52a7f9b8ee5b85a590c3e3a43c4ccd70c7795bec504e7f74848d_sk
signedCert:
path: commercial-paper/organization/digibank/users/Admin@digibank.com/signcerts/Admin@digibank.com-cert.pem
#
# List of orderers to send transaction and channel create/update requests to. For the time
# being only one orderer is needed. If more than one is defined, which one get used by the
# SDK is implementation specific. Consult each SDK's documentation for its handling of orderers.
#
orderers:
orderer.magnetocorp.com:
url: grpcs://localhost:7050
# these are standard properties defined by the gRPC library
# they will be passed in as-is to gRPC client constructor
grpcOptions:
ssl-target-name-override: orderer.example.com
tlsCACerts:
path: comercial-paper/organization/magnetocorp/orderer/orderer.magnetocorp.com/tlscacerts/example.com-cert.pem
#
# List of peers to send various requests to, including endorsement, query
# and event listener registration.
#
peers:
peer1.magnetocorp.com:
# this URL is used to send endorsement and query requests
url: grpcs://localhost:7051
grpcOptions:
ssl-target-name-override: peer1.magnetocorp.com
request-timeout: 120
tlsCACerts:
path: certificates/magnetocorp/magnetocorp.com-cert.pem
peer1.digibank.com:
url: grpcs://localhost:8051
grpcOptions:
ssl-target-name-override: peer1.digibank.com
tlsCACerts:
path: certificates/digibank/digibank.com-cert.pem
#
# Fabric-CA is a special kind of Certificate Authority provided by Hyperledger Fabric which allows
# certificate management to be done via REST APIs. Application may choose to use a standard
# Certificate Authority instead of Fabric-CA, in which case this section would not be specified.
#
certificateAuthorities:
ca-org1:
url: https://localhost:7054
# the properties specified under this object are passed to the 'http' client verbatim when
# making the request to the Fabric-CA server
httpOptions:
verify: false
tlsCACerts:
path: commercial-paper/organization/magnetocorp/ca/magnetocorp.com-cert.pem
# Fabric-CA supports dynamic user enrollment via REST APIs. A "root" user, a.k.a registrar, is
# needed to enroll and invoke new users.
registrar:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-magnetocorp
ca-org2:
url: https://localhost:8054
httpOptions:
verify: false
tlsCACerts:
path: commercial-paper/organization/digibank/ca/digibank.com-cert.pem
registrar:
- enrollId: admin
enrollSecret: adminpw
# [Optional] The optional name of the CA.
caName: ca-digibank