mvp.py

# This module is the main program.
#
# Run this program from the command line as per:
#   cd /home/pi/openag-mvp
#   python3 mvp.py
#
#   Note: pythone3 mvp.py --help  -> Will display available command line arguments.
#
# or run the program at startup as a systemd service using the following service file contents:
#    [Unit]
#    Description=mvp
#    Wants=network-online.target
#    After=network-online.target
#
#    [Service]
#    WorkingDirectory=/home/pi/openag-mvp
#    User=pi
#    ExecStart=/usr/bin/python3 /home/pi/openag-mvp/mvp.py --silent
#    Restart=on-failure
#
#    [Install]
#    WantedBy=multi-user.target
#
# It spawns the following threads:
# MQTT Client
# Light Controller
# Sensor Data Logger
# Fan Controller
# Camera Controller
# Website Chart Controller 
#
# The mvp provides a REPL loop for interactive operation. This loop can be turned off
# by invoking the mvp in silent mode.
#
# It is assumed that mvp.py is located in a directory that contains code and data organized
# identical to the way it is stored in github (https://github.com/ferguman/openag-mvp)
# 

# Ok let's get started!

# Make sure we are running a compatible version of python.
from check_python_version import check_python_version
check_python_version()

from python.mvp_logger import get_logger
from python.verify_config_files import verify_config_file
logger = get_logger()

logger.info('############## starting mvp system ##############')

# Check that the configuration file is present and then load it.
verify_config_file()

# After the above check we know it's safe to load the rest of the modules.
import threading

# Load mvp libraries
from python.adjustThermostat import start_fan_controller
from python.args import get_args
from python.camera_controller import start_camera_controller
from python.light_controller import start_light_controller
from python.logSensors import start_sensor_data_logger
from python.mqtt_client import start_mvp_mqtt_client
from python.repl import repl
from python.web_chart_controller import start_web_chart_controller

# Process the command line args
args = get_args()


app_state = {'stop': False, 'silent_mode':args.silent}

# Start the MQTT client if needed
mqtt_client = start_mvp_mqtt_client(app_state)

# Create all the threads
t2 = threading.Thread(target=start_light_controller, name="light_controller", args=(app_state, ))
t3 = threading.Thread(target=start_sensor_data_logger, name="sensor_logger", args=(mqtt_client, app_state))
t4 = threading.Thread(target=start_fan_controller, name="fan_controller", args=(app_state, ))
t5 = threading.Thread(target=start_camera_controller, name="camera_controller", args=(app_state, ))
t6 = threading.Thread(target=start_web_chart_controller, name="web_chart_controller", args=(app_state,))

# Start all threads
t2.start()
t3.start()
t4.start()
t5.start()
t6.start()

if not args.silent:
    repl(app_state)

# Wait for threads to complete.
#
t2.join()
t3.join()
t4.join()
t5.join()
t6.join()