101 líneas
3.4 KiB
Python
101 líneas
3.4 KiB
Python
import config
|
|
import json
|
|
import lirc
|
|
import logging
|
|
import mqtt
|
|
import report
|
|
import socket
|
|
import time
|
|
|
|
try:
|
|
from config import APP_NAME as ROOT_LOGGER_NAME
|
|
except ImportError:
|
|
ROOT_LOGGER_NAME = 'root'
|
|
logger = logging.getLogger(ROOT_LOGGER_NAME).getChild('main')
|
|
|
|
|
|
class remote_control(mqtt.mqtt_client):
|
|
def __init__(self):
|
|
self.__lirc_client__ = None
|
|
self.__lirc_init__()
|
|
#
|
|
self.__start_data__ = None
|
|
#
|
|
mqtt.mqtt_client.__init__(self, config.APP_NAME, config.MQTT_SERVER, 1883, config.MQTT_USER, config.MQTT_PASS)
|
|
#
|
|
for remote in config.SUPPORTED_REMOTES:
|
|
for command in config.SUPPORTED_REMOTES[remote]:
|
|
topic = config.MQTT_TOPIC + "/" + remote + "/" + command
|
|
self.add_callback(topic, self.mqtt_to_lirc)
|
|
|
|
def __lirc_init__(self):
|
|
if self.__lirc_client__ is not None:
|
|
logger.info("Closing crashed lirc client instance")
|
|
self.__lirc_client__.close()
|
|
logger.info("Initiating lirc connection")
|
|
self.__lirc_client__ = lirc.Client()
|
|
|
|
def mqtt_to_lirc(self, client, userdata, message):
|
|
try:
|
|
payload = json.loads(message.payload)
|
|
except json.decoder.JSONDecodeError:
|
|
payload = None
|
|
#
|
|
remote = message.topic.split("/")[-2]
|
|
command = message.topic.split("/")[-1]
|
|
#
|
|
if payload is None:
|
|
if self.__start_data__ is not None:
|
|
self.__send_stop__(*self.__start_data__)
|
|
self.__start_data__ = None
|
|
self.__send_once__(remote, command)
|
|
elif payload is True:
|
|
if self.__start_data__ is not None:
|
|
self.__send_stop__(*self.__start_data__)
|
|
self.__start_data__ = None
|
|
self.__start_data__ = remote, command
|
|
self.__send_start__(remote, command)
|
|
elif payload is False:
|
|
if self.__start_data__ is None:
|
|
self.__send_stop__(remote, command)
|
|
else:
|
|
self.__send_stop__(*self.__start_data__)
|
|
self.__start_data__ = None
|
|
|
|
def __send_once__(self, remote, command):
|
|
try:
|
|
self.__lirc_client__.send_once(remote, command)
|
|
except (TimeoutError, socket.timeout) as e:
|
|
self.__lirc_timeout_error__()
|
|
else:
|
|
logger.info("Sending once: %s to %s.", command, remote)
|
|
|
|
def __send_start__(self, remote, command):
|
|
try:
|
|
self.__lirc_client__.send_start(remote, command)
|
|
except (TimeoutError, socket.timeout) as e:
|
|
self.__lirc_timeout_error__()
|
|
else:
|
|
logger.info("Sending start: %s to %s.", command, remote)
|
|
|
|
def __send_stop__(self, remote, command):
|
|
try:
|
|
self.__lirc_client__.send_stop(remote, command)
|
|
except (TimeoutError, socket.timeout) as e:
|
|
self.__lirc_timeout_error__()
|
|
else:
|
|
logger.info("Sending stop: %s to %s.", command, remote)
|
|
|
|
def __lirc_timeout_error__(self):
|
|
logger.error("Timeout-Error while sending IR-Command.")
|
|
self.__lirc_init__()
|
|
|
|
|
|
if __name__ == '__main__':
|
|
report.appLoggingConfigure(config.__BASEPATH__, config.LOGTARGET, ((config.APP_NAME, config.LOGLVL), ), fmt=config.formatter, host=config.LOGHOST, port=config.LOGPORT)
|
|
#
|
|
rc = remote_control()
|
|
#
|
|
while (True):
|
|
time.sleep(30)
|