Restore metro functionality [4/n]

Summary: Restored Metro functionality; progress reports, metro logs, RN/Hermes debugging, reload / dev menu button

Reviewed By: passy

Differential Revision: D31055958

fbshipit-source-id: c243035c343c14718a9afe275c8f5f36a1aa3a94

desktop/app/src/__tests__/disconnect.node.tsx

@@ -14,6 +14,7 @@ import {
   createState,
   DevicePluginClient,
   PluginClient,
+  sleep,
 } from 'flipper-plugin';
 import {handleClientConnected} from '../dispatcher/flipperServer';
 import {TestDevice} from '../test-utils/TestDevice';
@@ -89,9 +90,7 @@ test('New device with same serial removes & cleans the old one', async () => {
       },
     },
   );
-  const {device, store, logger} = await createMockFlipperWithPlugin(
-    deviceplugin,
-  );
+  const {device, store} = await createMockFlipperWithPlugin(deviceplugin);
 
   const instance = device.sandyPluginStates.get(deviceplugin.id)!;
 
@@ -116,6 +115,7 @@ test('New device with same serial removes & cleans the old one', async () => {
     store.getState().connections.enabledDevicePlugins,
   );
 
+  await sleep(100);
   expect(device.isArchived).toBe(false);
   expect(device.connected.get()).toBe(false);
   expect(instance.instanceApi.destroy).toBeCalledTimes(1);

desktop/app/src/chrome/MetroButton.tsx

@@ -8,24 +8,23 @@
  */
 
 import React, {useCallback, useEffect, useState} from 'react';
-import MetroDevice, {
-  MetroReportableEvent,
-} from '../server/devices/metro/MetroDevice';
+import {MetroReportableEvent} from '../server/devices/metro/MetroDevice';
 import {useStore} from '../utils/useStore';
 import {Button as AntButton} from 'antd';
 import {MenuOutlined, ReloadOutlined} from '@ant-design/icons';
 import {theme} from 'flipper-plugin';
+import BaseDevice from '../devices/BaseDevice';
 
 export default function MetroButton() {
   const device = useStore((state) =>
     state.connections.devices.find(
       (device) => device.os === 'Metro' && device.connected.get(),
     ),
-  ) as MetroDevice | undefined;
+  ) as BaseDevice | undefined;
 
   const sendCommand = useCallback(
     (command: string) => {
-      device?.sendCommand(command);
+      device?.sendMetroCommand(command);
     },
     [device],
   );
@@ -50,9 +49,19 @@ export default function MetroButton() {
         setProgress(event.transformedFileCount / event.totalFileCount);
       }
     }
-    device.metroEventEmitter.on('event', metroEventListener);
+
+    const handle = device.addLogListener((l) => {
+      if (l.tag !== 'client_log') {
+        try {
+          metroEventListener(JSON.parse(l.message));
+        } catch (e) {
+          console.warn('Failed to parse metro message: ', l, e);
+        }
+      }
+    });
+
     return () => {
-      device.metroEventEmitter.off('event', metroEventListener);
+      device.removeLogListener(handle);
     };
   }, [device]);
 

desktop/app/src/devices/BaseDevice.tsx

@@ -229,6 +229,10 @@ export default class BaseDevice {
     return this.flipperServer.exec('device-shell-exec', this.serial, command);
   }
 
+  async sendMetroCommand(command: string): Promise<void> {
+    return this.flipperServer.exec('metro-command', this.serial, command);
+  }
+
   supportsPlugin(plugin: PluginDefinition | PluginDetails) {
     let pluginDetails: PluginDetails;
     if (plugin instanceof _SandyPluginDefinition) {

desktop/app/src/reducers/connections.tsx

@@ -250,7 +250,9 @@ export default (state: State = INITAL_STATE, action: Actions): State => {
             `Tried to replace still connected device '${d.serial}' with a new instance`,
           );
         }
-        d.destroy();
+        setImmediate(() => {
+          d.destroy();
+        });
         newDevices[existing] = payload;
       } else {
         newDevices.push(payload);

desktop/app/src/server/devices/metro/MetroDevice.tsx

@@ -8,7 +8,6 @@
  */
 
 import {LogLevel} from 'flipper-plugin';
-import {EventEmitter} from 'events';
 import util from 'util';
 import {FlipperServerImpl} from '../../FlipperServerImpl';
 import {ServerDevice} from '../ServerDevice';
@@ -142,7 +141,6 @@ function getLoglevelFromMessageType(
 
 export default class MetroDevice extends ServerDevice {
   ws?: WebSocket;
-  metroEventEmitter = new EventEmitter();
 
   constructor(
     flipperServer: FlipperServerImpl,
@@ -190,7 +188,6 @@ export default class MetroDevice extends ServerDevice {
         });
       }
     }
-    this.metroEventEmitter.emit('event', message);
   };
 
   sendCommand(command: string, params?: any) {