_C001_DomoHTTP.py

#!/usr/bin/env python3
#############################################################################
################# Domoticz HTTP Controller for RPIEasy ######################
#############################################################################
#
# Only one way data sending supported for obvious reasons.
#
# Copyright (C) 2018-2019 by Alexander Nagy - https://bitekmindenhol.blog.hu/
#
import controller
import rpieGlobals
from helper_domoticz import *
import misc
import urllib.request
from multiprocessing import Process
import base64

class Controller(controller.ControllerProto):
 CONTROLLER_ID = 1
 CONTROLLER_NAME = "Domoticz HTTP"

 def __init__(self,controllerindex):
  controller.ControllerProto.__init__(self,controllerindex)
  self.usesID = True
  self.usesAccount = True
  self.usesPassword = True

 def senddata(self,idx,sensortype,value,userssi=-1,usebattery=-1,tasknum=-1,changedvalue=-1):
  if self.enabled:
   if int(idx) != 0:
    if int(sensortype)==rpieGlobals.SENSOR_TYPE_SWITCH:
      url = "/json.htm?type=command&param=switchlight&idx="
      url += str(idx)
      url += "&switchcmd="
      if int(value[0]) == 0:
         url += "Off"
      else:
         url += "On"
    elif int(sensortype)==rpieGlobals.SENSOR_TYPE_DIMMER:
      url = "/json.htm?type=command&param=switchlight&idx="
      url += str(idx)
      url += "&switchcmd="
      if int(value[0]) == 0:
       url += "Off"
      else:
       url += "Set%20Level&level="
       url += str(value[0])
    else:
     url = "/json.htm?type=command&param=udevice&idx="
     url += str(idx)
     url += "&nvalue=0&svalue="
     url += formatDomoticzSensorType(sensortype,value)
    url += "&rssi="
    url += mapRSSItoDomoticz(userssi)
    if usebattery != -1 and usebattery != 255: # battery input 0..100%, 255 means not supported
     url += "&battery="
     url += str(usebattery)
    else:
     bval = misc.get_battery_value()
     url += "&battery="
     url += str(bval)
    urlstr = "http://"+self.controllerip+":"+self.controllerport+url+self.getaccountstr()
    misc.addLog(rpieGlobals.LOG_LEVEL_DEBUG,urlstr) # sendviahttp
    httpproc = Process(target=self.urlget, args=(urlstr,))  # use multiprocess to avoid blocking
    httpproc.start()
   else:
    misc.addLog(rpieGlobals.LOG_LEVEL_ERROR,"MQTT : IDX cannot be zero!")

 def urlget(self,url):
  try:
   content = urllib.request.urlopen(url,None,2)
  except:
   misc.addLog(rpieGlobals.LOG_LEVEL_ERROR,"Controller: "+self.controllerip+" connection failed")

 def getaccountstr(self):
  retstr = ""
  if self.controlleruser!="" or self.controllerpassword!="":
    acc = base64.b64encode(bytes(self.controlleruser,"utf-8")).decode("utf-8")
    pw =  base64.b64encode(bytes(self.controllerpassword,"utf-8")).decode("utf-8")
    retstr = "&username="+ str(acc) +"&password="+ str(pw)
  return retstr