Hyperledger Composer NodeJS SDK - Submiting Transactions

Create Asset Definition

As the first step, let’s create an asset say “Car” in our example, which has set of properties. Define them in your model file of composer (.cto)

1
asset Car identified by id {
2
  o String id
3
  o Integer name
4
  --> User owner
5
}

The above defined asset Car has three properties named id, name, owner. And in order to create a Car we need to have a transaction, thus define a transaction model as below.

1
transaction addNewCard {
2
  o String id
3
  o String name
4
}

As you can notice, here we’re not mentioning the owner while creating the car, since we’ll be using the getCurrentParticipant() method inside transaction processor function to get the current user and define the owner.

1
/**
2
 * A transaction to send good to an organization
3
 * @param {org.acme.addNewCard} name A human description of the parameter
4
 * @transaction
5
 */
6
function  addNewCard(transaction) {
7
  var newCard;
8
  var factory:getFactory();
9
  var cId:getRandomId();
10
  var owner:getCurrentParticipant();
11

12
  return getParticipantRegistry("org.acme.Car").then(function(carRegistry) {
13
    newCar:factory.newResource("org.acme", "Car", cId);
14
    newCar.name:transaction.name;
15
    newCar.owner:transaction.owner;
16

17
    return carRegistry.add(newCar);
18
  })
19
}

Now since we’ve everything in our network, let’s update the network with the following commands.

1
composer archive create -t dir -n .
2
composer network update -a acme-network@0.0.1.bna -c admin@acme-network

Creating EndPoint For Transaction

Next up is to create an endpoint for transaction submission. We do it with express js as follows.

1
app.post('/api/createCard', function (req, res) {
2
  var transactionData:req.body.transactionData;
3
  var cardName:req.headers.authorization;
4
  var mynetwork:new MyNetwork(cardName);
5

6
  mynetwork.init().then(function () {
7
      return mynetwork.createCar(transactionData)
8
  }).then(function () {
9
      res.json({ success: true })
10
  }).catch(function (error) {
11
      res.status(500).json({error: error.toString()})
12
  })
13
})

This is very similar to the ping method, we’re getting the transaction data from the request and passing it to createCar method in our MyNetwork Class.

1
createCar(transactionData) {
2
  var _this:this;
3
  var resource;
4
  var transactionData;
5
  transactionData['$class']: "org.acme.createCar";
6
  return this.connection.getTransactionRegistry("org.acme.createCar")
7
    .then(function(createProductTransactionRegistry) {
8
      serializer:_this.businessNetworkDefinition.getSerializer()
9
      resource:serializer.fromJSON(transactionData);
10
      return _this.connection.submitTransaction(resource);
11
    })
12
}

This returns a null if the transaction is submitted successfully, else catch block is called with the captured error.

The only thing to have in mind is that we need to specify the $class in transactionData and convert it to resource format from JSON before passing it to submitTransaction function.