From 0aba139aeff8ff80757c5d36502413299a0b449e Mon Sep 17 00:00:00 2001 From: Evgeny Zinoviev Date: Thu, 11 May 2023 04:18:08 +0300 Subject: mqtt, esp: add new esp8266-based device --- src/relay_mqtt_util.py | 45 --------------------------------------------- 1 file changed, 45 deletions(-) delete mode 100755 src/relay_mqtt_util.py (limited to 'src/relay_mqtt_util.py') diff --git a/src/relay_mqtt_util.py b/src/relay_mqtt_util.py deleted file mode 100755 index 45d2405..0000000 --- a/src/relay_mqtt_util.py +++ /dev/null @@ -1,45 +0,0 @@ -#!/usr/bin/env python3 -from typing import Optional -from argparse import ArgumentParser - -from home.config import config -from home.mqtt import MQTTRelay, MQTTRelayDevice -from home.mqtt.payload import MQTTPayload -from home.mqtt.payload.relay import ( - InitialStatPayload, StatPayload, OTAResultPayload -) - -mqtt_relay: Optional[MQTTRelay] = None - - -def on_mqtt_message(device_id, p: MQTTPayload): - message = None - - if isinstance(p, InitialStatPayload) or isinstance(p, StatPayload): - message = f'[stat] state={"on" if p.flags.state else "off"}' - message += f' rssi={p.rssi}' - message += f' free_heap={p.free_heap}' - if isinstance(p, InitialStatPayload): - message += f' fw={p.fw_version}' - - elif isinstance(p, OTAResultPayload): - message = f'[otares] result={p.result} error_code={p.error_code}' - - if message: - print(message) - - -if __name__ == '__main__': - parser = ArgumentParser() - parser.add_argument('--device-id', type=str, required=True) - - config.load('relay_mqtt_util', parser=parser) - arg = parser.parse_args() - - mqtt_relay = MQTTRelay(devices=MQTTRelayDevice(id=arg.device_id)) - mqtt_relay.set_message_callback(on_mqtt_message) - mqtt_relay.configure_tls() - try: - mqtt_relay.connect_and_loop() - except KeyboardInterrupt: - mqtt_relay.disconnect() -- cgit v1.2.3