import machine
import utime
import network
import umqtt.simple

# --- Configuration ---
SSID = "YOUR_WIFI_SSID"  # Replace with your Wi-Fi SSID
PASSWORD = "YOUR_WIFI_PASSWORD"  # Replace with your Wi-Fi password
MQTT_BROKER = "YOUR_MQTT_BROKER_IP"  # Replace with your MQTT broker's IP address or hostname
MQTT_TOPIC = "your/topic"  # Replace with the MQTT topic to subscribe to
LED_PIN = machine.Pin("LED", machine.Pin.OUT) # Built-in LED on Pico W

# --- Network setup ---
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(SSID, PASSWORD)

while not wlan.isconnected():
    utime.sleep(1)
    print("Connecting to Wi-Fi...")

print(f"Connected to Wi-Fi with IP: {wlan.ifconfig()[0]}")

# --- MQTT client setup ---
client = umqtt.simple.MQTTClient("pico_client", MQTT_BROKER) 

def mqtt_callback(topic, msg):
    print(f"Received message: {msg.decode()} on topic: {topic.decode()}")
    LED_PIN.value(1)  # Turn LED on
    utime.sleep(1)
    LED_PIN.value(0)  # Turn LED off


try:
    client.connect()
    client.set_callback(mqtt_callback)
    client.subscribe(MQTT_TOPIC)
    print(f"Subscribed to topic: {MQTT_TOPIC}")

    while True:
        LED_PIN.toggle() # Blink the LED on each loop
        client.check_msg() # Non-blocking check for messages
        utime.sleep_ms(500) # Adjust delay as needed
        

except (OSError, Exception) as e:  # Handle potential network errors
    print(f"Error: {e}")
    client.disconnect()  # Disconnect if there's an error
    machine.reset() # Optional: Reset the Pico on error

import machine
import utime as time
import network
import umqtt.simple as mqtt

# --- Configuration ---
MQTT_BROKER = "your_mqtt_broker_address"  # Replace with your MQTT broker's IP or hostname
MQTT_TOPIC = "your/mqtt/topic"          # Replace with the topic you want to subscribe to
WIFI_SSID = "your_wifi_ssid"       # Replace with your Wi-Fi SSID
WIFI_PASSWORD = "your_wifi_password" # Replace with your Wi-Fi password

# --- Hardware setup ---
led = machine.Pin("LED", machine.Pin.OUT)  # Built-in LED on Pico W

# --- Network connection ---
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(WIFI_SSID, WIFI_PASSWORD)

while not wlan.isconnected():
    time.sleep(1)
    print("Connecting to Wi-Fi...")

print(f"Connected to Wi-Fi, IP: {wlan.ifconfig()[0]}")


# --- MQTT client setup ---
client = mqtt.MQTTClient("pico_w_client", MQTT_BROKER)  # Give your client a unique ID

def mqtt_callback(topic, msg):
    print(f"Received message on topic {topic}: {msg.decode()}")
    led.value(1)  # Turn LED on
    time.sleep(1)  # Keep LED on for 1 second
    led.value(0)  # Turn LED off

try:
    client.connect()
    client.set_callback(mqtt_callback)
    client.subscribe(MQTT_TOPIC)
    print(f"Subscribed to topic: {MQTT_TOPIC}")

    while True:
        led.toggle()  # Blink the LED 
        client.check_msg() # Non-blocking check for messages
        time.sleep(0.5)   # Adjust blink speed


except OSError as e:  # Handle potential MQTT connection errors
    print(f"Error connecting to MQTT: {e}")
    while True: # Blink LED rapidly to indicate error
        led.toggle()
        time.sleep(0.1)

except KeyboardInterrupt:
    print("Disconnecting from MQTT...")
    client.disconnect()
    print("Done.")

import machine
import time
import ubinascii
import network
import umqtt.simple

# --- Configuration ---
MQTT_BROKER = "your_mqtt_broker_address"  # Replace with your MQTT broker's IP or hostname
MQTT_TOPIC = "your/mqtt/topic"  # Replace with the topic you want to subscribe to
WIFI_SSID = "your_wifi_ssid"
WIFI_PASSWORD = "your_wifi_password"

# --- Hardware setup ---
led = machine.Pin("LED", machine.Pin.OUT)


# --- Network connection ---
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(WIFI_SSID, WIFI_PASSWORD)

while not wlan.isconnected():
    time.sleep(1)
    print("Connecting to WiFi...")

print("Connected to WiFi:", wlan.ifconfig()[0])


# --- MQTT client setup ---
client_id = ubinascii.hexlify(machine.unique_id())  # Create a unique client ID
client = umqtt.simple.MQTTClient(client_id, MQTT_BROKER)

def mqtt_callback(topic, msg):
    print("Received message:", msg.decode())
    led.on()  # Turn on the LED
    time.sleep(1)  # Keep it on for a second
    led.off()

try:
    client.connect()
    client.set_callback(mqtt_callback)  # Set the callback function
    client.subscribe(MQTT_TOPIC)
    print("Subscribed to:", MQTT_TOPIC)

    while True:
        led.on()  # Blink the LED
        client.check_msg() # Check for messages in a non-blocking way
        led.off()
        time.sleep(0.2)  # Adjust blink rate as needed

except OSError as e:
    print("Error connecting to MQTT:", e)
    # Handle the error, e.g., reconnect or reset
except KeyboardInterrupt:
    print("Exiting...")
    client.disconnect()

import time
import machine
import network
import umqtt.simple

# --- Configuration ---
SSID = "YOUR_WIFI_SSID"       # Replace with your Wi-Fi SSID
PASSWORD = "YOUR_WIFI_PASSWORD"  # Replace with your Wi-Fi password
MQTT_BROKER = "YOUR_MQTT_BROKER" # Replace with your MQTT broker address
MQTT_TOPIC = "your/topic"    # Replace with your MQTT topic

# --- Hardware setup ---
led = machine.Pin("LED", machine.Pin.OUT)

# --- Network setup ---
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(SSID, PASSWORD)

while not wlan.isconnected():
    time.sleep(1)
    print("Connecting to Wi-Fi...")

print(f"Connected to Wi-Fi: {wlan.ifconfig()[0]}")

# --- MQTT setup ---
client = umqtt.simple.MQTTClient("pico-w-client", MQTT_BROKER) # Unique client ID

def connect_to_mqtt():
    try:
        client.connect()
        print(f"Connected to MQTT broker: {MQTT_BROKER}")
        client.subscribe(MQTT_TOPIC)  # Subscribe to the topic
        return True
    except OSError as e:
        print(f"MQTT connection failed: {e}")
        return False

# --- Main loop ---
mqtt_connected = connect_to_mqtt()
while True:
    led.toggle()  # Blink the LED

    if mqtt_connected:
        try:
            msg = client.check_msg() # Non-blocking check for messages
            if msg:
                print(f"Received message: {msg.decode()}")  # Assuming UTF-8 encoded message
                led.value(1)  # Turn LED on
                time.sleep(1)
                led.value(0)  # Turn LED off
        except OSError as e:
            print(f"MQTT error: {e}")
            mqtt_connected = False # Try to reconnect later


    if not mqtt_connected:
        print("Attempting to reconnect to MQTT...")
        if connect_to_mqtt():
            mqtt_connected = True

    time.sleep(0.1)  # Adjust the delay as needed

import machine
import utime
import network
import umqtt.simple

# --- Configuration ---
SSID = "YOUR_WIFI_SSID"  # Replace with your Wi-Fi SSID
PASSWORD = "YOUR_WIFI_PASSWORD"  # Replace with your Wi-Fi password
MQTT_BROKER = "YOUR_MQTT_BROKER_IP"  # Replace with your MQTT broker IP or hostname
MQTT_TOPIC = "your/topic"  # Replace with your MQTT topic

# --- Initialize hardware ---
led = machine.Pin("LED", machine.Pin.OUT)
led.off()  # Start with LED off

# --- Network connection ---
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect(SSID, PASSWORD)

while not wlan.isconnected():
    utime.sleep(1)
    print("Connecting to Wi-Fi...")

print(f"Connected to Wi-Fi with IP: {wlan.ifconfig()[0]}")

# --- MQTT client setup ---
client = umqtt.simple.MQTTClient("pico-w-client", MQTT_BROKER)

try:
    client.connect()
    client.subscribe(MQTT_TOPIC)
    print(f"Subscribed to MQTT topic: {MQTT_TOPIC}")
except OSError as e:
    print(f"Error connecting to MQTT broker: {e}")
    # Handle connection error (e.g., retry, exit)
    # For this example, we'll just exit
    import sys
    sys.exit()


# --- Main loop ---
message_received = False
while True:
    led.toggle()  # Blink the LED

    try:
        # Non-blocking check for messages
        msg = client.check_msg()

        if msg is not None:  # Message received!
            print(f"Received MQTT message: {msg.decode()}")
            message_received = True

        if message_received:
            led.on()  # Turn on LED solid
            utime.sleep(1)
            led.off()  # Turn off LED
            message_received = False # Reset flag

    except OSError as e:
        print(f"MQTT error: {e}")
        # Handle MQTT error (e.g., reconnect)
        # For simplicity, we'll just continue in this example


    utime.sleep(0.1)  # Short delay to avoid excessive blinking/polling

# Example Python MQTT publisher (run on your computer)
import paho.mqtt.client as mqtt

client = mqtt.Client()
client.connect("YOUR_MQTT_BROKER_IP", 1883, 60)  # Replace with your broker's IP and port
client.publish("your/topic", "Hello from Python!") # Replace with your topic
client.disconnect()