Timestamp and line are now unpacked from payload

software/coordinator2.py

@@ -249,7 +249,14 @@ class PRREvalClient(Thread):
             #create dir for Logs files if it does not exist yet!
             if not os.path.isdir("{}/{}".format(LOG_DIRECTORY, userdata)):
                 os.mkdir("{}/{}".format(LOG_DIRECTORY, userdata))
-            line = str(msg.payload)[2:][:-1]
+
+            #get first 8 bytes for ts and length of string
+            ts, length = struct.unpack('fi', msg.payload[0:8])
+
+            #now read the string!
+            line_bytes, = struct.unpack("{}s".format(length), msg.payload[8:])
+            line = line_bytes.decode("utf-8")
+
             node_id = topic[2]
 
             self.log_mutex.acquire()
@@ -259,7 +266,7 @@ class PRREvalClient(Thread):
             fh.setFormatter(self.file_formatter)
 
             self.logger.addHandler(fh)
-            self.logger.info("{:0<20},{},{}".format(time(), node_id, line))
+            self.logger.info("{:0<20},{},{}".format(ts, node_id, line))
             self.logger.removeHandler(fh)
 
             self.log_mutex.release()