master.py

import paho.mqtt.client as paho
from mqtt_point import *
from data import *
import time, threading
import uuid

class Master(MqttPoint):
    def makeOnMessageReplyCallback(self_inst):
        def cb_func(mesage):
            pass
        return cb_func
    
    def makeOnSlaveRequestCallback(self_inst):
        def cb_func(reqMessage: Data_MessageBase):
            if self_inst._on_slave_request_cb:
                self_inst._on_slave_request_cb(reqMessage)
        return cb_func

    def __init__(self):
        self._uuid = str(uuid.uuid4())
        id = self._uuid[:4] + '-' + self._uuid[-4:]
        slave_name = f'Master[{id}]'
        super().__init__(name=slave_name, 
                         listen_channel="com.ashimgaev.home/channel/slave_dbg", 
                         request_channel="com.ashimgaev.home/channel/master_dbg",
                         on_request_cb=Master.makeOnSlaveRequestCallback(self))
        self._on_slave_request_cb = None

    def getName(self):
        return self._uuid

    def sendConfigUpdateRequest(self, cfg_section: Data_ConfigSection, on_reply_cb):
        msg = Data_MasterConfigUpdateRequest(cfg_section=cfg_section)
        self.sendMessage(msg, on_reply_cb=on_reply_cb)

    def sendConfigListRequest(self, on_reply_cb):
        def onReply(msg):
            if on_reply_cb:
                on_reply_cb(msg)
        self.sendMessage(Data_MasterConfigListRequest(), onReply)

    def sendStatisticRequest(self, on_reply_cb):
        def onReply(msg):
            if on_reply_cb:
                on_reply_cb(msg)
        self.sendMessage(Data_MasterStatisticRequest(), onReply)

    def sendConfigRequestReply(self, reqMessage: Data_MessageBase, cfg_section: Data_ConfigSection):
        msg = Data_MasterConfigReply(cfg_section=cfg_section)
        msg.uuid = reqMessage.uuid
        self.sendMessage(msg)

    def sendMasterRoleRequest(self):
        msg = Data_MasterMasterRoleRequest(name=self._uuid)
        self.sendMessageToListenerChannel(msg)

    def sendMasterRoleRequestReply(self, reqMessage: Data_MessageBase):
        msg = Data_MasterMasterRoleReply(name=self.getName())
        self.sendMessageToListenerChannel(msg)

    def sendShowMessageRequest(self, msg: str):
        msg = Data_MasterShowMessageRequest(msg=msg)
        self.sendMessage(msg)

    def sendSlaveShutdownRequest(self, name: str):
        msg = Data_MasterShutdownSlaveRequest(name=name)
        self.sendMessage(msg)

    def start(self, on_config_request_cb):
        self._on_slave_request_cb = on_config_request_cb
        super().start()

    def stop(self):
        self._on_slave_request_cb = None
        super().stop()