[Pywebsvcs-checkins] SF.net SVN: pywebsvcs: [1393] trunk/zsi/ZSI/twisted

[<bov...@us...>]

Revision: 1393
          http://svn.sourceforge.net/pywebsvcs/?rev=1393&view=rev
Author:   boverhof
Date:     2007-06-12 11:45:39 -0700 (Tue, 12 Jun 2007)

Log Message:
-----------
M    twisted/WSresource.py
-- erased some comments
A    twisted/interfaces.py
-- move some stuff out of WSresource, 
use these handlers for wsgi, etc

Modified Paths:
--------------
    trunk/zsi/ZSI/twisted/WSresource.py

Added Paths:
-----------
    trunk/zsi/ZSI/twisted/interfaces.py

Modified: trunk/zsi/ZSI/twisted/WSresource.py
===================================================================
--- trunk/zsi/ZSI/twisted/WSresource.py	2007-06-08 21:59:37 UTC (rev 1392)
+++ trunk/zsi/ZSI/twisted/WSresource.py	2007-06-12 18:45:39 UTC (rev 1393)
@@ -190,33 +190,19 @@
             if debug: 
                 log.msg('\t%s handler: %s' %(arg, h), debug=1)
                 log.msg('\thandler callback: %s' %h.processRequest)
-            #arg = h.processRequest(arg, **kw)
             d.addCallback(h.processRequest, **kw)
             
-        #return self.handlercb.processRequest(arg, **kw)
         d.addCallback(self.handlercb.processRequest, **kw)
         reactor.callLater(.0001, d.callback, arg)
-        #return d
-            
-        #def processResponse(self, arg, **kw):
-        #from twisted.internet.defer import Deferred
-        
-        #debug = self.debug
+
         if debug: log.msg('===>DEFER PROCESS RESPONSE: %s' %str(arg), debug=1)
 
-        #if arg is None: 
-        #    return d
+
         
         for h in self.handlers:
             if debug: log.msg('\t%s handler: %s' %(arg, h), debug=1)
-            #arg = h.processResponse(arg, **kw)
             d.addCallback(h.processResponse, **kw)
-            
-        #s = str(arg)
-        #if debug: log.msg(s, debug=1)
-        #return s
-        
-        # convert SoapWriter into a string
+
         d.addCallback(str)
         return d
     

Added: trunk/zsi/ZSI/twisted/interfaces.py
===================================================================
--- trunk/zsi/ZSI/twisted/interfaces.py	                        (rev 0)
+++ trunk/zsi/ZSI/twisted/interfaces.py	2007-06-12 18:45:39 UTC (rev 1393)
@@ -0,0 +1,124 @@
+###########################################################################
+# Joshua R. Boverhof, LBNL
+# See Copyright for copyright notice!
+# $Id: WSresource.py 1287 2006-10-30 23:04:17Z feanor420 $
+###########################################################################
+
+import sys, warnings
+
+# twisted & related imports
+from zope.interface import classProvides, implements, Interface
+from twisted.python import log
+
+# ZSI imports
+from ZSI import EvaluateException, ParseException, ParsedSoap, SoapWriter
+
+
+# 
+# Stability: Unstable
+# 
+
+def CheckInputArgs(*interfaces):
+    """Must provide at least one interface, the last one may be repeated.
+    """
+    l = len(interfaces)
+    def wrapper(func):
+        def check_args(self, *args, **kw):
+            for i in range(len(args)):
+                if (l > i and interfaces[i].providedBy(args[i])) or interfaces[-1].providedBy(args[i]):
+                    continue
+                if l > i: raise TypeError, 'arg %s does not implement %s' %(args[i], interfaces[i])
+                raise TypeError, 'arg %s does not implement %s' %(args[i], interfaces[-1])
+            func(self, *args, **kw)
+        return check_args
+    return wrapper
+
+
+class HandlerChainInterface(Interface):
+    
+    def processRequest(self, input, **kw):
+        """returns a representation of the request, the 
+        last link in the chain must return a response
+        pyobj with a typecode attribute.
+        Parameters:
+            input --
+        Keyword Parameters:
+            request -- HTTPRequest instance
+            resource  -- Resource instance
+        """
+    def processResponse(self, output, **kw):
+        """returns a string representing the soap response.
+        Parameters
+            output --
+        Keyword Parameters:
+            request -- HTTPRequest instance
+            resource  -- Resource instance
+        """
+
+class CallbackChainInterface(Interface):
+    
+    def processRequest(self, input, **kw):
+        """returns a response pyobj with a typecode 
+        attribute.
+        Parameters:
+            input --
+        Keyword Parameters:
+            request -- HTTPRequest instance
+            resource  -- Resource instance
+        """
+
+class DataHandler:
+    """
+    class variables:
+        readerClass -- factory class to create reader for ParsedSoap instances.
+        writerClass -- ElementProxy implementation to use for SoapWriter instances.
+    """
+    classProvides(HandlerChainInterface)
+    readerClass = None
+    writerClass = None
+
+    @classmethod
+    def processRequest(cls, input, **kw):
+        return ParsedSoap(input, readerclass=cls.readerClass)
+
+    @classmethod
+    def processResponse(cls, output, **kw):
+        sw = SoapWriter(outputclass=cls.writerClass)
+        sw.serialize(output)
+        return sw
+
+
+class DefaultHandlerChain:
+
+    @CheckInputArgs(CallbackChainInterface, HandlerChainInterface)
+    def __init__(self, cb, *handlers):
+        self.handlercb = cb
+        self.handlers = handlers
+        self.debug = len(log.theLogPublisher.observers) > 0
+        
+    def processRequest(self, arg, **kw):
+        debug = self.debug
+        if debug: log.msg('--->PROCESS REQUEST: %s' %arg, debug=1)
+        
+        for h in self.handlers:
+            if debug: log.msg('\t%s handler: %s' %(arg, h), debug=1)
+            arg = h.processRequest(arg, **kw)
+            
+        return self.handlercb.processRequest(arg, **kw)
+            
+    def processResponse(self, arg, **kw):
+        debug = self.debug
+        if debug: log.msg('===>PROCESS RESPONSE: %s' %str(arg), debug=1)
+
+        if arg is None: 
+            return
+
+        for h in self.handlers:
+            if debug: log.msg('\t%s handler: %s' %(arg, h), debug=1)
+            arg = h.processResponse(arg, **kw)
+            
+        s = str(arg)
+        if debug: log.msg(s, debug=1)
+        
+        return s
+


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.