44import thread
55import re
66import logging
7+ import base64
78
89__author__ = 'Michel'
910
@@ -46,20 +47,21 @@ def received_message(self, message):
4647 except SerialException as se :
4748 self .logger .error ("Failed to connect to %s" , port )
4849 self .logger .error ("Serial exception message: %s" , se .message )
49- self .send ("Failed to connect to: %s using baud rate %s\n \r (%s)\n \r " % (port , baudrate , se .message ))
50+ self .send (base64 . b64encode ( "Failed to connect to: %s using baud rate %s\n \r (%s)\n \r " % (port , baudrate , se .message ) ))
5051 return
5152
5253 if self .serial .isOpen ():
5354 self .logger .info ("Serial port %s is open." , port )
54- self .send ("Connection established with: %s using baud rate %s\n \r " % (port , baudrate ))
55+ self .send (base64 . b64encode ( "Connection established with: %s using baud rate %s\n \r " % (port , baudrate ) ))
5556 thread .start_new_thread (serial_poll , (self .serial , self ))
5657 else :
57- self .send ("Failed to connect to: %s using baud rate %s\n \r " % (port , baudrate ))
58+ self .send (base64 . b64encode ( "Failed to connect to: %s using baud rate %s\n \r " % (port , baudrate ) ))
5859 else :
5960 if self .serial .isOpen ():
60- self .logger .info ("Sending serial data" )
61- self .send (message .data )
62- self .serial .write (message .data )
61+ #self.send(message.data)
62+ data = base64 .b64decode (message .data )
63+ self .logger .info ("Sending data to device: %s" , data )
64+ self .serial .write (data )
6365
6466 # close serial connection
6567 def close (self , code = 1000 , reason = '' ):
@@ -74,9 +76,9 @@ def serial_poll(serial, socket):
7476 try :
7577 while serial .isOpen ():
7678 data = serial .read (serial .inWaiting ())
77- if len ( data ) > 0 :
79+ if data :
7880 module_logger .debug ('Data received from device: %s' , data )
79- socket .send (data )
81+ socket .send (base64 . b64encode ( data ) )
8082 # Wait a half-second before listening again.
8183 sleep (0.5 )
8284 except SerialException as se :
0 commit comments