#!/usr/local/bin/python3.7
import sys
import traceback
import os
from threading import Thread
import time
from datetime import datetime
import constants
import renderer
import renderer
import renderer_catalog
import chooser
import logging
import trigger_catalog
import utils
def thread_change_current():
page_chooser = chooser.weighted_random_chooser_with_triggers(
trigger_catalog.get_triggers())
swap_page_target = 0
last_page = ""
while True:
now = time.time()
(page, triggered) = page_chooser.choose_next_page()
if triggered:
print('chooser[%s] - WE ARE TRIGGERED.' % utils.timestamp())
if page != last_page:
print('chooser[%s] - EMERGENCY PAGE %s LOAD NEEDED' % (
utils.timestamp(), page))
try:
f = open(os.path.join(constants.pages_dir,
'current.shtml'), 'w')
emit_wrapped(f, page)
f.close()
except:
print('chooser[%s] - page does not exist?!' % (
utils.timestamp()))
continue
last_page = page
swap_page_target = now + constants.refresh_period_sec
# Also notify XMLHTTP clients that they need to refresh now.
path = os.path.join(constants.pages_dir,
'reload_immediately.html')
f = open(path, 'w')
f.write('Reload, suckers!')
f.close()
# Fix this hack... maybe read the webserver logs and see if it
# actually was picked up?
time.sleep(0.750)
os.remove(path)
elif now >= swap_page_target:
if (page == last_page):
print(('chooser[%s] - nominal choice got the same page...' % (
utils.timestamp())))
continue
print('chooser[%s] - nominal choice of %s' % (utils.timestamp(), page))
try:
f = open(os.path.join(constants.pages_dir,
'current.shtml'), 'w')
emit_wrapped(f, page)
f.close()
except:
print('chooser[%s] - page does not exist?!' % (utils.timestamp()))
continue
last_page = page
swap_page_target = now + constants.refresh_period_sec
time.sleep(1)
def pick_background_color():
now = datetime.now()
if now.hour <= 6 or now.hour >= 21:
return "E6B8B8"
elif now.hour == 7 or now.hour == 20:
return "EECDCD"
else:
return "FFFFFF"
def emit_wrapped(f, filename):
age = utils.describe_age_of_file_briefly("pages/%s" % filename)
bgcolor = pick_background_color()
f.write("""
Kitchen Kiosk
""" % (bgcolor,
constants.refresh_period_sec * 1000,
bgcolor,
filename,
filename,
age))
def thread_invoke_renderers():
while True:
print("renderer[%s]: invoking all renderers in catalog..." % (
utils.timestamp()))
for r in renderer_catalog.get_renderers():
now = time.time()
try:
r.render()
except Exception as e:
traceback.print_exc()
print("renderer[%s] unknown exception in %s, swallowing it." % (
utils.timestamp(), r.get_name()))
except Error as e:
traceback.print_exc()
print("renderer[%s] unknown error in %s, swallowing it." % (
utils.timestamp(), r.get_name()))
delta = time.time() - now
if (delta > 1.0):
print("renderer[%s]: Warning: %s's rendering took %5.2fs." % (
utils.timestamp(), r.get_name(), delta))
print("renderer[%s]: thread having a little break for %ds..." % (
utils.timestamp(), constants.render_period_sec))
time.sleep(constants.render_period_sec)
if __name__ == "__main__":
logging.basicConfig()
changer_thread = None
renderer_thread = None
while True:
if (changer_thread == None or
not changer_thread.is_alive()):
print("MAIN[%s] - (Re?)initializing chooser thread..." % (
utils.timestamp()))
changer_thread = Thread(target = thread_change_current, args=())
changer_thread.start()
if (renderer_thread == None or
not renderer_thread.is_alive()):
print("MAIN[%s] - (Re?)initializing render thread..." % (
utils.timestamp()))
renderer_thread = Thread(target = thread_invoke_renderers, args=())
renderer_thread.start()
time.sleep(60)
print("Should never get here.")