fix connect identifier init for noencrypt

ExchangeUnion · Nov 3, 2020 · 9579322 · 9579322
1 parent d94a1b2
commit 9579322
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/lib/connextclient/ConnextClient.ts b/lib/connextclient/ConnextClient.ts
@@ -96,6 +96,7 @@ class ConnextClient extends SwapClient {
   public address?: string;
   /** A map of currency symbols to token addresses. */
   public tokenAddresses = new Map<string, string>();
+  public userIdentifier?: string;
   /**
    * A map of expected invoices by hash.
    * This is equivalent to invoices of lnd with the difference
@@ -371,9 +372,9 @@ class ConnextClient extends SwapClient {
         this.subscribeIncomingTransfer(),
         this.subscribeDeposit(),
       ]);
-      const { userIdentifier } = config;
+      this.userIdentifier = config.userIdentifier;
       this.emit('connectionVerified', {
-        newIdentifier: userIdentifier,
+        newIdentifier: this.userIdentifier,
       });
       this.setStatus(ClientStatus.ConnectionVerified);
     } catch (err) {

diff --git a/lib/swaps/Swaps.ts b/lib/swaps/Swaps.ts
@@ -143,7 +143,7 @@ class Swaps extends EventEmitter {
   }
 
   public init = async () => {
-    // update pool with lnd pubkeys
+    // update pool with current lnd & connext pubkeys
     this.swapClientManager.getLndClientsMap().forEach(({ pubKey, chain, currency, uris }) => {
       if (pubKey && chain) {
         this.pool.updateLndState({
@@ -154,6 +154,9 @@ class Swaps extends EventEmitter {
         });
       }
     });
+    if (this.swapClientManager.connextClient) {
+      this.pool.updateConnextState(this.swapClientManager.connextClient.tokenAddresses, this.swapClientManager.connextClient.userIdentifier);
+    }
 
     this.swapRecovery.beginTimer();
     const swapDealInstances = await this.repository.getSwapDeals();