main.py

import paho.mqtt.client as mqtt
import threading
import time
import json

class ChirpStackClient:
    def __init__(self, mqtt_host, mqtt_port, mqtt_username=None, mqtt_password=None):
        # MQTT setup
        self.mqtt_host = mqtt_host
        self.mqtt_port = mqtt_port
        self.mqtt_username = mqtt_username
        self.mqtt_password = mqtt_password
        self.mqtt_client = mqtt.Client()
        if mqtt_username and mqtt_password:
            self.mqtt_client.username_pw_set(mqtt_username, mqtt_password)
        self.mqtt_client.on_connect = self.on_connect
        self.mqtt_client.on_message = self.on_message
        self.uplink_callback = None

    def start_mqtt(self, application_id, dev_eui, uplink_callback=None):
        self.uplink_callback = uplink_callback
        topic = f"application/{application_id}/device/{dev_eui}/event/#"
        # topic = f"application/{application_id}/device/{dev_eui}/event/up"
        self.mqtt_client.connect(self.mqtt_host, self.mqtt_port, 60)
        self.mqtt_client.subscribe(topic)
        print(f"Subscribed to MQTT topic: {topic}")
        # Run MQTT loop in a separate thread
        threading.Thread(target=self.mqtt_client.loop_forever, daemon=True).start()

    def on_connect(self, client, userdata, flags, rc):
        if rc == 0:
            print("Connected to MQTT broker.")
        else:
            print(f"Failed to connect to MQTT broker, return code {rc}")

    def on_message(self, client, userdata, msg):
        print(f"Received uplink on topic {msg.topic}")
        try:
            payload = json.loads(msg.payload.decode())
            print(json.dumps(payload, indent=2))
            if self.uplink_callback:
                self.uplink_callback(payload)
        except Exception as e:
            print(f"Error parsing uplink message: {e}")

def main():
    # Fill in your details
    mqtt_host = "3.92.197.242"  # Replace with your MQTT broker
    mqtt_port = 1883  # Or 8883 for TLS
    mqtt_username = None  # Set if needed
    mqtt_password = None  # Set if needed
    application_id = "efacf7b1-e527-4e2d-8fb3-d9d1f9df33d4"  # Replace with your application ID
    dev_eui = "967d66e98d7e5458"  # Replace with your device EUI

    client = ChirpStackClient(mqtt_host, mqtt_port, mqtt_username, mqtt_password)

    # Uplink (MQTT) example
    def handle_uplink(payload):
        print("Custom uplink handler:")
        print(json.dumps(payload, indent=2))

    client.start_mqtt(application_id, dev_eui, uplink_callback=handle_uplink)

    # Keep the main thread alive
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        print("Exiting...")

if __name__ == "__main__":
    main()