123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857 |
- #!/usr/bin/python3 -u
- #
- # pip3 install pyyaml paho-mqtt pyserial
- import yaml
- from yaml.constructor import ConstructorError
- import serial
- import sys
- import time
- from time import sleep
- from time import localtime, strftime
- import datetime
- import paho.mqtt.client as mqtt
- import json
- import os
- import re
- import configparser
- version = 0.3
- # Change working dir to the same dir as this script
- os.chdir(sys.path[0])
- config = configparser.ConfigParser()
- config.read('cul2mqtt.ini')
- # global variables
- verbose = False
- debug = False
- quiet = True
- serialCULAvailable = False
- devdata = {}
- RXcodesToDevFunction_IT = {}
- RXcodesToDevFunction_RAW = {}
- InTopicsToDevIds = {}
- # config vars
- deviceConfigFile = config['main'].get('devices_config_yml')
- log_enable = config['main'].getboolean('log_enable')
- log_path = config['main'].get('log_path')
- if not os.path.exists(log_path):
- os.makedirs(log_path)
- mqtt_server = config['mqtt'].get('server')
- mqtt_port = config['mqtt'].getint('port')
- mqtt_user = config['mqtt'].get('user')
- mqtt_password = config['mqtt'].get('password')
- TX_interface_prefer = config['main'].get('TX_interface_prefer') # UART or MQTT
- repeat_received_commands = False # not yet implemented
- if len(sys.argv) >= 2:
- if sys.argv[1] == "-q":
- verbose = False
- debug = False
- quiet = True
- elif sys.argv[1] == "-v":
- verbose = True
- debug = False
- quiet = False
- elif sys.argv[1] == "-d":
- verbose = True
- debug = True
- quiet = False
- # serial (USB) CUL device
- receive_from_serial_cul = config['cul'].getboolean('receive_from_serial_cul')
- send_on_serial_cul = config['cul'].getboolean('send_on_serial_cul')
- serialPort = config['cul'].get('serialPort')
- serialBaudrate = config['cul'].getint('serialBaudrate')
- serialTimeout = config['cul'].getint('serialTimeout')
- # CUL init command for normal operation, i.E. X21, X05
- culInitCmd = config['cul'].get('culInitCmd') + '\r\n'
- culSendsRSSI = config['cul'].getboolean('culSendsRSSI') # set depending on culInitCmd chosen
- serialCulInitTimeout = config['cul'].getint('serialCulInitTimeout')
- forceSerialCULConnected = config['cul'].getboolean('forceSerialCULConnected')
- # MQTT CUL
- receive_from_mqtt_cul = config['cul'].getboolean('receive_from_mqtt_cul')
- send_on_mqtt_cul = config['cul'].getboolean('send_on_mqtt_cul')
- mqtt_cul_topic_received = config['cul'].get('mqtt_cul_topic_received')
- mqtt_cul_topic_send = config['cul'].get('mqtt_cul_topic_send')
- filterSelfSentIncomingTimeout = config['main'].get('filterSelfSentIncomingTimeout')
- try:
- from yaml import CLoader as Loader
- except ImportError:
- from yaml import Loader
-
- def no_duplicates_constructor(loader, node, deep=False):
- """Check for duplicate keys."""
- mapping = {}
- for key_node, value_node in node.value:
- key = loader.construct_object(key_node, deep=deep)
- value = loader.construct_object(value_node, deep=deep)
- if key in mapping:
- raise ConstructorError("while constructing a mapping", node.start_mark, "found duplicate key (%s)" % key, key_node.start_mark)
- mapping[key] = value
- return loader.construct_mapping(node, deep)
- yaml.add_constructor(yaml.resolver.BaseResolver.DEFAULT_MAPPING_TAG, no_duplicates_constructor)
- log_last_date = None
- logfilehandle = False
- def log_start():
- global logfilehandle, log_last_date
- if log_enable:
- if not os.path.exists(log_path):
- os.makedirs(log_path)
-
- try:
- _log_current_date = strftime("%Y%m%d")
- _logfilename = _log_current_date + ".log"
- logfilehandle = open(log_path + '/' + _logfilename, 'a')
- log_last_date = _log_current_date
- except:
- pass
- def log_rotate():
- global logfilehandle, log_last_date
- if log_enable:
- _log_current_date = strftime("%Y%m%d")
-
- if log_last_date != _log_current_date:
- try:
- logfilehandle.close()
- _logfilename = _log_current_date + ".log"
- logfilehandle = open(log_path + '/' + _logfilename, 'a')
- log_last_date = _log_current_date
- except:
- pass
-
-
- def log_write(_msg):
- global logfilehandle
- if not quiet: print(_msg)
- log_rotate()
- if log_enable:
- try:
- logfilehandle.write("[" + str(datetime.datetime.now()) + "] " + _msg + "\n")
- logfilehandle.flush()
- except:
- # guat dann hoit ned...
- pass
- log_start()
- log_write("CUL2MQTT v" + str(version))
- log_write("=====================================")
- try:
- with open(deviceConfigFile) as devfile:
- devdata = yaml.load(devfile, Loader=yaml.FullLoader)
- if debug:
- log_write("")
- log_write("")
- log_write("==== parsing config file ====")
- log_write("")
- log_write(devdata)
- log_write("")
-
- for deviceid in devdata:
- if debug:
- log_write("")
- log_write("")
- log_write("Device: " + deviceid)
- log_write(devdata[deviceid])
-
- if "RX" in devdata[deviceid].keys():
- if devdata[deviceid]["RX"] != "":
- if debug:
- log_write("RX codes:")
- for key, value in devdata[deviceid]["RX"].items():
- if debug:
- log_write(str(key) + "->" + str(value))
- if value.startswith("i"):
- # is InterTechno RX code
- if value in RXcodesToDevFunction_IT.keys():
- log_write("")
- log_write("")
- log_write("ERROR: RX-string '" + str(value) + "' is already defined for another device! Must be unique.")
- raise
- else:
- RXcodesToDevFunction_IT[value] = deviceid, key
- else:
- # is other RX code - lets call it RAW
- if value in RXcodesToDevFunction_RAW.keys():
- log_write("")
- log_write("")
- log_write("ERROR: RX-string '" + str(value) + "' is already defined for another device! Must be unique.")
- raise
- else:
- RXcodesToDevFunction_RAW[value] = deviceid, key
-
- if "cmdTopic" in devdata[deviceid].keys():
- if devdata[deviceid]["cmdTopic"] != "":
- cmdTopic = devdata[deviceid]["cmdTopic"]
- if debug:
- log_write("cmdTopic: " + cmdTopic)
- if cmdTopic in InTopicsToDevIds.keys():
- log_write("")
- log_write("")
- log_write("ERROR: cmdTopic '" + str(cmdTopic) + "' is already defined for another device! Must be unique.")
- raise
- else:
- InTopicsToDevIds[cmdTopic] = deviceid
-
- if debug:
- log_write("")
- log_write("")
- log_write("")
- log_write("RXcodesToDevFunction_IT:")
- log_write(RXcodesToDevFunction_IT)
- log_write("")
- log_write("")
- log_write("RXcodesToDevFunction_RAW:")
- log_write(RXcodesToDevFunction_RAW)
- log_write("")
- log_write("")
- log_write("InTopicsToDevIds:")
- log_write(InTopicsToDevIds)
- log_write("")
- log_write("")
- log_write("InTopicsToDevIds.keys():")
- log_write(InTopicsToDevIds.keys())
- log_write("")
- log_write("")
- log_write("devdata.keys():")
- log_write(devdata.keys())
- log_write("")
- log_write("")
- log_write("==== parsing config file complete ====")
- log_write("")
- log_write("")
- log_write("")
- log_write("")
- except ConstructorError as err:
- log_write("ERROR on parsing configfile:")
- log_write(err)
- exit(1)
- except:
- log_write("ERROR opening configfile")
- log_write("Unexpected error: " + str(sys.exc_info()[0]))
- exit(1)
- lastReceivedMaxAge = config['main'].getint('lastReceivedMaxAge') # ignore repeated messages when they are younger than x ms
- lastReceivedTime = dict()
- lastSentTime = {}
- lastSentMinInterval = config['main'].getint('lastSentMinInterval') # ignore repeated messages when they are younger than x ms, should be > 1500
- lastSentCmd = ""
- lastSentCmdTime = 0
- lastSentDev = ""
- lastSentDevCmd = ""
- def touch(fname, times=None):
- with open(fname, 'a'):
- os.utime(fname, times)
- def on_connect(client, userdata, flags, rc):
- if verbose:
- log_write("MQTT connected with result code " + str(rc))
- if receive_from_mqtt_cul:
- if mqtt_cul_topic_received != "":
- client.subscribe(mqtt_cul_topic_received)
-
- if mqtt_cul_topic_send != "":
- #client.publish
- mqttc.publish(mqtt_cul_topic_send, culInitCmd, qos=0, retain=False)
-
- for in_topic in InTopicsToDevIds.keys():
- if in_topic != "":
- client.subscribe(in_topic)
- if verbose:
- log_write("MQTT subscribed: " + in_topic)
- def on_disconnect(client, userdata, rc):
- if rc != 0:
- log_write("Unexpected MQTT disconnection. Will auto-reconnect")
-
- def on_message(client, userdata, msg):
- #print(msg.topic + ": " + str(msg.payload))
- payload = msg.payload.decode("utf-8")
-
- if verbose:
- log_write("")
- log_write("MQTT received: " + msg.topic + " -> " + str(payload))
-
- # MQTT message is output from CUL
- if receive_from_mqtt_cul and msg.topic == mqtt_cul_topic_received:
- payload = payload.rstrip()
-
- # support output from Tasmota SerialBridge on tele/[DEVICE]/RESULT topic
- # example: {"SerialReceived":"p10 144 80 480 48 32 1360 28 1 3 4 160 6336 0 735C1470"}
- if payload.startswith('{"SerialReceived":'):
- payload_json = json.loads(payload)
- payload = payload_json.get('SerialReceived')
- if payload != None:
- cul_received(payload, "MQTT") # to lower case as MQTT CUL via Tasmota SerialBridge with Rule changes output to all uppercase
- if verbose:
- log_write("MQTT-CUL RX: '" + payload + "'")
- elif not payload.startswith('{'):
- # ignore everything different starting with {
- cul_received(payload.lower(), "MQTT") # to lower case as MQTT CUL via Tasmota SerialBridge with Rule changes output to all uppercase
- if verbose:
- log_write("MQTT-CUL RX: '" + payload.lower() + "'")
-
- else:
- for in_topic, dev in InTopicsToDevIds.items():
- if msg.topic == in_topic:
- if verbose: log_write("MQTT received - '" + msg.topic + "' = '" + payload + "' => DEV: " + dev)
-
- if 'name' in devdata[dev].keys():
- log_write('devName: ' + devdata[dev]['name'])
-
- global lastSentDev, lastSentDevCmd, lastSentCmdTime
- now = int(round(time.time() * 1000))
- if debug:
- log_write("dev="+dev+", lastSentDevCmd="+lastSentDevCmd)
- if dev == lastSentDev and payload == lastSentDevCmd and (now - lastSentCmdTime) < 1000:
- if verbose:
- log_write("MQTT: ignored command as we just sent this.")
- else:
- cul_send(dev, payload)
-
- if 'statTopic' in devdata[dev].keys():
- if verbose: log_write('statTopic: ' + devdata[dev]['statTopic'])
- mqttc.publish(devdata[dev]['statTopic'], payload, qos=0, retain=False)
-
- if 'add_statTopics_on' in devdata[dev].keys():
- if verbose: log_write("add_statTopics_on:")
- for res in devdata[dev]['add_statTopics_on']:
- if 'on_payload' in res and 'topic' in res and 'payload' in res:
- if payload == res['on_payload'] and payload != "" and res['topic'] != "" and res['payload'] != "":
- if verbose: log_write(" on '" + payload + "': '" + res['payload'] + "' => '" + res['topic'] + "'")
- mqttc.publish(res[topic], res[payload], qos=0, retain=False)
-
- def publish_device_statusupdate(device, cmd):
- if device in devdata.keys():
- if 'statTopic' in devdata[device].keys():
- statTopic = devdata[device].get('statTopic')
- if verbose: log_write("MQTT publish: '" + cmd + "' -> '" + statTopic + "'")
- mqttc.publish(statTopic, cmd, qos=0, retain=False)
-
- if 'add_statTopics_on' in devdata[device].keys():
- if verbose: log_write(" MQTT publish add_statTopics_on:")
- for res in devdata[device].get('add_statTopics_on'):
- if 'on_payload' in res and 'topic' in res and 'payload' in res:
- if cmd == res['on_payload']:
- if verbose: log_write(" on '" + res['on_payload'] + "' -> publish '" + res['payload'] + "' on topic '" + res['topic'] + "'")
- mqttc.publish(res['topic'], res['payload'], qos=0, retain=False)
-
- if 'add_statTopics' in devdata[device].keys():
- if verbose: log_write(" MQTT publish on add_statTopics:")
- for res in devdata[device]['add_statTopics']:
- if verbose: log_write(" '" + cmd + "' -> '" + res + "'")
- mqttc.publish(res, cmd, qos=0, retain=False)
-
- def parseRXCode(rx_code, source_cul):
- receivedForDevice = None
- receivedCmnd = None
-
- if rx_code.startswith("i"):
- # parse InterTechno RX code
- if debug: log_write("INTERTECHNO PROTOCOL")
- sucessfullyParsedITCode = False
-
- # look if this code is in the device_config
- if rx_code in RXcodesToDevFunction_IT:
- receivedForDevice = RXcodesToDevFunction_IT[rx_code][0]
- receivedCmnd = RXcodesToDevFunction_IT[rx_code][1]
- sucessfullyParsedITCode = True
- if debug: log_write("DEV: " + receivedForDevice + ", CMD: " + receivedCmnd + ", RX: " + rx_code)
- if verbose:
- log_write("")
- log_write("CUL '" + source_cul + "' received '" + rx_code + "' => DEV: " + receivedForDevice + ", CMD: " + receivedCmnd)
-
- # if this had no result -> try again with removed last 2 chars as it is in many cases omitted as its only RSSI and not part of the code
- rx_code = rx_code[0:-2]
- if not sucessfullyParsedITCode and rx_code in RXcodesToDevFunction_IT:
- receivedForDevice = RXcodesToDevFunction_IT[rx_code][0]
- receivedCmnd = RXcodesToDevFunction_IT[rx_code][1]
- sucessfullyParsedITCode = True
- if debug: log_write("DEV: " + receivedForDevice + ", CMD: " + receivedCmnd + ", RX: " + rx_code)
- if verbose:
- log_write("")
- log_write("CUL '" + source_cul + "' received '" + rx_code + "' => DEV: " + receivedForDevice + ", CMD: " + receivedCmnd)
-
- # if this also did not work, try to parse it as "default/cheap" IT code...
- if not sucessfullyParsedITCode:
- receivedForDevice, receivedCmnd = decodeInterTechnoRX(rx_code)
- if debug:
- log_write(str(receivedForDevice) + ", " + str(receivedCmnd))
-
- else:
- # parse other/RAW RX code
- if debug: log_write("OTHER/RAW PROTOCOL")
- if rx_code in RXcodesToDevFunction_RAW:
- receivedForDevice = RXcodesToDevFunction_RAW[rx_code][0]
- receivedCmnd = RXcodesToDevFunction_RAW[rx_code][1]
- if debug: log_write("DEV: " + receivedForDevice + ", CMD: " + receivedCmnd + ", RX: " + rx_code)
- if verbose:
- log_write("")
- log_write("CUL '" + source_cul + "' received '" + rx_code + "' => DEV: " + receivedForDevice + ", CMD: " + receivedCmnd)
-
- if debug:
- log_write("DEV: " + str(receivedForDevice) + ", CMD: " + str(receivedCmnd) + ", RX: " + rx_code)
-
- if receivedForDevice != None and receivedCmnd != None and receivedForDevice != False and receivedCmnd != False:
- publish_device_statusupdate(receivedForDevice, receivedCmnd)
- def decodeInterTechnoRX(rx_code):
- # decode old fixed code from InterTechno remotes
- _housecode = None
- _devaddr = None
- _command = None
- _itname = None
-
- #print(rx_code[0:1])
- #print(rx_code[1:3])
- #print(rx_code[3:5])
- #print(rx_code[5:7])
-
- if rx_code[0:1] == "i":
- if rx_code[1:3] == "00": _housecode = "A"
- elif rx_code[1:3] == "40": _housecode = "B"
- elif rx_code[1:3] == "10": _housecode = "C"
- elif rx_code[1:3] == "50": _housecode = "D"
- elif rx_code[1:3] == "04": _housecode = "E"
- elif rx_code[1:3] == "44": _housecode = "F"
- elif rx_code[1:3] == "14": _housecode = "G"
- elif rx_code[1:3] == "54": _housecode = "H"
- elif rx_code[1:3] == "01": _housecode = "I"
- elif rx_code[1:3] == "41": _housecode = "J"
- elif rx_code[1:3] == "11": _housecode = "K"
- elif rx_code[1:3] == "51": _housecode = "L"
- elif rx_code[1:3] == "05": _housecode = "M"
- elif rx_code[1:3] == "45": _housecode = "N"
- elif rx_code[1:3] == "15": _housecode = "O"
- elif rx_code[1:3] == "55": _housecode = "P"
-
- if rx_code[3:5] == "00": _devaddr = "1"
- elif rx_code[3:5] == "40": _devaddr = "2"
- elif rx_code[3:5] == "10": _devaddr = "3"
- elif rx_code[3:5] == "50": _devaddr = "4"
- elif rx_code[3:5] == "04": _devaddr = "5"
- elif rx_code[3:5] == "44": _devaddr = "6"
- elif rx_code[3:5] == "14": _devaddr = "7"
- elif rx_code[3:5] == "54": _devaddr = "8"
- elif rx_code[3:5] == "01": _devaddr = "9"
- elif rx_code[3:5] == "41": _devaddr = "10"
- elif rx_code[3:5] == "11": _devaddr = "11"
- elif rx_code[3:5] == "51": _devaddr = "12"
- elif rx_code[3:5] == "05": _devaddr = "13"
- elif rx_code[3:5] == "45": _devaddr = "14"
- elif rx_code[3:5] == "15": _devaddr = "15"
- elif rx_code[3:5] == "55": _devaddr = "16"
-
- if rx_code[5:7] == "15": _command = "ON"
- elif rx_code[5:7] == "14": _command = "OFF"
-
- if _housecode != None and _devaddr != None and _command != None:
- _itname = "IT_" + _housecode + _devaddr
- if debug: log_write("valid IT code: '" + _itname + "' => '" + _command + "'")
- return _itname, _command
-
- else:
- if debug: log_write("unknown or invalid IT code '" + rx_code + "'")
- return False, False
- else:
- if debug: log_write("unknown or invalid IT code '" + rx_code + "'")
- def encodeInterTechnoRX(itname, cmd):
- # decode old fixed code from InterTechno remotes
- _housecode = None
- _devaddr = None
- _command = None
-
- #print(itname[0:3])
- #print(itname[3:4])
- #print(itname[4:])
-
- if itname[0:3] == "IT_":
- if itname[3:4] == "A": _housecode = "00"
- elif itname[3:4] == "B": _housecode = "40"
- elif itname[3:4] == "C": _housecode = "10"
- elif itname[3:4] == "D": _housecode = "50"
- elif itname[3:4] == "E": _housecode = "04"
- elif itname[3:4] == "F": _housecode = "44"
- elif itname[3:4] == "G": _housecode = "14"
- elif itname[3:4] == "H": _housecode = "54"
- elif itname[3:4] == "I": _housecode = "01"
- elif itname[3:4] == "J": _housecode = "41"
- elif itname[3:4] == "K": _housecode = "11"
- elif itname[3:4] == "L": _housecode = "51"
- elif itname[3:4] == "M": _housecode = "05"
- elif itname[3:4] == "N": _housecode = "45"
- elif itname[3:4] == "O": _housecode = "15"
- elif itname[3:4] == "P": _housecode = "55"
-
- if itname[4:] == "1": _devaddr = "00"
- elif itname[4:] == "2": _devaddr = "40"
- elif itname[4:] == "3": _devaddr = "10"
- elif itname[4:] == "4": _devaddr = "50"
- elif itname[4:] == "5": _devaddr = "04"
- elif itname[4:] == "6": _devaddr = "44"
- elif itname[4:] == "7": _devaddr = "14"
- elif itname[4:] == "8": _devaddr = "54"
- elif itname[4:] == "9": _devaddr = "01"
- elif itname[4:] == "10": _devaddr = "41"
- elif itname[4:] == "11": _devaddr = "11"
- elif itname[4:] == "12": _devaddr = "51"
- elif itname[4:] == "13": _devaddr = "05"
- elif itname[4:] == "14": _devaddr = "45"
- elif itname[4:] == "15": _devaddr = "15"
- elif itname[4:] == "16": _devaddr = "55"
-
- if cmd == "ON": _command = "15"
- elif cmd == "OFF": _command = "14"
-
- if debug: print("IT housecode=", _housecode, "- devaddr=", _devaddr, "- command=", _command)
-
- if _housecode != None and _devaddr != None and _command != None:
- _rxcode = "i" + _housecode + _devaddr + _command
- #print("encoded IT RX code: '" + itname + "' => '" + cmd + "' = '" + _rxcode)
- return _rxcode
-
- else:
- if debug: log_write("unknown or invalid IT code '" + rx_code + "'")
- return False
-
- else:
- if debug: log_write("unknown or invalid IT code '" + rx_code + "'")
- def cul_received(payload, source_cul):
- global lastReceivedTime, lastReceivedMaxAge
-
- if payload[:2] == 'is': # msg is reply from CUL to raw send command
- pass
-
- elif payload[:1] == 'i': # is a IT compatible command - so look it up in the code table
-
- if culSendsRSSI:
- inCmd = payload[:-2] #strip last 2 chars, depending on used CUL receive mode - if enabled this is only RSSI
- else:
- inCmd = payload
-
- if verbose:
- log_write("inCmd: " + inCmd + ", receiving CUL: " + source_cul)
-
- # filter fast repeated commands (strip first char on IT commands as the repetation will come in as RAW without "i" prefix)
- ignoreCommand = False
- if inCmd in lastReceivedTime.keys():
- lastTime = int(lastReceivedTime[inCmd])
- now = int(round(time.time() * 1000))
- tdelta = (now - lastTime)
- if debug: log_write("TDELTA = " + str(tdelta))
- if debug: log_write("lastTime = " + str(lastTime))
-
- if tdelta < lastReceivedMaxAge:
- if verbose: log_write("ignoring command from CUL '" + source_cul + "', CMD: '" + inCmd + "' - already received " + str(tdelta) + " ms ago")
- ignoreCommand = True
-
- if not ignoreCommand:
- lastReceivedTime[inCmd] = int(round(time.time() * 1000))
- parseRXCode(inCmd, source_cul)
-
- elif payload[:1] == 'p': # is RAW data
- # example: "p11 288 864 800 320 288 832 33 1 4 1 288 10224 0 A4CEF09580"
- # split string and extract last row as we dont need the rest
- splitPayload = payload.split(' ')
- actualPayload = splitPayload[len(splitPayload)-1]
- if debug: log_write("actualPayload: '" + actualPayload)
-
- ignoreCommand = False
-
- # handle/filter repetations of IT commands
- isITrepetation = False
- if ('i'+actualPayload) in lastReceivedTime.keys():
- isITrepetation = True
- if debug: log_write("IS IT REPETATION")
- lastTime = int(lastReceivedTime['i'+actualPayload])
- now = int(round(time.time() * 1000))
- tdelta = (now - lastTime)
- if debug: log_write("TDELTA = " + str(tdelta))
- if tdelta < lastReceivedMaxAge:
- if verbose: log_write("ignoring command from CUL '" + source_cul + "', CMD: '" + 'i'+actualPayload + "' - already received " + str(tdelta) + " ms ago")
- ignoreCommand = True
-
- # filter fast repeated commands
- if not isITrepetation:
- if actualPayload in lastReceivedTime.keys():
- lastTime = int(lastReceivedTime[actualPayload])
- now = int(round(time.time() * 1000))
- tdelta = (now - lastTime)
- if debug: log_write("TDELTA = " + str(tdelta))
- if tdelta < lastReceivedMaxAge:
- if verbose: log_write("ignoring command from CUL '" + source_cul + "', CMD: '" + actualPayload + "' - already received " + str(tdelta) + " ms ago")
- ignoreCommand = True
-
- if not ignoreCommand:
- if isITrepetation:
- # treat as IT command
- lastReceivedTime['i'+actualPayload] = int(round(time.time() * 1000))
- parseRXCode('i'+actualPayload, source_cul)
- else:
- lastReceivedTime[actualPayload] = int(round(time.time() * 1000))
- parseRXCode(actualPayload, source_cul)
-
- #if repeat_received_commands:
- # lastSentLength = len(lastSent)
- # i = 0
- # dontRepeat = False
- # while i < lastSentLength:
- # #print(str(i) + ": " + lastReceived[i])
- # if lastSent[i] == decCmd:
- # lastTime = int(lastSentTime[i])
- # now = int(round(time.time() * 1000))
- # tdelta = (now - lastTime)
- # #print("TDELTA = " + str(tdelta))
- # if tdelta < lastSentMaxAge:
- # print("ignoring command as it originated from ourselfs " + inCmd + " " + str(tdelta) + " ms ago")
- # dontRepeat = True
- # #break
- # i += 1
- # #cmdToSend = culSendCmds[decCmd]
- # if not dontRepeat:
- # if device != "" and cmd != "":
- # print("REPEATING COMMAND: " + cmd + " TO DEVICE " + device)
- # cul_send(device, cmd)
-
- def IT_RXtoTXCode(itReceiveCode):
- if debug:
- statusstr = "IT_RXtoTXCode "
- statusstr += "RX: "
- statusstr += itReceiveCode
- #print("IT_RXtoTXCode ReceiveCode: " + itReceiveCode)
-
- itReceiveCode = itReceiveCode[1:] # remove first character "i"
- itReceiveCodeLengthBytes = int(len(itReceiveCode)/2)
-
- itReceiveCodeBytes = []
- itTransmitTristate = "is"
-
- for x in range(itReceiveCodeLengthBytes):
- itReceiveCodeBytes.append(bin(int(itReceiveCode[x*2:(x*2+2)],16))[2:].zfill(8))
-
- for x in range(len(itReceiveCodeBytes)):
- #print("IT REC byte " + str(x) + " = " + str(itReceiveCodeBytes[x]))
- for y in range(4):
- quarterbyte = str(itReceiveCodeBytes[x][y*2:y*2+2])
- if quarterbyte == "00":
- tmpTristate = "0";
- elif quarterbyte == "01":
- tmpTristate = "F";
- elif quarterbyte == "10":
- tmpTristate = "D";
- elif quarterbyte == "11":
- tmpTristate = "1";
- #print(quarterbyte + " -> " + tmpTristate)
- itTransmitTristate = itTransmitTristate + tmpTristate
-
- if debug:
- statusstr += " -> TX: "
- statusstr += itTransmitTristate
- #print("IT_RXtoTXCode TransmitCode: " + itTransmitTristate)
- log_write(statusstr)
-
- return(itTransmitTristate)
-
- def cul_send(device, cmd):
- global lastSentTime
- culCmd = ""
- culSendCmdsKeyName = device + ' ' + cmd
- if debug: log_write("CUL send '" + cmd + "' to device '" + device + "'")
-
- tx_code = False
-
- if 'TX' in devdata[device]:
- if debug: print("TX data available, cmd="+cmd)
- if debug: print(devdata[device]['TX'])
- if cmd in devdata[device]['TX'].keys():
- tx_code = devdata[device]['TX'][cmd]
- if verbose: log_write(" TX code for '" + cmd + "': " + tx_code)
-
- if not tx_code:
- if verbose: log_write(" deviceID: " + device)
- if 'RX' in devdata[device].keys():
- if verbose:
- log_write(" RX code configured, cmd=" + cmd)
- log_write(devdata[device]['RX'])
- if cmd in devdata[device]['RX'].keys():
- rx_code = devdata[device]['RX'][cmd]
- if debug: log_write(" RX code for '" + cmd + "': " + rx_code)
- tx_code = IT_RXtoTXCode(rx_code)
- if verbose: log_write(" TX code for '" + cmd + "': " + tx_code)
- else:
- log_write(" RX code for '" + cmd + "' NOT FOUND")
-
- elif device.startswith("IT_"):
- # InterTechno device with fixed code - encode RX code for IT device name and convert to TX code
- rx_code = encodeInterTechnoRX(device, cmd)
- if rx_code:
- if debug: log_write(" RX code for '" + cmd + "': " + rx_code)
- tx_code = IT_RXtoTXCode(rx_code)
- if verbose: log_write(" TX code for '" + cmd + "': " + tx_code)
-
- if not tx_code:
- if verbose: log_write(" no valid TX code for this device/command")
- else:
- now = int(round(time.time() * 1000))
-
- # look if this command has been sent in the past, and when
- if culSendCmdsKeyName in lastSentTime.keys():
- lastTime = lastSentTime[culSendCmdsKeyName]
- else:
- lastTime = 0
-
- lastTimeAge = now - lastTime
- if verbose: log_write(' lastTime: ' + str(lastTimeAge) + 'ms ago')
-
- if lastTimeAge > lastSentMinInterval: # only send if last time + min interval is exceeded
- lastSentTime[culSendCmdsKeyName] = now # save what we send, so that we dont repeat our own sent messages if repeating is enabled
-
- TX_interface = TX_interface_prefer
- if 'TX_interface' in devdata[device].keys():
- if verbose: log_write(" TX_interface: " + devdata[device]['TX_interface'])
-
- if TX_interface == "UART" and not serialCULAvailable:
- TX_interface = "MQTT"
-
- global lastSentCmd, lastSentCmdTime, lastSentDev, lastSentDevCmd
- lastSentCmd = tx_code
- lastSentCmdTime = now
- lastSentDev = device
- lastSentDevCmd = cmd
-
- if send_on_mqtt_cul and (TX_interface == "MQTT" or TX_interface == "both"):
- log_write(" TX via MQTT: " + tx_code)
- mqttc.publish(mqtt_cul_topic_send, tx_code, qos=0, retain=False)
-
- if serialCULAvailable and send_on_serial_cul and (TX_interface == "UART" or TX_interface == "both"):
- log_write(" TX via UART: " + tx_code)
- culCmd = tx_code + '\r\n'
- ser.write(culCmd.encode('ascii'))
-
- else:
- log_write("WARNING: CUL send command repeated too quickly.")
-
- publish_device_statusupdate(device, cmd)
- # main
- if receive_from_serial_cul or send_on_serial_cul:
- if not os.path.exists(serialPort):
- log_write("ERROR opening connection to serial CUL... device '" + serialPort + "' does not exist.")
- if log_enable: log_write("CUL2MQTT v"+str(version)+" starting")
-
- if receive_from_mqtt_cul:
- if forceSerialCULConnected:
- exit(2)
- else:
- log_write("resuming in MQTT-CUL only mode...")
- TX_interface_prefer = "MQTT"
- receive_from_serial_cul = False
- send_on_serial_cul = False
- serialCULAvailable = False
- log_write("")
- log_write("")
- else:
- log_write("opening connection to serial CUL...")
- serLine = ""
- ser = serial.Serial(port=serialPort,baudrate=serialBaudrate,parity=serial.PARITY_NONE,stopbits=serial.STOPBITS_ONE,bytesize=serial.EIGHTBITS,timeout=serialTimeout)
- sleep(serialCulInitTimeout)
- ser.write('V\r\n'.encode('ascii')) # get CUL version info
- serLine = ser.readline()
- serLine = serLine.decode('ascii').rstrip('\r\n')
- if serLine.startswith("V ") and serLine.find("culfw") != -1:
- log_write("connected. CUL version: " + serLine)
- serialCULAvailable = True
- sleep(0.1)
- log_write('Initializing CUL with command: ' + culInitCmd.rstrip('\r\n'))
- ser.write(culInitCmd.encode('ascii')) # initialize CUL in normal receive mode
- sleep(0.5)
- else:
- log_write("WARNING: could not connect serial CUL")
- receive_from_serial_cul = False
- send_on_serial_cul = False
- serialCULAvailable = False
- TX_interface_prefer = "MQTT"
- if forceSerialCULConnected:
- exit(2)
- mqttc = mqtt.Client()
- mqttc.on_connect = on_connect
- mqttc.on_disconnect = on_disconnect
- mqttc.on_message = on_message
- if mqtt_user is not None and mqtt_password is not None:
- if len(mqtt_user) > 0 and len(mqtt_password) > 0:
- mqttc.username_pw_set(mqtt_user, mqtt_password)
-
- mqttc.connect(mqtt_server, mqtt_port, 60)
- mqttc.loop_start()
- while True:
- if receive_from_serial_cul:
- serLine = ser.readline()
- if len(serLine) > 0:
- now = int(round(time.time() * 1000))
- recvCmd = serLine.decode('ascii')
- recvCmd = recvCmd.rstrip('\r\n')
-
- #if debug:
- # print("lastSentCmd: " + lastSentCmd + ", lastSentCmdTime=" + str(lastSentCmdTime))
-
- if recvCmd == lastSentCmd and (now - lastSentCmdTime) < filterSelfSentIncomingTimeout:
- pass
- else:
- if verbose:
- log_write("")
- log_write("Serial-CUL RX: '" + recvCmd + "'")
- cul_received(recvCmd, "UART")
-
- sleep(0.05)
-
- ## #print "test"
- ## #touch("/tmp/culagent_running")
- #except KeyboardInterrupt:
- # print("\n")
|