from threading import Event
from loguru import logger
from MqttBase import AbstractMqttPublisher


class TestPublish(AbstractMqttPublisher):
    def __init__(self, config):
        super().__init__(config)

    def localLoop(self):
        cnt = 0
        while not self.killBill:
            cnt += 1
            topic = self.config["publishTopic"]
            payload = str(cnt)
            self.client.publish(topic, payload)
            logger.warning("mqtt message sent: {} -> {}".format(topic, payload))

            self.killEvent.wait(timeout=float(self.config["publishPeriod"]))