import Adafruit_DHT
import time
from datetime import datetime
#from paho.mqtt import client as mqtt_client
import paho.mqtt.publish as publish

DHT_SENSOR = Adafruit_DHT.DHT22
DHT_PIN = 4
PROBE_NAME = "PI4"

broker = '10.0.3.37'
port = 1883
topic = "/dht/kueche"
client_id = f'dht-script'

#client= mqtt_client.Client(client_id)                           #create client object
#client.connect(broker,port)                                 #establish connection

#while True:
#    humidity, temperature = Adafruit_DHT.read_retry(DHT_SENSOR, DHT_PIN)
#    infot = client.publish(topic+"/humidity", str(humidity));
#    infot.wait_for_publish()
#    time.sleep(10)

while True:
    humidity, temperature = Adafruit_DHT.read_retry(DHT_SENSOR, DHT_PIN)
    if humidity is not None and temperature is not None:
        print("T={0:0.1f} H={1:0.1f}".format(temperature, humidity))
        if humidity <= 100:
            publish.single(topic+"/temperature", str(round(temperature,1)), hostname=broker)
            publish.single(topic+"/humidity", str(round(humidity,1)), hostname=broker);
        else:
            print("corrupted transmission");
    else:
        print("Failed to retrieve data from humidity sensor")
    time.sleep(30)