from machine import Pin, ADC
import time 
from umqtt.simple import MQTTClient
import ujson
import network
import utime as time

# Device Setup
DEVICE_ID = "wokwi001"

# WiFi Setup
WIFI_SSID       = "Wokwi-GUEST"
WIFI_PASSWORD   = ""

# MQTT Setup
MQTT_BROKER             = "broker.mqttdashboard.com"
MQTT_CLIENT             = DEVICE_ID
MQTT_TELEMETRY_TOPIC    = "iot/telemetry"
MQTT_CONTROL_TOPIC      = "iot/control"

led_r = Pin (14, Pin.OUT)
led_v = Pin (26, Pin.OUT)
caudalimetro = Pin (34)
Caudalimetro = ADC (Pin (34))
led_b = (Pin(2, Pin.OUT))
led_r.on()
led_b.on()

Caudalimetro.width(ADC.WIDTH_10BIT)
Caudalimetro.atten(ADC.ATTN_11DB)

lectura = int(Caudalimetro.read())

Agua = 75 / 1023
flujo = Agua * lectura
time.sleep_ms(500)

"""
while True:

    if flujo <= 0:
        print ("No está pasando agua por el caudalímetro")
        led_r.value(1)
        led_v.value(0)

    if flujo > 0 and flujo < 75:
        print (f"se están usando {flujo} Litros por segundo de agua en la casa")
        led_r.value(0)
        led_v.value(1)

    if flujo >= 75:
        print ("conecte el caudalimetro a una tuberia de 25mm o menor")
        led_r.value(1)
        led_v.value(0)

    time.sleep_ms(500)
"""

# Methods
def did_recieve_callback(topic, message):
    print('\n\nData Recieved! \ntopic = {0}, message = {1}'.format(topic, message))

    # device_id/lamp/color/state
    # device_id/lamp/state
    # lamp/state
    if topic == MQTT_CONTROL_TOPIC.encode():
        if message == ('{0}/lamp/red/on'.format(DEVICE_ID)).encode():
            led_r.on()
        elif message == ('{0}/lamp/red/off'.format(DEVICE_ID)).encode():
            led_r.off()
        elif message == ('{0}/lamp/blue/on'.format(DEVICE_ID)).encode():
            led_v.on()
        elif message == ('{0}/lamp/blue/off'.format(DEVICE_ID)).encode():
            led_v.off()
        elif message == ('{0}/lamp/on'.format(DEVICE_ID)).encode() or message == b'lamp/on':
            led_r.on()
            led_v.on()
        elif message == ('{0}/lamp/off'.format(DEVICE_ID)).encode() or message == b'lamp/off':
            led_r.off()
            led_v.off()
        elif message == ('{0}/status'.format(DEVICE_ID)).encode() or message == ('status').encode():
            global telemetry_data_old
            mqtt_client_publish(MQTT_TELEMETRY_TOPIC, telemetry_data_old)
        else:
            return
        
        send_led_status()


def mqtt_connect():
    print("Connecting to MQTT broker ...", end="")
    mqtt_client = MQTTClient(MQTT_CLIENT, MQTT_BROKER, user="", password="")
    mqtt_client.set_callback(did_recieve_callback)
    mqtt_client.connect()
    print("Connected.")
    mqtt_client.subscribe(MQTT_CONTROL_TOPIC)
    return mqtt_client

def create_json_data(Lectura, Flujo):
    data = ujson.dumps({
        "device_id": DEVICE_ID,
        "Resolución del sensor": Lectura,
        "Caudal de agua detectado por el caudalimetro en litros por segundo": flujo,
        "type": "sensor de caudalimetro"
    })
    return data

def mqtt_client_publish(topic, data):
    print("\nUpdating MQTT Broker...")
    mqtt_client.publish(topic, data)
    print(data)

def send_led_status():
    data = ujson.dumps({
        "device_id": DEVICE_ID,
        "red_led": "ON" if led_r.value() == 1 else "OFF",
        "blue_led": "ON" if led_v.value() == 1 else "OFF",
        "type": "lamp"
    })
    mqtt_client_publish(MQTT_TELEMETRY_TOPIC, data)


# Application Logic

# Connect to WiFi
wifi_client = network.WLAN(network.STA_IF)
wifi_client.active(True)
print("Connecting device to WiFi")
wifi_client.connect(WIFI_SSID, WIFI_PASSWORD)

# Wait until WiFi is Connected
while not wifi_client.isconnected():
    print("Connecting")
    time.sleep(0.1)
print("WiFi Connected!")
print(wifi_client.ifconfig())

# Connect to MQTT
mqtt_client = mqtt_connect()
led_r.off()
led_v.off()
#mqtt_client_publish(MQTT_CONTROL_TOPIC, 'lamp/off')
sensor = (Caudalimetro)
telemetry_data_old = ""

while True:
    mqtt_client.check_msg()
    print(". ", end="")

    led_b.on()
    try:
      sensor.measure()
    except:
      pass
    
    time.sleep(0.2)
    led_b.off()

    telemetry_data_new = create_json_data(sensor.read(), Caudalimetro.read())
    mqtt_client_publish(MQTT_TELEMETRY_TOPIC, telemetry_data_new)

    if telemetry_data_new != telemetry_data_old:
        mqtt_client_publish(MQTT_TELEMETRY_TOPIC, telemetry_data_new)
        telemetry_data_old = telemetry_data_new

    time.sleep(0.1)