mirror of
https://github.com/letscontrolit/ESPEasy.git
synced 2026-07-28 04:07:47 +00:00
TD-er
81022e4605
The plugin BMx280 can handle BMP280 and BME280. The BMP version has no humidity sensor. For Domoticz you have to send the data formatted differently. Now the same plugin can be used for both BME280 and BMP280 and the settings in Domoticz can be set accordingly.
255 lines
10 KiB
Python
255 lines
10 KiB
Python
from espcore import *
|
|
|
|
import json
|
|
import threading
|
|
from queue import Queue
|
|
from logging import getLogger
|
|
import time
|
|
import re
|
|
|
|
SENSOR_TYPE_SINGLE = 1
|
|
SENSOR_TYPE_TEMP_HUM = 2
|
|
SENSOR_TYPE_TEMP_BARO = 3
|
|
SENSOR_TYPE_TEMP_HUM_BARO = 4
|
|
SENSOR_TYPE_DUAL = 5
|
|
SENSOR_TYPE_TRIPLE = 6
|
|
SENSOR_TYPE_QUAD = 7
|
|
SENSOR_TYPE_TEMP_EMPTY_BARO = 8
|
|
SENSOR_TYPE_SWITCH = 10
|
|
SENSOR_TYPE_DIMMER = 11
|
|
SENSOR_TYPE_LONG = 20
|
|
SENSOR_TYPE_WIND = 21
|
|
|
|
class ControllerEmu:
|
|
"""class that emulates and decodes various types of controllers. run various threads in the background to recveive and queue stuff"""
|
|
|
|
|
|
|
|
def __init__(self):
|
|
self.log=logging.getLogger("controller")
|
|
self.start_mqtt()
|
|
self.start_http()
|
|
self.start_linebased()
|
|
self.log_enabled=True
|
|
|
|
|
|
def start_mqtt(self):
|
|
"""generic mqtt receiver. just queues all reqeived mqtt messages on all topics"""
|
|
getLogger("mqtt").debug("Connecting to {mqtt_broker}".format(mqtt_broker=config.mqtt_broker))
|
|
|
|
import paho.mqtt.client as mqtt
|
|
|
|
mqtt_client = mqtt.Client()
|
|
mqtt_client.connect(config.mqtt_broker, 1883, 60)
|
|
mqtt_client.loop_start()
|
|
mqtt_client.subscribe('#')
|
|
|
|
self.mqtt_messages=Queue()
|
|
def mqtt_on_message(client, userdata, message):
|
|
if self.log_enabled:
|
|
logging.getLogger("mqtt").debug("Received message '" + str(message.payload) + "' on topic '"
|
|
+ message.topic + "' with QoS " + str(message.qos))
|
|
self.mqtt_messages.put(message)
|
|
|
|
mqtt_client.on_message=mqtt_on_message
|
|
|
|
|
|
def clear_mqtt(self):
|
|
"""clear queue"""
|
|
time.sleep(1)
|
|
while not self.mqtt_messages.empty():
|
|
self.mqtt_messages.get()
|
|
|
|
|
|
def start_http(self):
|
|
"""generic http receiver. just queues all shallow copy of all http requests objects"""
|
|
import bottle
|
|
|
|
self.http_requests = Queue()
|
|
@bottle.post('<filename:path>')
|
|
@bottle.get('<filename:path>')
|
|
def urlhandler(filename):
|
|
if self.log_enabled:
|
|
logging.getLogger("http").debug(bottle.request.method+" "+str(dict(bottle.request.params)))
|
|
self.http_requests.put(bottle.request.copy())
|
|
|
|
|
|
http_thread=threading.Thread(target=bottle.run, kwargs=dict(host='0.0.0.0', port=config.http_port, reloader=False, quiet=True))
|
|
http_thread.daemon=True
|
|
http_thread.start()
|
|
|
|
|
|
def clear_http(self):
|
|
"""clear queue"""
|
|
while not self.http_requests.empty():
|
|
self.http_requests.get()
|
|
|
|
|
|
def start_linebased(self):
|
|
"""generic linebased receiver (like telnet). for nodo plugin"""
|
|
import socket
|
|
import sys
|
|
|
|
|
|
self.linebased_lines=Queue()
|
|
|
|
|
|
def handle_connect(connection, client_address):
|
|
if self.log_enabled:
|
|
logging.getLogger("linebased").debug("Connect from "+str(client_address))
|
|
|
|
fh = connection.makefile()
|
|
for line in fh:
|
|
line=line.rstrip()
|
|
if self.log_enabled:
|
|
logging.getLogger("linebased").debug("Recv from "+str(client_address)+" :"+line)
|
|
self.linebased_lines.put( ( client_address, line ) )
|
|
|
|
if self.log_enabled:
|
|
logging.getLogger("linebased").debug("Disconnect from "+str(client_address))
|
|
|
|
def wait_accept():
|
|
# Create a TCP/IP socket
|
|
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
server_address = ('', config.linebased_port)
|
|
sock.bind(server_address)
|
|
sock.listen()
|
|
|
|
while True:
|
|
# Wait for a connection
|
|
connection, client_address = sock.accept()
|
|
connect_thread=threading.Thread(target=handle_connect, kwargs=dict(connection=connection, client_address=client_address))
|
|
connect_thread.daemon=True
|
|
connect_thread.start()
|
|
|
|
accept_thread=threading.Thread(target=wait_accept)
|
|
accept_thread.daemon=True
|
|
accept_thread.start()
|
|
|
|
|
|
def clear_linebased(self):
|
|
"""clear queue"""
|
|
while not self.linebased_lines.empty():
|
|
self.linebased_lines.get()
|
|
|
|
|
|
def clear(self, sleep=0):
|
|
self.clear_http()
|
|
self.clear_mqtt()
|
|
self.clear_linebased()
|
|
time.sleep(sleep)
|
|
|
|
|
|
def recv_domoticz_http(self, sensor_type, idx, timeout=60):
|
|
"""recv a domoticz http request from espeasy, and convert back to espeasy values"""
|
|
|
|
start_time=time.time()
|
|
self.log.info("Waiting for domoticz http request idx {idx} with sensortype {sensor_type}".format(sensor_type=sensor_type,idx=idx))
|
|
|
|
# self.clear_http()
|
|
|
|
# read and parse http requests
|
|
while time.time()-start_time<timeout:
|
|
request=self.http_requests.get(block=True, timeout=timeout)
|
|
if request.path == "/json.htm":
|
|
if int(request.params.get('idx'))==idx:
|
|
if request.params.get('param')=='udevice':
|
|
# svalues_str=request.params.get('svalue').split(";")
|
|
#nooozzz..the ; isnt properly escaped so python only returns the first value. woraround:
|
|
svalues_str=re.findall('svalue=([0-9.;]*)',request.query_string)[0].split(";")
|
|
|
|
svalues=[]
|
|
for svalue in svalues_str:
|
|
try:
|
|
f=float(svalue)
|
|
except:
|
|
f=0
|
|
svalues.append(f)
|
|
|
|
if ( sensor_type==SENSOR_TYPE_SINGLE or sensor_type==SENSOR_TYPE_LONG ) and len(svalues)==1:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_DUAL and len(svalues)==2:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_TEMP_HUM and len(svalues)==3:
|
|
return [svalues[0], svalues[1]]
|
|
elif sensor_type==SENSOR_TYPE_TEMP_BARO and len(svalues)==4:
|
|
return [svalues[0], svalues[1]]
|
|
elif sensor_type==SENSOR_TYPE_TEMP_EMPTY_BARO and len(svalues)==4:
|
|
return [svalues[0], svalues[2]]
|
|
elif sensor_type==SENSOR_TYPE_TRIPLE and len(svalues)==3:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_TEMP_HUM_BARO and len(svalues)==5:
|
|
return [svalues[0],svalues[1], svalues[3]]
|
|
elif sensor_type==SENSOR_TYPE_QUAD and len(svalues)==4:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_WIND and len(svalues)==6:
|
|
return [svalues[0], svalues[2]/10, svalues[3]/10]
|
|
|
|
elif request.params.get('param')=='switchlight':
|
|
if sensor_type==SENSOR_TYPE_DIMMER or sensor_type == SENSOR_TYPE_SWITCH:
|
|
if request.params.get('switchcmd') == 'Off':
|
|
return [0]
|
|
elif request.params.get('switchcmd') == 'On':
|
|
return [1]
|
|
elif request.params.get('switchcmd') == 'Set Level':
|
|
return [float(request.params.get('level'))]
|
|
|
|
raise(Exception("Timeout"))
|
|
|
|
|
|
def recv_domoticz_mqtt(self, sensor_type, idx, timeout=60):
|
|
"""recv a domoticz mqtt request from espeasy, and convert back to espeasy values"""
|
|
|
|
|
|
start_time=time.time()
|
|
self.log.info("Waiting for domoticz mqtt request idx {idx} with sensortype {sensor_type}".format(sensor_type=sensor_type,idx=idx))
|
|
|
|
# self.clear_mqtt()
|
|
|
|
# read and parse mqtt requests
|
|
while time.time()-start_time<timeout:
|
|
message=self.mqtt_messages.get(block=True, timeout=timeout)
|
|
if message.topic == "domoticz/in":
|
|
#decode domoticz json (should be valid json! otherwise there is a bug)
|
|
params=json.loads(message.payload.decode())
|
|
if int(params.get('idx'))==idx:
|
|
if 'command' not in params:
|
|
svalues_str=params.get('svalue').split(";")
|
|
svalues=[]
|
|
for svalue in svalues_str:
|
|
try:
|
|
f=float(svalue)
|
|
except:
|
|
f=0
|
|
svalues.append(f)
|
|
|
|
if ( sensor_type==SENSOR_TYPE_SINGLE or sensor_type==SENSOR_TYPE_LONG ) and len(svalues)==1:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_DUAL and len(svalues)==2:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_TEMP_HUM and len(svalues)==3:
|
|
return [svalues[0], svalues[1]]
|
|
elif sensor_type==SENSOR_TYPE_TEMP_BARO and len(svalues)==4:
|
|
return [svalues[0], svalues[1]]
|
|
elif sensor_type==SENSOR_TYPE_TEMP_EMPTY_BARO and len(svalues)==4:
|
|
return [svalues[0], svalues[2]]
|
|
elif sensor_type==SENSOR_TYPE_TRIPLE and len(svalues)==3:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_TEMP_HUM_BARO and len(svalues)==5:
|
|
return [svalues[0],svalues[1], svalues[3]]
|
|
elif sensor_type==SENSOR_TYPE_QUAD and len(svalues)==4:
|
|
return svalues
|
|
elif sensor_type==SENSOR_TYPE_WIND and len(svalues)==6:
|
|
return [svalues[0], svalues[2]/10, svalues[3]/10]
|
|
|
|
elif params.get('command')=='switchlight':
|
|
if sensor_type==SENSOR_TYPE_DIMMER or sensor_type == SENSOR_TYPE_SWITCH:
|
|
if params.get('switchcmd') == 'Off':
|
|
return [0]
|
|
elif params.get('switchcmd') == 'On':
|
|
return [1]
|
|
elif params.get('Set%20Level'):
|
|
return [int(params.get('Set%20Level'))]
|
|
|
|
raise(Exception("Timeout while expecting mqtt json message"))
|