from mqtt_as import MQTTClient, config #type:ignore
import asyncio

#Local configuration
config["ssid"] = "CANTOVELL"
config["wifi_pw"] = "c0ntrasenyaCANT0VELLpassw0rd"
config["server"] = "mqtt.tovellmatic.com"
config["port"] = "1883"
config["client_id"] = "ESP32"
config["user"] = "tovellma"
config["password"] = "c0ntrasenyaT0VELLMATICpassw0rd"

def callback(topic, msg, retained, properties=None):  # MQTT V5 passes properties
    print((topic.decode(), msg.decode(), retained))

async def conn_han(client):
    await client.subscribe('foo_topic', 1)

async def main(client):
    await client.connect()
    n = 0
    while True:
        await asyncio.sleep(5)
        print('publish', n)
        # If WiFi is down the following will pause for the duration.
        await client.publish('result', '{}'.format(n), qos = 1)
        n += 1

config['subs_cb'] = callback
config['connect_coro'] = conn_han

MQTTClient.DEBUG = True  # Optional: print diagnostic messages
client = MQTTClient(config)
try:
    asyncio.run(main(client))
finally:
    client.close()  # Prevent LmacRxBlk:1 errors

Checking WiFi integrity.
Got reliable connection
Connecting to broker.
Traceback (most recent call last):
  File "<stdin>", line 36, in <module>
  File "asyncio/core.py", line 1, in run
  File "asyncio/core.py", line 1, in run_until_complete
  File "asyncio/core.py", line 1, in run_until_complete
  File "<stdin>", line 21, in main
  File "mqtt_as/__init__.py", line 800, in connect
  File "mqtt_as/__init__.py", line 341, in _connect
  File "mqtt_as/__init__.py", line 278, in _as_write
OSError: [Errno 104] ECONNRESET