mirror of
https://github.com/joBr99/nspanel-lovelace-ui.git
synced 2025-12-22 23:44:25 +01:00
remove custom logging stuff
This commit is contained in:
@@ -1,14 +1,9 @@
|
|||||||
from helper import dict_recursive_update
|
from helper import dict_recursive_update
|
||||||
import logging
|
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
HA_API = None
|
|
||||||
|
|
||||||
class Entity(object):
|
class Entity(object):
|
||||||
def __init__(self, entity_input_config):
|
def __init__(self, entity_input_config):
|
||||||
if type(entity_input_config) is not dict:
|
if type(entity_input_config) is not dict:
|
||||||
LOGGER.error("Config error, not a dict check your entity configs")
|
#self._ha_api.log("Config error, not a dict check your entity configs")
|
||||||
self.entityId = "error"
|
self.entityId = "error"
|
||||||
self.nameOverride = None
|
self.nameOverride = None
|
||||||
self.iconOverride = None
|
self.iconOverride = None
|
||||||
@@ -33,7 +28,7 @@ class Card(object):
|
|||||||
for e in card_input_config.get("entities", []):
|
for e in card_input_config.get("entities", []):
|
||||||
self.entities.append(Entity(e))
|
self.entities.append(Entity(e))
|
||||||
self.id = f"{self.cardType}_{self.key}".replace(".","_").replace("~","_").replace(" ","_")
|
self.id = f"{self.cardType}_{self.key}".replace(".","_").replace("~","_").replace(" ","_")
|
||||||
LOGGER.info(f"Created Card {self.cardType} with pos {pos} and id {self.id}")
|
#self._ha_api.log(f"Created Card {self.cardType} with pos {pos} and id {self.id}")
|
||||||
|
|
||||||
def get_entity_list(self):
|
def get_entity_list(self):
|
||||||
entityIds = []
|
entityIds = []
|
||||||
@@ -105,8 +100,7 @@ class LuiBackendConfig(object):
|
|||||||
}
|
}
|
||||||
|
|
||||||
def __init__(self, ha_api, config_in):
|
def __init__(self, ha_api, config_in):
|
||||||
global HA_API
|
self._ha_api = ha_api
|
||||||
HA_API = ha_api
|
|
||||||
self._config = {}
|
self._config = {}
|
||||||
self._config_cards = []
|
self._config_cards = []
|
||||||
self._config_screensaver = None
|
self._config_screensaver = None
|
||||||
@@ -115,8 +109,9 @@ class LuiBackendConfig(object):
|
|||||||
self.load(config_in)
|
self.load(config_in)
|
||||||
|
|
||||||
def load(self, inconfig):
|
def load(self, inconfig):
|
||||||
|
self._ha_api.log(f"Input config: {inconfig}")
|
||||||
self._config = dict_recursive_update(inconfig, self._DEFAULT_CONFIG)
|
self._config = dict_recursive_update(inconfig, self._DEFAULT_CONFIG)
|
||||||
LOGGER.info(f"Loaded config: {self._config}")
|
self._ha_api.log(f"Loaded config: {self._config}")
|
||||||
|
|
||||||
# parse cards displayed on panel
|
# parse cards displayed on panel
|
||||||
pos = 0
|
pos = 0
|
||||||
|
|||||||
@@ -1,11 +1,8 @@
|
|||||||
import logging
|
|
||||||
import datetime
|
import datetime
|
||||||
from helper import scale, pos_to_color
|
from helper import scale, pos_to_color
|
||||||
|
|
||||||
from pages import LuiPagesGen
|
from pages import LuiPagesGen
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
class LuiController(object):
|
class LuiController(object):
|
||||||
|
|
||||||
def __init__(self, ha_api, config, send_mqtt_msg):
|
def __init__(self, ha_api, config, send_mqtt_msg):
|
||||||
@@ -40,13 +37,19 @@ class LuiController(object):
|
|||||||
|
|
||||||
# calculate current brightness
|
# calculate current brightness
|
||||||
self.current_screensaver_brightness = self.calc_current_screensaver_brightness()
|
self.current_screensaver_brightness = self.calc_current_screensaver_brightness()
|
||||||
|
|
||||||
# call update_screensaver_brightness on changes of entity configured in brightnessScreensaverTracking
|
# call update_screensaver_brightness on changes of entity configured in brightnessScreensaverTracking
|
||||||
bst = self._config.get("sleepTracking")
|
bst = self._config.get("sleepTracking")
|
||||||
if bst is not None and self._ha_api.entity_exists(bst):
|
if bst is not None and self._ha_api.entity_exists(bst):
|
||||||
self._ha_api.listen_state(self.update_screensaver_brightness_state_callback, entity_id=bst)
|
self._ha_api.listen_state(self.update_screensaver_brightness_state_callback, entity_id=bst)
|
||||||
|
|
||||||
|
# register callback for state changes on tracked value
|
||||||
|
sleep_brightness_config = self._config.get("sleepBrightness")
|
||||||
|
if type(sleep_brightness_config) == str and self._ha_api.entity_exists(sleep_brightness_config):
|
||||||
|
self._ha_api.listen_state(self.update_screensaver_brightness_state_callback, entity_id=sleep_brightness_config)
|
||||||
|
|
||||||
def startup(self):
|
def startup(self):
|
||||||
LOGGER.info(f"Startup Event")
|
self._ha_api.log(f"Startup Event")
|
||||||
# send time and date on startup
|
# send time and date on startup
|
||||||
self._pages_gen.update_time("")
|
self._pages_gen.update_time("")
|
||||||
self._pages_gen.update_date("")
|
self._pages_gen.update_date("")
|
||||||
@@ -63,6 +66,10 @@ class LuiController(object):
|
|||||||
|
|
||||||
|
|
||||||
def update_screensaver_brightness_state_callback(self, entity, attribute, old, new, kwargs):
|
def update_screensaver_brightness_state_callback(self, entity, attribute, old, new, kwargs):
|
||||||
|
x = type(self._config.get("sleepBrightness"))
|
||||||
|
y = self._config.get("sleepBrightness")
|
||||||
|
if type(self._config.get("sleepBrightness")) == str:
|
||||||
|
self.current_screensaver_brightness = self.calc_current_screensaver_brightness()
|
||||||
self.update_screensaver_brightness(kwargs={"value": self.current_screensaver_brightness})
|
self.update_screensaver_brightness(kwargs={"value": self.current_screensaver_brightness})
|
||||||
|
|
||||||
def update_screensaver_brightness(self, kwargs):
|
def update_screensaver_brightness(self, kwargs):
|
||||||
@@ -77,19 +84,22 @@ class LuiController(object):
|
|||||||
|
|
||||||
def calc_current_screensaver_brightness(self):
|
def calc_current_screensaver_brightness(self):
|
||||||
current_screensaver_brightness = 20
|
current_screensaver_brightness = 20
|
||||||
|
sleep_brightness_config = self._config.get("sleepBrightness")
|
||||||
# set brightness of screensaver
|
# set brightness of screensaver
|
||||||
if type(self._config.get("sleepBrightness")) == int:
|
if type(sleep_brightness_config) == int:
|
||||||
current_screensaver_brightness = self._config.get("sleepBrightness")
|
current_screensaver_brightness = sleep_brightness_config
|
||||||
elif type(self._config.get("sleepBrightness")) == list:
|
elif type(sleep_brightness_config) == str:
|
||||||
sorted_timesets = sorted(self._config.get("sleepBrightness"), key=lambda d: self._ha_api.parse_time(d['time']))
|
current_screensaver_brightness = int(float(self._ha_api.get_state(sleep_brightness_config)))
|
||||||
|
elif type(sleep_brightness_config) == list:
|
||||||
|
sorted_timesets = sorted(sleep_brightness_config, key=lambda d: self._ha_api.parse_time(d['time']))
|
||||||
# calc current screensaver brightness
|
# calc current screensaver brightness
|
||||||
found_current_dim_value = False
|
found_current_dim_value = False
|
||||||
for index, timeset in enumerate(sorted_timesets):
|
for index, timeset in enumerate(sorted_timesets):
|
||||||
LOGGER.info("Current time %s", self._ha_api.get_now().time())
|
self._ha_api.log("Current time %s", self._ha_api.get_now().time())
|
||||||
if self._ha_api.parse_time(timeset["time"]) > self._ha_api.get_now().time() and not found_current_dim_value:
|
if self._ha_api.parse_time(timeset["time"]) > self._ha_api.get_now().time() and not found_current_dim_value:
|
||||||
# first time after current time, set dim value
|
# first time after current time, set dim value
|
||||||
current_screensaver_brightness = sorted_timesets[index-1]["value"]
|
current_screensaver_brightness = sorted_timesets[index-1]["value"]
|
||||||
LOGGER.info("Setting dim value to %s", sorted_timesets[index-1])
|
self._ha_api.log("Setting dim value to %s", sorted_timesets[index-1])
|
||||||
found_current_dim_value = True
|
found_current_dim_value = True
|
||||||
# still no dim value
|
# still no dim value
|
||||||
if not found_current_dim_value:
|
if not found_current_dim_value:
|
||||||
@@ -98,16 +108,16 @@ class LuiController(object):
|
|||||||
|
|
||||||
def register_callbacks(self):
|
def register_callbacks(self):
|
||||||
items = self._config.get_all_entity_names()
|
items = self._config.get_all_entity_names()
|
||||||
LOGGER.info(f"Registering callbacks for the following items: {items}")
|
self._ha_api.log(f"Registering callbacks for the following items: {items}")
|
||||||
for item in items:
|
for item in items:
|
||||||
if self._ha_api.entity_exists(item):
|
if self._ha_api.entity_exists(item):
|
||||||
self._ha_api.listen_state(self.state_change_callback, entity_id=item, attribute="all")
|
self._ha_api.listen_state(self.state_change_callback, entity_id=item, attribute="all")
|
||||||
|
|
||||||
def state_change_callback(self, entity, attribute, old, new, kwargs):
|
def state_change_callback(self, entity, attribute, old, new, kwargs):
|
||||||
LOGGER.debug(f"Got callback for: {entity}")
|
self._ha_api.log(f"Got callback for: {entity}", level="DEBUG")
|
||||||
LOGGER.debug(f"Current page has the following items: {self._current_card.get_entity_list()}")
|
self._ha_api.log(f"Current page has the following items: {self._current_card.get_entity_list()}", level="DEBUG")
|
||||||
if entity in self._current_card.get_entity_list():
|
if entity in self._current_card.get_entity_list():
|
||||||
LOGGER.debug(f"Callback Entity is on current page: {entity}")
|
self._ha_api.log(f"Callback Entity is on current page: {entity}", level="DEBUG")
|
||||||
self._pages_gen.render_card(self._current_card, send_page_type=False)
|
self._pages_gen.render_card(self._current_card, send_page_type=False)
|
||||||
# send detail page update, just in case
|
# send detail page update, just in case
|
||||||
if self._current_card.cardType in ["cardGrid", "cardEntities"]:
|
if self._current_card.cardType in ["cardGrid", "cardEntities"]:
|
||||||
@@ -124,7 +134,7 @@ class LuiController(object):
|
|||||||
self._pages_gen.generate_light_detail_page(entity_id)
|
self._pages_gen.generate_light_detail_page(entity_id)
|
||||||
|
|
||||||
def button_press(self, entity_id, button_type, value):
|
def button_press(self, entity_id, button_type, value):
|
||||||
LOGGER.info(f"Button Press Event; entity_id: {entity_id}; button_type: {button_type}; value: {value} ")
|
self._ha_api.log(f"Button Press Event; entity_id: {entity_id}; button_type: {button_type}; value: {value} ")
|
||||||
# internal buttons
|
# internal buttons
|
||||||
if entity_id == "screensaver" and button_type == "bExit":
|
if entity_id == "screensaver" and button_type == "bExit":
|
||||||
# get default card if there is one
|
# get default card if there is one
|
||||||
|
|||||||
@@ -1,21 +1,18 @@
|
|||||||
import json
|
import json
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
class LuiMqttListener(object):
|
class LuiMqttListener(object):
|
||||||
|
|
||||||
def __init__(self, mqtt_api, topic, controller, updater):
|
def __init__(self, mqtt_api, topic, controller, updater):
|
||||||
self._controller = controller
|
self._controller = controller
|
||||||
self._updater = updater
|
self._updater = updater
|
||||||
|
self._mqtt_api = mqtt_api
|
||||||
# Setup, mqtt subscription and callback
|
# Setup, mqtt subscription and callback
|
||||||
mqtt_api.mqtt_subscribe(topic=topic)
|
mqtt_api.mqtt_subscribe(topic=topic)
|
||||||
mqtt_api.listen_event(self.mqtt_event_callback, "MQTT_MESSAGE", topic=topic, namespace='mqtt')
|
mqtt_api.listen_event(self.mqtt_event_callback, "MQTT_MESSAGE", topic=topic, namespace='mqtt')
|
||||||
|
|
||||||
|
|
||||||
def mqtt_event_callback(self, event_name, data, kwargs):
|
def mqtt_event_callback(self, event_name, data, kwargs):
|
||||||
LOGGER.debug(f'MQTT callback for: {data}')
|
self._mqtt_api.log(f'MQTT callback for: {data}')
|
||||||
# Parse Json Message from Tasmota and strip out message from nextion display
|
# Parse Json Message from Tasmota and strip out message from nextion display
|
||||||
data = json.loads(data["payload"])
|
data = json.loads(data["payload"])
|
||||||
if("nlui_driver_version" in data):
|
if("nlui_driver_version" in data):
|
||||||
@@ -25,7 +22,7 @@ class LuiMqttListener(object):
|
|||||||
if("CustomRecv" not in data):
|
if("CustomRecv" not in data):
|
||||||
return
|
return
|
||||||
msg = data["CustomRecv"]
|
msg = data["CustomRecv"]
|
||||||
LOGGER.info(f"Received Message from Screen: {msg}")
|
self._mqtt_api.log(f"Received Message from Screen: {msg}")
|
||||||
# Split message into parts seperated by ","
|
# Split message into parts seperated by ","
|
||||||
msg = msg.split(",")
|
msg = msg.split(",")
|
||||||
# run action based on received command
|
# run action based on received command
|
||||||
|
|||||||
@@ -1,4 +1,3 @@
|
|||||||
import logging
|
|
||||||
import datetime
|
import datetime
|
||||||
import dateutil.parser as dp
|
import dateutil.parser as dp
|
||||||
|
|
||||||
@@ -13,8 +12,6 @@ babel_spec = importlib.util.find_spec("babel")
|
|||||||
if babel_spec is not None:
|
if babel_spec is not None:
|
||||||
import babel.dates
|
import babel.dates
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
class LuiPagesGen(object):
|
class LuiPagesGen(object):
|
||||||
|
|
||||||
def __init__(self, ha_api, config, send_mqtt_msg):
|
def __init__(self, ha_api, config, send_mqtt_msg):
|
||||||
@@ -64,7 +61,7 @@ class LuiPagesGen(object):
|
|||||||
if self._ha_api.entity_exists(we_name):
|
if self._ha_api.entity_exists(we_name):
|
||||||
we = self._ha_api.get_entity(we_name)
|
we = self._ha_api.get_entity(we_name)
|
||||||
else:
|
else:
|
||||||
LOGGER.error(f"Skipping Weather Update, entity {we_name} not found")
|
self._ha_api.error(f"Skipping Weather Update, entity {we_name} not found")
|
||||||
return
|
return
|
||||||
|
|
||||||
icon_cur = get_icon_id_ha("weather", state=we.state)
|
icon_cur = get_icon_id_ha("weather", state=we.state)
|
||||||
@@ -84,7 +81,7 @@ class LuiPagesGen(object):
|
|||||||
icon = get_icon_id_ha("weather", state=we.attributes.forecast[i-1]['condition'])
|
icon = get_icon_id_ha("weather", state=we.attributes.forecast[i-1]['condition'])
|
||||||
down = convert_temperature(we.attributes.forecast[i-1]['temperature'], unit)
|
down = convert_temperature(we.attributes.forecast[i-1]['temperature'], unit)
|
||||||
else:
|
else:
|
||||||
LOGGER.info(f"Forecast {i} is overriden with {wOF}")
|
self._ha_api.log(f"Forecast {i} is overriden with {wOF}")
|
||||||
icon = wOF.get("icon")
|
icon = wOF.get("icon")
|
||||||
name = wOF.get("name")
|
name = wOF.get("name")
|
||||||
entity = self._ha_api.get_entity(wOF.get("entity"))
|
entity = self._ha_api.get_entity(wOF.get("entity"))
|
||||||
@@ -107,7 +104,7 @@ class LuiPagesGen(object):
|
|||||||
# type of the item is the string before the "." in the entityId
|
# type of the item is the string before the "." in the entityId
|
||||||
entityType = entityId.split(".")[0]
|
entityType = entityId.split(".")[0]
|
||||||
|
|
||||||
LOGGER.debug(f"Generating item for {entityId} with type {entityType}",)
|
self._ha_api.log(f"Generating item for {entityId} with type {entityType}", level="DEBUG")
|
||||||
# Internal types
|
# Internal types
|
||||||
if entityType == "delete":
|
if entityType == "delete":
|
||||||
return f"~{entityType}~~~~~"
|
return f"~{entityType}~~~~~"
|
||||||
@@ -326,7 +323,7 @@ class LuiPagesGen(object):
|
|||||||
self._send_mqtt_msg(command)
|
self._send_mqtt_msg(command)
|
||||||
|
|
||||||
def render_card(self, card, send_page_type=True):
|
def render_card(self, card, send_page_type=True):
|
||||||
LOGGER.info(f"Started rendering of page {card.pos} with type {card.cardType}")
|
self._ha_api.log(f"Started rendering of page {card.pos} with type {card.cardType}")
|
||||||
if len(self._config._config_cards) == 1:
|
if len(self._config._config_cards) == 1:
|
||||||
navigation = "0|0"
|
navigation = "0|0"
|
||||||
else:
|
else:
|
||||||
|
|||||||
@@ -1,9 +1,8 @@
|
|||||||
import logging
|
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
class Updater:
|
class Updater:
|
||||||
def __init__(self, send_mqtt_msg, topic_send, mode, desired_display_firmware_version, desired_display_firmware_model, desired_display_firmware_url, desired_tasmota_driver_version, desired_tasmota_driver_url):
|
def __init__(self, log, send_mqtt_msg, topic_send, mode, desired_display_firmware_version, desired_display_firmware_model, desired_display_firmware_url, desired_tasmota_driver_version, desired_tasmota_driver_url):
|
||||||
|
|
||||||
|
self._log = log
|
||||||
|
|
||||||
self.desired_display_firmware_version = desired_display_firmware_version
|
self.desired_display_firmware_version = desired_display_firmware_version
|
||||||
self.desired_display_firmware_model = desired_display_firmware_model
|
self.desired_display_firmware_model = desired_display_firmware_model
|
||||||
self.desired_display_firmware_url = desired_display_firmware_url
|
self.desired_display_firmware_url = desired_display_firmware_url
|
||||||
@@ -43,10 +42,10 @@ class Updater:
|
|||||||
# return's true if a notification was send to the panel
|
# return's true if a notification was send to the panel
|
||||||
# run pre req check
|
# run pre req check
|
||||||
if self.check_pre_req():
|
if self.check_pre_req():
|
||||||
LOGGER.info("Update Pre-Check sucessful Tasmota Driver Version: %s Panel Version: %s", self.current_tasmota_driver_version, self.current_display_firmware_version)
|
self._log("Update Pre-Check sucessful Tasmota Driver Version: %s Panel Version: %s", self.current_tasmota_driver_version, self.current_display_firmware_version)
|
||||||
# check if tasmota driver needs update
|
# check if tasmota driver needs update
|
||||||
if self.current_tasmota_driver_version < self.desired_tasmota_driver_version:
|
if self.current_tasmota_driver_version < self.desired_tasmota_driver_version:
|
||||||
LOGGER.info("Update of Tasmota Driver needed")
|
self._log("Update of Tasmota Driver needed")
|
||||||
# in auto mode just do the update
|
# in auto mode just do the update
|
||||||
if self.mode == "auto":
|
if self.mode == "auto":
|
||||||
self.update_berry_driver()
|
self.update_berry_driver()
|
||||||
@@ -59,14 +58,14 @@ class Updater:
|
|||||||
return False
|
return False
|
||||||
# check if model has changed
|
# check if model has changed
|
||||||
if self.current_display_model is not None and self.current_display_model != self.desired_display_firmware_model:
|
if self.current_display_model is not None and self.current_display_model != self.desired_display_firmware_model:
|
||||||
LOGGER.info(f"Mismatch between Display Firmware ({self.current_display_model}) and configured model ({self.desired_display_firmware_model})")
|
self._log(f"Mismatch between Display Firmware ({self.current_display_model}) and configured model ({self.desired_display_firmware_model})")
|
||||||
update_msg = f"The configured display firmware model has changed, do you want to start the update now? Current Model: {self.current_display_model} Configured Model: {self.desired_display_firmware_model} If the update fails check the installation manual and flash your version again over the Tasmota console. Be patient, the update will take a while."
|
update_msg = f"The configured display firmware model has changed, do you want to start the update now? Current Model: {self.current_display_model} Configured Model: {self.desired_display_firmware_model} If the update fails check the installation manual and flash your version again over the Tasmota console. Be patient, the update will take a while."
|
||||||
self.send_message_page("updateDisplayNoYes", "Display Update available!", update_msg, "Dismiss", "Yes")
|
self.send_message_page("updateDisplayNoYes", "Display Update available!", update_msg, "Dismiss", "Yes")
|
||||||
return True
|
return True
|
||||||
|
|
||||||
# check if display firmware needs an update
|
# check if display firmware needs an update
|
||||||
if self.current_display_firmware_version < self.desired_display_firmware_version:
|
if self.current_display_firmware_version < self.desired_display_firmware_version:
|
||||||
LOGGER.info("Update of Display Firmware needed")
|
self._log("Update of Display Firmware needed")
|
||||||
# in auto mode just do the update
|
# in auto mode just do the update
|
||||||
if self.mode == "auto":
|
if self.mode == "auto":
|
||||||
self.update_panel_driver()
|
self.update_panel_driver()
|
||||||
@@ -78,7 +77,7 @@ class Updater:
|
|||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
else:
|
else:
|
||||||
LOGGER.info("Update Pre-Check failed Tasmota Driver Version: %s Panel Version: %s", self.current_tasmota_driver_version, self.current_display_firmware_version)
|
self._log("Update Pre-Check failed Tasmota Driver Version: %s Panel Version: %s", self.current_tasmota_driver_version, self.current_display_firmware_version)
|
||||||
return False
|
return False
|
||||||
|
|
||||||
def request_berry_driver_version(self):
|
def request_berry_driver_version(self):
|
||||||
|
|||||||
@@ -8,46 +8,10 @@ from luibackend.controller import LuiController
|
|||||||
from luibackend.mqttListener import LuiMqttListener
|
from luibackend.mqttListener import LuiMqttListener
|
||||||
from luibackend.updater import Updater
|
from luibackend.updater import Updater
|
||||||
|
|
||||||
LOGGER = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
class AppDaemonLoggingHandler(logging.Handler):
|
|
||||||
def __init__(self, app):
|
|
||||||
super().__init__()
|
|
||||||
self._app = app
|
|
||||||
|
|
||||||
def emit(self, record):
|
|
||||||
message = record.getMessage()
|
|
||||||
if record.exc_info:
|
|
||||||
message += '\nTraceback (most recent call last):\n'
|
|
||||||
message += '\n'.join(traceback.format_tb(record.exc_info[2]))
|
|
||||||
message += f'{record.exc_info[0].__name__}: {record.exc_info[1]}'
|
|
||||||
self._app.log(message, level=record.levelname)
|
|
||||||
|
|
||||||
|
|
||||||
class NsPanelLovelaceUIManager(hass.Hass):
|
class NsPanelLovelaceUIManager(hass.Hass):
|
||||||
def __init__(self, *args, **kwargs):
|
|
||||||
super().__init__(*args, **kwargs)
|
|
||||||
self._redirect_logging()
|
|
||||||
|
|
||||||
def _redirect_logging(self):
|
|
||||||
# Add a handler for the logging module that will convert the
|
|
||||||
# calls to AppDaemon's logger with the self instance, so that
|
|
||||||
# we can simply use logging in the rest of the application
|
|
||||||
rlogger = logging.getLogger()
|
|
||||||
rlogger.handlers = [
|
|
||||||
h for h in rlogger.handlers
|
|
||||||
if type(h).__name__ != AppDaemonLoggingHandler.__name__
|
|
||||||
]
|
|
||||||
rlogger.addHandler(AppDaemonLoggingHandler(self))
|
|
||||||
|
|
||||||
# We want to grab all the logs, AppDaemon will
|
|
||||||
# then care about filtering those we asked for
|
|
||||||
rlogger.setLevel(logging.DEBUG)
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def initialize(self):
|
def initialize(self):
|
||||||
LOGGER.info('Starting')
|
self.log('Starting')
|
||||||
mqtt_api = self._mqtt_api = self.get_plugin_api("MQTT")
|
mqtt_api = self._mqtt_api = self.get_plugin_api("MQTT")
|
||||||
cfg = self._cfg = LuiBackendConfig(self, self.args["config"])
|
cfg = self._cfg = LuiBackendConfig(self, self.args["config"])
|
||||||
|
|
||||||
@@ -55,7 +19,7 @@ class NsPanelLovelaceUIManager(hass.Hass):
|
|||||||
def send_mqtt_msg(msg, topic=None):
|
def send_mqtt_msg(msg, topic=None):
|
||||||
if topic is None:
|
if topic is None:
|
||||||
topic = topic_send
|
topic = topic_send
|
||||||
LOGGER.info(f"Sending MQTT Message: {msg}")
|
self.log(f"Sending MQTT Message: {msg}")
|
||||||
mqtt_api.mqtt_publish(topic, msg)
|
mqtt_api.mqtt_publish(topic, msg)
|
||||||
|
|
||||||
# Request Tasmota Driver Version
|
# Request Tasmota Driver Version
|
||||||
@@ -82,9 +46,9 @@ class NsPanelLovelaceUIManager(hass.Hass):
|
|||||||
|
|
||||||
mode = cfg.get("updateMode")
|
mode = cfg.get("updateMode")
|
||||||
topic_send = cfg.get("panelSendTopic")
|
topic_send = cfg.get("panelSendTopic")
|
||||||
updater = Updater(send_mqtt_msg, topic_send, mode, desired_display_firmware_version, model, desired_display_firmware_url, desired_tasmota_driver_version, desired_tasmota_driver_url)
|
updater = Updater(self.log, send_mqtt_msg, topic_send, mode, desired_display_firmware_version, model, desired_display_firmware_url, desired_tasmota_driver_version, desired_tasmota_driver_url)
|
||||||
|
|
||||||
topic_recv = cfg.get("panelRecvTopic")
|
topic_recv = cfg.get("panelRecvTopic")
|
||||||
LuiMqttListener(mqtt_api, topic_recv, controller, updater)
|
LuiMqttListener(mqtt_api, topic_recv, controller, updater)
|
||||||
|
|
||||||
LOGGER.info('Started')
|
self.log('Started')
|
||||||
|
|||||||
Reference in New Issue
Block a user