101 lines
2.9 KiB
Python
101 lines
2.9 KiB
Python
import logging
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class Property(object):
|
|
def __init__(self, value = None):
|
|
self.value = value
|
|
self.callbacks = []
|
|
def getValue(self):
|
|
return self.value
|
|
def setValue(self, value):
|
|
if (self.value == value):
|
|
return self
|
|
self.value = value
|
|
for c in self.callbacks:
|
|
try:
|
|
c(self.value)
|
|
except Exception as e:
|
|
logger.exception(e)
|
|
return self
|
|
def wire(self, callback):
|
|
self.callbacks.append(callback)
|
|
if not self.value is None: callback(self.value)
|
|
return self
|
|
|
|
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(dict((name, self.getProperty(name) if self.hasProperty(name) else Property()) for name in props))
|
|
|
|
def __init__(self, properties = None):
|
|
self.properties = {}
|
|
self.callbacks = []
|
|
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.callbacks:
|
|
try:
|
|
c(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):
|
|
self.callbacks.append(callback)
|
|
return self
|
|
|
|
def unwire(self, callback):
|
|
self.callbacks.remove(callback)
|
|
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, filename):
|
|
cfg = __import__(filename)
|
|
for name, value in cfg.__dict__.items():
|
|
if name.startswith("__"):
|
|
continue
|
|
self[name] = value
|
|
return self
|