+
+
+def _maybe_subproxy(proxy, name, value):
+ """ Return a sub world proxy if appropriate. """
+ if isinstance(value, dict):
+ prefix = "%s%s." % (proxy._prefix, name)
+ return WorldDictProxy(value, _prefix=prefix, _top=proxy._top)
+ elif isinstance(value, list):
+ prefix = "%s%s." % (proxy._prefix, name)
+ return WorldListProxy(value, _prefix=prefix, _top=proxy._top)
+ return value
+
+
+class WorldBaseProxy:
+ """ Base for world proxies. """
+
+ def __init__(self, state, _prefix='', _top=None):
+ if _top is None:
+ _top = self
+ _events = []
+ else:
+ _events = None
+ self.__dict__.update({
+ "_state": state,
+ "_prefix": _prefix,
+ "_top": _top,
+ "_events": _events,
+ })
+
+ def _record_change(self, fullname, value):
+ self._events.append(WorldEvent("set", {
+ fullname: value
+ }))
+
+ def pop_events(self):
+ events, self._events = self._events, []
+ return events
+
+
+class WorldDictProxy(WorldBaseProxy):
+ """ World dictionary proxy that records changes and produces events. """
+
+ def items(self):
+ return (
+ (k, _maybe_subproxy(self, k, v)) for k, v in self._state.items())
+
+ def __setattr__(self, name, value):
+ self._top._record_change("%s%s" % (self._prefix, name), value)
+
+ def __getattr__(self, name):
+ return _maybe_subproxy(self, name, self._state[name])
+
+
+class WorldListProxy(WorldBaseProxy):
+ """ World list proxy that records changes and produces events. """
+
+ def __setitem__(self, index, value):
+ self._top._record_change("%s%s" % (self._prefix, index), value)
+
+ def __getitem__(self, index):
+ return _maybe_subproxy(self, index, self._state[index])