support messages from serial monitor with port [EDITOR-621]

Author: smellai

README.md

@@ -38,11 +38,22 @@ daemon.devicesList.subscribe(({serial, network}) => {
 // Open serial monitor
 daemon.openSerialMonitor('port-name');
 
-// Read from serial monitor
+// Read from serial monitor (ouputs string)
 daemon.serialMonitorMessages.subscribe(message => {
   console.log(message);
 });
 
+// Read from serial monitor, output object with source port name
+/*
+  {
+    "P": "dev/ttyACM0",
+    "D":"output text here\r\n"
+  }
+*/
+daemon.serialMonitorMessagesWithPort.subscribe(messageObj => {
+  console.log(messageObj);
+});
+
 // Write to serial monitor
 daemon.writeSerial('port-name', 'message');
 
@@ -72,7 +83,7 @@ daemon.downloading.subscribe(download => {
 
 ## Version 2
 
-Version 2 of the arduino-create-agent aims to provide a cleaner api based on promises. 
+Version 2 of the arduino-create-agent aims to provide a cleaner api based on promises.
 It will remain confined to a v2 property on the daemon object until it will be stable.
 At the moment it only supports tool management.
 

demo/app.jsx

@@ -134,6 +134,10 @@ class App extends React.Component {
       scrollToBottom(serialTextarea);
     });
 
+    daemon.serialMonitorMessagesWithPort.subscribe(messageObj => {
+      console.log(messageObj);
+    });
+
     daemon.uploading.subscribe(upload => {
       this.setState({ uploadStatus: upload.status, uploadError: upload.err });
       // console.log(upload);

src/daemon.js

@@ -50,6 +50,7 @@ export default class Daemon {
     this.appMessages = new Subject();
     this.serialMonitorOpened = new BehaviorSubject(false);
     this.serialMonitorMessages = new Subject();
+    this.serialMonitorMessagesWithPort = new Subject();
     this.uploading = new BehaviorSubject({ status: this.UPLOAD_NOPE });
     this.uploadingDone = this.uploading.pipe(filter(upload => upload.status === this.UPLOAD_DONE))
       .pipe(first())

src/socket-daemon.js

@@ -240,6 +240,7 @@ export default class SocketDaemon extends Daemon {
     // Serial monitor message
     if (message.D) {
       this.serialMonitorMessages.next(message.D);
+      this.serialMonitorMessagesWithPort.next(message);
     }
 
     if (message.ProgrammerStatus) {