From c9390ee41722180516c4ec314a43b39c963c3784 Mon Sep 17 00:00:00 2001 From: Gleb Tcivie Date: Fri, 9 Aug 2024 09:18:15 +0300 Subject: [PATCH 1/2] Added support for multiple topics (comma seperated) --- .env | 2 +- main.py | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/.env b/.env index fce0291..51c314e 100644 --- a/.env +++ b/.env @@ -13,7 +13,7 @@ MQTT_PORT=1883 MQTT_USERNAME=meshdev MQTT_PASSWORD=large4cats MQTT_KEEPALIVE=60 -MQTT_TOPIC='msh/#' +MQTT_TOPIC='msh/EU_868/#,msh/US/#' MQTT_IS_TLS=false # MQTT protocol version (default: MQTTv5) the public MQTT server supports MQTTv311 diff --git a/main.py b/main.py index 9770f80..d090783 100644 --- a/main.py +++ b/main.py @@ -30,7 +30,9 @@ def release_connection(conn): def handle_connect(client, userdata, flags, reason_code, properties): print(f"Connected with result code {reason_code}") - client.subscribe(os.getenv('MQTT_TOPIC', 'msh/israel/#')) + topics = os.getenv('MQTT_TOPIC', 'msh/israel/#').split(',') + topics_tuples = [(topic, 0) for topic in topics] + client.subscribe(topics_tuples) def update_node_status(node_number, status): From 45f47d107a4a6fdcba440102d3fe8dc4aa9e2941 Mon Sep 17 00:00:00 2001 From: Gleb Tcivie Date: Fri, 9 Aug 2024 09:22:14 +0300 Subject: [PATCH 2/2] Update main.yml --- .github/workflows/main.yml | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml index 250d8c1..937cfca 100644 --- a/.github/workflows/main.yml +++ b/.github/workflows/main.yml @@ -12,7 +12,7 @@ jobs: uses: actions/checkout@v4 - name: Start Docker Compose - run: docker-compose up -d + run: docker compose up -d - name: Wait for containers to start run: sleep 60 # 1 Minute @@ -23,11 +23,11 @@ jobs: for service in "${services[@]}" do - container_id=$(docker-compose ps -q $service) + container_id=$(docker compose ps -q $service) if [ -z "$container_id" ]; then echo "Error: Container for $service not found" - docker-compose logs $service + docker compose logs $service exit 1 fi @@ -37,14 +37,14 @@ jobs: if [ "$status" != "running" ]; then echo "Error: Container $service ($container_id) is not running. Current status: $status" echo "Last logs for $service:" - docker-compose logs --tail=50 $service + docker compose logs --tail=50 $service exit 1 fi if [ "$restarts" -gt 0 ]; then echo "Error: Container $service ($container_id) has restarted $restarts times" echo "Last logs for $service:" - docker-compose logs --tail=50 $service + docker compose logs --tail=50 $service exit 1 fi @@ -65,4 +65,4 @@ jobs: - name: Clean up if: always() - run: docker-compose down -v + run: docker compose down -v