From: erickson Date: Fri, 15 Jun 2007 14:31:30 +0000 (+0000) Subject: more tuning of hinted object handling. added support for hinted object parsing in... X-Git-Url: https://old-git.evergreen-ils.org/?a=commitdiff_plain;h=9ffa4f118c5810adc9e16424895d0ce5caf9c9fb;p=opensrf%2Fbjwebb.git more tuning of hinted object handling. added support for hinted object parsing in gateway parser git-svn-id: svn://svn.open-ils.org/OpenSRF/trunk@952 9efc2488-bf62-4759-914b-345cdb29e865 --- diff --git a/src/python/osrf/gateway.py b/src/python/osrf/gateway.py index 96d03ad..c9f9392 100644 --- a/src/python/osrf/gateway.py +++ b/src/python/osrf/gateway.py @@ -5,7 +5,7 @@ from net_obj import * import urllib, urllib2, sys, re defaultHost = None -paramRegex = re.compile('\%27') +#paramRegex = re.compile('\%27') class GatewayRequest: def __init__(self, service, method, params=[]): @@ -36,10 +36,7 @@ class GatewayRequest: }) for p in self.params: - # XXX for some reason, the gateway does not like escaped single-quotes ? - param = paramRegex.sub("'", urllib.quote(self.encodeParam(p))) - params += '¶m=%s' % urllib.quote(self.encodeParam(param)) - + params += '¶m=%s' % urllib.quote(self.encodeParam(p), "'/") return params def setDefaultHost(host): @@ -78,6 +75,7 @@ class XMLGatewayParser(handler.ContentHandler): self.result = None self.objStack = [] self.keyStack = [] + self.posStack = [] # for tracking array-based hinted object indices def getResult(self): return self.result @@ -102,7 +100,12 @@ class XMLGatewayParser(handler.ContentHandler): hint = self.__getAttr(attrs, 'class_hint') if hint: - obj = osrfNetworkObject.newFromHint(hint) + obj = osrfNewObjectFromHint(hint) + self.appendChild(obj) + self.objStack.append(obj) + if name == 'array': + self.posStack.append(0) + return if name == 'array': obj = [] @@ -130,17 +133,30 @@ class XMLGatewayParser(handler.ContentHandler): parent = self.objStack[len(self.objStack)-1] - if( isinstance(parent, list) ): + if isinstance(parent, list): parent.append(child) else: - parent[self.keyStack.pop()] = child + if isinstance(parent, dict): + parent[self.keyStack.pop()] = child + else: + if isinstance(parent, osrfNetworkObject): + key = None + if parent.getRegistry().wireProtocol == 'array': + keys = parent.getRegistry().keys + i = self.posStack.pop() + key = keys[i] + if i+1 < len(keys): + self.posStack.append(i+1) + else: + key = self.keyStack.pop() + + parent.setField(key, child) def endElement(self, name): if name == 'array' or name == 'object': self.objStack.pop() def characters(self, chars): - #self.appendChild(''.join(chars[start:leng+start])) self.appendChild(urllib.unquote_plus(chars)) diff --git a/src/python/osrf/net_obj.py b/src/python/osrf/net_obj.py index a95dda0..792c613 100644 --- a/src/python/osrf/net_obj.py +++ b/src/python/osrf/net_obj.py @@ -5,11 +5,15 @@ from xml.sax import saxutils class osrfNetworkObject(object): ''' Base class for all network serializable objects ''' pass - def newFromHint(hint): + +def osrfNewObjectFromHint(hint): + try: obj = None exec('obj = osrfNetworkObject.%s()' % hint) return obj - newFromHint = staticmethod(newFromHint) + except AttributeError: + return osrfNetworkObject.__unknown() +#newFromHint = staticmethod(newFromHint) ''' Global object registry ''' @@ -59,6 +63,12 @@ def __makeGetData(cls): def get(self): return self.__data setattr(cls, 'getData', get) + +def __makeSetField(cls): + ''' Creates a generic mutator for fields by fieldname ''' + def set(self, field, value): + self.__data[field] = value + setattr(cls, 'setField', set) def __osrfNetworkObjectInit(self, data={}): @@ -107,6 +117,7 @@ def osrfNetworkRegisterHint(hint, keys, type='hash'): setattr(cls, '__init__', __osrfNetworkObjectInit) __makeGetRegistry(cls, registry) __makeGetData(cls) + __makeSetField(cls) # attach our new class to the osrfNetworkObject