leo benny reporting and blocking.py

import paho.mqtt.client as mqtt

# Define the callback functions
def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to broker")
    else:
        print(f"Connection failed with code {rc}")

def on_message(client, userdata, message):
    print(f"Received message: {message.payload.decode()}")

# Create an MQTT client
client = mqtt.Client()

# Set the callback functions
client.on_connect = on_connect
client.on_message = on_message

# Set the broker and port
broker_address = "broker.hivemq.com"
port = 8883

# Connect to the broker
client.connect(broker_address, port)

# Subscribe to the "blocking" topic
client.subscribe("blocking")

# Publish a report message
client.publish("report", "Blocked user: user123")

# Start the MQTT loop
client.loop_forever()