williamp/localtuya-modded
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #1424 from rospogrigio/fix_socket.send_exceptions

Browse Source 
Fix for socket.send() exceptions in the logs
This commit is contained in:
rospogrigio
2023-06-07 12:27:31 +02:00
committed by GitHub
parent 53e1ad8488 ba5670fc1d
commit f06e4848e6
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
custom_components/localtuya/manifest.json
View File

@@ -10,5 +10,5 @@
"iot_class": "local_push", "iot_class": "local_push",
"issue_tracker": "https://github.com/rospogrigio/localtuya/issues", "issue_tracker": "https://github.com/rospogrigio/localtuya/issues",
"requirements": [], "requirements": [],
"version": "5.2.0" "version": "5.2.1"
} }

7
custom_components/localtuya/pytuya/__init__.py
View File

@@ -766,10 +766,9 @@ class TuyaProtocol(asyncio.Protocol, ContextualLogger):
enc_payload = self._encode_message(payload) enc_payload = self._encode_message(payload)
self.transport.write(enc_payload) self.transport.write(enc_payload)
try:
msg = await self.dispatcher.wait_for(seqno, payload.cmd) msg = await self.dispatcher.wait_for(seqno, payload.cmd)
except Exception as ex: if msg is None:
self.debug("Wait was aborted for seqno %d (%s)", seqno, ex) self.debug("Wait was aborted for seqno %d", seqno)
return None return None
# TODO: Verify stuff, e.g. CRC sequence number? # TODO: Verify stuff, e.g. CRC sequence number?
@@ -954,7 +953,7 @@ class TuyaProtocol(asyncio.Protocol, ContextualLogger):
json_payload = json.loads(payload) json_payload = json.loads(payload)
except Exception as ex: except Exception as ex:
raise DecodeError( raise DecodeError(
"could not decrypt data: wrong local_key? (exception %s)", ex "could not decrypt data: wrong local_key? (exception: %s)" % ex
) )
# json_payload = self.error_json(ERR_JSON, payload) # json_payload = self.error_json(ERR_JSON, payload)