[14.0][ADD] attachment synchronize mixins

attachment_synchronize_mixins/__init__.py

@@ -0,0 +1 @@
+from . import models

attachment_synchronize_mixins/__manifest__.py

@@ -0,0 +1,18 @@
+# Copyright 2023 Akretion
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+
+{
+    "name": "Attachment Synchronize exportable importable",
+    "summary": """
+        Base synchronizable mixins""",
+    "version": "14.0.1.0.0",
+    "license": "AGPL-3",
+    "author": "Akretion,Odoo Community Association (OCA)",
+    "website": "https://github.com/akretion/ak-odoo-incubator",
+    "depends": [
+        "base_sparse_field",
+        "attachment_synchronize",
+    ],
+    "data": [],
+    "demo": [],
+}

attachment_synchronize_mixins/models/__init__.py

@@ -0,0 +1,3 @@
+from . import attachment_synchronize_task
+from . import synchronize_importable_mixin
+from . import synchronize_exportable_mixin

attachment_synchronize_mixins/models/attachment_synchronize_task.py

@@ -0,0 +1,18 @@
+# Copyright 2023 Akretion
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+
+from odoo import models
+
+
+class AttachmentSynchronizeTask(models.Model):
+    _inherit = "attachment.synchronize.task"
+
+    def scheduler_export(self, model, domain=False):
+        if not domain:
+            recs = self.env[model].search()
+        else:
+            recs = self.env[model].search(domain)
+        if not recs:
+            return
+        attachments = recs.with_context(attachment_task=self).synchronize_export()
+        attachments.run()

attachment_synchronize_mixins/models/synchronize_exportable_mixin.py

@@ -0,0 +1,58 @@
+# Copyright 2023 Akretion
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+
+import base64
+import csv
+import datetime
+import uuid
+from io import StringIO
+
+from odoo import fields, models
+
+
+class SynchronizeExportableMixin(models.AbstractModel):
+    _name = "synchronize.exportable.mixin"
+    _description = "Synchronizable export mixin"
+    export_date = fields.Date()
+    export_attachment = fields.Char()
+    export_flag = fields.Boolean()
+
+    def synchronize_export(self):
+        data = self._prepare_export_data()
+        if not data:
+            return self.env["attachment.queue"]
+        attachment = self._format_to_exportfile(data)
+        self.track_export(attachment)
+        self.export_flag = False
+        return attachment
+
+    def track_export(self, attachment):
+        self.export_date = datetime.datetime.now()
+        self.export_attachment = attachment
+
+    def _prepare_export_data(self) -> list:
+        raise NotImplementedError
+
+    def _format_to_exportfile(self, data):
+        return self._format_to_exportfile_csv(data)
+
+    def _format_to_exportfile_csv(self, data):
+        csv_file = StringIO()
+        delimiter = self.env.context.get("csv_delimiter") or ";"
+        writer = csv.DictWriter(
+            csv_file, fieldnames=data[0].keys(), delimiter=delimiter
+        )
+        for row in data:
+            writer.writerow(row)
+        csv_file.seek(0)
+        ast = self.env.context.get("attachment_task")
+        vals = {
+            "name": self._get_export_name(),
+            "datas": base64.b64encode(csv_file.getvalue().encode("utf-8")),
+            "task_id": ast.id,
+            "file_type": ast.file_type,
+        }
+        return self.env["attachment.queue"].create(vals)
+
+    def _get_export_name(self):
+        return str(uuid.uuid4())

attachment_synchronize_mixins/models/synchronize_importable_mixin.py

@@ -0,0 +1,22 @@
+# Copyright 2023 Akretion
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+
+import datetime
+
+from odoo import fields, models
+
+
+class SynchronizeImportableMixin(models.AbstractModel):
+    _name = "synchronize.importable.mixin"
+    _description = "Synchronizable import mixin"
+
+    import_date = fields.Date()
+    import_file_id = fields.Many2one("attachment.queue")
+
+    def track_model_import(self):
+        self.write(
+            {
+                "import_date": datetime.datetime.now(),
+                "import_file_id": self.env.context.get("attachment_queue"),
+            }
+        )

attachment_synchronize_mixins/readme/CONTRIBUTORS.rst

@@ -0,0 +1 @@
+* Kevin Khao <[email protected]>

attachment_synchronize_mixins/readme/DESCRIPTION.rst

@@ -0,0 +1 @@
+Base functionality for import and export of external systems with attachment_synchronize