#-----------------------------------------------------------------------------
#
# Programme de display des messages recus par le server MQTT sur le hat
#
#-----------------------------------------------------------------------------
import paho.mqtt.client as mqtt
from sense_hat import SenseHat
# Configuration du hat
sense=SenseHat()
sense.set_rotation(90)
color=(0, 0, 255)
# Configuration du mqtt
MQTT_BROKER = "localhost"
MQTT_PORT = 1883
MQTT_KEEPALIVE_INTERVAL = 45
MQTT_TOPIC1 = "Heure"
MQTT_TOPIC2 = "Info/#"
# Define on_connect event Handler
def on_connect(client, userdata, falgs, rc):
    print("Connected with result code "+str(rc))
    #Subscribe to a the Topic
    client.subscribe(MQTT_TOPIC1, 0)
    client.subscribe(MQTT_TOPIC2, 0)
# Define on_subscribe event Handler
def on_subscribe(client, userdata, mid, granted_qos):
    print("Subscribed to MQTT Topic")
# Define on_message event Handler
def on_message(client, userdata, message):
    print(message.topic+" "+str(message.payload.decode("ascii")))
    sense.show_message(message.payload.decode("ascii"), text_colour=color)
# Initiate MQTT Client
client=mqtt.Client()
# Register Event Handlers
client.on_message=	on_message
client.on_connect=   	on_connect
client.on_subscribe=	on_subscribe
# Connect with MQTT Broker
client.connect(MQTT_BROKER, MQTT_PORT, MQTT_KEEPALIVE_INTERVAL )
# Continue the network loop
client.loop_forever()