# Registry.py 14/05/2016 D.J.Whale # # A simple registry of connected devices. # # NOTE: This is an initial, non persisted implementation only import time try: import Devices # python 2 except ImportError: from . import Devices # python 3 def deprecated(m): print("warning: deprecated method %s" % str(m)) return m def unimplemented(m): print("warning: unimplemented method %s" % str(m)) def inner(*args, **kwargs): print("warning: unimplemented method %s" % str(m)) return m() return inner def untested(m): print("warning: untested method %s" % str(m)) return m directory = {} @deprecated def allkeys(d): result = "" for k in d: if len(result) != 0: result += ',' result += str(k) return result @deprecated def update(message): """Update the local directory with information about this device""" now = time.time() header = message["header"] sensorId = header["sensorid"] if not (sensorId in directory): # new device discovered desc = Devices.getDescription(header["mfrid"], header["productid"]) print("ADD device:%s %s" % (hex(sensorId), desc)) directory[sensorId] = {"header": message["header"]} #trace(allkeys(directory)) directory[sensorId]["time"] = now #TODO would be good to keep recs, but need to iterate through all and key by paramid, #not as a list index, else merging will be hard. @deprecated def size(): return len(directory) @deprecated def get_sensorids(): return directory.keys() @deprecated def get_info(sensor_id): return directory[sensor_id] #----- NEW DEVICE REGISTRY ---------------------------------------------------- # Done as a class, so we can have multiple registries if we want. # TODO: file format? platform dependent database format, like dbm but there is # a platform dependent one - but need the licence to be MIT so we can # just embed it here to have zero dependencies. # TODO: serialisation format for the individual device meta record? json? def log_method(m): def inner(*args, **kwargs): print("CALL %s with: %s %s" % (m, args, kwargs)) r = m(*args, **kwargs) print("RETURN %s with: %s" % (m, r)) return r return inner class RegistryStore(): """A mock in-memory only store, for testing and debugging""" def __init__(self, filename): self.filename = filename #TODO: Intentionally not used elsewhere self.store = {} #@log_method def __setitem__(self, key, value): self.store[key] = value #@log_method def __getitem__(self, key): return self.store[key] #@log_method def __delitem__(self, key): del self.store[key] #@log_method def keys(self): return self.store.keys() class DeviceRegistry(): """A persistent registry for device class instance configurations""" def __init__(self, filename): self.store = RegistryStore(filename) # A dummy store, for testing @unimplemented def load(self): pass # load registry from disk/parse it @unimplemented def save(self): pass # persist registry to disk/write back new entries def add(self, device, name): """Add a device class instance to the registry, with a friendly name""" self.store[name] = device def get(self, name): # -> Device """Get the description for a device class from the store, and construct a class instance""" c = self.store[name] #TODO: Construct a new device class that is configured as per this data #for now, just return the metadata, it could be serialised data too return c def delete(self, name): """Delete the named class instance""" del self.store[name] def auto_create(self, context): """auto-create variables in the provided context, for all persisted registry entries""" if context == None: raise ValueError("Must provide a context to hold new variables") for name in self.store.keys(): c = self.get(name) #TODO: should return an instantiated class # This creates a variable inside the context of this name, points to class instance setattr(context, name, c) def list(self): """List the registry in a vaguely printable format, mostly for debug""" for k in self.store.keys(): print("DEVICE %s" % k) print(" %s" % self.store[k]) registry = DeviceRegistry("registry.txt") # This will create all class instance variables in the module that imports the registry. # So, if there is an entry called "tv" in the registry, then the app module # will get a variable called tv that is bound to the appropriate device instance. # You can then just say tv.turn_on() regardless of the type of device it is, as long # as it has switching capability. # # usage: # import sys # from Registry import registry # registry.auto_create(sys.modules[__file__]) #----- SIMPLE TEST HARNESS ---------------------------------------------------- if __name__ == "__main__": # seed the registry registry.add(Devices.MIHO005(device_id=0x68b), "tv") registry.add(Devices.ENER002(device_id=(0xC8C8C, 1)), "fan") # test the auto create mechanism import sys registry.auto_create(sys.modules[__name__]) # variables should now be created in module scope print(tv) print(fan) tv.turn_on() fan.turn_on() # END