pystat/ThermostatMain.py at master · willik/pystat · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
__author__ = 'matt'
import time
import threading
from FileManager import FileManager
import ThermostatConfiguration
from ThermostatService import ThermostatService
from ThermostatScheduler import ThermostatScheduler
from ThermostatWeb import ThermostatWeb
from TemperatureReader import TemperatureReader
from ThermostatWeather import ThermostatWeather
from ThermostatDatabase import ThermostatDatabase

def main():

    # magic constants
    #configurationFileName = "../../PyStat/thermostat.conf"
    configurationFileName = "thermostat.conf"
    currentFileName = "current.set"
    scheduleFileName = "schedule.conf"
    databaseName = "pystat.db"

    # make the static utility classes
    fileManager = FileManager(configurationFileName, currentFileName, scheduleFileName)
    configuration = fileManager.read_configuration()
    temperatureReader = TemperatureReader()
    weather = ThermostatWeather(configuration.weatherAPIKey, configuration.weatherurl,
                                configuration.latlong, configuration.weatherFlags)

    # create the database utility class
    databaseHelper = ThermostatDatabase(databaseName)

    if configuration is None:
        print("Configuration file could not be read.")
        exit(1)

    if "-1" == configuration.heatPin \
            or "-1" == configuration.acPin \
            or "-1" == configuration.fanPin \
            or configuration.heatPin == configuration.acPin \
            or configuration.heatPin == configuration.fanPin \
            or configuration.acPin == configuration.fanPin:
        print("The pin settings provided are invalid:")
        print("\tHeat pin: " + str(configuration.heatPin))
        print("\tAC pin: " + str(configuration.acPin))
        print("\tFan pin: " + str(configuration.fanPin))
        exit(2)

    service = ThermostatService(0, "service", configuration, fileManager,
                                temperatureReader)
    service.start()

    scheduler = ThermostatScheduler(1, "scheduler", configuration, fileManager,
                                    temperatureReader)
    scheduler.start()

    web = ThermostatWeb(2, "web", configuration, fileManager,
                        temperatureReader, weather)
    web.start()

    while True:
        current = fileManager.read_current()

        currentWeather = weather.current_weather()
        outdoorTemperature = None

        if currentWeather is not None:
            outdoorTemperature = currentWeather['temperature']

        databaseHelper.insert_current_data(temperatureReader.CurrentTemperature(),
                                           current["temperature"], outdoorTemperature,
                                           current["mode"],
                                           ("heat" in configuration.running),
                                           ("ac" in configuration.running),
                                           ("fan" in configuration.running))

        print("Polling threads")
        if not service.is_alive():
            print("PANIC SERVICE IS DEAD")
        if not scheduler.is_alive():
            print("PANIC SCHEDULER IS DEAD")
        if not web.is_alive():
            print("PANIC WEB IS DEAD")

        time.sleep(30)

main()