/usr/lib/python2.7/dist-packages/etcd_settings/proxy.py is in python-django-etcd-settings 0.1.13+dfsg-1.
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 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 | import os
import re
from importlib import import_module
from django.conf import settings as django_settings
from .manager import EtcdConfigManager
from .utils import (
attrs_to_dir, copy_if_mutable, dict_rec_update, find_project_root,
)
class EtcdSettingsProxy(object):
def __init__(self):
self.env = getattr(django_settings, 'DJES_ENV', None)
dev_params = getattr(django_settings, 'DJES_DEV_PARAMS', None)
etcd_details = getattr(django_settings, 'DJES_ETCD_DETAILS', None)
self._init_req_getter(
getattr(django_settings, 'DJES_REQUEST_GETTER', None))
self._locate_wsgi_file(
getattr(django_settings, 'DJES_WSGI_FILE', None))
if etcd_details is not None:
self._etcd_mgr = EtcdConfigManager(dev_params, **etcd_details)
self._config_sets = self._etcd_mgr.get_config_sets()
self._env_defaults = self._etcd_mgr.get_env_defaults(self.env)
else:
self._etcd_mgr = None
self._config_sets = dict()
self._env_defaults = EtcdConfigManager.get_dev_params(dev_params)
def _locate_wsgi_file(self, wsgi_file):
if wsgi_file is None:
self._wsgi_file = None
elif wsgi_file.startswith(os.path.sep):
self._wsgi_file = wsgi_file
else:
self._wsgi_file = os.path.join(
find_project_root('manage.py'),
wsgi_file)
def _init_req_getter(self, s):
if s is not None:
r = re.compile('(?P<module>.*)\.(?P<f>[\w_]+)')
m = re.match(r, s)
mod_s = m.group('module')
fun_s = m.group('f')
mod = import_module(mod_s)
self._req_getter = getattr(mod, fun_s)
else:
self._req_getter = None
def _parse_req_config_sets(self):
sets = []
if self._req_getter is not None:
request = self._req_getter()
if request and getattr(request, "META", None):
sets = request.META.get('HTTP_X_DYNAMIC_SETTING', '').split()
return sets
def start_monitors(self):
if self._etcd_mgr is not None:
self._etcd_mgr.monitor_env_defaults(
env=self.env, conf=self._env_defaults,
wsgi_file=self._wsgi_file)
self._etcd_mgr.monitor_config_sets(conf=self._config_sets)
def __getattr__(self, attr):
try:
dj_value = getattr(django_settings, attr)
dj_value_exists = True
except AttributeError:
dj_value_exists = False
dj_value = None
try:
value = self._env_defaults[attr]
value_exists = True
except KeyError:
value_exists = dj_value_exists
value = dj_value
for override_set in self._parse_req_config_sets():
config_set = self._config_sets.get(override_set, {})
if attr in config_set:
new_value = config_set[attr]
value = copy_if_mutable(value)
if isinstance(value, dict) and isinstance(new_value, dict):
dict_rec_update(value, new_value)
else:
value = new_value
if value or value_exists:
return value
else:
raise AttributeError(attr)
def as_dict(self):
items = attrs_to_dir(django_settings)
items.update(self._env_defaults)
return items
proxy = EtcdSettingsProxy()
|