lars
d9f01ff0b8
I just have no f**** clue.... There's no structure in this god damn project but let's hope for the best.
102 lines
3.8 KiB
Python
102 lines
3.8 KiB
Python
# general imports
|
|
import os
|
|
import time
|
|
import numpy as np
|
|
import datetime
|
|
|
|
"""
|
|
All classes are ranked in their hierarchy, like this (ranks of the US Marines):
|
|
Capt << BGen << MajGen << LtGen << Gen
|
|
"""
|
|
# imports from project
|
|
import RaspberryPie.tasks as tasks
|
|
import RaspberryPie.hardwareControl as hardwareControl
|
|
import RaspberryPie.config as config
|
|
import RaspberryPie.logger as logger
|
|
import RaspberryPie.internetHandling as internetHandling
|
|
|
|
captScribe = logger.CaptScribe(config.config.config["File Locations"]["logfile_info"], config.config.config["File Locations"]["logfile_error"])
|
|
internetHandling._set_captScribe(captScribe)
|
|
hardwareControl._set_captScribe(captScribe)
|
|
|
|
|
|
ltGenInterpreter, genScheduler = None
|
|
|
|
tasks = [
|
|
tasks.Task(hardwareControl.majGenGPIOController.open, lambda msg: 1 if ("auf" == msg.subject.lower() or "open" == msg.subject.lower()) else 0),
|
|
tasks.Task(hardwareControl.majGenGPIOController.close, lambda msg: 1 if ("zu" == msg.subject.lower() or "close" == msg.subject.lower()) else 0)
|
|
]
|
|
|
|
|
|
class LtGenInterpreter:
|
|
def __init__(self, tasks: list, communicator: internetHandling.MajGenApiCom, schedule_timing=None):
|
|
if not schedule_timing:
|
|
schedule_timing = config.config.config["Timing"]["maildelta"]
|
|
self.schedule_timing
|
|
self.tasks = tasks
|
|
self.communicator = communicator
|
|
|
|
def get_schedule(self):
|
|
return self.schedule_timing
|
|
|
|
def execute(self):
|
|
messages = self.communicator.get_emails()
|
|
for message in messages:
|
|
for task in self.tasks:
|
|
if task.test(message):
|
|
task.function()
|
|
|
|
class GenScheduler:
|
|
def __init__(self, subordinates: list):
|
|
self.subordinates = subordinates
|
|
self.schedule = {}
|
|
self.schedule_delta = {}
|
|
for subordinate in self.subordinates:
|
|
self.schedule[subordinate] = list(datetime.datetime.now())
|
|
self.schedule_delta[subordinate] = list(subordinate.get_schedule())
|
|
self.time = datetime.datetime.now
|
|
|
|
def execute(self):
|
|
while True:
|
|
try:
|
|
for subordinate in self.schedule:
|
|
if self.schedule[subordinate][np.argmin(self.schedule[subordinate])] <= self.time():
|
|
subordinate.execute()
|
|
self.schedule[subordinate][np.argmin(self.schedule[subordinate])] += self.schedule_delta[subordinate][np.argmin(self.schedule[subordinate])]
|
|
|
|
time_list = lambda: [self.schedule[subordinate][np.argmin(self.schedule[subordinate])] for subordinate in self.schedule]
|
|
sleep_duration = time_list()[np.argmin(time_list())]
|
|
time.sleep(sleep_duration)
|
|
except Exception as e:
|
|
captScribe.critical("A not expected error occured: {}".format(str(e)), "GenScheduler.execute")
|
|
|
|
def initiate_shutdown(self, reboot=True):
|
|
hardwareControl.majGenGPIOController.finalMission()
|
|
reboot_str = lambda: " -r" if reboot else ""
|
|
os.system("shutdown{} 0".format(reboot_str()))
|
|
|
|
|
|
def init():
|
|
global ltGenInterpreter, genScheduler
|
|
ltGenInterpreter = LtGenInterpreter(tasks, internetHandling.majGenApiCom)
|
|
genScheduler = GenScheduler((ltGenInterpreter, hardwareControl.majGenVisualRecorder, hardwareControl.majGenAirRecoder))
|
|
|
|
|
|
def main():
|
|
suspend_shutdown = False
|
|
if genScheduler is GenScheduler:
|
|
try:
|
|
genScheduler.execute()
|
|
except Exception as e:
|
|
captScribe.critical(str(e), "main()")
|
|
if e is KeyboardInterrupt:
|
|
suspend_shutdown = True
|
|
finally:
|
|
if not suspend_shutdown:
|
|
genScheduler.initiate_shutdown()
|
|
print("The programm has finished. For more information see the log files.")
|
|
|
|
|
|
init()
|
|
main()
|