feat: show EVM lockup transactions

BoltzExchange · Nov 4, 2024 · 947a05b · 947a05b
1 parent eb5bc5e
commit 947a05b
Show file tree

Hide file tree

Showing 3 changed files with 73 additions and 31 deletions.
diff --git a/src/components/BlockExplorerLink.tsx b/src/components/BlockExplorerLink.tsx
@@ -1,4 +1,11 @@
-import { Accessor, Show, createEffect, createSignal } from "solid-js";
+import {
+    Accessor,
+    Match,
+    Show,
+    Switch,
+    createEffect,
+    createSignal,
+} from "solid-js";
 
 import { RBTC } from "../consts/Assets";
 import { SwapType } from "../consts/Enums";
@@ -43,6 +50,8 @@ const BlockExplorerLink = (props: {
     swap: Accessor<SomeSwap>;
     swapStatus: Accessor<string>;
 }) => {
+    const isRsk = () => getRelevantAssetForSwap(props.swap()) === RBTC;
+
     return (
         <Show
             when={props.swap().type !== SwapType.Chain}
@@ -52,37 +61,52 @@ const BlockExplorerLink = (props: {
                     swapStatus={props.swapStatus}
                 />
             }>
-            {/* Showing addresses makes no sense for EVM based chains */}
-            <Show
-                when={getRelevantAssetForSwap(props.swap()) !== RBTC}
-                fallback={
-                    <Show when={props.swap().claimTx !== undefined}>
+            <Switch>
+                <Match when={!isRsk()}>
+                    {/* Refund transactions are handled in SwapRefunded */}
+                    <Show
+                        when={
+                            getRelevantAssetForSwap(props.swap()) &&
+                            props.swapStatus() !== null &&
+                            props.swapStatus() !== "invoice.set" &&
+                            props.swapStatus() !== "swap.created"
+                        }>
+                        <BlockExplorer
+                            asset={getRelevantAssetForSwap(props.swap())}
+                            txId={props.swap().claimTx}
+                            address={
+                                props.swap().type === SwapType.Submarine
+                                    ? (props.swap() as SubmarineSwap).address
+                                    : (props.swap() as ReverseSwap)
+                                          .lockupAddress
+                            }
+                        />
+                    </Show>
+                </Match>
+
+                {/* Showing addresses makes no sense for EVM based chains */}
+                <Match when={isRsk()}>
+                    <Show
+                        when={props.swap().claimTx !== undefined}
+                        fallback={
+                            <Show when={props.swap().lockupTx}>
+                                <BlockExplorer
+                                    asset={getRelevantAssetForSwap(
+                                        props.swap(),
+                                    )}
+                                    txId={props.swap().lockupTx}
+                                    typeLabel={"lockup_tx"}
+                                />
+                            </Show>
+                        }>
                         <BlockExplorer
                             asset={getRelevantAssetForSwap(props.swap())}
                             txId={props.swap().claimTx}
                             typeLabel={"claim_tx"}
                         />
                     </Show>
-                }>
-                {/* Refund transactions are handled in SwapRefunded */}
-                <Show
-                    when={
-                        getRelevantAssetForSwap(props.swap()) &&
-                        props.swapStatus() !== null &&
-                        props.swapStatus() !== "invoice.set" &&
-                        props.swapStatus() !== "swap.created"
-                    }>
-                    <BlockExplorer
-                        asset={getRelevantAssetForSwap(props.swap())}
-                        txId={props.swap().claimTx}
-                        address={
-                            props.swap().type === SwapType.Submarine
-                                ? (props.swap() as SubmarineSwap).address
-                                : (props.swap() as ReverseSwap).lockupAddress
-                        }
-                    />
-                </Show>
-            </Show>
+                </Match>
+            </Switch>
         </Show>
     );
 };

diff --git a/src/components/LockupEvm.tsx b/src/components/LockupEvm.tsx
@@ -1,6 +1,7 @@
 import { Show, createEffect, createSignal } from "solid-js";
 
 import { useGlobalContext } from "../context/Global";
+import { usePayContext } from "../context/Pay";
 import { customDerivationPathRdns, useWeb3Signer } from "../context/Web3";
 import { HardwareSigner } from "../utils/hardware/HadwareSigner";
 import { prefix0x, satoshiToWei } from "../utils/rootstock";
@@ -30,6 +31,7 @@ const LockupEvm = (props: {
     derivationPath?: string;
     timeoutBlockHeight: number;
 }) => {
+    const { setSwap } = usePayContext();
     const { getEtherSwap, signer, providers } = useWeb3Signer();
     const { t, getSwap, setSwapStorage } = useGlobalContext();
 
@@ -75,6 +77,7 @@ const LockupEvm = (props: {
                         ).getDerivationPath();
                     }
 
+                    setSwap(currentSwap);
                     await setSwapStorage(currentSwap);
                 }}
                 children={<ConnectWallet />}

diff --git a/src/components/SwapChecker.tsx b/src/components/SwapChecker.tsx
@@ -32,7 +32,7 @@ type SwapStatus = {
     status: string;
 
     failureReason?: string;
-    transaction: SwapStatusTransaction;
+    transaction?: SwapStatusTransaction;
 };
 
 const reconnectInterval = 5_000;
@@ -75,6 +75,10 @@ class BoltzWebSocket {
     };
 
     public subscribeUpdates = (ids: string[]) => {
+        if (ids.every((id) => this.relevantIds.has(id))) {
+            return;
+        }
+
         ids.forEach((id) => this.relevantIds.add(id));
         if (this.ws.readyState !== WebSocket.OPEN) {
             return;
@@ -188,10 +192,21 @@ export const SwapChecker = () => {
             return;
         }
 
-        if (
-            currentSwap.version !== OutputType.Taproot ||
-            getRelevantAssetForSwap(currentSwap) === RBTC
-        ) {
+        if (getRelevantAssetForSwap(currentSwap) === RBTC) {
+            if (
+                data.status === swapStatusPending.TransactionMempool &&
+                data.transaction !== undefined
+            ) {
+                currentSwap.lockupTx = data.transaction.id;
+
+                setSwap(currentSwap);
+                await setSwapStorage(currentSwap);
+            }
+
+            return;
+        }
+
+        if (currentSwap.version !== OutputType.Taproot) {
             return;
         }