[18.0][MIG] connector_extension: Migration to 18.0

connector_extension/README.rst

@@ -0,0 +1,86 @@
+===================
+Connector Extension
+===================
+
+.. 
+   !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+   !! This file is generated by oca-gen-addon-readme !!
+   !! changes will be overwritten.                   !!
+   !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+   !! source digest: sha256:39b64c10f88d1224bc1e05fc967b018cce54a165a66cc8fd65dbf1c03f196c2d
+   !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+
+.. |badge1| image:: https://img.shields.io/badge/maturity-Beta-yellow.png
+    :target: https://odoo-community.org/page/development-status
+    :alt: Beta
+.. |badge2| image:: https://img.shields.io/badge/licence-LGPL--3-blue.png
+    :target: http://www.gnu.org/licenses/lgpl-3.0-standalone.html
+    :alt: License: LGPL-3
+.. |badge3| image:: https://img.shields.io/badge/github-NuoBiT%2Fodoo--addons-lightgray.png?logo=github
+    :target: https://github.com/NuoBiT/odoo-addons/tree/18.0/connector_extension
+    :alt: NuoBiT/odoo-addons
+
+|badge1| |badge2| |badge3|
+
+The "connector_extension" module is an add-on for the Odoo ERP system
+that enhances the functionality of the base "connector" module. This
+extension provides additional features, tools, and integrations, making
+it easier for developers to create, manage, and maintain connections
+between Odoo and various third-party systems, APIs, or services.
+
+The module aims to simplify the connector development process by
+providing a robust and flexible framework. The "connector_extension"
+module allows developers to focus on implementing specific business
+logic and requirements, while the extension handles common tasks.
+
+- Extended connector framework: The module extends the base connector
+  framework by providing new classes, methods, and utilities for easier
+  integration with third-party systems.
+- Reusable components: Pre-built components for handling common tasks
+  such error handling, and data synchronization.
+- Enhanced data mapping: Advanced data mapping capabilities to transform
+  and adapt data between Odoo and external systems seamlessly.
+- Scalability and performance improvements: Optimized for handling large
+  datasets and concurrent connections, ensuring smooth and efficient
+  data synchronization.
+- Linking with existing records: Enables linking with existing records,
+  using alternate keys, which allows for easier data management and
+  reduced redundancy.
+
+**Table of contents**
+
+.. contents::
+   :local:
+
+Bug Tracker
+===========
+
+Bugs are tracked on `GitHub Issues <https://github.com/NuoBiT/odoo-addons/issues>`_.
+In case of trouble, please check there if your issue has already been reported.
+If you spotted it first, help us to smash it by providing a detailed and welcomed
+`feedback <https://github.com/NuoBiT/odoo-addons/issues/new?body=module:%20connector_extension%0Aversion:%2018.0%0A%0A**Steps%20to%20reproduce**%0A-%20...%0A%0A**Current%20behavior**%0A%0A**Expected%20behavior**>`_.
+
+Do not contact contributors directly about support or help with technical issues.
+
+Credits
+=======
+
+Authors
+-------
+
+* NuoBiT Solutions SL
+
+Contributors
+------------
+
+- `NuoBiT <https://www.nuobit.com>`__:
+
+  - Kilian Niubo kniubo@nuobit.com
+  - Eric Antones eantones@nuobit.com
+
+Maintainers
+-----------
+
+This module is part of the `NuoBiT/odoo-addons <https://github.com/NuoBiT/odoo-addons/tree/18.0/connector_extension>`_ project on GitHub.
+
+You are welcome to contribute.

connector_extension/__init__.py

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

connector_extension/__manifest__.py

@@ -0,0 +1,17 @@
+# Copyright NuoBiT Solutions SL - Kilian Niubo <kniubo@nuobit.com>
+# Copyright NuoBiT Solutions SL - Eric Antones <eantones@nuobit.com>
+# Copyright 2025 NuoBiT Solutions SL - Deniz Gallo <dgallo@nuobit.com>
+# License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
+
+{
+    "name": "Connector Extension",
+    "summary": "This module extends the connector module",
+    "version": "18.0.1.0.0",
+    "author": "NuoBiT Solutions SL",
+    "license": "LGPL-3",
+    "category": "Connector",
+    "website": "https://github.com/NuoBiT/odoo-addons",
+    "depends": ["connector"],
+    # The dependency on queue_context is necessary so that
+    # when a job calls another job, the company is not lost
+}

connector_extension/common/tools.py

@@ -0,0 +1,168 @@
+# Copyright NuoBiT Solutions SL - Eric Antones <eantones@nuobit.com>
+# Copyright NuoBiT Solutions SL - Kilian Niubo <kniubo@nuobit.com>
+# Copyright 2025 NuoBiT Solutions SL - Deniz Gallo <dgallo@nuobit.com>
+# License LGPL-3.0 or later (http://www.gnu.org/licenses/lgpl.html)
+import datetime
+import hashlib
+import re
+import unicodedata
+
+from odoo import _
+from odoo.exceptions import ValidationError
+
+
+def list2hash(_list):
+    _hash = hashlib.sha256()
+    for e in _list:
+        if isinstance(e, int):
+            e9 = str(e)
+        elif isinstance(e, str):
+            e9 = e
+        elif isinstance(e, float):
+            e9 = str(e)
+        elif e is None:
+            e9 = ""
+        else:
+            raise Exception(f"Unexpected type for a key: type {type(e)}")
+        _hash.update(e9.encode("utf8"))
+    return _hash.hexdigest()
+
+
+def domain_to_normalized_dict(self, domain):
+    """Convert, if possible, standard Odoo domain to a dictionary.
+    To do so it is necessary to convert all operators to
+    equal '=' operator.
+    """
+    res = {}
+    for elem in domain:
+        if len(elem) != 3:
+            raise ValidationError(_("Wrong domain clause format %s") % elem)
+        field, op, value = elem
+        if op == "=":
+            if field in res:
+                raise ValidationError(_("Duplicated field %s") % field)
+            res[field] = self._normalize_value(value)
+        elif op == "!=":
+            if not isinstance(value, bool):
+                raise ValidationError(
+                    _("Not equal operation not supported for non boolean fields")
+                )
+            if field in res:
+                raise ValidationError(_("Duplicated field %s") % field)
+            res[field] = self._normalize_value(not value)
+        elif op == "in":
+            if not isinstance(value, (tuple | list)):
+                raise ValidationError(
+                    _(
+                        "Operator '%(OPERATOR)s' only supports "
+                        "tuples or lists, not %(TYPES)s"
+                    )
+                    % {
+                        "OPERATOR": op,
+                        "TYPES": type(value),
+                    }
+                )
+            if field in res:
+                raise ValidationError(_("Duplicated field %s") % field)
+            res[field] = self._normalize_value(value)
+        elif op in (">", ">=", "<", "<="):
+            if not isinstance(value, (datetime.date | datetime.datetime | int)):
+                raise ValidationError(
+                    _("Type %(value_type)s not supported for operator %(operator)s")
+                    % {"value_type": type(value), "operator": op}
+                )
+            if op in (">", "<"):
+                adj = 1
+                if isinstance(value, (datetime.date | datetime.datetime)):
+                    adj = datetime.timedelta(days=adj)
+                if op == "<":
+                    op, value = "<=", value - adj
+                else:
+                    op, value = ">=", value + adj
+
+            res[field] = self._normalize_value(value)
+        else:
+            raise ValidationError(_("Operator %s not supported") % op)
+
+    return res
+
+
+def convert_item_to_json(item, ct, namespace):
+    jitem = {}
+    for path, func, key, multi in ct:
+        if key in jitem:
+            raise ValidationError(_("Key %s already exists") % key)
+        value = item.xpath(path, namespaces=namespace)
+        if not value:
+            jitem[key] = None
+        else:
+            if multi:
+                jitem[key] = func(value)
+            else:
+                if len(value) > 1:
+                    raise ValidationError(_("Multiple values found for '%s'") % path)
+                else:
+                    jitem[key] = func(value[0])
+    return jitem
+
+
+def convert_to_json(data, ct, namespace):
+    res = []
+    for d in data:
+        res.append(convert_item_to_json(d, ct, namespace))
+    return res
+
+
+def slugify(value):
+    if not value:
+        return None
+    return (
+        unicodedata.normalize("NFKD", value)
+        .encode("ascii", "ignore")
+        .decode("ascii")
+        .lower()
+        .replace(" ", "")
+    )
+
+
+def trim_domain(domain):
+    """
+    Takes an Odoo-style domain (a Python list of clauses) and returns a new domain where
+    any string values in the third position of 3‑element clauses have leading/trailing
+    whitespace removed.
+    """
+    trimmed_domain = []
+    for d in domain:
+        if isinstance(d, (list | tuple)):
+            if len(d) == 3 and isinstance(d[2], str):
+                trimmed_domain.append((d[0], d[1], d[2].strip()))
+            elif len(d) == 3 and isinstance(d[2], (list | tuple)):
+                trimmed_value = [
+                    value.strip() if isinstance(value, str) else value for value in d[2]
+                ]
+                trimmed_domain.append((d[0], d[1], trimmed_value))
+            else:
+                trimmed_domain.append(d)
+        else:
+            raise Exception(f"Unexpected domain format: {d}")
+    return trimmed_domain
+
+
+def color_rgb2hex(data):
+    def conv_rgb(match):
+        rgb_hex_l = []
+        groups = match.groups()
+        for value, percent in zip(groups[0::2], groups[1::2], strict=True):
+            if percent:
+                hex_value = round(float(value) * 255 / 100)
+            else:
+                hex_value = int(value)
+            rgb_hex_l.append(f"{hex_value:02X}")
+        return f'#{"".join(rgb_hex_l)}'
+
+    return re.sub(
+        r"rgb\( *([0-9.]+) *(%?) *, *([0-9.]+) *(%?) *, *([0-9.]+) *(%?) *\)",
+        conv_rgb,
+        data,
+        flags=re.IGNORECASE,
+    )

connector_extension/components/__init__.py

@@ -0,0 +1,9 @@
+from . import adapter
+from . import binder
+from . import synchronizer
+from . import export_deleter
+from . import exporter
+from . import importer
+from . import import_deleter
+from . import listener
+from . import mapper