chunk_processing: add json processor

Author: sebastienbeau

chunk_processing/components/__init__.py

@@ -1,5 +1,6 @@
 from . import processor
 from . import processor_xml
+from . import processor_json
 from . import splitter
 from . import splitter_json
 from . import splitter_xml

chunk_processing/components/processor.py

@@ -10,5 +10,24 @@ class ChunkProcessor(AbstractComponent):
     _name = "chunk.processor"
     _collection = "chunk.item"
 
-    def run(self):
+    def _import_item(self):
         raise NotImplementedError
+
+    def _prepare_error_message(self, idx, item, error):
+        return {
+            "rows": {"from": idx, "to": idx},
+            "type": type(error).__name__,
+            "message": str(error),
+        }
+
+    def run(self):
+        res = {"ids": [], "messages": []}
+        for idx, item in enumerate(self._parse_data()):
+            try:
+                with self.env.cr.savepoint():
+                    res["ids"] += self._import_item(item)
+            except Exception as e:
+                if self.env.context.get("chunk_raise_if_exception"):
+                    raise
+                res["messages"].append(self._prepare_error_message(idx, item, e))
+        return res

chunk_processing/components/processor_json.py

@@ -0,0 +1,17 @@
+# Copyright 2021 Akretion (https://www.akretion.com).
+# @author Sébastien BEAU <[email protected]>
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+
+import base64
+import json
+
+from odoo.addons.component.core import AbstractComponent
+
+
+class ChunkProcessorJson(AbstractComponent):
+    _name = "chunk.importer.json"
+    _inherit = "chunk.processor"
+    _collection = "chunk.item"
+
+    def _parse_data(self):
+        return json.loads(base64.b64decode(self.collection.data))

chunk_processing/components/processor_xml.py

@@ -11,31 +11,10 @@
 
 class ChunkProcessorXml(AbstractComponent):
     _name = "chunk.importer.xml"
+    _inherit = "chunk.processor"
     _collection = "chunk.item"
 
     def _parse_data(self):
         return objectify.fromstring(
             base64.b64decode(self.collection.data)
         ).iterchildren()
-
-    def _import_item(self):
-        raise NotImplementedError
-
-    def _prepare_error_message(self, idx, item, error):
-        return {
-            "rows": {"from": idx, "to": idx},
-            "type": type(error).__name__,
-            "message": str(error),
-        }
-
-    def run(self):
-        res = {"ids": [], "messages": []}
-        for idx, item in enumerate(self._parse_data()):
-            try:
-                with self.env.cr.savepoint():
-                    res["ids"] += self._import_item(item)
-            except Exception as e:
-                if self.env.context.get("chunk_raise_if_exception"):
-                    raise
-                res["messages"].append(self._prepare_error_message(idx, item, e))
-        return res