nodeA.py

from node import Node
from secure_mqtt_node import SecureMQTTNode
import sys

# On crée un nœud A et on fait une demande à la PKI pour générer un certificat (ce qui va implicitement générer une CSR)
nodeA = Node("A")
nodeA.request_certificate()

# On crée un nœud MQTT à partir des attributs du nœud A. Ce noeud va écouter les messages, et va permettre d'en envoyer dans la file mqtt
secure_nodeA = SecureMQTTNode("A", nodeA)

secure_nodeA.start_loop()

print("[A] En écoute des messages...")

# Permet de lancer le script avec un argument "send" pour envoyer un message au noeud B qui écoute
if len(sys.argv) > 1 and sys.argv[1] == "send":
    secure_nodeA.send_message("B", "Message de A vers B")

while True:
    pass