Conexion done

conexion.py

@@ -3,16 +3,17 @@ import paho.mqtt.client as mqtt
 class Conexion:   
     
 
-    def __init__(self, on_msg):
+    def __init__(self, topics,on_msg):
 
         
 
 
         # Configuración del broker MQTT
-        self.__broker_address = "192.168.0.19"  # Cambia por la dirección de tu broker MQTT
+        self.__broker_address = "192.168.48.245"  # Cambia por la dirección de tu broker MQTT
         #self.__broker_address = "192.168.0.100"  # Cambia por la dirección de tu broker MQTT
         self.__port = 1883  # Puerto predeterminado para MQTT
-        self.__topic = ["A3-467/GrupoL","map"]
+        #self.__topic = ["A3-467/GrupoL","map"]
+        self.__topic = topics
 
 
         #def on_message(client, userdata, message):
@@ -52,19 +53,19 @@ class Conexion:
 
         
 
-    def publicar(self,msg):
+    def publicar(self,topic,msg):
         
         client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)        
         client.connect(self.__broker_address, self.__port)
-        result = client.publish(self.__topic[0],msg)
+        result = client.publish(topic,msg)
         client.disconnect()
         #result = self.__client.publish(self.__topic[0],msg)
         # result: [0, 1]
         status = result[0]
         if status == 0:
-            print(f"Send `{msg}` to topic `{self.__topic[0]}`")
+            print(f"Send `{msg}` to topic `{topic}`")
         else:
-            print(f"Failed to send message to topic {self.__topic[0]}")   
+            print(f"Failed to send message to topic {topic}")   
 
     def desconectar(self):
         self.__client.loop_stop()
@@ -73,7 +74,7 @@ class Conexion:
 
 
 # Función para enviar mensajes MQTT al broker
-def send_mqtt_message( message,topic="A3-467/GrupoL"):
+def send_mqtt_message( topic,message):
     client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
     client.connect("192.168.0.19" , 1883)
     client.publish(topic, message)

main_interfaz.py

@@ -30,24 +30,20 @@ def leerMapa(msg : str):
 lista = []
 
 def on_message(client, userdata, message):
-            if(message.topic == "map"):
-                 leerMapa(str(message.payload.decode("utf-8")))
-            lista.append(f'{message.topic}{separadorTopic}{str(message.payload.decode("utf-8"))}')
+    print(f'Topic:{message.topic} Mensage:{str(message.payload.decode("utf-8"))}')
+            #if(message.topic == "map"):
+            #     leerMapa(str(message.payload.decode("utf-8")))
+            #lista.append(f'{message.topic}{separadorTopic}{str(message.payload.decode("utf-8"))}')
 
 
           
        
+topics = ["A3-467/GrupoL/Interfaz","map"]
 
-conex = cn.Conexion(on_msg=on_message)
+conex = cn.Conexion(topics=topics,on_msg=on_message)
 
-time.sleep(3)
-finished = False
-while(not finished):
-    if(len(lista) != 0):
-        msg = lista.pop()
-        print(msg)
-        #finished = True    
-    time.sleep(1)
+
+conex.publicar("A3-467/GrupoL/Robot","hola mundo")
 
 
 

main_robot.py

@@ -3,25 +3,13 @@ import time
 
 lista = []
 
-def on_message(client, userdata, message):
-            lista.append(f'{message.topic}-{str(message.payload.decode("utf-8"))}')
-
-
-conex = cn.Conexion(on_msg=on_message)
-
-time.sleep(3)
-
-mapa = "0202000105030705000200041109060110031000000200080101100110000106010701"
-
-finished = False
-while(not finished):
-    if(len(lista) != 0):
-        msg = lista.pop()
-        print(msg)
-        #finished = True    
-    time.sleep(1)
+def on_message(client, userdata, message):    
+    print(f'Topic:{message.topic} Mensage:{str(message.payload.decode("utf-8"))}')
+            #lista.append(f'{message.topic}-{str(message.payload.decode("utf-8"))}')
 
+topics = ["A3-467/GrupoL/Robot","map"]
 
+conex = cn.Conexion(topics=topics,on_msg=on_message)
 
 
 conex.desconectar()
\ No newline at end of file