fix: disposable gas payer timeout & ibc shielding with multicore (#1593)

* fix: increase disposable gas payer timeout

* feat: ibc shielding in web worker

Author: mateuszjasiuk

apps/extension/src/storage/LocalStorage.ts

@@ -148,8 +148,8 @@ export class LocalStorage extends ExtStorage {
       data,
       O.map((data) => {
         const newData = Object.entries(data).reduce((acc, [key, value]) => {
-          // We clear the disposable signers after 2 minutes
-          if (currentTime - value.timestamp < 120000) {
+          // We clear the disposable signers after 60 minutes
+          if (currentTime - value.timestamp < 3600000) {
             acc[key] = value;
           }
 

apps/namadillo/src/atoms/integrations/services.ts

@@ -9,10 +9,13 @@ import {
   StargateClient,
   StdFee,
 } from "@cosmjs/stargate";
+import * as Comlink from "comlink";
 import { TxRaw } from "cosmjs-types/cosmos/tx/v1beta1/tx";
 
 import { sanitizeUrl } from "@namada/utils";
 import { getIndexerApi } from "atoms/api";
+import { chainParametersAtom } from "atoms/chain";
+import { rpcUrlAtom } from "atoms/settings";
 import { queryForAck, queryForIbcTimeout } from "atoms/transactions";
 import BigNumber from "bignumber.js";
 import { getDefaultStore } from "jotai";
@@ -27,6 +30,9 @@ import {
 } from "types";
 import { getKeplrWallet } from "utils/ibc";
 import { getSdkInstance } from "utils/sdk";
+import { GenerateIbcShieldingMemo } from "workers/MaspTxMessages";
+import { Worker as MaspTxWorkerApi } from "workers/MaspTxWorker";
+import MaspTxWorker from "workers/MaspTxWorker?worker";
 import { rpcByChainAtom } from "./atoms";
 import {
   getChainRegistryIbcFilePath,
@@ -61,13 +67,31 @@ export const getShieldedArgs = async (
   destinationChannelId: string
 ): Promise<{ receiver: string; memo: string }> => {
   const sdk = await getSdkInstance();
+  const store = getDefaultStore();
+  const rpcUrl = store.get(rpcUrlAtom);
+  const chain = store.get(chainParametersAtom);
 
-  const memo = await sdk.tx.generateIbcShieldingMemo(
-    target,
-    token,
-    amount,
-    destinationChannelId
-  );
+  if (!chain.isSuccess) throw "Chain not loaded";
+
+  const worker = new MaspTxWorker();
+  const workerLink = Comlink.wrap<MaspTxWorkerApi>(worker);
+  await workerLink.init({
+    type: "init",
+    payload: { rpcUrl, token: sdk.nativeToken, maspIndexerUrl: "" },
+  });
+
+  const msg: GenerateIbcShieldingMemo = {
+    type: "generate-ibc-shielding-memo",
+    payload: {
+      target,
+      token,
+      amount,
+      destinationChannelId,
+      chainId: chain.data.chainId,
+    },
+  };
+
+  const memo = (await workerLink.generateIbcShieldingMemo(msg)).payload;
 
   return {
     receiver: sdk.masp.maspAddress(),

apps/namadillo/src/workers/MaspTxMessages.ts

@@ -5,6 +5,7 @@ import {
   TxResponseMsgValue,
   UnshieldingTransferMsgValue,
 } from "@namada/types";
+import BigNumber from "bignumber.js";
 import { EncodedTxData, TransactionPair } from "lib/query";
 import { ChainSettings, GasConfig } from "types";
 import { WebWorkerMessage } from "./utils";
@@ -61,6 +62,22 @@ export type ShieldedTransferDone = WebWorkerMessage<
   EncodedTxData<ShieldedTransferMsgValue>
 >;
 
+type GenerateIbcShieldingMemoPayload = {
+  target: string;
+  token: string;
+  amount: BigNumber;
+  destinationChannelId: string;
+  chainId: string;
+};
+export type GenerateIbcShieldingMemo = WebWorkerMessage<
+  "generate-ibc-shielding-memo",
+  GenerateIbcShieldingMemoPayload
+>;
+export type GenerateIbcShieldingMemoDone = WebWorkerMessage<
+  "generate-ibc-shielding-memo-done",
+  string
+>;
+
 type BroadcastPayload = TransactionPair<unknown>;
 
 export type Broadcast = WebWorkerMessage<"broadcast", BroadcastPayload>;

apps/namadillo/src/workers/MaspTxWorker.ts

@@ -11,6 +11,8 @@ import { buildTx, EncodedTxData } from "lib/query";
 import {
   Broadcast,
   BroadcastDone,
+  GenerateIbcShieldingMemo,
+  GenerateIbcShieldingMemoDone,
   Init,
   InitDone,
   Shield,
@@ -61,6 +63,18 @@ export class Worker {
     };
   }
 
+  async generateIbcShieldingMemo(
+    m: GenerateIbcShieldingMemo
+  ): Promise<GenerateIbcShieldingMemoDone> {
+    if (!this.sdk) {
+      throw new Error("SDK is not initialized");
+    }
+    return {
+      type: "generate-ibc-shielding-memo-done",
+      payload: await generateIbcShieldingMemo(this.sdk, m.payload),
+    };
+  }
+
   async broadcast(m: Broadcast): Promise<BroadcastDone> {
     if (!this.sdk) {
       throw new Error("SDK is not initialized");
@@ -142,6 +156,23 @@ async function shieldedTransfer(
   return encodedTxData;
 }
 
+async function generateIbcShieldingMemo(
+  sdk: Sdk,
+  payload: GenerateIbcShieldingMemo["payload"]
+): Promise<string> {
+  const { target, token, amount, destinationChannelId, chainId } = payload;
+  await sdk.masp.loadMaspParams("", chainId);
+
+  const memo = await sdk.tx.generateIbcShieldingMemo(
+    target,
+    token,
+    amount,
+    destinationChannelId
+  );
+
+  return memo;
+}
+
 // TODO: We will probably move this to the separate worker
 async function broadcast(
   sdk: Sdk,
@@ -178,6 +209,9 @@ export const registerTransferHandlers = (): void => {
   registerBNTransferHandler<ShieldedTransfer>("shielded-transfer");
   registerBNTransferHandler<UnshieldDone>("unshield-done");
   registerBNTransferHandler<Unshield>("unshield");
+  registerBNTransferHandler<GenerateIbcShieldingMemo>(
+    "generate-ibc-shielding-memo"
+  );
   registerBNTransferHandler<Broadcast>("broadcast");
 };