async function main()

in events/listener.js [56:90]

• 28 lines of code
• 2 McCabe index (conditional complexity)

async function main() {
    logger.info('============ Starting Listening for Events');

    await connection.getRegisteredUser(username, orgName, true);
    const fabric_client = await connection.getClientForOrg(orgName, username);
    const channel = fabric_client.getChannel()
    const eventHub = channel.getChannelEventHubsForOrg()[0];
    eventHub.connect(true);
    logger.info('Listening for %s on %s using org %s', eventName, channel, orgName);

    eventHub.registerChaincodeEvent(chaincodeName, eventName,
        (event, block_num, txnid, status) => {
            console.log(event);

            var record = JSON.parse(event['payload'])
            console.log(record)

            var params = {
                Data: JSON.stringify(record) + "\n",
                PartitionKey: record['ToBankID'],
                StreamName: kinesis_stream
            };

            kinesis.putRecord(params, function(err, data) {
                if (err) console.log(err, err.stack); // an error occurred
                else console.log(data); // successful response
            });


        },
        (error) => {
            console.log('Failed to receive the chaincode event ::' + error);
        }
    );
}