refetch transaction after confirming on sui (#249)

* refetch transaction after confirming on sui

* v7.3.2

Author: Yolley

lerna.json

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

packages/common/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/common",
-  "version": "7.3.1",
+  "version": "7.3.2",
   "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.1",
+  "version": "7.3.2",
   "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/package.json

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

packages/launchpad/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@streamflow/launchpad",
-  "version": "7.3.1",
+  "version": "7.3.2",
   "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.1",
+  "version": "7.3.2",
   "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.1",
+  "version": "7.3.2",
   "description": "JavaScript SDK to interact with Streamflow protocol.",
   "homepage": "https://github.com/streamflow-finance/js-sdk/",
   "main": "./dist/esm/index.js",
@@ -54,7 +54,6 @@
     "@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,5 +1,4 @@
 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";
@@ -109,40 +108,20 @@ export default class SuiStreamClient extends BaseStreamClient {
     const errors: ICreateMultiError[] = [];
 
     try {
-      const { digest, events, effects } = await wallet.signAndExecuteTransaction({
+      const executedTx = await wallet.signAndExecuteTransaction({
         transaction: tx,
         options: { showEffects: true, showEvents: true },
       });
-      txs.push(digest);
-
-      // effects may be string according to Sui Wallet standard
+      const digest = executedTx.digest;
+      // effects may be string according to Sui Wallet standard, events won't even be returned
       // 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}`);
-      }
+      const { events, effects } =
+        !executedTx.effects || typeof executedTx.effects === "string"
+          ? await this.client.getTransactionBlock({ digest, options: { showEvents: true, showEffects: true } })
+          : executedTx;
+      txs.push(digest);
 
-      if (effectsShort?.status === "failure") {
+      if (effects!.status.status === "failure") {
         multipleStreamData.recipients.forEach((recipient) => {
           errors.push({
             error: effects!.status.error ?? "Unknown error!",