broker = config.mqtt_broker

def on_connect(client, userdata, flags, rc, properties):
    if rc == 0:
        print("connected to topics")
        client.subscribe(config.main_topic + config.bileterka + "/#")
        client.subscribe(config.main_topic + config.terminal + "/#")
    else:
        print("errror")


def publish_data_to_broker(topic, msg, retain):
    global ostatnia_wiadomosc
    """
    Publikuje dane do brokera
    :param: topic, msg, retain
    """
    print(topic + " " + msg)
    info = client.publish("test", msg, qos=2, retain=retain)
    info.wait_for_publish()
    print(info)

    if info.is_published():
        print("published OK")
        return True
    else:
        logging.info(f"Pub fail {topic} {msg}")
    return False


def on_message(client, userdata, msg):
    msgIn = msg.payload.decode("utf-8")
    try:
        if "numerrej" in msg.topic:
            print("----")
            publish_data_to_broker(msg.topic, "test", False)
    except Exception as e:
        logging.error(f"on message {e}")


if __name__ == "__main__":
    client.username_pw_set(username=config.mqtt_login, password=config.mqtt_passwd)
    client.on_connect = on_connect
    client.on_message = on_message
    try:
        client.connect(broker, config.mqtt_port, config.mqtt_keepalive)
    except:
        logging.info("ERROR: Connect error")
    client.loop_forever()