mirror of
https://github.com/hyperledger/fabric-samples.git
synced 2026-06-17 23:45:10 +00:00
1efd213110
Add a channel event handler sample based on block events. Scope: create a block event handler write events received to the console write events received to a log file write events to an off chain couchdb database demonstrate a basic map reduce view for aggregation Change-Id: I5420ddc7070dbee785218ce5960f7604ac799f90 Signed-off-by: Chris Elder <chris.elder@us.ibm.com>
117 lines
4.5 KiB
JavaScript
117 lines
4.5 KiB
JavaScript
/*
|
|
* Copyright IBM Corp. All Rights Reserved.
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*
|
|
*/
|
|
|
|
/*
|
|
*
|
|
* addMarbles.js will add random sample data to blockchain.
|
|
*
|
|
* $ node addMarbles.js
|
|
*
|
|
* addMarbles will add 10 marbles by default with a starting marble name of "marble100".
|
|
* Additional marbles will be added by incrementing the number at the end of the marble name.
|
|
*
|
|
* The properties for adding marbles are stored in addMarbles.json. This file will be created
|
|
* during the first execution of the utility if it does not exist. The utility can be run
|
|
* multiple times without changing the properties. The nextMarbleNumber will be incremented and
|
|
* stored in the JSON file.
|
|
*
|
|
* {
|
|
* "nextMarbleNumber": 100,
|
|
* "numberMarblesToAdd": 10
|
|
* }
|
|
*
|
|
*/
|
|
|
|
'use strict';
|
|
|
|
const { FileSystemWallet, Gateway } = require('fabric-network');
|
|
const fs = require('fs');
|
|
const path = require('path');
|
|
|
|
const addMarblesConfigFile = path.resolve(__dirname, 'addMarbles.json');
|
|
|
|
const colors=[ 'blue', 'red', 'yellow', 'green', 'white', 'purple' ];
|
|
const owners=[ 'tom', 'fred', 'julie', 'james', 'janet', 'henry', 'alice', 'marie', 'sam', 'debra', 'nancy'];
|
|
const sizes=[ 10, 20, 30, 40, 50, 60, 70, 80, 90, 100 ];
|
|
const docType='marble'
|
|
|
|
const config = require('./config.json');
|
|
const channelid = config.channelid;
|
|
|
|
async function main() {
|
|
|
|
try {
|
|
|
|
let nextMarbleNumber;
|
|
let numberMarblesToAdd;
|
|
let addMarblesConfig;
|
|
|
|
// check to see if there is a config json defined
|
|
if (fs.existsSync(addMarblesConfigFile)) {
|
|
// read file the next marble and number of marbles to create
|
|
let addMarblesConfigJSON = fs.readFileSync(addMarblesConfigFile, 'utf8');
|
|
addMarblesConfig = JSON.parse(addMarblesConfigJSON);
|
|
nextMarbleNumber = addMarblesConfig.nextMarbleNumber;
|
|
numberMarblesToAdd = addMarblesConfig.numberMarblesToAdd;
|
|
} else {
|
|
nextMarbleNumber = 100;
|
|
numberMarblesToAdd = 20;
|
|
// create a default config and save
|
|
addMarblesConfig = new Object;
|
|
addMarblesConfig.nextMarbleNumber = nextMarbleNumber;
|
|
addMarblesConfig.numberMarblesToAdd = numberMarblesToAdd;
|
|
fs.writeFileSync(addMarblesConfigFile, JSON.stringify(addMarblesConfig, null, 2));
|
|
}
|
|
|
|
// Parse the connection profile. This would be the path to the file downloaded
|
|
// from the IBM Blockchain Platform operational console.
|
|
const ccpPath = path.resolve(__dirname, '..', 'first-network', 'connection-org1.json');
|
|
const ccp = JSON.parse(fs.readFileSync(ccpPath, 'utf8'));
|
|
|
|
// Configure a wallet. This wallet must already be primed with an identity that
|
|
// the application can use to interact with the peer node.
|
|
const walletPath = path.resolve(__dirname, 'wallet');
|
|
const wallet = new FileSystemWallet(walletPath);
|
|
|
|
// Create a new gateway, and connect to the gateway peer node(s). The identity
|
|
// specified must already exist in the specified wallet.
|
|
const gateway = new Gateway();
|
|
await gateway.connect(ccpPath, { wallet, identity: 'user1', discovery: { enabled: true, asLocalhost: true } });
|
|
|
|
// Get the network channel that the smart contract is deployed to.
|
|
const network = await gateway.getNetwork(channelid);
|
|
|
|
// Get the smart contract from the network channel.
|
|
const contract = network.getContract('marbles');
|
|
|
|
for (var counter = nextMarbleNumber; counter < nextMarbleNumber + numberMarblesToAdd; counter++) {
|
|
|
|
var randomColor = Math.floor(Math.random() * (6));
|
|
var randomOwner = Math.floor(Math.random() * (11));
|
|
var randomSize = Math.floor(Math.random() * (10));
|
|
|
|
// Submit the 'initMarble' transaction to the smart contract, and wait for it
|
|
// to be committed to the ledger.
|
|
await contract.submitTransaction('initMarble', docType+counter, colors[randomColor], ''+sizes[randomSize], owners[randomOwner]);
|
|
console.log("Adding marble: " + docType + counter + " owner:" + owners[randomOwner] + " color:" + colors[randomColor] + " size:" + '' + sizes[randomSize] );
|
|
|
|
}
|
|
|
|
await gateway.disconnect();
|
|
|
|
addMarblesConfig.nextMarbleNumber = nextMarbleNumber + numberMarblesToAdd;
|
|
|
|
fs.writeFileSync(addMarblesConfigFile, JSON.stringify(addMarblesConfig, null, 2));
|
|
|
|
} catch (error) {
|
|
console.error(`Failed to submit transaction: ${error}`);
|
|
process.exit(1);
|
|
}
|
|
|
|
}
|
|
|
|
main();
|