@@ -347,7 +347,7 @@ def has_suffix(payload):
347347 """Check to see if payload has valid Tuya suffix"""
348348 if len (payload ) < 4 :
349349 return False
350- log .debug ("buffer %r = %r" % ( payload [- 4 :], SUFFIX_BIN ) )
350+ log .debug ("buffer %r = %r" , payload [- 4 :], SUFFIX_BIN )
351351 return payload [- 4 :] == SUFFIX_BIN
352352
353353def error_json (number = None , payload = None ):
@@ -549,11 +549,11 @@ def _send_receive(self, payload, minresponse=28, getresponse=True):
549549 data = self .socket .recv (1024 )
550550 # device may send null ack (28 byte) response before a full response
551551 if self .retry and len (data ) <= minresponse :
552- log .debug ("received null payload (%r), fetch new one" % data )
552+ log .debug ("received null payload (%r), fetch new one" , data )
553553 time .sleep (0.1 )
554554 data = self .socket .recv (1024 ) # try to fetch new payload
555555 success = True
556- log .debug ("received data=%r HEX" % binascii .hexlify (data ))
556+ log .debug ("received data=%r" , binascii .hexlify (data ))
557557 # legacy/default mode avoids persisting socket across commands
558558 if not self .socketPersistent :
559559 self .socket .close ()
@@ -630,7 +630,7 @@ def _send_receive(self, payload, minresponse=28, getresponse=True):
630630 try :
631631 msg = unpack_message (data )
632632 # Data available: seqno cmd retcode payload crc
633- log .debug ("raw unpacked message = %r" % msg )
633+ log .debug ("raw unpacked message = %r" , msg )
634634 result = self ._decode_payload (msg .payload )
635635 except :
636636 log .debug ("error unpacking or decoding tuya JSON payload" )
@@ -639,15 +639,16 @@ def _send_receive(self, payload, minresponse=28, getresponse=True):
639639 # Did we detect a device22 device? Return ERR_DEVTYPE error.
640640 if dev_type != self .dev_type :
641641 log .debug (
642- "Device22 detected and updated (%s -> %s) - Update payload and try again" %
643- (dev_type , self .dev_type )
642+ "Device22 detected and updated (%s -> %s) - Update payload and try again" ,
643+ dev_type ,
644+ self .dev_type ,
644645 )
645646 result = error_json (ERR_DEVTYPE )
646647
647648 return result
648649
649650 def _decode_payload (self , payload ):
650- log .debug ("decode payload=%r" % payload )
651+ log .debug ("decode payload=%r" , payload )
651652 cipher = AESCipher (self .local_key )
652653
653654 if payload .startswith (PROTOCOL_VERSION_BYTES_31 ):
@@ -663,15 +664,15 @@ def _decode_payload(self, payload):
663664 PROTOCOL_VERSION_BYTES_33
664665 ):
665666 payload = payload [len (PROTOCOL_33_HEADER ) :]
666- log .debug ("removing 3.3=%r" % payload )
667+ log .debug ("removing 3.3=%r" , payload )
667668 try :
668- log .debug ("decrypting=%r" % payload )
669+ log .debug ("decrypting=%r" , payload )
669670 payload = cipher .decrypt (payload , False )
670671 except :
671- log .debug ("incomplete payload=%r" % payload )
672+ log .debug ("incomplete payload=%r" , payload )
672673 return None
673674
674- log .debug ("decrypted 3.3 payload=%r" % payload )
675+ log .debug ("decrypted 3.3 payload=%r" , payload )
675676 # Try to detect if device22 found
676677 log .debug ("payload type = %s" % type (payload ))
677678 if not isinstance (payload , str ):
@@ -685,17 +686,17 @@ def _decode_payload(self, payload):
685686 # set at least one DPS
686687 self .dps_to_request = {"1" : None }
687688 log .debug (
688- "'data unvalid' error detected: switching to dev_type %r" %
689- self .dev_type
689+ "'data unvalid' error detected: switching to dev_type %r" ,
690+ self .dev_type ,
690691 )
691692 return None
692693 elif not payload .startswith (b"{" ):
693- log .debug ("Unexpected payload=%r" % payload )
694+ log .debug ("Unexpected payload=%r" , payload )
694695 return error_json (ERR_PAYLOAD , payload )
695696
696697 if not isinstance (payload , str ):
697698 payload = payload .decode ()
698- log .debug ("decoded results=%r" % payload )
699+ log .debug ("decoded results=%r" , payload )
699700 try :
700701 json_payload = json .loads (payload )
701702 except :
@@ -900,7 +901,7 @@ def generate_payload(self, command, data=None, gwId=None, devId=None, uid=None):
900901 # if spaces are not removed device does not respond!
901902 payload = payload .replace (" " , "" )
902903 payload = payload .encode ("utf-8" )
903- log .debug ("building payload=%r" % payload )
904+ log .debug ("building payload=%r" , payload )
904905
905906 if self .version == 3.3 :
906907 # expect to connect and then disconnect to set new
@@ -937,7 +938,7 @@ def generate_payload(self, command, data=None, gwId=None, devId=None, uid=None):
937938 msg = TuyaMessage (self .seqno , int (command_hb , 16 ), 0 , payload , 0 )
938939 self .seqno += 1 # increase message sequence number
939940 buffer = pack_message (msg )
940- log .debug ("payload generated=%r HEX" % binascii .hexlify (buffer ))
941+ log .debug ("payload generated=%r" , binascii .hexlify (buffer ))
941942 return buffer
942943
943944
@@ -947,11 +948,11 @@ def __init__(self, dev_id, address, local_key="", dev_type="default"):
947948
948949 def status (self ):
949950 """Return device status."""
950- log .debug ("status() entry (dev_type is %s)" % self .dev_type )
951+ log .debug ("status() entry (dev_type is %s)" , self .dev_type )
951952 payload = self .generate_payload (DP_QUERY )
952953
953954 data = self ._send_receive (payload )
954- log .debug ("status() received data=%r" % data )
955+ log .debug ("status() received data=%r" , data )
955956 # Error handling
956957 if data and "Err" in data :
957958 if data ["Err" ] == str (ERR_DEVTYPE ):
@@ -976,7 +977,7 @@ def set_status(self, on, switch=1):
976977 payload = self .generate_payload (CONTROL , {switch : on })
977978
978979 data = self ._send_receive (payload )
979- log .debug ("set_status received data=%r" % data )
980+ log .debug ("set_status received data=%r" , data )
980981
981982 return data
982983
@@ -988,7 +989,7 @@ def product(self):
988989 # open device, send request, then close connection
989990 payload = self .generate_payload (AP_CONFIG )
990991 data = self ._send_receive (payload , 0 )
991- log .debug ("product received data=%r" % data )
992+ log .debug ("product received data=%r" , data )
992993 return data
993994
994995 def heartbeat (self ):
@@ -999,7 +1000,7 @@ def heartbeat(self):
9991000 # open device, send request, then close connection
10001001 payload = self .generate_payload (HEART_BEAT )
10011002 data = self ._send_receive (payload , 0 )
1002- log .debug ("heartbeat received data=%r" % data )
1003+ log .debug ("heartbeat received data=%r" , data )
10031004 return data
10041005
10051006 def updatedps (self , index = [1 ]):
@@ -1009,11 +1010,11 @@ def updatedps(self, index=[1]):
10091010 Args:
10101011 index(array): list of dps to update (ex. [4, 5, 6, 18, 19, 20])
10111012 """
1012- log .debug ("updatedps() entry (dev_type is %s)" % self .dev_type )
1013+ log .debug ("updatedps() entry (dev_type is %s)" , self .dev_type )
10131014 # open device, send request, then close connection
10141015 payload = self .generate_payload (UPDATEDPS , index )
10151016 data = self ._send_receive (payload , 0 )
1016- log .debug ("updatedps received data=%r" % data )
1017+ log .debug ("updatedps received data=%r" , data )
10171018 return data
10181019
10191020 def set_value (self , index , value ):
@@ -1062,7 +1063,7 @@ def set_timer(self, num_secs, dps_id=0):
10621063 payload = self .generate_payload (CONTROL , {dps_id : num_secs })
10631064
10641065 data = self ._send_receive (payload )
1065- log .debug ("set_timer received data=%r" % data )
1066+ log .debug ("set_timer received data=%r" , data )
10661067 return data
10671068
10681069
@@ -2188,7 +2189,7 @@ def _tuyaplatform(self, uri, action='GET', post=None, ver='v1.0', recursive=Fals
21882189 )
21892190 else :
21902191 log .debug (
2191- "POST: URL=%s HEADERS=%s DATA=%s" % (url , headers , body )
2192+ "POST: URL=%s HEADERS=%s DATA=%s" % (url , headers , body ),
21922193 )
21932194 response = requests .post (url , headers = headers , data = body )
21942195
@@ -2244,7 +2245,7 @@ def _getuid(self, deviceid=None):
22442245
22452246 if not response_dict ['success' ]:
22462247 log .debug (
2247- "Error from Tuya Cloud: %r" % response_dict ['msg' ]
2248+ "Error from Tuya Cloud: %r" % response_dict ['msg' ],
22482249 )
22492250 return None
22502251 uid = response_dict ['result' ]['uid' ]
@@ -2290,7 +2291,7 @@ def _getdevice(self, param='status', deviceid=None):
22902291
22912292 if not response_dict ['success' ]:
22922293 log .debug (
2293- "Error from Tuya Cloud: %r" % response_dict ['msg' ]
2294+ "Error from Tuya Cloud: %r" % response_dict ['msg' ],
22942295 )
22952296 return (response_dict )
22962297
@@ -2326,7 +2327,7 @@ def getdps(self, deviceid=None):
23262327
23272328 if not response_dict ['success' ]:
23282329 log .debug (
2329- "Error from Tuya Cloud: %r" % response_dict ['msg' ]
2330+ "Error from Tuya Cloud: %r" % response_dict ['msg' ],
23302331 )
23312332 return (response_dict )
23322333
@@ -2344,6 +2345,6 @@ def sendcommand(self, deviceid=None, commands=None):
23442345
23452346 if not response_dict ['success' ]:
23462347 log .debug (
2347- "Error from Tuya Cloud: %r" % response_dict ['msg' ]
2348+ "Error from Tuya Cloud: %r" % response_dict ['msg' ],
23482349 )
23492350 return (response_dict )
0 commit comments