# 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__])
#----- DISCOVERY AND LEARNING -------------------------------------------------
#5. LEARN/DISCOVER: To be able to instigate and manage learn mode from within an app
#
# a. To send specific commands to green button devices so they can
# learn the pattern
# ? broadcast specific (house_code, index) repeatedly
# ? user assisted start/stop
#
# b. To sniff for any messages from MiHome devices and capture them
# for later analysis and turning into device objects
# ? either as a special receive-only learn mode
# ? or as part of normal receive operation through routing unknown device id's
# ? need a way to take a device id and consult active directory list,
# and route to the correct class instance - a router for incoming messages
#
# c. To process MiHome join requests, and send MiHome join acks
# ? this would be routed by address to the device class
#----- 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 %s" % tv)
print("fan %s" % fan)
tv.turn_on()
fan.turn_on()
print("tv switch:%s" % tv.has_switch())
print("tv send:%s" % tv.can_send())
print("tv receive:%s" % tv.can_receive())
print("fan switch:%s" % fan.has_switch())
print("fan send:%s" % fan.can_send())
print("fan receive:%s" % fan.can_receive())
# END