HomeServerIOExt/ioext/ioext.py

#!/usr/bin/python3 -u
#
import serial
from time import sleep
import os
import sys
import paho.mqtt.client as mqtt
import json

# --- CONFIGURATION ---
import config
# --- END CONFIGURATION ---



# --- GLOBAL VARS ---
noReceiveCount = 0  # increase everytime the serial readline times out (1s timeout)
#getStatusCount = 0  # used as heartbeat, get status every 30s
verbose = False
debug = False
quiet = True

lastState_tk = None
lastState_pir1 = None
lastState_pir2 = None
# --- END GLOBAL VARS ---


if len(sys.argv) >= 2:
    if sys.argv[1] == "-q":
        verbose = False
        debug = False
        quiet = True
        #print("VERBOSE=ON")
    elif sys.argv[1] == "-v":
        verbose = True
        debug = False
        quiet = False
        #print("VERBOSE=ON")
    elif sys.argv[1] == "-d":
        verbose = True
        quiet = False
        debug = True
        #print("DEBUG=ON")


def on_connect(client, userdata, flags, rc):
    if not quiet:
        print("MQTT connected with result code " + str(rc))
    #client.subscribe(mqtt_topic_cmd)
    
#def on_message(client, userdata, msg):    
#    if msg.topic == mqtt_topic_cmd:
#        payload = msg.payload.decode('ascii')
#        if payload == "status" or payload == "get conf" or payload == "clear" or payload == "open door" or payload.startswith("set prof ") or payload.startswith("set conf "):
#            if verbose:
#                print("serCmd: " + payload)
#            serCmd = payload + '\n'
#            ser.write(serCmd.encode('ascii'))
#        elif verbose:
#            print("unknown command:", payload)

def touch(fname, times=None):
    with open(fname, 'a'):
        os.utime(fname, times)

mqttc = mqtt.Client()
mqttc.on_connect = on_connect
#mqttc.on_disconnect = on_disconnect
#mqttc.on_message = on_message

mqttc.username_pw_set(config.mqtt_user, config.mqtt_password)
mqttc.connect(config.mqtt_server, config.mqtt_port, 60)

mqttc.loop_start()

ser = serial.Serial(port=config.serialPort,
    baudrate = config.serialBaud,
    parity=serial.PARITY_NONE,
    stopbits=serial.STOPBITS_ONE,
    bytesize=serial.EIGHTBITS,
    timeout=config.serialTimeout)
    


try:
    while True:
        ##ser.flushInput()        ## attention truncates incoming strings if there is little time between them 
        
        #read buffer until cr/lf
        serLine = ser.readline().strip()
        
        # catch exception on invalid char coming in: UnicodeDecodeError: 'ascii' codec can't decode byte 0xf4 in position 6: ordinal not in range(128)
        try: 
            serLine = serLine.decode('ascii')
        except:
            serLine = ""
        
        # if there came something in...
        if(serLine):
            noReceiveCount = 0
            
            # touch status file if configured
            try:
                config.statusFile
            except:
                if debug:
                    print("statusFile not defined")
            else:
                if config.statusFile is not None and config.statusFile != "":
                    try:
                        touch(config.statusFile)
                    except:
                        if debug:
                            print("ERROR - could not touch statusFile '" + str(config.statusFile) + "'")
                else:
                    if debug:
                        print("statusFile not configured")                        
            
            if verbose:
                print ('RX: ' + repr(serLine))    #Echo the serial buffer bytes up to the CRLF back to screen
            mqttc.publish(config.mqtt_base_topic + "/RX", str(serLine), qos=0, retain=False)
            
            # Tuerkontakt
            if serLine.startswith('P2='):
                newState = None
                if serLine == "P2=L":
                    newState = "OFF"
                elif serLine == "P2=H":
                    newState = "ON"
                    
                if newState is not None and lastState_tk != newState:
                    lastState_tk = newState
                    mqttc.publish(config.mqtt_topic_tuerkontakt, newState, qos=0, retain=False)
                    
            # PIR #1
            if serLine.startswith('P3='):
                newState = None
                if serLine == "P3=L":
                    newState = "OFF"
                elif serLine == "P3=H":
                    newState = "ON"
                    
                if newState is not None and lastState_pir1 != newState:
                    lastState_pir1 = newState
                    mqttc.publish(config.mqtt_topic_pir1, newState, qos=0, retain=False)
            
            # PIR #2
            if serLine.startswith('P4='):
                newState = None
                if serLine == "P4=L":
                    newState = "OFF"
                elif serLine == "P4=H":
                    newState = "ON"
                
                if newState is not None and lastState_pir2 != newState:
                    lastState_pir2 = newState
                    mqttc.publish(config.mqtt_topic_pir2, newState, qos=0, retain=False)
                   
            # DHT TH sensor
            # {"T":26.60,"H":36}
            if serLine.startswith('{"T":'):
                th = json.loads(serLine)
                t = round(float(th["T"]), 1)
                h = int(th["H"])
                if t >= -20 and t <= 50:
                    mqttc.publish(config.mqtt_topic_out_temp, str(t), qos=0, retain=False)
                if h >= 0 and h <= 100:
                    mqttc.publish(config.mqtt_topic_out_hum, str(h), qos=0, retain=False)
                
                
        # nothing came in this time...
        else:
            noReceiveCount += 1
            if debug:
                print("noReceiveCount=" + str(noReceiveCount))
            
            # quit script if nothing has been received for some time - will be restarted by systemd
            if noReceiveCount >= config.quitOnNoReceiveTimeout:
                quit()
            
except KeyboardInterrupt:
    print('\n')