From a2f4079223aaf964720d44db79b3719b9036c6da Mon Sep 17 00:00:00 2001 From: coon Date: Thu, 25 Sep 2025 22:27:48 +0200 Subject: [PATCH] mqtt_client.py: subscribe to actual topic + require mqtt broker hostname via arg --- mqtt_client.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/mqtt_client.py b/mqtt_client.py index 3ff7ed6..3b7e5b8 100644 --- a/mqtt_client.py +++ b/mqtt_client.py @@ -7,7 +7,6 @@ import paho.mqtt.client as mqtt import mixer from mixer import Mixer -MQTT_SERVER_ADDRESS = "localhost" MQTT_SERVER_PORT = 1883 MQTT_TOPIC = "homeassistant/device/mixer" @@ -16,7 +15,7 @@ m: Mixer = None def on_connect(client, userdata, flags, reason_code, properties): print(f"Connected: {reason_code}") - client.subscribe("#") + client.subscribe(MQTT_TOPIC) def on_message(client, userdata, msg): @@ -35,18 +34,20 @@ def on_message(client, userdata, msg): def main(): parser = argparse.ArgumentParser(description="Allen & Heath Qu MQTT Remote Control") - parser.add_argument("ip", help="IP of the mixer") + parser.add_argument("mixer_ip", help="IP of the mixer") + parser.add_argument("mqtt_hostname", help="IP of the MQTT broker") args = parser.parse_args() - print(f"IP: {args.ip}") + + print(f"Mixer IP: {args.mixer_ip}, MQTT broker hostname: {args.mqtt_hostname}") global m - m = mixer.Mixer(args.ip, mixer.MIXER_PORT) + m = mixer.Mixer(args.mixer_ip) client = mqtt.Client(callback_api_version=mqtt.CallbackAPIVersion.VERSION2) client.on_connect = on_connect client.on_message = on_message - client.connect(MQTT_SERVER_ADDRESS, MQTT_SERVER_PORT, 60) + client.connect(args.mqtt_hostname, MQTT_SERVER_PORT, 60) client.loop_forever()