150 lines
4.1 KiB
Python
150 lines
4.1 KiB
Python
import importlib.util
|
|
import logging
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class Subscription(object):
|
|
def __init__(self, subscriptee, subscriber):
|
|
self.subscriptee = subscriptee
|
|
self.subscriber = subscriber
|
|
|
|
def call(self, *args, **kwargs):
|
|
self.subscriber(*args, **kwargs)
|
|
|
|
def cancel(self):
|
|
self.subscriptee.unwire(self)
|
|
|
|
|
|
class Property(object):
|
|
def __init__(self, value=None):
|
|
self.value = value
|
|
self.subscribers = []
|
|
|
|
def getValue(self):
|
|
return self.value
|
|
|
|
def setValue(self, value):
|
|
if self.value == value:
|
|
return self
|
|
self.value = value
|
|
for c in self.subscribers:
|
|
try:
|
|
c.call(self.value)
|
|
except Exception as e:
|
|
logger.exception(e)
|
|
return self
|
|
|
|
def wire(self, callback):
|
|
sub = Subscription(self, callback)
|
|
self.subscribers.append(sub)
|
|
if not self.value is None:
|
|
sub.call(self.value)
|
|
return sub
|
|
|
|
def unwire(self, sub):
|
|
try:
|
|
self.subscribers.remove(sub)
|
|
except ValueError:
|
|
# happens when already removed before
|
|
pass
|
|
return self
|
|
|
|
|
|
class ConfigNotFoundException(Exception):
|
|
pass
|
|
|
|
|
|
class PropertyManager(object):
|
|
sharedInstance = None
|
|
|
|
@staticmethod
|
|
def getSharedInstance():
|
|
if PropertyManager.sharedInstance is None:
|
|
PropertyManager.sharedInstance = PropertyManager()
|
|
return PropertyManager.sharedInstance
|
|
|
|
def collect(self, *props):
|
|
return PropertyManager(
|
|
{name: self.getProperty(name) if self.hasProperty(name) else Property() for name in props}
|
|
)
|
|
|
|
def __init__(self, properties=None):
|
|
self.properties = {}
|
|
self.subscribers = []
|
|
if properties is not None:
|
|
for (name, prop) in properties.items():
|
|
self.add(name, prop)
|
|
|
|
def add(self, name, prop):
|
|
self.properties[name] = prop
|
|
|
|
def fireCallbacks(value):
|
|
for c in self.subscribers:
|
|
try:
|
|
c.call(name, value)
|
|
except Exception as e:
|
|
logger.exception(e)
|
|
|
|
prop.wire(fireCallbacks)
|
|
return self
|
|
|
|
def __contains__(self, name):
|
|
return self.hasProperty(name)
|
|
|
|
def __getitem__(self, name):
|
|
return self.getPropertyValue(name)
|
|
|
|
def __setitem__(self, name, value):
|
|
if not self.hasProperty(name):
|
|
self.add(name, Property())
|
|
self.getProperty(name).setValue(value)
|
|
|
|
def __dict__(self):
|
|
return {k: v.getValue() for k, v in self.properties.items()}
|
|
|
|
def hasProperty(self, name):
|
|
return name in self.properties
|
|
|
|
def getProperty(self, name):
|
|
if not self.hasProperty(name):
|
|
self.add(name, Property())
|
|
return self.properties[name]
|
|
|
|
def getPropertyValue(self, name):
|
|
return self.getProperty(name).getValue()
|
|
|
|
def wire(self, callback):
|
|
sub = Subscription(self, callback)
|
|
self.subscribers.append(sub)
|
|
return sub
|
|
|
|
def unwire(self, sub):
|
|
try:
|
|
self.subscribers.remove(sub)
|
|
except ValueError:
|
|
# happens when already removed before
|
|
pass
|
|
return self
|
|
|
|
def defaults(self, other_pm):
|
|
for (key, p) in self.properties.items():
|
|
if p.getValue() is None:
|
|
p.setValue(other_pm[key])
|
|
return self
|
|
|
|
def loadConfig(self):
|
|
for file in ["/etc/config_webrx.py", "./config_webrx.py"]:
|
|
try:
|
|
spec = importlib.util.spec_from_file_location("config_webrx", file)
|
|
cfg = importlib.util.module_from_spec(spec)
|
|
spec.loader.exec_module(cfg)
|
|
for name, value in cfg.__dict__.items():
|
|
if name.startswith("__"):
|
|
continue
|
|
self[name] = value
|
|
return self
|
|
except FileNotFoundError:
|
|
logger.debug("not found: %s", file)
|
|
raise ConfigNotFoundException("no usable config found! please make sure you have a valid configuration file!")
|