import network
from meu_mqtt import MeuMqtt
from hcsr04 import HCSR04
from time import sleep


print("Conectando-se ao Wi-Fi", end="")
rede = network.WLAN(network.STA_IF)
rede.active(True)
rede.connect("Wokwi-GUEST", "")
while not rede.isconnected():
    print(".", end="")
    sleep(0.1)

meu_mqtt = MeuMqtt("hello", 22140, 22155)
meu_mqtt.connect_and_subscribe()

sensor = HCSR04(trigger_pin=14, echo_pin=5)

while True:
    distancia = sensor.distance_cm()

    mensagem = b'{ "aluno" : "22140", "dist": %0.2f }' %(distancia)
    print(mensagem)

    meu_mqtt.publicar(b"hello", mensagem)
    try:
        meu_mqtt.client.check_msg()
    except OSError as e:
        meu_mqtt.reiniciar()

    sleep(1)