emails: add Message-Id, In-Reply-To and References headers (#89284)

@@ -232,0 +258,4 @@
+        }
+        return message_id
+
+    def get_references(self, formdata, addresses):

@@ -52,2 +54,4 @@
         self.mail_subject = mail_subject
         self.mail_body = mail_body
+        self.message_id = message_id
+        self.references = references

@@ -232,0 +237,4 @@
+        for tenant in get_publisher().get_tenants():
+            if tenant.directory == get_publisher().app_dir:
+                hostname = tenant.hostname
+                break

@@ -232,0 +246,4 @@
+        if isinstance(formdata.formdef, CardDef):
+            form_type = 'card'
+        else:
+            form_type = 'form'

@@ -232,0 +260,4 @@
+
+    def get_references(self, formdata, addresses):
+        for part in reversed(list(formdata.iter_evolution_parts(klass=EmailEvolutionPart))):
+            if part.addresses == addresses:

@@ -403,0 +454,4 @@
+            'email_from': email_from,
+            'attachments': attachments,
+            'extra_headers': extra_headers,
+        }

@@ -4135,0 +4146,4 @@
+    ts = datetime.datetime.now().strftime('%Y%m%d.%H%M%S.')
+    hostname = 'example.net'
+    expt_id = f'wcs-carddata-{carddef.id}-{carddata.id}.{ts}[^@]+@{hostname}'
+    assert re.match(expt_id, headers['Message-Id'])

@@ -47,2 +50,4 @@
 
 
+def _get_message_id_re(msg_id_fmt):
+    return re.compile(msg_id_fmt % {'ts': datetime.datetime.now().strftime(r'%Y%m%d\.%H%M%S\.')})

@@ -77,2 +84,4 @@
     get_response().process_after_jobs()
     assert emails.count() == 0
+    for part in formdata.evolution[-1].parts:
+        assert not isinstance(part, EmailEvolutionPart)

@@ -125,6 +167,12 @@ def test_email(pub, emails):
     assert emails.count() == 1
     assert emails.get('foobar')['to'] == 'Undisclosed recipients:;'
     assert set(emails.get('foobar')['email_rcpt']) == {'foo@localhost', 'bar@localhost', 'baz@localhost'}
+    # recipients changed, the email is not a reply-to the previous one

@@ -232,0 +236,4 @@
+
+        message_id = 'wcs-%(type)s-%(formdef_id)s-%(formdata_id)s.%(ts)s@%(hostname)s'
+
+        message_id %= {

@@ -232,0 +248,4 @@
+    def get_first_messages_id(self, formdata, addresses):
+        remaining = set(addresses)
+        result = {}
+        for part in list(formdata.iter_evolution_parts(klass=EmailEvolutionPart)):

@@ -394,2 +428,4 @@
+        for first_id, id_addr in self.get_first_messages_id(formdata, addresses).items():
+            message_id = self.get_message_id(formdata)
             formdata.evolution[-1].add_part(
                 EmailEvolutionPart(

@@ -427,0 +451,4 @@
+            email_kwargs = {
+                **common_kwargs,
+                **dest_kwargs,
+                'extra_headers': {'Message-Id': message_id, **reply_headers},

@@ -232,0 +255,4 @@
+            if len(remaining) == 0:
+                break
+        else:
+            result[None] = (self.get_message_id(formdata), list(remaining))