[IMP] edi_mail_import_oca: Move logic to backend

Author: etobella

edi_mail_import_oca/README.rst

@@ -49,6 +49,23 @@ however, there is an standard way to receive files that is emails.
 This module tries to offer a way to reuse EDI and mail interface in
 order to handle everything.
 
+Configuration
+=============
+
+For handling this incoming data, you just need to create a Backend and
+define the alias.
+
+The alias will be used to detect input mails. If the system detects an
+email, it will take all the exchange types related to the backend and
+review by exchange_filename if the pattern is filled. Also, if the
+backend has the ``full_mail_exchange_type_id`` field filled, it will
+store the full dict.
+
+If not exchange type can be found, a UserError and a bounce email are
+sent.
+
+Processing will be handled in the standard way.
+
 Bug Tracker
 ===========
 

edi_mail_import_oca/__manifest__.py

@@ -10,7 +10,7 @@
     "website": "https://github.com/OCA/edi-framework",
     "depends": ["edi_core_oca", "mail"],
     "data": [
-        "views/edi_exchange_type.xml",
+        "views/edi_backend.xml",
     ],
     "demo": [],
 }

edi_mail_import_oca/models/__init__.py

@@ -1,2 +1,2 @@
-from . import edi_exchange_type
+from . import edi_backend
 from . import edi_exchange_record

edi_mail_import_oca/models/edi_backend.py

@@ -0,0 +1,35 @@
+# Copyright 2026 Dixmit
+# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
+import ast
+
+from odoo import fields, models
+
+
+class EdiBackend(models.Model):
+    _name = "edi.backend"
+    _inherit = ["edi.backend", "mail.alias.mixin"]
+
+    full_mail_exchange_type_id = fields.Many2one(
+        "edi.exchange.type",
+    )
+
+    def _alias_get_creation_values(self):
+        values = super()._alias_get_creation_values()
+        values["alias_model_id"] = self.env["ir.model"]._get("edi.exchange.record").id
+        if self.id:
+            values["alias_defaults"] = defaults = ast.literal_eval(
+                self.alias_defaults or "{}"
+            )
+            defaults["backend_id"] = self.id
+        return values
+
+    def _mail_exchange_type_pending_input_domain(self):
+        """Domain for retrieving input exchange types for emails."""
+        return [
+            ("backend_type_id", "=", self.backend_type_id.id),
+            ("direction", "=", "input"),
+            "|",
+            ("backend_id", "=", False),
+            ("backend_id", "=", self.id),
+            ("exchange_filename_pattern", "!=", False),
+        ]

edi_mail_import_oca/models/edi_exchange_record.py

@@ -7,6 +7,7 @@
 import re
 
 from odoo import api, models
+from odoo.exceptions import UserError
 
 _logger = logging.getLogger(__name__)
 
@@ -16,42 +17,69 @@ class EdiExchangeRecord(models.Model):
 
     @api.model
     def message_new(self, msg_dict, custom_values=None):
+        backend_id = custom_values.get("backend_id") if custom_values else None
+        if backend_id:
+            backend = self.env["edi.backend"].browse(backend_id)
+            content = False
+            filename = False
+            if (
+                not custom_values.get("type_id")
+                and not backend.full_mail_exchange_type_id
+            ):
+                types = self.env["edi.exchange.type"].search(
+                    backend._mail_exchange_type_pending_input_domain()
+                )
+                for exchange_type in types:
+                    for attachment in msg_dict.get("attachments", []):
+                        if re.match(
+                            exchange_type.exchange_filename_pattern,
+                            attachment.fname,
+                            re.IGNORECASE,
+                        ):
+                            content = self._process_email_attachment(attachment)
+                            filename = attachment.fname
+                            custom_values["type_id"] = exchange_type.id
+                            break
+                    if content:
+                        custom_values["type_id"] = exchange_type.id
+                        break
+            else:
+                if backend.full_mail_exchange_type_id:
+                    custom_values["type_id"] = backend.full_mail_exchange_type_id.id
+                new_message_dict = msg_dict.copy()
+                attachments = new_message_dict.pop("attachments", [])
+                new_message_dict["attachments"] = []
+                for attachment in attachments:
+                    new_message_dict["attachments"].append(
+                        {
+                            "info": attachment.info,
+                            "data": self._process_email_attachment(attachment),
+                            "fname": attachment.fname,
+                        }
+                    )
+                content = json.dumps(new_message_dict)
+                filename = "email_message.json"
+        if not custom_values or "type_id" not in custom_values:
+            _logger.warning(
+                "No exchange type found for incoming email with subject '%s'",
+                msg_dict.get("subject"),
+            )
+            raise UserError(
+                self.env._(
+                    "No exchange type found for incoming email with subject '%s'",
+                    msg_dict.get("subject"),
+                )
+            )
         record = super().message_new(
             msg_dict,
             custom_values=custom_values,
         )
-        if record.type_id.mail_as_attachment:
-            new_message_dict = msg_dict.copy()
-            attachments = new_message_dict.pop("attachments", [])
-            new_message_dict["attachments"] = []
-            for attachment in attachments:
-                new_message_dict["attachments"].append(
-                    {
-                        "info": attachment.info,
-                        "data": self._process_email_attachment(attachment),
-                        "fname": attachment.fname,
-                    }
-                )
-            record._set_file_content(json.dumps(new_message_dict))
-            record.edi_exchange_state = "input_received"
-        else:
-            content = False
-            filename = False
-            for attachment in msg_dict.get("attachments", []):
-                if re.match(
-                    record.type_id.exchange_filename_pattern or ".*",
-                    attachment.fname,
-                    re.IGNORECASE,
-                ):
-                    content = self._process_email_attachment(attachment)
-                    filename = attachment.fname
-                    break
-            if content:
-                record._set_file_content(content)
-                record.exchange_filename = filename
-                record.edi_exchange_state = "input_received"
+        record._set_file_content(content)
+        record.exchange_filename = filename
+        record.edi_exchange_state = "input_received"
         return record
 
+    @api.model
     def _process_email_attachment(self, attachment):
         """Process email attachment to be stored as file content."""
         data = attachment[1]

edi_mail_import_oca/models/edi_exchange_type.py

@@ -0,0 +1,9 @@
+For handling this incoming data, you just need to create a Backend and define the alias.
+
+The alias will be used to detect input mails.
+If the system detects an email, it will take all the exchange types related to the backend and review by exchange_filename if the pattern is filled.
+Also, if the backend has the `full_mail_exchange_type_id` field filled, it will store the full dict.
+
+If not exchange type can be found, a UserError and a bounce email are sent.
+
+Processing will be handled in the standard way.

edi_mail_import_oca/readme/CONFIGURE.md

@@ -381,11 +381,12 @@ <h1>Edi Mail Import Oca</h1>
 <div class="contents local topic" id="contents">
 <ul class="simple">
 <li><a class="reference internal" href="#use-cases-context" id="toc-entry-1">Use Cases / Context</a></li>
-<li><a class="reference internal" href="#bug-tracker" id="toc-entry-2">Bug Tracker</a></li>
-<li><a class="reference internal" href="#credits" id="toc-entry-3">Credits</a><ul>
-<li><a class="reference internal" href="#authors" id="toc-entry-4">Authors</a></li>
-<li><a class="reference internal" href="#contributors" id="toc-entry-5">Contributors</a></li>
-<li><a class="reference internal" href="#maintainers" id="toc-entry-6">Maintainers</a></li>
+<li><a class="reference internal" href="#configuration" id="toc-entry-2">Configuration</a></li>
+<li><a class="reference internal" href="#bug-tracker" id="toc-entry-3">Bug Tracker</a></li>
+<li><a class="reference internal" href="#credits" id="toc-entry-4">Credits</a><ul>
+<li><a class="reference internal" href="#authors" id="toc-entry-5">Authors</a></li>
+<li><a class="reference internal" href="#contributors" id="toc-entry-6">Contributors</a></li>
+<li><a class="reference internal" href="#maintainers" id="toc-entry-7">Maintainers</a></li>
 </ul>
 </li>
 </ul>
@@ -397,24 +398,37 @@ <h2><a class="toc-backref" href="#toc-entry-1">Use Cases / Context</a></h2>
 <p>This module tries to offer a way to reuse EDI and mail interface in
 order to handle everything.</p>
 </div>
+<div class="section" id="configuration">
+<h2><a class="toc-backref" href="#toc-entry-2">Configuration</a></h2>
+<p>For handling this incoming data, you just need to create a Backend and
+define the alias.</p>
+<p>The alias will be used to detect input mails. If the system detects an
+email, it will take all the exchange types related to the backend and
+review by exchange_filename if the pattern is filled. Also, if the
+backend has the <tt class="docutils literal">full_mail_exchange_type_id</tt> field filled, it will
+store the full dict.</p>
+<p>If not exchange type can be found, a UserError and a bounce email are
+sent.</p>
+<p>Processing will be handled in the standard way.</p>
+</div>
 <div class="section" id="bug-tracker">
-<h2><a class="toc-backref" href="#toc-entry-2">Bug Tracker</a></h2>
+<h2><a class="toc-backref" href="#toc-entry-3">Bug Tracker</a></h2>
 <p>Bugs are tracked on <a class="reference external" href="https://github.com/OCA/edi-framework/issues">GitHub Issues</a>.
 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
 <a class="reference external" href="https://github.com/OCA/edi-framework/issues/new?body=module:%20edi_mail_import_oca%0Aversion:%2019.0%0A%0A**Steps%20to%20reproduce**%0A-%20...%0A%0A**Current%20behavior**%0A%0A**Expected%20behavior**">feedback</a>.</p>
 <p>Do not contact contributors directly about support or help with technical issues.</p>
 </div>
 <div class="section" id="credits">
-<h2><a class="toc-backref" href="#toc-entry-3">Credits</a></h2>
+<h2><a class="toc-backref" href="#toc-entry-4">Credits</a></h2>
 <div class="section" id="authors">
-<h3><a class="toc-backref" href="#toc-entry-4">Authors</a></h3>
+<h3><a class="toc-backref" href="#toc-entry-5">Authors</a></h3>
 <ul class="simple">
 <li>Dixmit</li>
 </ul>
 </div>
 <div class="section" id="contributors">
-<h3><a class="toc-backref" href="#toc-entry-5">Contributors</a></h3>
+<h3><a class="toc-backref" href="#toc-entry-6">Contributors</a></h3>
 <ul class="simple">
 <li><a class="reference external" href="https://www.dixmit.com">Dixmit</a><ul>
 <li>Enric Tobella</li>
@@ -423,7 +437,7 @@ <h3><a class="toc-backref" href="#toc-entry-5">Contributors</a></h3>
 </ul>
 </div>
 <div class="section" id="maintainers">
-<h3><a class="toc-backref" href="#toc-entry-6">Maintainers</a></h3>
+<h3><a class="toc-backref" href="#toc-entry-7">Maintainers</a></h3>
 <p>This module is maintained by the OCA.</p>
 <a class="reference external image-reference" href="https://odoo-community.org">
 <img alt="Odoo Community Association" src="https://odoo-community.org/logo.png" />

edi_mail_import_oca/static/description/index.html

@@ -1 +1,2 @@
 from . import test_mail_import_oca
+from . import test_mail_import_oca_no_file