WIP - Added connect/disconnect callback (working)

Author: csarnataro

src/daemon.js

@@ -61,7 +61,8 @@ export default class Daemon {
       first(),
       takeUntil(
         this.uploading.pipe(
-          filter(upload => upload.status === this.UPLOAD_ERROR || upload.status === this.UPLOAD_DONE))
+          filter(upload => upload.status === this.UPLOAD_ERROR || upload.status === this.UPLOAD_DONE)
+        )
       )
     );
 

src/web-serial-daemon.js

@@ -19,13 +19,20 @@ export default class WebSerialDaemon extends Daemon {
     this.agentFound.next(true);
     this.channelOpenStatus.next(true);
     this.uploader = uploader;
+    this.connectedPorts = [];
 
-    this._populateSupportedBoards();
+    this.init();
   }
 
-  _populateSupportedBoards() {
+  init() {
     const supportedBoards = this.uploader.getSupportedBoards();
     this.appMessages.next({ supportedBoards });
+
+    this.uploader.listBoards().then(ports => {
+      this.connectedPorts = ports;
+      this.appMessages.next({ ports });
+    });
+
   }
 
   // eslint-disable-next-line class-methods-use-this
@@ -41,10 +48,35 @@ export default class WebSerialDaemon extends Daemon {
       });
       // this.handleListMessage(message);
     }
-
-    if (message.supportedBoards) {
+    else if (message.supportedBoards) {
       this.supportedBoards.next(message.supportedBoards);
     }
+    else if (message.connectedSerialPort) {
+      console.dir('******** BEGIN: web-serial-daemon:68 ********');
+      console.dir(message.connectedSerialPort, { depth: null, colors: true });
+
+      const port = this.uploader.getBoardInfoFromSerialPort(message.connectedSerialPort);
+      this.connectedPorts.push(port);
+      console.dir(this.connectedPorts, { depth: null, colors: true });
+      console.dir('********   END: web-serial-daemon:68 ********');
+      this.devicesList.next({
+        serial: this.connectedPorts,
+        network: []
+      });
+    }
+    else if (message.disconnectedSerialPort) {
+      console.dir('******** BEGIN: web-serial-daemon:79 ********');
+      console.dir(message.disconnectedSerialPort, { depth: null, colors: true });
+      const port = this.uploader.getBoardInfoFromSerialPort(message.disconnectedSerialPort);
+      this.connectedPorts = this.connectedPorts.filter(connectedPort => connectedPort.Name !== port.Name);
+      console.dir(this.connectedPorts, { depth: null, colors: true });
+      console.dir('********   END: web-serial-daemon:79 ********');
+      console.dir(this.connectedPorts, { depth: null, colors: true });
+      this.devicesList.next({
+        serial: this.connectedPorts,
+        network: []
+      });
+    }
   }
 
   /**
@@ -90,6 +122,15 @@ export default class WebSerialDaemon extends Daemon {
       });
   }
 
+  /** A proxy method to get info from the specified SerialPort object */
+  getBoardInfoFromSerialPort(serialPort) {
+    return this.uploader.getBoardInfoFromSerialPort(serialPort);
+  }
+
+  connectToSerialDevice() {
+    return this.uploader.connectToSerialDevice();
+  }
+
   /**
    * @param {object} uploadPayload
    * TODO: document param's shape