Domoticz

Code: Select all

#!/usr/bin/python

import requests
import json
import urllib
import urllib2
import hashlib

from xml.etree import ElementTree as ET

#config plex url
plexURL                         = '192.168.15.23:32400' #base url (default port = 32400)

#domoticz settings
domoticz_user           = 'user' 		#Ange den användare i domoticz som ska användas
domoticz_pwd            = 'password'	 	#Lösenordet för ovan användare
domoticz_host           = '192.168.15.25'
domoticz_port           = '8080'
domoticz_url            = "http://" + domoticz_user + ":" + domoticz_pwd + "@" + domoticz_host + ":" + domoticz_port + "/json.htm"
influxDB_host		= "192.168.15.21:8086"

#domoticz idx

#building url
requestURL = 'http://'+plexURL+'/status/sessions'
print requestURL


def skickaData(videotitle, playinguser, playingstate):
  #Check plex_usernamne
  if playinguser == "Plexuser1":
        domoticz_SwitchIDX = 313   		#domoticz SwitchIDX för Plexuser1
        domoticzvariableIDX  = 1   		#VariableIDX för user 1
        domoticzvariablename = "variable1"	#Domoticz Variable Namn user 1
  elif  playinguser == "Plexuser2":  		
        domoticz_SwitchIDX = 325		
        domoticzvariableIDX = 2			
        domoticzvariablename = "variable2"
  elif  playinguser ==  "Plexuser1": 	
        domoticz_SwitchIDX = 326	
        domoticzvariableIDX = 3
        domoticzvariablename = "variable3"
  elif playinguser == "Plexuser1":
        domoticz_SwitchIDX = 327
        domoticzvariableIDX = 4
        domoticzvariablename = "variable4"
  else:
        result = -1

  #Check variable for specific user in domoticz and parse the json result
  varurl = (domoticz_url+ "?type=command&param=getuservariable&idx=" + str(domoticzvariableIDX))
  variablestaterequest=urllib.urlopen(varurl).read()
  #Parse Json result
  variable_json_object = json.loads(variablestaterequest)
  print "variablState for:",playinguser ,": ", variable_json_object["result"][0]["Value"]
  #Check if playing state has changed according to variable in domoticz
  if playingstate != variable_json_object["result"][0]["Value"]: 
    #Update variable in domoticz
    print "Update domoticz with new state for user", playinguser
    updateVarUrl = (domoticz_url + "?type=command&param=updateuservariable&vname=" + domoticzvariablename + "&vtype=2&vvalue=" + playingstate)
    urllib.urlopen(updateVarUrl).read()
    #Update log in domoticz
    urllib.urlopen(domoticz_url+ "?type=command&param=addlogmessage&message=User: " + playinguser + " Changed Plex Status -- Film: " + videotitle + "-- State: " + playingstate)
    #Update switch in Domoticz
    switchurl = (domoticz_url+ "?type=command&param=udevice&idx=" + str(domoticz_SwitchIDX) + "&nvalue=0&svalue=Film: " + videotitle + "-- State: " + playingstate)
    urllib.urlopen(switchurl)
    #Update influxDB
    if (playingstate == "playing") or  (playingstate == "paused"):
      statusnumber = 1
    else:
      statusnumber = 0
    influxurl = "http://" + influxDB_host + "/write?db=domoticzDB" # --data-binary plexStatus" + playinguser + ",host=plexserver value=" + statusnumber)
    headers = {'Content-Type': 'application/x-www-form-urlencoded'}
    payload = "plexStatus" + playinguser + ",host=plexserver,region=us-west value=" + str(statusnumber)
    r = requests.post(influxurl, data=payload, headers=headers)
    print "Updated state for", playinguser, "to influxdb"
  return


try:
  activeUserArray=["a"]
  #call session url
  test = urllib.urlopen(requestURL).read()
  #Parse XML response from Plexsession
  root = ET.XML(test)
  print "Root size is: ",root.get('size')
  if root.get('size') != "0":
    #"XML Parsing"
    for element in root:
      title = element.get('title')
      for item in element.iterfind('User'):
        plexuser = item.get('title')
        activeUserArray.append(plexuser)
        print plexuser, "is playing:", title
      for item in element.iterfind('Player'):
        state = item.get('state')
        #print "The state is:", state
    skickaData(title, plexuser, state) 
  print "Check Idle users"
  if not ("plexuser1" in activeUserArray):
    skickaData(" ", "plexuser1", "Idle")
  if not ("plexuser2" in activeUserArray):
    skickaData(" ", "plexuser2", "Idle")
  if not ("plexuser3" in activeUserArray):
    skickaData(" ", "plexuser3", "Idle")
  if not ("plexuser4" in activeUserArray):
    skickaData(" ", "plexuser4", "Idle")


except Exception:
  print 'Error'
  raise