add env var for polling ops (#83)

Author: hozzjss

.env.sample

@@ -10,3 +10,4 @@ BANNER_CONTENT=
 RECLAIM_LOCK_TIME=
 NEXT_TELEMETRY_DISABLED=1
 LIVECHAT_ID=
+POLLING_INTERVAL=5000

src/actions/get-sbtc-bridge-config.ts

@@ -14,6 +14,7 @@ export default cache(async function getSbtcBridgeConfig() {
   const RECLAIM_LOCK_TIME = env.RECLAIM_LOCK_TIME;
   const PUBLIC_MEMPOOL_URL = env.PUBLIC_MEMPOOL_URL;
   const LIVECHAT_ID = env.LIVECHAT_ID;
+  const POLLING_INTERVAL = env.POLLING_INTERVAL;
 
   return {
     EMILY_URL,
@@ -23,5 +24,6 @@ export default cache(async function getSbtcBridgeConfig() {
     RECLAIM_LOCK_TIME,
     PUBLIC_MEMPOOL_URL,
     LIVECHAT_ID,
+    POLLING_INTERVAL,
   };
 });

src/env.ts

@@ -20,4 +20,5 @@ export const env = {
   BANNER_CONTENT: process.env.BANNER_CONTENT,
   RECLAIM_LOCK_TIME: process.env.RECLAIM_LOCK_TIME,
   LIVECHAT_ID: process.env.LIVECHAT_ID,
+  POLLING_INTERVAL: Number(process.env.POLLING_INTERVAL) || 5000,
 };

src/hooks/use-deposit-status.ts

@@ -36,8 +36,11 @@ export function useDepositStatus(txId: string) {
   const confirmedBlockHeight = useMemo(() => {
     return statusResponse?.status.block_height || 0;
   }, [statusResponse]);
-  const { EMILY_URL: emilyUrl, RECLAIM_LOCK_TIME } =
-    useAtomValue(bridgeConfigAtom);
+  const {
+    EMILY_URL: emilyUrl,
+    RECLAIM_LOCK_TIME,
+    POLLING_INTERVAL,
+  } = useAtomValue(bridgeConfigAtom);
 
   const recipient = useMemo(() => {
     return emilyResponse?.recipient || "";
@@ -105,10 +108,11 @@ export function useDepositStatus(txId: string) {
         }
       };
       check();
-      const interval = setInterval(check, 5000);
+      const interval = setInterval(check, POLLING_INTERVAL);
       return () => clearInterval(interval);
     }
   }, [
+    POLLING_INTERVAL,
     RECLAIM_LOCK_TIME,
     emilyUrl,
     notifyEmily,

src/hooks/use-reclaim-status.ts

@@ -1,4 +1,6 @@
 import { getRawTransaction } from "@/actions/bitcoinClient";
+import { bridgeConfigAtom } from "@/util/atoms";
+import { useAtomValue } from "jotai";
 import { useEffect, useState } from "react";
 
 export enum ReclaimStatus {
@@ -8,6 +10,7 @@ export enum ReclaimStatus {
 }
 
 export const useReclaimStatus = (txId: string) => {
+  const { POLLING_INTERVAL } = useAtomValue(bridgeConfigAtom);
   // we'll need to fetch this from the bitcoin rpc to get the current status of the tx
   const [reclaimStatus, setReclaimStatus] = useState<ReclaimStatus>(
     ReclaimStatus.Pending,
@@ -17,8 +20,7 @@ export const useReclaimStatus = (txId: string) => {
     if (txId && reclaimStatus !== ReclaimStatus.Completed) {
       // fetch the status of the reclaim tx from the bitcoin rpc
       // and update the reclaimStatus
-
-      const interval = setInterval(async () => {
+      const check = async () => {
         const reclaimTx = (await getRawTransaction(txId))!;
         let status = ReclaimStatus.Pending;
 
@@ -28,10 +30,12 @@ export const useReclaimStatus = (txId: string) => {
         }
 
         setReclaimStatus(status);
-      }, 1000);
+      };
+      check();
+      const interval = setInterval(check, POLLING_INTERVAL);
       return () => clearInterval(interval);
     }
-  }, [reclaimStatus, txId]);
+  }, [POLLING_INTERVAL, reclaimStatus, txId]);
 
   return reclaimStatus;
 };

src/util/atoms.ts

@@ -17,6 +17,7 @@ export const bridgeConfigAtom = atom<BridgeConfig>({
   RECLAIM_LOCK_TIME: undefined,
   PUBLIC_MEMPOOL_URL: "",
   LIVECHAT_ID: undefined,
+  POLLING_INTERVAL: 5000,
 });
 export const depositMaxFeeAtom = atom(80000);