from umqtt.simple import MQTTClient
import utime
from machine import Pin

# WiFi credentials
ssid = "your_wifi_ssid"
password = "your_wifi_password"

# MQTT Broker details
mqtt_broker = "your_mqtt_broker_ip"
mqtt_port = 1883  # Default MQTT port
mqtt_topic = "your/topic"
mqtt_client_id = "pico-w-subscriber"  # Unique client ID

# Set up the onboard LED
led = Pin("LED", Pin.OUT)

# Function to connect to WiFi
def connect_wifi():
    import network
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(ssid, password)
    while not wlan.isconnected():
        print("Connecting to WiFi...")
        utime.sleep(1)
    print("Connected to WiFi!")
    print("IP address:", wlan.ifconfig()[0])

# Function to handle incoming MQTT messages
def on_message(topic, msg):
    print(f"New message on topic {topic.decode('utf-8')}: {msg.decode('utf-8')}")
    led.value(1)  # Turn on LED
    utime.sleep(1)  # Keep LED on for 1 second
    led.value(0)  # Turn off LED

# Connect to WiFi
connect_wifi()

# Set up the MQTT client
client = MQTTClient(mqtt_client_id, mqtt_broker, port=mqtt_port)
client.set_callback(on_message)
client.connect()
client.subscribe(mqtt_topic)
print(f"Subscribed to topic: {mqtt_topic}")

# Main loop
while True:
    client.check_msg()  # Non-blocking check for new messages
    led.value(not led.value())  # Toggle the LED state (blink)
    utime.sleep(0.5)  # Adjust blink speed

from machine import Pin, Timer
from time import sleep
import network
import ubinascii
from umqtt.simple import MQTTClient

# Configure your WiFi credentials
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

# Configure MQTT broker details
MQTT_BROKER = "your_mqtt_broker_ip"  # Replace with your MQTT broker IP
MQTT_PORT = 1883  # Default MQTT port
MQTT_CLIENT_ID = ubinascii.hexlify(machine.unique_id())  # Create a unique client ID
MQTT_TOPIC = "your/topic"  # Replace with your desired topic

# Set up the onboard LED
led = Pin("LED", Pin.OUT)

# Flag to indicate if a message has been received
message_received = False


def connect_wifi():
    """Connects to the configured WiFi network."""
    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(WIFI_SSID, WIFI_PASSWORD)

    # Wait for connection
    max_wait = 10
    while max_wait > 0:
        if wlan.status() < 0 or wlan.status() >= 3:
            break
        max_wait -= 1
        print("Waiting for connection...")
        sleep(1)

    if wlan.status() != 3:
        raise RuntimeError("Network connection failed")
    else:
        print("Connected to WiFi")
        status = wlan.ifconfig()
        print("IP = " + status[0])


def mqtt_callback(topic, msg):
    """Callback function for MQTT messages."""
    global message_received
    print(f"New message on topic {topic.decode('utf-8')}: {msg.decode('utf-8')}")
    message_received = True


def connect_mqtt():
    """Connects to the MQTT broker."""
    client = MQTTClient(MQTT_CLIENT_ID, MQTT_BROKER, port=MQTT_PORT)
    client.set_callback(mqtt_callback)
    client.connect()
    print(f"Connected to MQTT broker at {MQTT_BROKER}")
    client.subscribe(MQTT_TOPIC)
    print(f"Subscribed to topic: {MQTT_TOPIC}")
    return client


def main():
    global message_received

    connect_wifi()
    client = connect_mqtt()

    while True:
        # Check for messages and process them in a non-blocking way
        client.check_msg()

        # Blink LED every loop iteration
        led.toggle()
        sleep(0.5)

        # If a message was received, turn on the LED for 1 second
        if message_received:
            led.on()
            sleep(1)
            led.off()
            message_received = False


if __name__ == "__main__":
    main()

from umqtt.simple import MQTTClient
import machine
import time
import ubinit

# Important: Change the following to match your network settings
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

# MQTT Broker settings
MQTT_BROKER = "your_mqtt_broker_ip"
MQTT_PORT = 1883  # Default MQTT port
MQTT_TOPIC = "your/mqtt/topic"

# LED Pin
LED_PIN = machine.Pin("LED", machine.Pin.OUT)

# Connect to Wi-Fi
try:
    from network import WLAN, STA_IF
    wlan = WLAN(STA_IF)
    wlan.active(True)
    wlan.connect(WIFI_SSID, WIFI_PASSWORD)
    while not wlan.isconnected():
        print("Connecting to WiFi...")
        time.sleep(1)
    print("Connected to WiFi:", wlan.ifconfig()[0])

except ImportError:
    print("Unable to import network module. Please check your MicroPython firmware.")
    
# Define callback function for MQTT messages
def mqtt_callback(topic, msg):
    print("Message received on topic:", topic, "Message:", msg)
    LED_PIN.on()  # Turn LED on
    time.sleep(1)  # Wait for 1 second
    LED_PIN.off()  # Turn LED off

# Connect to MQTT broker
try:
    client = MQTTClient(client_id="pico-w-subscriber", server=MQTT_BROKER, port=MQTT_PORT)
    client.set_callback(mqtt_callback)  # Set the callback function
    client.connect()
    print("Connected to MQTT broker")
    client.subscribe(MQTT_TOPIC)
    print("Subscribed to topic:", MQTT_TOPIC)

except Exception as e:
    print("Error connecting to MQTT broker:", e)

# Main loop
while True:
    client.check_msg()  # Check for new messages
    LED_PIN.toggle()  # Blink the LED
    time.sleep(0.5)  # Adjust blink speed here

from machine import Pin, Timer
from time import sleep
from umqtt.simple import MQTTClient

# Configure your WiFi credentials
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

# Configure MQTT broker details
MQTT_BROKER = "your_mqtt_broker_ip"  # Replace with your broker's IP or hostname
MQTT_PORT = 1883  # Default MQTT port
MQTT_TOPIC = "your/mqtt/topic"  # Replace with your desired topic

# Set up the onboard LED
led = Pin("LED", Pin.OUT)

# Flag to track if a message has been received
message_received = False


def connect_wifi():
    import network

    wlan = network.WLAN(network.STA_IF)
    wlan.active(True)
    wlan.connect(WIFI_SSID, WIFI_PASSWORD)

    # Wait for connection
    max_wait = 10
    while max_wait > 0:
        if wlan.status() < 0 or wlan.status() >= 3:
            break
        max_wait -= 1
        print("Waiting for connection...")
        sleep(1)

    if wlan.status() != 3:
        raise RuntimeError("Network connection failed")
    else:
        print("Connected to WiFi")
        status = wlan.ifconfig()
        print("IP Address:", status[0])


def mqtt_callback(topic, msg):
    global message_received
    print(f"Received message on topic {topic}: {msg.decode()}")
    message_received = True


def connect_mqtt():
    client = MQTTClient("pico-w-subscriber", MQTT_BROKER, port=MQTT_PORT)
    client.set_callback(mqtt_callback)
    client.connect()
    client.subscribe(MQTT_TOPIC)
    print(f"Connected to MQTT broker at {MQTT_BROKER} on port {MQTT_PORT}")
    print(f"Subscribed to topic: {MQTT_TOPIC}")
    return client


def main():
    global message_received

    connect_wifi()
    client = connect_mqtt()

    while True:
        # Check for messages (non-blocking)
        client.check_msg()

        # Blink the LED
        led.toggle()

        # If a message was received, turn on the LED for a second
        if message_received:
            led.on()
            sleep(1)
            led.off()
            message_received = False

        sleep(0.5)  # Adjust the blinking speed as needed


if __name__ == "__main__":
    main()