Changeset 153 for plone4bio.biosql/trunk/src/plone4bio/biosql/content/root.py

Timestamp:

08/05/10 18:37:06 (22 months ago)

Author:

mauro

Message:

plone4

Files:

• plone4bio.biosql/trunk/src/plone4bio/biosql/content/root.py (modified) (11 diffs)

plone4bio.biosql/trunk/src/plone4bio/biosql/content/root.py

@@ +1 @@
+# -*- coding: utf-8 -*-
 __author__ = '''Mauro Amico <mauro@biodec.com>'''
 __docformat__ = 'plaintext'
 
+from threading import local
 from zope.interface import implements
 from zope.component.factory import Factory
 from zope.schema.fieldproperty import FieldProperty
+
+from Acquisition import aq_base
 
 from plone.app.content.container import Container
@@ -14 +18 @@
 from Products.CMFPlone.utils import base_hasattr
 from Products.CMFPlone.utils import safe_callable
+from Products.CMFPlone.interfaces.constrains import IConstrainTypes
+
+from Products.ATContentTypes.content.base import ATCTContent
+from Products.ATContentTypes.content.schemata import ATContentTypeSchema
+
+from Products.Archetypes import atapi
+
+from Products.Archetypes.atapi import Schema
+from Products.Archetypes.atapi import BooleanWidget
+from Products.Archetypes.atapi import StringField
+from Products.Archetypes.atapi import StringWidget
+from Products.Archetypes.atapi import registerType
+
 from zope.app.container.interfaces import IContainer
 from plone.app.content.interfaces import INameFromTitle
@@ -43 +60 @@
     return self.dsn
 
-# WebDAV ... Collection
-# class BioSQLRoot(BaseContent, BrowserDefaultMixin):
+"""
+
 class BioSQLRoot(Container):
-    __implements__ = (BrowserDefaultMixin.__implements__)
     portal_type='BioSQLRoot'
+
     implements(IBioSQLRoot, IContainer, IFolderish, INameFromTitle)
+
     security = ClassSecurityInfo()
     # isPrincipiaFolderish = True # already on Container
-    dsn = FieldProperty(IBioSQLRoot['dsn'])
+    # dsn = FieldProperty(IBioSQLRoot['dsn'])
+    dsn = 'postgres://postgres@localhost/plone4bio'
     seqrecord_key = FieldProperty(IBioSQLRoot['seqrecord_key'])
-    _v_dbserver = None
+    _v_thread_local = local()
+
+    def __init__(self, *args, **kwargs):
+        if kwargs.has_key('parent'):
+            parent = kwargs['parent']
+            del(kwargs['parent'])
+        super(BioSQLRoot, self).__init__(*args, **kwargs)
+"""
+
+
+Plone4BioSchema = ATContentTypeSchema.copy() + Schema((
+    StringField("dsn",
+        required = True,
+        widget = StringWidget(
+            label = "dsn",
+            label_msgid = "dsn_label",
+            description = "DSN "
+                          "... "
+                          "...",
+            description_msgid = "dsn_help",
+            i18n_domain = "plone4bio")
+        ),
+    ))
+
+class BioSQLRoot(ATCTContent):
+    portal_type='BioSQLRoot'
+
+    implements(IBioSQLRoot, IConstrainTypes)
+
+    security = ClassSecurityInfo()
+    schema = Plone4BioSchema
+    _at_rename_after_creation = True
+    isPrincipiaFolderish = True 
+    # dsn = atapi.ATFieldProperty('dsn')
+    dsn = 'postgres://postgres@localhost/plone4bio'
+    seqrecord_key = "version"
+    _v_thread_local = local()
+
+    # XXX
+    def getLocallyAllowedTypes(self):
+        return []
 
     # see CMFPlone/CatalogTool.py
     def refreshCatalog(self, clear=1):
+        return
         def indexObject(obj, path):
             if (base_hasattr(obj, 'indexObject') and
@@ -66 +126 @@
                     # take different args, and will fail
                     pass
+                except: # CatalogError:
+                    # import pdb; pdb.set_trace()
+                    # obj.indexObject()
+                    logger.exception("indexObject %r for %r" % (obj, self))
         for database in self.values():
             database.invalidateCache()
@@ -73 +137 @@
         portal_catalog.ZopeFindAndApply(self, search_sub=True, apply_func=indexObject)
 
+    """
     def __getattr__(self, name):
         if self.has_key(name):
@@ -78 +143 @@
         else:
             raise AttributeError, name
+    """
 
     security.declareProtected(View, "getBioSQLRoot")
@@ -91 +157 @@
         if not self.dsn:
             return None
-        if self._v_dbserver is None or not self._v_dbserver.adaptor.conn.is_valid:
+        dbserver = getattr(self._v_thread_local, 'dbserver', None)
+        if dbserver is None or not dbserver.adaptor.conn.is_valid:
             try:
                 wrapper = getSAWrapper(self.dsn)
@@ -97 +164 @@
                 wrapper = createSAWrapper(dsn=self.dsn, name=self.dsn)
             #TODO: manage OperationalError on connection
-            self._v_dbserver = DBServer(wrapper.connection, __import__(drivers[self.dsn.split(':')[0]]))
-        return self._v_dbserver
+            dbserver = DBServer(wrapper.connection, __import__(drivers[self.dsn.split(':')[0]]))
+            self._v_thread_local.dbserver = dbserver
+        return dbserver
 
     security.declareProtected(View, "getValues")
@@ -123 +191 @@
             logger.exception("getDBServer")
             raise StopIteration
+        if not dbserver:
+            raise StopIteration
         for name in dbserver.keys():
-            yield name
+            yield str(name)
         #try:
         #    for name in dbserver.keys():
@@ -149 +219 @@
             yield (k, self[k])
 
+    def __bobo_traverse__(self, REQUEST, name):
+        try:
+            return self[name]
+        except KeyError:
+            pass        
+        if hasattr(aq_base(self), name):
+            return getattr(self, name)
+        # webdav
+        """
+        method = REQUEST.get('REQUEST_METHOD', 'GET').upper()
+        if (method not in ('GET', 'POST') and not
+              isinstance(REQUEST.RESPONSE, xmlrpc.Response) and
+              REQUEST.maybe_webdav_client and not REQUEST.path):
+            return ReflectoNullResource(self, name, REQUEST).__of__(self)
+        """
+        return ATCTContent.__bobo_traverse__(self, REQUEST, name)
+
     # zope2/lib/python/OFS/ObjectManager.py
     def _getOb(self, id, default=_marker):
@@ -194 +281 @@
     setattr(BioSQLRoot, m, getattr(DictMixin, m).im_func)
 
+# XXX: ???
 bioSQLRootFactory = Factory(BioSQLRoot, title=_(u"Create a new BioSQL Root"))
+
+atapi.registerType(BioSQLRoot, 'plone4bio.biosql')
+