Changeset 8214 for main/waeup.kofa/trunk/src/waeup/kofa/utils

Timestamp:

19 Apr 2012, 12:43:37 (13 years ago)

Author:

uli

Message:

Lots of trash to sketch filtered imports.

Location:

main/waeup.kofa/trunk/src/waeup/kofa/utils

Files:

• batching.py (modified) (2 diffs)
• converters.py (modified) (9 diffs)

main/waeup.kofa/trunk/src/waeup/kofa/utils/batching.py

@@ -32 +32 @@
 from waeup.kofa.interfaces import (
     IBatchProcessor, FatalCSVError, IObjectConverter,
-    ICSVExporter, DELETIONMARKER)
+    ICSVExporter, DELETION_MARKER, IGNORE_MARKER)
 
 class BatchProcessor(grok.GlobalUtility):
@@ -205 +205 @@
             if hasattr(obj, key):
                 # Set attribute to None if value is marked for deletion
-                if value == DELETIONMARKER:
-                    setattr(obj, key, None)
-                elif value is not None:
+                if value != '<IGNORE>':
                     setattr(obj, key, value)
+                #if value == DELETIONMARKER:
+                #    setattr(obj, key, None)
+                #elif value is not None:
+                #    setattr(obj, key, value)
         return
 

main/waeup.kofa/trunk/src/waeup/kofa/utils/converters.py

@@ -30 +30 @@
 from waeup.kofa.interfaces import (
     IObjectConverter, IResultEntryField, IFieldConverter, SubjectSource,
-    GradeSource)
+    GradeSource, DELETION_MARKER, IGNORE_MARKER)
 from waeup.kofa.schema.interfaces import IPhoneNumber
 from waeup.kofa.schoolgrades import ResultEntry
@@ -114 +114 @@
 class DefaultFieldConverter(grok.Adapter):
     grok.context(Interface)
-    grok.provides(IFieldConverter)
-
-    def request_data(self, name, value, schema_field, prefix=''):
+    grok.implements(IFieldConverter)
+
+    def request_data(self, name, value, schema_field, prefix='',
+                     mode='create'):
         return {prefix: value}
 
 class ListFieldConverter(grok.Adapter):
     grok.context(IList)
-    grok.provides(IFieldConverter)
-
-    def request_data(self, name, value, schema_field, prefix=''):
+    grok.implements(IFieldConverter)
+
+    def request_data(self, name, value, schema_field, prefix='',
+                     mode='create'):
         value_type = schema_field.value_type
         try:
@@ -144 +146 @@
     """
     grok.context(IPhoneNumber)
-    grok.provides(IFieldConverter)
-
-    def request_data(self, name, value, schema_field, prefix=''):
+    grok.implements(IFieldConverter)
+
+    def request_data(self, name, value, schema_field, prefix='',
+                     mode='create'):
         parts = value.split('-', 2)
         country = ''
@@ -168 +171 @@
 class ResultEntryConverter(grok.Adapter):
     grok.context(IResultEntryField)
-    grok.provides(IFieldConverter)
-
-    def request_data(self, name, value, schema_field, prefix=''):
+    grok.implements(IFieldConverter)
+
+    def request_data(self, name, value, schema_field, prefix='',
+                     mode='create'):
         """Turn CSV values into ResultEntry-compatible form data.
 
@@ -208 +212 @@
 
     grok.context(Interface)
-    grok.provides(IObjectConverter)
+    grok.implements(IObjectConverter)
 
     def __init__(self, iface):
@@ -217 +221 @@
         return
 
-    def fromStringDict(self, data_dict, context, form_fields=None):
+    def fromStringDict(self, data_dict, context, form_fields=None,
+                       mode='create'):
         """Convert values in `data_dict`.
 
@@ -262 +267 @@
 
         request = TestRequest(form={})
+        new_data = dict()
         for key, val in data_dict.items():
             field = form_fields.get(key, None)
@@ -269 +275 @@
                 schema_field = field.interface[field.__name__]
                 field_converter = IFieldConverter(schema_field)
+                if mode == 'update':
+                    if val == DELETION_MARKER:
+                        val = schema_field.missing_value
+                        if schema_field.required:
+                            val = schema_field.default
+                        new_data[key] = val
+                        continue
+                    if val == IGNORE_MARKER:
+                        continue
                 request.form.update(
                     field_converter.request_data(
@@ -283 +298 @@
             form_fields, 'form', obj, request)
 
-        new_data = dict()
+        #new_data = dict()
         errors = getWidgetsData(widgets, 'form', new_data)