[Bug]: Exception in async def exchange()

[Lurker00]

LocalTuya Version

3.2.5.2b6

Home Assistant Version

2024.4.3

Environment

• Does the device work using the Home Assistant Tuya Cloud component?
• Is this device connected to another local integration, including Home Assistant and any other tools?
• The devices are within the same HA subnet, and they get discovered automatically when I add them

What happened?

The line numbers in the log are for my source code. They correspond to:

hass-localtuya/custom_components/localtuya/core/pytuya/__init__.py

Lines 982 to 983 in bb90383

	await self.transport_write(enc_payload, delay)
	msg = await self.dispatcher.wait_for(seqno, payload.cmd)

Note, that close() performs

hass-localtuya/custom_components/localtuya/core/pytuya/__init__.py

Lines 908 to 910 in bb90383

	if self.dispatcher is not None:
	self.dispatcher.abort()
	self.dispatcher = None

and, probably, can be called concurrently.

Steps to reproduce.

Don't know

Relevant log output

2024-04-28 19:59:57.100 ERROR (MainThread) [custom_components.localtuya.core.pytuya] [bf2...38k] Heartbeat failed ('NoneType' object has no attribute 'wait_for'), disconnecting
Traceback (most recent call last):
File "/config/custom_components/localtuya/core/pytuya/__init__.py", line 900, in heartbeat_loop
await self.heartbeat()
File "/config/custom_components/localtuya/core/pytuya/__init__.py", line 1061, in heartbeat
return await self.exchange(HEART_BEAT)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/config/custom_components/localtuya/core/pytuya/__init__.py", line 1023, in exchange
msg = await self.dispatcher.wait_for(seqno, payload.cmd)
^^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: 'NoneType' object has no attribute 'wait_for'

Diagnostics information.

No response

[xZetsubou]

It seems "transport_write" closed the connection, thanks for the catch 👍

edit: resolved in 6d9491d

[github-actions]

This issue was closed because it was resolved on the release: