feat(amplifier): add save payload

examples/amplifier/README.md

@@ -135,6 +135,7 @@ The following endpoints are available to facilitate GMP calls:
 1. `verify` -- triggers a verification on the source chain (routing is handled automatically)
 2. `subscribe-to-approvals` -- creates a channel to return all calls that are approved on the destination chain 
 3. `get-payload` -- queries the payload of the initial source-chain transaction by its hash
+4. `save-payload` -- stores a payload of the initial source-chain transaction and returns its hash
 
 ### `verify`
 
@@ -219,6 +220,20 @@ execute data: 09c5eabe0000000000000000000000000000000000000000000000000000000000
 ---
 ```
 
+### `save-payload`
+
+To save a payload that was submitted by the transaction on the source chain, use `save-payload`:
+
+```bash
+$ node amplifier save-payload --payload 00000000000000000000000000000000000000000000000000000000000000400000000000000000000000000000000000000000000000000000000000000080000000000000000000000000000000000000000000000000000000000000000f68656c6c6f206176616c616e63686500000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000
+Saving payload 00000000000000000000000000000000000000000000000000000000000000400000000000000000000000000000000000000000000000000000000000000080000000000000000000000000000000000000000000000000000000000000000f68656c6c6f206176616c616e63686500000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000
+Connecting to server at localhost:50051
+Payload hash:
+0xa9b070ad799e19f1166fdbf4524b684f8026df510fe6a7770f949ad54047098c
+```
+
+- `payload` -- the payload
+
 ### `get-payload`
 
 To get the payload that was submitted by the transaction on the source chain, use `get-payload`:

examples/amplifier/amplifier.js

@@ -2,6 +2,7 @@ const commander = require('commander');
 const { broadcast } = require('./endpoints/broadcast.js');
 const { getReceipt } = require('./endpoints/get-receipt.js');
 const { getPayload } = require('./endpoints/get-payload.js');
+const { savePayload } = require('./endpoints/save-payload.js');
 const { subscribe_to_approvals } = require('./endpoints/subscribe-to-approvals.js');
 const { subscribe_to_wasm_events } = require('./endpoints/subscribe-to-wasm-events.js');
 const { verify } = require('./endpoints/verify.js');
@@ -30,6 +31,13 @@ program
         getPayload(options.hash);
     });
 
+program
+    .command('save-payload')
+    .requiredOption('--payload, <payload>', 'payload')
+    .action((options) => {
+        savePayload(options.payload);
+    });
+
 program
     .command('subscribe-to-approvals')
     .requiredOption("-c, --chain <chain>", "The chain to subscribe to")
@@ -47,7 +55,7 @@ program
 
 program
     .command('verify')
-    .requiredOption("-i, --id <transaction id>", "The id of the transaction (txHash:logIndex)")
+    .requiredOption("-i, --id <transaction id>", "The id of the transaction (txHash-logIndex)")
     .requiredOption("--source-chain <source chain>", "The source chain")
     .requiredOption("--source-address <source address>", "The source address")
     .requiredOption("--destination-chain <destination chain>", "The destination chain")

examples/amplifier/amplifier.proto

@@ -25,6 +25,12 @@ service Amplifier {
       get : "/v1beta1/receipt/{receipt_id}"
     };
   }
+  rpc SavePayload(SavePayloadRequest) returns (SavePayloadResponse) {
+    option (google.api.http) = {
+      post : "/v1beta1/payload"
+      body : "*"
+    };
+  }
 }
 
 message Message {
@@ -43,6 +49,10 @@ message GetPayloadRequest { bytes hash = 1; }
 
 message GetPayloadResponse { bytes payload = 1; }
 
+message SavePayloadRequest { bytes payload = 1; }
+
+message SavePayloadResponse { bytes hash = 1; }
+
 message SubscribeToApprovalsRequest {
   repeated string chains = 1;
   optional uint64 start_height = 2; // can be used to replay events

examples/amplifier/endpoints/save-payload.js

@@ -0,0 +1,23 @@
+const newClient = require('../grpc/client');
+
+function savePayload(payload) {
+    console.log("Saving payload", payload);
+
+    const client = newClient();
+    const savePayloadRequest = { payload: Buffer.from(payload, 'hex') };
+    response = client.SavePayload(savePayloadRequest, (err, response) => {
+        if (err) {
+            console.error("Error", err);
+            process.exit(1)
+        }
+
+        if (response) {
+            console.log("Payload hash:\n" + response.hash);
+            process.exit(0)
+        }
+    });
+}
+
+module.exports = {
+    savePayload,
+};

examples/amplifier/endpoints/subscribe-to-wasm-events.js

@@ -4,7 +4,7 @@ function subscribe_to_wasm_events(startHeight) {
     console.log("Subscribing to events starting from block:", startHeight == 0 ? "latest" : startHeight);
 
     const client = newClient();
-    const call = client.SubscribeToWasmEvents({ startHeight: startHeight });
+    const call = client.SubscribeToWasmEvents(startHeight);
     call.on('data', (response) => {
         console.log("Event:", response);
     });

examples/amplifier/endpoints/verify.js

@@ -3,8 +3,8 @@ const newClient = require('../grpc/client');
 function verify(id, sourceChain, sourceAddress, destinationChain, destinationAddress, payload) {
     console.log("Verifying message with id, sourceChain, sourceAddress, destinationChain, destinationAddress, and payload:", id, sourceChain, sourceAddress, destinationChain, destinationAddress, payload);
 
-    if (id.split(':').length != 2) {
-        console.error("Invalid transaction id. Expected format: txHash:logIndex");
+    if (id.split('-').length != 2) {
+        console.error("Invalid transaction id. Expected format: txHash-logIndex");
         process.exit(1);
     }
     payload = payload.replace('0x', '');