Changeset 2716 in products

Timestamp:

Aug 3, 2010 3:39:15 PM (14 years ago)

Author:

mylan

Message:

Added dict type field serialization and deserialization

File:

• quintagroup.transmogrifier/branches/dictionary/quintagroup/transmogrifier/namespaces/atns.py (modified) (4 diffs)

quintagroup.transmogrifier/branches/dictionary/quintagroup/transmogrifier/namespaces/atns.py

@@ -18 +18 @@
 
 
+
+#######################################
+#         Setup logging system        #
+#######################################
+import logging
+DEFAULT_LOG = "/tmp/quintagroup.transmogrifier.log"
+FORMAT = "[%(asctime)s]: %(message)s"
+#FORMAT = "[%H:%M:%S]: %(message)s"
+def createHandler(hndlr_cls, level, *args, **kwargs):
+    hndlr = hndlr_cls(*args, **kwargs)
+    hndlr.setLevel(level)
+    hndlr.setFormatter(logging.Formatter(FORMAT, datefmt="%H:%M:%S"))
+    return hndlr
+
+# Very IMPORTANT create logger as logging.Logger NOT logging.getLogger !!!
+logger = logging.Logger("Quintagroup Transmogrifier", logging.NOTSET)
+logger.addHandler(createHandler(
+        logging.FileHandler, logging.DEBUG, DEFAULT_LOG))
+
+#######################################
+
+_marker = ()
+
+
 class ATAttribute(base.ATAttribute):
 
@@ -25 +49 @@
         if not values:
             return
+
+        # if self.name in ['payablesMap', 'fieldMap']:
+        #     import ipdb;ipdb.set_trace()
 
         is_ref = self.isReference(instance)
@@ -61 +88 @@
                 node.appendChild(value_node)
             else:
+                items = getattr(value, 'items', _marker)
+                if items is not _marker and callable(items):
+                    type_attr = dom.createAttribute("type")
+                    type_attr.value = "dict"
+                    node.setAttributeNode( type_attr )
                 value_node = dom.createTextNode(value)
                 node.appendChild(value_node)
@@ -81 +113 @@
         if te is not None:
             value = value.decode(te)
+        # process dictionary type
+        vtype = context.node.attrib.get('type', None)
+        if vtype and vtype=='dict':
+            try:
+                s = value.strip("{}\t\n")
+                # value = dict([map(lambda x:x.strip(" '\""), item.split("': '")) \
+                #              for item in s.split("', '")])
+                value = dict([map(lambda x:x.strip(" '\""), item.split(": ")) \
+                             for item in s.split(", ")])
+            except:
+                #import ipdb;ipdb.set_trace()
+                logger.error("Error on processing '%s' dict type field,\n"\
+                    " for object: '%s'\n  " \
+                    " for the following data: '%s'" % (str(context.instance.id),
+                     context.instance.absolute_url(), str(value)))
+
 
         data = context.getDataFor(self.namespace.xmlns)