ebbe.bass
/
PiXelTubes
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

removed universe count 

Signed-off-by: Ebbe Baß <ebbe.bass>
main
Ebbe Baß 2024-02-14 22:33:40 +01:00
parent 30cd752d13
commit e90e68fe77
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
server/app.py
View File

@ -38,8 +38,6 @@ db = MySQLdb.connect(
database=config['mysql']['database'], database=config['mysql']['database'],
) )
universe_count = config['artnet']['universe_count']
mqtt_client_id = "PiXelTubeMaster-"+wlan_mac_address mqtt_client_id = "PiXelTubeMaster-"+wlan_mac_address
# Function to register a tube in the database # Function to register a tube in the database
@ -109,7 +107,7 @@ def connect_mqtt():
client.connect("localhost", 1883) client.connect("localhost", 1883)
return client return client
def start_mqtt_publishers(universe_count): def start_mqtt_publishers():
# Create and start a thread for each universe # Create and start a thread for each universe
mqtt_client = connect_mqtt() mqtt_client = connect_mqtt()
artnetBindIp = get_eth0_ip() artnetBindIp = get_eth0_ip()
@ -119,7 +117,6 @@ def start_mqtt_publishers(universe_count):
try: try:
while True: while True:
try: try:
# for universe in range(universe_count):
# Gets whatever the last Art-Net packet we received is # Gets whatever the last Art-Net packet we received is
artNetPacket = artNet.readPacket() artNetPacket = artNet.readPacket()
# Make sure we actually *have* a packet # Make sure we actually *have* a packet
@ -137,8 +134,6 @@ def start_mqtt_publishers(universe_count):
mqtt_client.publish(topic, str(dmxPacket[i-1])) mqtt_client.publish(topic, str(dmxPacket[i-1]))
except KeyboardInterrupt: except KeyboardInterrupt:
break break
time.sleep(0.001)
except Exception as e: except Exception as e:
print(e) print(e)
except KeyboardInterrupt: except KeyboardInterrupt:
@ -147,7 +142,7 @@ def start_mqtt_publishers(universe_count):
print(e) print(e)
if __name__ == "__main__": if __name__ == "__main__":
start_mqtt_publishers(universe_count) start_mqtt_publishers()
# flask_thread = threading.Thread(target=flask_api()) # flask_thread = threading.Thread(target=flask_api())
# flask_thread.start() # flask_thread.start()
# flask_thread.join() # flask_thread.join()