chore: add logs

driver/lib/sessions/ios.ts

@@ -95,11 +95,14 @@ export const getObservatoryWsUri = async (
       destroyCommChannel();
       localSocket.destroy();
     });
+    remoteSocket.on('error', (e) => log.debug(e));
+
     localSocket.once(`end`, destroyCommChannel);
     localSocket.once(`close`, () => {
       destroyCommChannel();
       remoteSocket.destroy();
     });
+    localSocket.on('error', (e) => log.warn(e.message));
     localSocket.pipe(remoteSocket);
     remoteSocket.pipe(localSocket);
   });
@@ -111,13 +114,15 @@ export const getObservatoryWsUri = async (
   try {
     await listeningPromise;
   } catch (e) {
+    flutterDriver.localServer = null;
     throw new Error(`Cannot listen on the local port ${localPort}. Original error: ${e.message}`);
   }
 
   log.info(`Forwarding the remote port ${remotePort} to the local port ${localPort}`);
 
   process.on(`beforeExit`, () => {
     flutterDriver.localServer?.close();
+    flutterDriver.localServer = null;
   });
   return urlObject.toJSON();
 };

driver/lib/sessions/observatory.ts

@@ -72,7 +72,7 @@
 
         // Add an 'error' event handler for the client socket
         const onErrorListener = (ex: Error) => {
-          log.error(JSON.stringify(ex));
+          log.error(`Connection to ${dartObservatoryURL} got an error: ${ex.message}`);
           removeListenerAndResolve(null);
         };
         socket.on(`error`, onErrorListener);
@@ -183,14 +183,14 @@
   isolateId: string|number
 ) {
   log.debug(`>>> getIsolate`);
   const isolate = await this.socket!.call(`getIsolate`, { isolateId: `${isolateId}` });
   log.debug(`<<< ${_.truncate(JSON.stringify(isolate), {'length': truncateLength})}`);
   return isolate;
 };
 
 export const executeGetVMCommand = async function(this: FlutterDriver) {
   log.debug(`>>> getVM`);
   const vm = await this.socket!.call(`getVM`) as {
     isolates: [{
       name: string,
       id: number,
@@ -208,7 +208,7 @@
   const elementObject = elementBase64 ? JSON.parse(decode(elementBase64)) : {};
   const serializedCommand = { command, ...elementObject, ...extraArgs };
   log.debug(`>>> ${JSON.stringify(serializedCommand)}`);
   const data = await this.socket!.executeSocketCommand(serializedCommand);
   log.debug(`<<< ${JSON.stringify(data)} | previous command ${command}`);
   if (data.isError) {
     throw new Error(