feat(rpc): add flag for connext to unlock response

This adds a flag to the `UnlockNode` response to indicate whether
a Connext client is connected and ready to accept calls. In the cli,
`ETH` gets added to the list of wallets that are unlocked and ready when
this new flag is true.

Closes #1932.

lib/cli/commands/unlock.ts

@@ -11,11 +11,15 @@ export const builder = {};
 
 const formatOutput = (response: UnlockNodeResponse.AsObject) => {
   console.log('xud was unlocked successfully');
+  const readyClients = response.unlockedLndsList;
+  if (response.connextReady) {
+    readyClients.push('ETH');
+  }
   if (response.unlockedLndsList.length) {
-    console.log(`The following wallets were unlocked: ${response.unlockedLndsList.join(', ')}`);
+    console.log(`The following wallets are unlocked and ready: ${readyClients.join(', ')}`);
   }
   if (response.lockedLndsList.length) {
-    console.log(`The following wallets could not be unlocked: ${response.lockedLndsList.join(', ')}`);
+    console.log(`The following wallets could not be unlocked: ${readyClients.join(', ')}`);
   }
 };
 

lib/grpc/GrpcInitService.ts

@@ -72,6 +72,7 @@ class GrpcInitService {
       const response = new xudrpc.UnlockNodeResponse();
       response.setUnlockedLndsList(unlockNodeResult.unlockedLndClients);
       response.setLockedLndsList(unlockNodeResult.lockedLndClients);
+      response.setConnextReady(unlockNodeResult.connextReady);
 
       callback(null, response);
     } catch (err) {

lib/swaps/SwapClientManager.ts

@@ -283,6 +283,7 @@ class SwapClientManager extends EventEmitter {
     const unlockWalletPromises: Promise<any>[] = [];
     const unlockedLndClients: string[] = [];
     const lockedLndClients: string[] = [];
+    let connextReady = false;
 
     for (const swapClient of this.swapClients.values()) {
       if (isLndClient(swapClient)) {
@@ -294,18 +295,24 @@ class SwapClientManager extends EventEmitter {
             swapClient.logger.debug(`could not unlock wallet: ${err.message}`);
           });
           unlockWalletPromises.push(unlockWalletPromise);
+        } else if (swapClient.isConnected()) {
+          // if the swap client is already unlocked, we add it to the list
+          unlockedLndClients.push(swapClient.currency);
         } else if (swapClient.isDisconnected() || swapClient.isMisconfigured() || swapClient.isNotInitialized()) {
           // if the swap client is not connected, we treat it as locked since lnd will likely be locked when it comes online
           lockedLndClients.push(swapClient.currency);
         }
+      } else if (isConnextClient(swapClient)) {
+        // TODO(connext): unlock Connext using connextSeed
+        if (swapClient.isConnected()) {
+          connextReady = true;
+        }
       }
     }
 
     await Promise.all(unlockWalletPromises);
 
-    // TODO(connext): unlock Connext using connextSeed
-
-    return { unlockedLndClients, lockedLndClients };
+    return { unlockedLndClients, lockedLndClients, connextReady };
   }
 
   /**

proto/xudrpc.proto

@@ -966,6 +966,8 @@ message UnlockNodeResponse {
   repeated string unlocked_lnds = 1;
   // The list of lnd clients that could not be unlocked.
   repeated string locked_lnds = 3;
+  // Whether the Connext client is connected and ready to accept calls.
+  bool connext_ready = 4;
 }
 
 message WithdrawRequest {