broker.py

# This is an example of a mqtt broker to test the server mqtt
# Normally the server should send the reveived information to the broker

from dotenv import load_dotenv
import os
import asyncio
from amqtt.broker import Broker 

load_dotenv()
HOST = os.getenv("HOST", "0.0.0.0")
PORT = int(os.getenv("PORT", "1885"))

# This is a default basic config
config= {
    "listeners" : {
        "default": {
            "type" : "tcp",
            "bind" : f"{HOST}:{PORT}"
        }
    },
    "sys_interval" : 10,
    "topic-check" : {
        "enabled" : False,
    }
}

async def main():
    broker = Broker(config)
    await broker.start()
    print(f"{HOST}:{PORT}")
    
    try:
        while 1:
            await asyncio.sleep(3600)
    finally:
        await broker.shutdown()

if __name__ == "__main__":
    asyncio.run(main())