Publisher.py

###########################################################################################################################
#                                                                                                                         #
#    Author:         D. Nenicka                                                                                           #
#    Created:        3. 11. 2023                                                                                          #
#    Modified:       25. 8. 2024                                                                                          #
#    Description:    Module for publishing current rotator azimuth and elevation to be subscribed by station computer     #
#                                                                                                                         #
###########################################################################################################################


import paho.mqtt.client as paho                                            # for publishing data from MQTT broker

from threading import Timer


class Publisher:
    def __init__(self, az, el):
        self.client = paho.Client()                                        # create mqtt client
        self.az = az
        self.el = el
        self.client.username_pw_set(<username>, password=<password>)       # mqtt server authorization
        if self.client.connect(<hostname>, port=<port>) == 0:
            print('Publisher connected to MQTT Broker', sep=', ')
        else:
            print('Publisher could not connect to MQTT Broker', sep=', ')
        self.per = 1
        Timer(self.per, self.reg_pub).start()

    def reg_pub(self):
        self.client.publish('azimuth', str(self.az.direction), 0)
        self.client.publish('elevation', str(self.el.direction), 0)
        Timer(self.per, self.reg_pub).start()