import paho.mqtt.client as mqtt #import the client1
import time

Czujnik_1 = []
Czujnik_2 = []
Czujnik_3 = []
Czujnik_4 = []
Czujnik_5 = []
A = 0
B = 0
C = 0
D = 0
E = 0

Ilosc_pomiarow = 0
############
def on_message(client, userdata, message):
    mes = str(message.payload.decode("utf-8"))
    print("message received " ,mes)
    print("Liczba ",int(mes[1:]))
    print(mes[0])

    if mes[0] == 'A':
        liczba = int(mes[1:])
        Czujnik_1[A] = liczba
        A=A + 1
        Ilosc_pomiarow=Ilosc_pomiarow + 1
        print("chuj")
    if mes[0] == 'B':
        liczba = int(mes[1:])
        Czujnik_2[B] = liczba
        B+=1
        Ilosc_pomiarow=Ilosc_pomiarow + 1
    if mes[0] == 'C':
        liczba = int(mes[1:])
        Czujnik_3[C] = liczba
        C+=1
        Ilosc_pomiarow=Ilosc_pomiarow + 1
    if mes[0] == 'D':
        liczba = int(mes[1:])
        Czujnik_4[D] = liczba
        D+=1
        Ilosc_pomiarow=Ilosc_pomiarow + 1
    if mes[0] == 'E':
        liczba = int(mes[1:])
        Czujnik_5[E] = liczba
        E+=1
        Ilosc_pomiarow=Ilosc_pomiarow + 1

    #print("Client" + str(client))
    #print("Userdata" + str(userdata));
    #print("message topic=",message.topic)
    #print("message qos=",message.qos)
    #print("message retain flag=",message.retain)
########################################
#broker_address="tcp://192.168.1.1:1883"
broker_address="localhost"
x = input("Podaj nazwe topicu:")
print("creating new instance")
client = mqtt.Client("P1") #create new instance
client.on_message=on_message #attach function to callback
print("connecting to broker")
client.connect(broker_address) #connect to broker
client.loop_start() #start the loop
print("Subscribing to topic"+ x)
client.subscribe(x)
while 1:
    client.loop_start()
    client.loop_stop()
    #print(A)
"""
while Ilosc_pomiarow<10:
    client.loop_start() #start the loop
    print(Ilosc_pomiarow)
client.loop_stop()
print(A)
"""