Minor fixes for protocol

force_bdss/core_plugins/dummy/ui_notification/ui_notification.py

 import errno
 import logging
-from traits.api import Any, List, Instance
+from traits.api import Any, List
 
 from force_bdss.api import BaseNotificationListener
 import zmq
 
-from force_bdss.mco.events import BaseMCOEvent, MCOStartEvent, MCOFinishEvent, \
+from force_bdss.mco.events import MCOStartEvent, MCOFinishEvent, \
     MCOProgressEvent
 
 
@@ -51,14 +51,14 @@ class UINotification(BaseNotificationListener):
 
     def _format_event(self, event):
         if isinstance(event, MCOStartEvent):
-            data = "MCO_START\n"
+            data = "MCO_START"
         elif isinstance(event, MCOFinishEvent):
-            data = "MCO_FINISH\n"
+            data = "MCO_FINISH"
         elif isinstance(event, MCOProgressEvent):
-            data = "MCO_PROGRESS\n{}\n{}\n".format(
+            data = "MCO_PROGRESS\n{}\n{}".format(
                 " ".join([str(x) for x in event.input]),
                 " ".join([str(x) for x in event.output]))
         else:
             return None
 
-        return ("EVENT {}".format(data)).encode("utf-8")
+        return ("EVENT\n{}".format(data)).encode("utf-8")

utils/zmq_client.py

@@ -11,10 +11,10 @@ send_socket.connect("tcp://localhost:12346")
 send_socket.send("SYNC".encode("utf-8"))
 data = send_socket.recv_multipart()
 for d in data:
-    split_data = d.split()
+    split_data = d.decode("utf-8").split("\n")
     print("SYNCED ", split_data)
 
 while True:
     string = socket.recv()
-    split_data = string.split()
+    split_data = string.decode('utf-8').split("\n")
     print(split_data)