from LED import Led
from time import sleep
from red import conectar
from cliente_mqtt import ClienteMQTT
import sys
import select
led = Led(2)
topic_Propio = "prueba/103"
topic_suscribir = "Prueba/suscribir"
conectar("Wokwi-GUEST", "")
mqtt = ClienteMQTT("Teban", "broker.emqx.io")
mqtt.conectar()
mqtt.publicar("programacion2/grupo105/chat", "Hola buenas")

def imprimirmensaje(topico, mensaje):
  print("mensaje recibido: ")
  print(mensaje.decode())
  led.blink()

mqtt.suscribirse(topic_suscribir, imprimirmensaje)

serial = select.poll()
serial.register(sys.stdin, select.POLLIN)
print("Chat iniciando")

while True:
  mqtt.revisarmensaje()
  if serial.poll(0):
    mesage= (sys.stdin.readline().strip())
    if mensaje:
      mqtt.publicar(topic_Propio,mensaje)