support bcs effects parsing (#248)

* support bcs effects parsing

Author: Yolley

lerna.json

@@ -2,6 +2,6 @@
   "packages": [
     "packages/*"
   ],
-  "version": "7.3.0",
+  "version": "7.3.1",
   "$schema": "node_modules/lerna/schemas/lerna-schema.json"
 }

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/common",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "description": "Common utilities and types used by streamflow packages.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/esm/index.js",

packages/distributor/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/distributor",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "description": "JavaScript SDK to interact with Streamflow Airdrop protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/esm/index.js",

packages/eslint-config/index.js

@@ -36,7 +36,7 @@ module.exports = {
     "react/jsx-filename-extension": "off",
     "@typescript-eslint/no-throw-literal": "off",
     "no-debugger": "warn",
-    "no-console": "warn",
+    "no-console": ["warn", { allow: ["warn"] }],
     "import/prefer-default-export": "off",
     "import/no-unresolved": "warn",
     "no-plusplus": "off",

packages/eslint-config/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/eslint-config",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "license": "ISC",
   "main": "index.js",
   "files": [

packages/launchpad/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/launchpad",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "description": "JavaScript SDK to interact with Streamflow Launchpad protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/esm/index.js",

packages/staking/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/staking",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "description": "JavaScript SDK to interact with Streamflow Staking protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "dist/esm/index.js",

packages/stream/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/stream",
-  "version": "7.3.0",
+  "version": "7.3.1",
   "description": "JavaScript SDK to interact with Streamflow protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/esm/index.js",
@@ -54,6 +54,7 @@
     "@coral-xyz/anchor": "^0.30.1",
     "@coral-xyz/borsh": "0.30.1",
     "@manahippo/aptos-wallet-adapter": "1.0.10",
+    "@mysten/bcs": "1.1.0",
     "@mysten/sui": "1.12.0",
     "@solana/buffer-layout": "4.0.1",
     "@solana/spl-token": "0.4.9",

packages/stream/sui/StreamClient.ts

@@ -1,4 +1,5 @@
 import BN from "bn.js";
+import { fromBase64 } from "@mysten/bcs";
 import { CoinStruct, SuiClient } from "@mysten/sui/client";
 import { Transaction, TransactionObjectArgument } from "@mysten/sui/transactions";
 import { SUI_CLOCK_OBJECT_ID, SUI_TYPE_ARG } from "@mysten/sui/utils";
@@ -114,7 +115,34 @@ export default class SuiStreamClient extends BaseStreamClient {
       });
       txs.push(digest);
 
-      if (effects!.status.status === "failure") {
+      // effects may be string according to Sui Wallet standard
+      // https://github.com/MystenLabs/ts-sdks/blob/main/packages/wallet-standard/src/features/suiSignAndExecuteTransaction.ts#L34
+      // Loosely ported from https://github.com/MystenLabs/ts-sdks/blob/main/packages/graphql-transport/src/mappers/transaction-block.ts#L376
+      let effectsShort: { status: "success" | "failure"; error?: string } | undefined = undefined;
+      if (typeof effects === "string") {
+        const parsedEffects = bcs.TransactionEffects.parse(fromBase64(effects));
+        const currentEffects = parsedEffects.V2 || parsedEffects.V1;
+        if (currentEffects) {
+          effectsShort = currentEffects.status.Success
+            ? {
+                status: "success",
+              }
+            : {
+                status: "failure",
+                error: currentEffects.status.$kind,
+              };
+        }
+      } else if (effects && effects.status) {
+        effectsShort = {
+          status: effects.status.status,
+          error: effects.status.error,
+        };
+      }
+      if (!effectsShort) {
+        console.warn(`Got no effects from the transaction ${digest}, raw: ${effects}`);
+      }
+
+      if (effectsShort?.status === "failure") {
         multipleStreamData.recipients.forEach((recipient) => {
           errors.push({
             error: effects!.status.error ?? "Unknown error!",