import paho.mqtt.client as mqtt
from sense_emu import SenseHat

localhost = '192.168.0.23'
port = 1993
timeout = 60
topic = "/test/podtest"

def on_connect(client, userdata, flags, rc):
  print("error = "+str(rc))
  client.subscribe(topic)

def on_message(client, userdata, msg):
  sense = SenseHat()
  celcius = round(sense.temp, 1)
  fahrenheit = round(1.8 * celcius + 32, 1)
  humidity = round(sense.get_humidity(), 1)
  pressure = round(sense.get_pressure(), 1)
  print("Celcius:", celcius, "Fahrenheit:", fahrenheit, "Humidity:", humidity, "Pressure:", pressure)
  print(msg.payload)

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect(localhost, port, timeout)
client.loop_forever()