Merge pull request #379 from ergolabs/dev

v.1.1.6
spectrum-finance · Feb 5, 2022 · 6972246 · 6972246
2 parents 6adfe95 + 6ffc6fd
commit 6972246
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/src/network/ergo/balance/common.ts b/src/network/ergo/balance/common.ts
@@ -3,6 +3,7 @@ import { AssetInfo } from '@ergolabs/ergo-sdk/build/main/entities/assetInfo';
 import {
   combineLatest,
   debounceTime,
+  defaultIfEmpty,
   from,
   map,
   Observable,
@@ -34,7 +35,7 @@ export const availableTokensData$: Observable<[bigint, AssetInfo][]> = utxos$
             }),
           ),
         ),
-      ),
+      ).pipe(defaultIfEmpty([])),
     ),
     map((availableTokensData) =>
       availableTokensData.filter(([, assetInfo]) => !!assetInfo),

diff --git a/src/pages/Swap/Swap.tsx b/src/pages/Swap/Swap.tsx
@@ -10,7 +10,7 @@ import {
   combineLatest,
   debounceTime,
   distinctUntilChanged,
-  first,
+  filter,
   map,
   Observable,
   of,
@@ -61,7 +61,6 @@ const getSelectedPool = (
   xId && yId
     ? getAmmPoolsByAssetPair(xId, yId).pipe(
         map((pools) => maxBy(pools, (p) => p.lp.amount)),
-        first(),
       )
     : of(undefined);
 
@@ -150,9 +149,11 @@ export const Swap = (): JSX.Element => {
   useSubscription(
     combineLatest([
       form.controls.fromAsset.valueChangesWithSilent$.pipe(
+        filter(Boolean),
         distinctUntilChanged(),
       ),
       form.controls.toAsset.valueChangesWithSilent$.pipe(
+        filter(Boolean),
         distinctUntilChanged(),
       ),
     ]).pipe(

diff --git a/src/services/new/core.ts b/src/services/new/core.ts
@@ -3,6 +3,7 @@ import { AssetInfo } from '@ergolabs/ergo-sdk/build/main/entities/assetInfo';
 import {
   combineLatest,
   distinctUntilChanged,
+  exhaustMap,
   filter,
   from,
   interval,
@@ -85,15 +86,15 @@ export const appTick$ = walletState$.pipe(
 );
 
 export const utxos$ = appTick$.pipe(
-  switchMap(() => from(ergo.get_utxos())),
+  exhaustMap(() => from(ergo.get_utxos())),
   map((bs) => bs?.map((b) => ergoBoxFromProxy(b))),
   map((data) => data ?? []),
   publishReplay(1),
   refCount(),
 );
 
 export const nativeTokenBalance$ = appTick$.pipe(
-  switchMap(() => from(ergo.get_balance(ERG_TOKEN_NAME))),
+  exhaustMap(() => from(ergo.get_balance(ERG_TOKEN_NAME))),
   map((balance) => renderFractions(balance, ERG_DECIMALS)),
   publishReplay(1),
   refCount(),