/usr/lib/python3/dist-packages/klaus/contrib/wsgi_autoreload.py is in python3-klaus 1.2.1-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | from __future__ import print_function
import os
import time
import threading
import warnings
from io import open, StringIO
from klaus import make_app
from .app_args import get_args_from_env
# Shared state between poller and application wrapper
class _:
#: the real WSGI app
inner_app = None
should_reload = True
def poll_for_changes(interval, dir):
"""
Polls `dir` for changes every `interval` seconds and sets `should_reload`
accordingly.
"""
old_contents = os.listdir(dir)
while 1:
time.sleep(interval)
if _.should_reload:
# klaus application has not seen our change yet
continue
new_contents = os.listdir(dir)
if new_contents != old_contents:
# Directory contents changed => should_reload
old_contents = new_contents
_.should_reload = True
def make_autoreloading_app(repos_root, *args, **kwargs):
def app(environ, start_response):
if _.should_reload:
# Refresh inner application with new repo list
print("Reloading repository list...")
_.inner_app = make_app(
[os.path.join(repos_root, x) for x in os.listdir(repos_root)],
*args, **kwargs
)
_.should_reload = False
return _.inner_app(environ, start_response)
# Background thread that polls the directory for changes
poller_thread = threading.Thread(target=(lambda: poll_for_changes(10, repos_root)))
poller_thread.daemon = True
poller_thread.start()
return app
if 'KLAUS_REPOS' in os.environ:
warnings.warn("use KLAUS_REPOS_ROOT instead of KLAUS_REPOS for the autoreloader apps", DeprecationWarning)
args, kwargs = get_args_from_env()
repos_root = os.environ.get('KLAUS_REPOS_ROOT') or os.environ['KLAUS_REPOS']
args = (repos_root,) + args[1:]
if kwargs['htdigest_file']:
# Cache the contents of the htdigest file, the application will not read
# the file like object until later when called.
with open(kwargs['htdigest_file'], encoding='utf-8') as htdigest_file:
kwargs['htdigest_file'] = StringIO(htdigest_file.read())
application = make_autoreloading_app(*args, **kwargs)
|