# -*- test-case-name: twisted.test.test_woven -*- # Twisted, the Framework of Your Internet # Copyright (C) 2000-2002 Matthew W. Lefkowitz # # This library is free software; you can redistribute it and/or # modify it under the terms of version 2.1 of the GNU Lesser General Public # License as published by the Free Software Foundation. # # This library is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU # Lesser General Public License for more details. # # You should have received a copy of the GNU Lesser General Public # License along with this library; if not, write to the Free Software # Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA __version__ = "$Revision: 1.32 $"[11:-2] import types import weakref import warnings from twisted.python import components, reflect from twisted.internet import defer from twisted.web.woven import interfaces def adaptToIModel(m, parent=None, submodel=None): adapted = components.getAdapter(m, interfaces.IModel, None) if adapted is None: adapted = Wrapper(m) adapted.parent = parent adapted.name = submodel return adapted class Model: """ A Model which keeps track of views which are looking at it in order to notify them when the model changes. """ __implements__ = interfaces.IModel def __init__(self, *args, **kwargs): self.name = '' self.parent = None self.views = [] self.subviews = {} self.submodels = {} self.initialize(*args, **kwargs) def __getstate__(self): self.views = [] self.subviews = {} return self.__dict__ def initialize(self, *args, **kwargs): """ Hook for subclasses to initialize themselves without having to mess with the __init__ chain. """ pass def addView(self, view): """ Add a view for the model to keep track of. """ if view not in self.views: self.views.append(weakref.ref(view)) def addSubview(self, name, subview): subviewList = self.subviews.get(name, []) subviewList.append(weakref.ref(subview)) self.subviews[name] = subviewList def removeView(self, view): """ Remove a view that the model no longer should keep track of. """ for weakref in self.views: ref = weakref() if ref is view or ref is None: print "removed a view." self.views.remove(weakref) def notify(self, changed=None): """ Notify all views that something was changed on me. Passing a dictionary of {'attribute': 'new value'} in changed will pass this dictionary to the view for increased performance. If you don't want to do this, don't, and just use the traditional MVC paradigm of querying the model for things you're interested in. """ if changed is None: changed = {} retVal = [] for view in self.views: ref = view() if ref is not None: retVal.append((ref, ref.modelChanged(changed))) else: self.views.remove(view) for key, value in self.subviews.items(): if value.wantsAllNotifications or changed.has_key(key): for item in value: ref = item() if ref is not None: retVal.append((ref, ref.modelChanged(changed))) else: self.views.remove(view) return retVal def __cmp__(self, other): if other is None: return -1 for elem in self.__dict__.keys(): if elem in ["views", 'suvbiews', 'modelStack', 'parent']: continue if getattr(self, elem) != getattr(other, elem, None): return -1 else: return 0 protected_names = ['initialize', 'addView', 'addSubview', 'removeView', 'notify', 'getSubmodel', 'setSubmodel', 'getData', 'setData'] allowed_names = [] def lookupSubmodel(self, submodelName): """ Look up a full submodel name. I will split on `/' and call L{getSubmodel} on each element in the 'path'. Override me if you don't want 'traversing'-style lookup, but would rather like to look up a model based on the entire model name specified. If you override me to return Deferreds, make sure I look up values in a cache (created by L{setSubmodel}) before doing a regular Deferred lookup. XXX: Move bits of this docstring to interfaces.py """ if not submodelName: return None # Special case: If the first character is / # Start at the bottom of the model stack currentModel = self if submodelName[0] == '/': while currentModel.parent is not None: currentModel = currentModel.parent submodelName = submodelName[1:] submodelList = submodelName.split('/') #[:-1] # print "submodelList", submodelList for element in submodelList: if element == '.' or element == '': continue elif element == '..': currentModel = currentModel.parent else: currentModel = currentModel.getSubmodel(element) if currentModel is None: return None if isinstance(currentModel, defer.Deferred): currentModel.addCallback(self._getModelWrapper, element, parentModel) return currentModel return currentModel def _getModelWrapper(self, currentModel, element, parentModel): adapted = components.getAdapter(currentModel, interfaces.IModel, None) if adapted is None: adapted = Wrapper(currentModel) adapted.parent = parentModel adapted.name = element return adapted def submodelCheck(self, name): """Check if a submodel name is allowed. Subclass me to implement a name security policy. """ if self.allowed_names: return (name in self.allowed_names) else: return (name and name[0] != '_' and name not in self.protected_names) def submodelFactory(self, name): warnings.warn("Warning: default Model lookup strategy is changing:" "use either AttributeModel or MethodModel for now.", DeprecationWarning) if hasattr(self, name): return getattr(self, name) else: return None def getSubmodel(self, name): """ Get the submodel `name' of this model. If I ever return a Deferred, then I ought to check for cached values (created by L{setSubmodel}) before doing a regular Deferred lookup. """ if self.submodels.has_key(name): return self.submodels[name] if not self.submodelCheck(name): return None m = self.submodelFactory(name) if m is None: return None sm = adaptToIModel(m, self, name) self.submodels[name] = sm return sm def setSubmodel(self, name, value): """ Set a submodel on this model. If getSubmodel or lookupSubmodel ever return a Deferred, I ought to set this in a place that lookupSubmodel/getSubmodel know about, so they can use it as a cache. """ if self.submodelCheck(name): if self.submodels.has_key(name): del self.submodels[name] setattr(self, name, value) def getData(self): return self def setData(self, data): if hasattr(self, 'parent') and self.parent: self.parent.setSubmodel(self.name, data) if hasattr(self, 'orig'): self.orig = data class MethodModel(Model): """Look up submodels with wmfactory_* methods. """ def submodelCheck(self, name): """Allow any submodel for which I have a submodel. """ return hasattr(self, "wmfactory_"+name) def submodelFactory(self, name): """Call a wmfactory_name method on this model. """ return getattr(self, "wmfactory_"+name)() class AttributeModel(Model): """Look up submodels as attributes with hosts.allow/deny-style security. """ def submodelFactory(self, name): if hasattr(self, name): return getattr(self, name) else: return None #backwards compatibility WModel = Model class Wrapper(Model): """ I'm a generic wrapper to provide limited interaction with the Woven models and submodels. """ parent = None name = None def __init__(self, orig): Model.__init__(self) self.orig = orig def getData(self): return self.orig def setData(self, data): if self.parent: self.parent.setSubmodel(self.name, data) self.orig = data def __repr__(self): myLongName = reflect.qual(self.__class__) return "<%s instance at 0x%x: wrapped data: %s>" % (myLongName, id(self), self.orig) class ListModel(Wrapper): """ I wrap a Python list and allow it to interact with the Woven models and submodels. """ def getSubmodel(self, name): if self.submodels.has_key(name): return self.submodels[name] orig = self.orig sm = adaptToIModel(orig[int(name)], self, name) self.submodels[name] = sm return sm def setSubmodel(self, name, value): self.orig[int(name)] = value def __getitem__(self, name): return self.getSubmodel(name) def __setitem__(self, name, value): self.setSubmodel(name, value) def __repr__(self): myLongName = reflect.qual(self.__class__) return "<%s instance at 0x%x: wrapped data: %s>" % (myLongName, id(self), self.orig) class StringModel(ListModel): """ I wrap a Python string and allow it to interact with the Woven models and submodels. """ def setSubmodel(self, name, value): raise ValueError("Strings are immutable.") # pyPgSQL returns "PgResultSet" instances instead of lists, which look, act # and breathe just like lists. pyPgSQL really shouldn't do this, but this works try: from pyPgSQL import PgSQL components.registerAdapter(ListModel, PgSQL.PgResultSet, interfaces.IModel) except: pass class DictionaryModel(Wrapper): """ I wrap a Python dictionary and allow it to interact with the Woven models and submodels. """ def getSubmodel(self, name): if self.submodels.has_key(name): return self.submodels[name] orig = self.orig sm = adaptToIModel(orig[name], self, name) self.submodels[name] = sm return sm def setSubmodel(self, name, value): self.orig[name] = value def getData(self): return self.orig class AttributeWrapper(Wrapper): """ I wrap an attribute named "name" of the given parent object. """ def __init__(self, parent, name): self.orig = None parent = ObjectWrapper(parent) Wrapper.__init__(self, parent.getSubmodel(name)) self.parent = parent self.name = name class ObjectWrapper(Wrapper): """ I may wrap an object and allow it to interact with the Woven models and submodels. By default, I am not registered for use with anything. """ def getSubmodel(self, name): if self.submodels.has_key(name): return self.submodels[name] sm = adaptToIModel(getattr(self.orig, name), self, name) self.submodels[name] = sm return sm def setSubmodel(self, name, value): setattr(self.orig, name, value) class UnsafeObjectWrapper(ObjectWrapper): """ I may wrap an object and allow it to interact with the Woven models and submodels. By default, I am not registered for use with anything. I am unsafe because I allow methods to be called. In fact, I am dangerously unsafe. Be wary or I will kill your security model! """ def getSubmodel(self, name): if self.submodels.has_key(name): return self.submodels[name] value = getattr(self.orig, name) if callable(value): return value() sm = adaptToIModel(value, self, name) self.submodels = sm return sm class DeferredWrapper(Wrapper): def setData(self, data): if isinstance(data, defer.Deferred): self.orig = data else: views, subviews = self.views, self.subviews new = adaptToIModel(data, self.parent, self.name) self.__class__ = new.__class__ self.__dict__ = new.__dict__ self.views, self.subviews = views, subviews class Link(AttributeModel): def __init__(self, href, text): AttributeModel.__init__(self) self.href = href self.text = text try: components.registerAdapter(StringModel, types.StringType, interfaces.IModel) components.registerAdapter(ListModel, types.ListType, interfaces.IModel) components.registerAdapter(ListModel, types.TupleType, interfaces.IModel) components.registerAdapter(DictionaryModel, types.DictionaryType, interfaces.IModel) components.registerAdapter(DeferredWrapper, defer.Deferred, interfaces.IModel) except ValueError: # The adapters were already registered pass