1*8d741a5dSApple OSS Distributionsimport logging 2*8d741a5dSApple OSS Distributions 3*8d741a5dSApple OSS Distributions 4*8d741a5dSApple OSS Distributionsclass Message(object): 5*8d741a5dSApple OSS Distributions """represents a message of Remote serial protocol""" 6*8d741a5dSApple OSS Distributions def __init__(self, data): 7*8d741a5dSApple OSS Distributions super().__init__() 8*8d741a5dSApple OSS Distributions self.data = data 9*8d741a5dSApple OSS Distributions 10*8d741a5dSApple OSS Distributions def __str__(self): 11*8d741a5dSApple OSS Distributions return "Message: %s" % (self.data) 12*8d741a5dSApple OSS Distributions 13*8d741a5dSApple OSS Distributions def getData(self): 14*8d741a5dSApple OSS Distributions #TODO need to parse data and unescape 15*8d741a5dSApple OSS Distributions return self.data 16*8d741a5dSApple OSS Distributions 17*8d741a5dSApple OSS Distributions def getRSPByteData(self): 18*8d741a5dSApple OSS Distributions retval = ''.join(['$',self.data,'#']) 19*8d741a5dSApple OSS Distributions checksum = 0 20*8d741a5dSApple OSS Distributions for i in self.data: 21*8d741a5dSApple OSS Distributions checksum += ord(i) 22*8d741a5dSApple OSS Distributions checksum = checksum % 0x100 23*8d741a5dSApple OSS Distributions checksum_str = "{:02x}".format(checksum) 24*8d741a5dSApple OSS Distributions retval += checksum_str 25*8d741a5dSApple OSS Distributions return retval 26*8d741a5dSApple OSS Distributions 27*8d741a5dSApple OSS Distributions @classmethod 28*8d741a5dSApple OSS Distributions def fromRSPByteData(cls, bytedata): 29*8d741a5dSApple OSS Distributions data_begin = 0 30*8d741a5dSApple OSS Distributions data_end = 0 31*8d741a5dSApple OSS Distributions try: 32*8d741a5dSApple OSS Distributions data_begin = bytedata.index('$') 33*8d741a5dSApple OSS Distributions data_end = bytedata.index('#') 34*8d741a5dSApple OSS Distributions except ValueError as e: 35*8d741a5dSApple OSS Distributions logging.error('Invalid bytedata considered as message %s' % bytedata) 36*8d741a5dSApple OSS Distributions return None 37*8d741a5dSApple OSS Distributions 38*8d741a5dSApple OSS Distributions #validate the data 39*8d741a5dSApple OSS Distributions if data_begin + 1 >= data_end: 40*8d741a5dSApple OSS Distributions logging.debug("empty message %s"%bytedata) 41*8d741a5dSApple OSS Distributions data_begin -= 1 42*8d741a5dSApple OSS Distributions 43*8d741a5dSApple OSS Distributions data_begin += 1 44*8d741a5dSApple OSS Distributions logging.debug("Creating message from data %s" % bytedata[data_begin:data_end]) 45*8d741a5dSApple OSS Distributions ret_obj = cls(bytedata[data_begin:data_end]) 46*8d741a5dSApple OSS Distributions return ret_obj 47*8d741a5dSApple OSS Distributions 48*8d741a5dSApple OSS Distributionsclass ProtocolAcknowledgement(Message): 49*8d741a5dSApple OSS Distributions """Ack Messages""" 50*8d741a5dSApple OSS Distributions def __init__(self, ack_str): 51*8d741a5dSApple OSS Distributions super().__init__(ack_str) 52*8d741a5dSApple OSS Distributions self.data = ack_str 53*8d741a5dSApple OSS Distributions 54*8d741a5dSApple OSS Distributions def getRSPByteData(self): 55*8d741a5dSApple OSS Distributions return self.data 56*8d741a5dSApple OSS Distributions 57*8d741a5dSApple OSS Distributions 58*8d741a5dSApple OSS DistributionsOKMessage = Message('OK') 59*8d741a5dSApple OSS Distributions 60*8d741a5dSApple OSS DistributionsAckMessage = ProtocolAcknowledgement('+') 61*8d741a5dSApple OSS DistributionsNAckMessage = ProtocolAcknowledgement('-') 62*8d741a5dSApple OSS DistributionsUnSupportedMessage = Message('') 63