import pywemo
from pprint import pformat as pf
from influxdb import InfluxDBClient
import time
from datetime import datetime, timezone

########################### INFLUXDB CONFIG ###########################
influxdb_url = '192.168.1.20'
influxdb_port = 8086
influxdb_username = ''
influxdb_password = ''
db_name = 'homelab'

INFLUX_CLIENT = InfluxDBClient(influxdb_url,
                               influxdb_port,
                               influxdb_username,
                               influxdb_password,
                               db_name)


def wemo_status():
   CURRENT_TIME = datetime.now(timezone.utc).astimezone().isoformat()
   for dev in pywemo.discover_devices():
       alias = str(dev).replace('<','')
       alias = alias.replace('>','')
       state = dev.get_state()
       time = CURRENT_TIME
       INFLUX_PAYLOAD = [
       {
           "measurement": "Homelab",
		   "tags": {
                   "alias": alias,
                   "state": state,
               },
           "time": time,
           "fields": {
               "alias": alias,
               "state": state,

           }
       }
       ]
       #IF THIS IS YOUR FIRST RUN UNCOMMENT LINE 44 and 45 AND COMMENT LINES 46 TO 53 LET IT RUN FOR 10-15 SECONDS AND THEN COMMENT 44 and 45 AND UNCOMMENT 46-53
       #INFLUX_CLIENT.write_points(INFLUX_PAYLOAD)
       #print(alias+' is: '+str(state)+': Test')
       INFLUX_QUERY = "SELECT state FROM Homelab WHERE (alias = '"+alias+"') ORDER BY time DESC limit 1"
       results = INFLUX_CLIENT.query(INFLUX_QUERY)
       PREV_STATE = results.raw['series'][0]['values'][0][1]
       if PREV_STATE == state:
         print(alias+' is: '+str(state)+': No State Change')
       else:
         INFLUX_CLIENT.write_points(INFLUX_PAYLOAD)
         print(alias+' is: '+str(state)+': State Has Changed')

while True:
    wemo_status()
    time.sleep(3)