Cosmos JS

src/families/cosmos/api/Cosmos.ts

@@ -143,12 +143,12 @@ export const getRedelegations = async (address: string): Promise<any> => {
   });
 
   data.redelegation_responses.forEach((elem) => {
-    elem.entries.forEach((entries) => {
+    elem.entries.forEach((entry) => {
       redelegations.push({
-        validatorSrcAddress: elem.validator_src_address,
-        validatorDstAddress: elem.validator_dst_address,
-        amount: new BigNumber(entries.initial_balance),
-        completionDate: new Date(entries.completion_time),
+        validatorSrcAddress: elem.redelegation.validator_src_address,
+        validatorDstAddress: elem.redelegation.validator_dst_address,
+        amount: new BigNumber(entry.redelegation_entry.initial_balance),
+        completionDate: new Date(entry.redelegation_entry.completion_time),
       });
     });
   });

src/families/cosmos/js-signOperation.ts

@@ -1,4 +1,9 @@
-import { Account, Operation, OperationType, SignOperationEvent } from "../../types";
+import {
+  Account,
+  Operation,
+  OperationType,
+  SignOperationEvent,
+} from "../../types";
 import type { Transaction } from "./types";
 import { getAccount, getChainId } from "./api/Cosmos";
 import { Observable } from "rxjs";
@@ -145,7 +150,7 @@ const signOperation = ({
 
         o.next({ type: "device-signature-granted" });
 
-        const txHash = ""; // resolved at broadcast time
+        const hash = ""; // resolved at broadcast time
         const accountId = account.id;
         const type: OperationType =
           transaction.mode === "undelegate"
@@ -158,19 +163,27 @@ const signOperation = ({
             ? "REWARD"
             : "OUT";
 
+        const senders = [] as any;
+        const recipients = [] as any;
+
+        if (type === "OUT") {
+          senders.push(account.freshAddress);
+          recipients.push(transaction.recipient);
+        }
+
         // build optimistic operation
         const operation: Operation = {
-          id: encodeOperationId(accountId, txHash, type),
-          hash: txHash,
-          type: type,
+          id: encodeOperationId(accountId, hash, type),
+          hash,
+          type,
           value: transaction.amount,
           fee: transaction.fees || new BigNumber(0),
           extra: {},
           blockHash: null,
           blockHeight: null,
-          senders: [account.freshAddress],
-          recipients: [transaction.recipient],
-          accountId: accountId,
+          senders,
+          recipients,
+          accountId,
           date: new Date(),
         };
 

src/families/cosmos/js-synchronisation.ts

@@ -42,56 +42,87 @@ const txToOps = (info: any, id: string, txs: any): Operation[] => {
       // https://docs.cosmos.network/v0.42/modules/staking/07_events.html
       switch (message.type) {
         case "transfer":
-          op.senders.push(attributes["sender"]);
-          op.recipients.push(attributes["recipient"]);
-
-          op.value = op.value.plus(
-            attributes["amount"].replace(currency.units[1].code, "")
-          );
-
-          if (attributes["sender"] === address) {
-            op.type = "OUT";
-            op.value = op.value.plus(fees);
-          } else if (attributes["recipient"] === address) {
-            op.type = "IN";
+          if (
+            attributes["sender"] &&
+            attributes["recipient"] &&
+            attributes["amount"]
+          ) {
+            op.senders.push(attributes["sender"]);
+            op.recipients.push(attributes["recipient"]);
+
+            if (attributes["amount"].indexOf(currency.units[1].code) != -1) {
+              op.value = op.value.plus(
+                attributes["amount"].replace(currency.units[1].code, "")
+              );
+            }
+
+            if (attributes["sender"] === address) {
+              op.type = "OUT";
+              op.value = op.value.plus(fees);
+            } else if (attributes["recipient"] === address) {
+              op.type = "IN";
+            }
           }
           break;
 
         case "withdraw_rewards":
-          op.type = "REWARD";
-          op.value = new BigNumber(fees);
-          op.extra.validators.push({
-            amount: attributes["amount"].replace(currency.units[1].code, ""),
-            address: attributes.validator,
-          });
+          if (
+            attributes["amount"] &&
+            attributes["amount"].indexOf(currency.units[1].code) != -1
+          ) {
+            op.type = "REWARD";
+            op.value = new BigNumber(fees);
+            op.extra.validators.push({
+              amount: attributes["amount"].replace(currency.units[1].code, ""),
+              address: attributes.validator,
+            });
+          }
           break;
 
         case "delegate":
-          op.type = "DELEGATE";
-          op.value = new BigNumber(fees);
-          op.extra.validators.push({
-            amount: attributes["amount"].replace(currency.units[1].code, ""),
-            address: attributes.validator,
-          });
+          if (
+            attributes["amount"] &&
+            attributes["amount"].indexOf(currency.units[1].code) != -1
+          ) {
+            op.type = "DELEGATE";
+            op.value = new BigNumber(fees);
+            op.extra.validators.push({
+              amount: attributes["amount"].replace(currency.units[1].code, ""),
+              address: attributes.validator,
+            });
+          }
           break;
 
         case "redelegate":
-          op.type = "REDELEGATE";
-          op.value = new BigNumber(fees);
-          op.extra.validators.push({
-            amount: attributes["amount"].replace(currency.units[1].code, ""),
-            address: attributes.destination_validator,
-          });
-          op.extra.cosmosSourceValidator = attributes.source_validator;
+          if (
+            attributes["amount"] &&
+            attributes["amount"].indexOf(currency.units[1].code) != -1 &&
+            attributes.destination_validator &&
+            attributes.source_validator
+          ) {
+            op.type = "REDELEGATE";
+            op.value = new BigNumber(fees);
+            op.extra.validators.push({
+              amount: attributes["amount"].replace(currency.units[1].code, ""),
+              address: attributes.destination_validator,
+            });
+            op.extra.cosmosSourceValidator = attributes.source_validator;
+          }
           break;
 
         case "unbond":
-          op.type = "UNDELEGATE";
-          op.value = new BigNumber(fees);
-          op.extra.validators.push({
-            amount: attributes["amount"].replace(currency.units[1].code, ""),
-            address: attributes.validator,
-          });
+          if (
+            attributes["amount"] &&
+            attributes["amount"].indexOf(currency.units[1].code) != -1 &&
+            attributes.validator
+          ) {
+            op.type = "UNDELEGATE";
+            op.value = new BigNumber(fees);
+            op.extra.validators.push({
+              amount: attributes["amount"].replace(currency.units[1].code, ""),
+              address: attributes.validator,
+            });
+          }
           break;
       }
     });