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

Fixed HEARTBEAT command

Browse Source
This commit is contained in:
rospogrigio
2023-01-07 22:59:08 +01:00
committed by rospogrigio
parent c6a9460d06
commit 0fb619960c
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -99,12 +99,6 @@ error_codes = {
None: "Unknown Error", None: "Unknown Error",
} }
SET = "set"
STATUS = "status"
HEARTBEAT = "heartbeat"
RESET = "reset"
UPDATEDPS = "updatedps" # Request refresh of DPS
# Tuya Command Types # Tuya Command Types
# Reference: https://github.com/tuya/tuya-iotos-embeded-sdk-wifi-ble-bk7231n/blob/master/sdk/include/lan_protocol.h # Reference: https://github.com/tuya/tuya-iotos-embeded-sdk-wifi-ble-bk7231n/blob/master/sdk/include/lan_protocol.h
AP_CONFIG = 0x01 # FRM_TP_CFG_WF # only used for ap 3.0 network config AP_CONFIG = 0x01 # FRM_TP_CFG_WF # only used for ap 3.0 network config
@@ -697,9 +691,9 @@ class TuyaProtocol(asyncio.Protocol, ContextualLogger):
# Wait for special sequence number if heartbeat or reset # Wait for special sequence number if heartbeat or reset
seqno = self.seqno seqno = self.seqno
if payload.cmd == HEARTBEAT: if payload.cmd == HEART_BEAT:
seqno = MessageDispatcher.HEARTBEAT_SEQNO seqno = MessageDispatcher.HEARTBEAT_SEQNO
elif payload.cmd == RESET: elif payload.cmd == UPDATEDPS:
seqno = MessageDispatcher.RESET_SEQNO seqno = MessageDispatcher.RESET_SEQNO
enc_payload = self._encode_message(payload) enc_payload = self._encode_message(payload)
@@ -737,14 +731,14 @@ class TuyaProtocol(asyncio.Protocol, ContextualLogger):
async def heartbeat(self): async def heartbeat(self):
"""Send a heartbeat message.""" """Send a heartbeat message."""
return await self.exchange(HEARTBEAT) return await self.exchange(HEART_BEAT)
async def reset(self, dpIds=None): async def reset(self, dpIds=None):
"""Send a reset message (3.3 only).""" """Send a reset message (3.3 only)."""
if self.version == 3.3: if self.version == 3.3:
self.dev_type = "type_0a" self.dev_type = "type_0a"
self.debug("reset switching to dev_type %s", self.dev_type) self.debug("reset switching to dev_type %s", self.dev_type)
return await self.exchange(RESET, dpIds) return await self.exchange(UPDATEDPS, dpIds)
return True return True