cccb/mixer-rpc
cccb/mixer-rpc
0
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

mqtt_client.py: subscribe to actual topic + require mqtt broker hostname via arg

Browse source
This commit is contained in:
coon 2025-09-25 22:27:48 +02:00
parent 6bf5debce8
commit a2f4079223
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
mqtt_client.py
View file

@ -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()