deltachat/
html.rs

1//! # Get message as HTML.
2//!
3//! Use `Message.has_html()` to check if the UI shall render a
4//! corresponding button and `MsgId.get_html()` to get the full message.
5//!
6//! Even when the original mime-message is not HTML,
7//! `MsgId.get_html()` will return HTML -
8//! this allows nice quoting, handling linebreaks properly etc.
9
10use std::mem;
11
12use anyhow::{Context as _, Result};
13use base64::Engine as _;
14use mailparse::ParsedContentType;
15use mime::Mime;
16
17use crate::context::Context;
18use crate::headerdef::{HeaderDef, HeaderDefMap};
19use crate::log::warn;
20use crate::message::{self, Message, MsgId};
21use crate::mimeparser::parse_message_id;
22use crate::param::Param::SendHtml;
23use crate::plaintext::PlainText;
24
25impl Message {
26    /// Check if the message can be retrieved as HTML.
27    /// Typically, this is the case, when the mime structure of a Message is modified,
28    /// meaning that some text is cut or the original message
29    /// is in HTML and `simplify()` may hide some maybe important information.
30    /// The corresponding ffi-function is `dc_msg_has_html()`.
31    /// To get the HTML-code of the message, use `MsgId.get_html()`.
32    pub fn has_html(&self) -> bool {
33        self.mime_modified
34    }
35
36    /// Set HTML-part part of a message that is about to be sent.
37    /// The HTML-part is written to the database before sending and
38    /// used as the `text/html` part in the MIME-structure.
39    ///
40    /// Received HTML parts are handled differently,
41    /// they are saved together with the whole MIME-structure
42    /// in `mime_headers` and the HTML-part is extracted using `MsgId::get_html()`.
43    /// (To underline this asynchronicity, we are using the wording "SendHtml")
44    pub fn set_html(&mut self, html: Option<String>) {
45        if let Some(html) = html {
46            self.param.set(SendHtml, html);
47            self.mime_modified = true;
48        } else {
49            self.param.remove(SendHtml);
50            self.mime_modified = false;
51        }
52    }
53}
54
55/// Type defining a rough mime-type.
56/// This is mainly useful on iterating
57/// to decide whether a mime-part has subtypes.
58enum MimeMultipartType {
59    Multiple,
60    Single,
61    Message,
62}
63
64/// Function takes a content type from a ParsedMail structure
65/// and checks and returns the rough mime-type.
66fn get_mime_multipart_type(ctype: &ParsedContentType) -> MimeMultipartType {
67    let mimetype = ctype.mimetype.to_lowercase();
68    if mimetype.starts_with("multipart") && ctype.params.contains_key("boundary") {
69        MimeMultipartType::Multiple
70    } else if mimetype == "message/rfc822" {
71        MimeMultipartType::Message
72    } else {
73        MimeMultipartType::Single
74    }
75}
76
77/// HtmlMsgParser converts a mime-message to HTML.
78#[derive(Debug)]
79struct HtmlMsgParser {
80    pub html: String,
81    pub plain: Option<PlainText>,
82    pub(crate) msg_html: String,
83}
84
85impl HtmlMsgParser {
86    /// Function takes a raw mime-message string,
87    /// searches for the main-text part
88    /// and returns that as parser.html
89    pub async fn from_bytes<'a>(
90        context: &Context,
91        rawmime: &'a [u8],
92    ) -> Result<(Self, mailparse::ParsedMail<'a>)> {
93        let mut parser = HtmlMsgParser {
94            html: "".to_string(),
95            plain: None,
96            msg_html: "".to_string(),
97        };
98
99        let parsedmail = mailparse::parse_mail(rawmime).context("Failed to parse mail")?;
100
101        parser.collect_texts_recursive(context, &parsedmail).await?;
102
103        if parser.html.is_empty() {
104            if let Some(plain) = &parser.plain {
105                parser.html = plain.to_html();
106            }
107        } else {
108            parser.cid_to_data_recursive(context, &parsedmail).await?;
109        }
110        parser.html += &mem::take(&mut parser.msg_html);
111        Ok((parser, parsedmail))
112    }
113
114    /// Function iterates over all mime-parts
115    /// and searches for text/plain and text/html parts and saves the
116    /// first one found.
117    /// in the corresponding structure fields.
118    ///
119    /// Usually, there is at most one plain-text and one HTML-text part,
120    /// multiple plain-text parts might be used for mailinglist-footers,
121    /// therefore we use the first one.
122    async fn collect_texts_recursive<'a>(
123        &'a mut self,
124        context: &'a Context,
125        mail: &'a mailparse::ParsedMail<'a>,
126    ) -> Result<()> {
127        match get_mime_multipart_type(&mail.ctype) {
128            MimeMultipartType::Multiple => {
129                for cur_data in &mail.subparts {
130                    Box::pin(self.collect_texts_recursive(context, cur_data)).await?
131                }
132                Ok(())
133            }
134            MimeMultipartType::Message => {
135                let raw = mail.get_body_raw()?;
136                if raw.is_empty() {
137                    return Ok(());
138                }
139                let (parser, mail) = Box::pin(HtmlMsgParser::from_bytes(context, &raw)).await?;
140                if !parser.html.is_empty() {
141                    let mut text = "\r\n\r\n".to_string();
142                    for h in mail.headers {
143                        let key = h.get_key();
144                        if matches!(
145                            key.to_lowercase().as_str(),
146                            "date"
147                                | "from"
148                                | "sender"
149                                | "reply-to"
150                                | "to"
151                                | "cc"
152                                | "bcc"
153                                | "subject"
154                        ) {
155                            text += &format!("{key}: {}\r\n", h.get_value());
156                        }
157                    }
158                    text += "\r\n";
159                    self.msg_html += &PlainText {
160                        text,
161                        flowed: false,
162                        delsp: false,
163                    }
164                    .to_html();
165                    self.msg_html += &parser.html;
166                }
167                Ok(())
168            }
169            MimeMultipartType::Single => {
170                let mimetype = mail.ctype.mimetype.parse::<Mime>()?;
171                if mimetype == mime::TEXT_HTML {
172                    if self.html.is_empty()
173                        && let Ok(decoded_data) = mail.get_body()
174                    {
175                        self.html = decoded_data;
176                    }
177                } else if mimetype == mime::TEXT_PLAIN
178                    && self.plain.is_none()
179                    && let Ok(decoded_data) = mail.get_body()
180                {
181                    self.plain = Some(PlainText {
182                        text: decoded_data,
183                        flowed: if let Some(format) = mail.ctype.params.get("format") {
184                            format.as_str().eq_ignore_ascii_case("flowed")
185                        } else {
186                            false
187                        },
188                        delsp: if let Some(delsp) = mail.ctype.params.get("delsp") {
189                            delsp.as_str().eq_ignore_ascii_case("yes")
190                        } else {
191                            false
192                        },
193                    });
194                }
195                Ok(())
196            }
197        }
198    }
199
200    /// Replace cid:-protocol by the data:-protocol where appropriate.
201    /// This allows the final html-file to be self-contained.
202    async fn cid_to_data_recursive<'a>(
203        &'a mut self,
204        context: &'a Context,
205        mail: &'a mailparse::ParsedMail<'a>,
206    ) -> Result<()> {
207        match get_mime_multipart_type(&mail.ctype) {
208            MimeMultipartType::Multiple => {
209                for cur_data in &mail.subparts {
210                    Box::pin(self.cid_to_data_recursive(context, cur_data)).await?;
211                }
212                Ok(())
213            }
214            MimeMultipartType::Message => Ok(()),
215            MimeMultipartType::Single => {
216                let mimetype = mail.ctype.mimetype.parse::<Mime>()?;
217                if mimetype.type_() == mime::IMAGE
218                    && let Some(cid) = mail.headers.get_header_value(HeaderDef::ContentId)
219                    && let Ok(cid) = parse_message_id(&cid)
220                    && let Ok(replacement) = mimepart_to_data_url(mail)
221                {
222                    let re_string = format!(
223                        "(<img[^>]*src[^>]*=[^>]*)(cid:{})([^>]*>)",
224                        regex::escape(&cid)
225                    );
226                    match regex::Regex::new(&re_string) {
227                        Ok(re) => {
228                            self.html = re
229                                .replace_all(
230                                    &self.html,
231                                    format!("${{1}}{replacement}${{3}}").as_str(),
232                                )
233                                .as_ref()
234                                .to_string()
235                        }
236                        Err(e) => warn!(
237                            context,
238                            "Cannot create regex for cid: {} throws {}", re_string, e
239                        ),
240                    }
241                }
242                Ok(())
243            }
244        }
245    }
246}
247
248/// Convert a mime part to a data: url as defined in [RFC 2397](https://tools.ietf.org/html/rfc2397).
249fn mimepart_to_data_url(mail: &mailparse::ParsedMail<'_>) -> Result<String> {
250    let data = mail.get_body_raw()?;
251    let data = base64::engine::general_purpose::STANDARD.encode(data);
252    Ok(format!("data:{};base64,{}", mail.ctype.mimetype, data))
253}
254
255impl MsgId {
256    /// Get HTML by database message id.
257    /// Returns `Some` at least if `Message.has_html()` is true.
258    /// NB: we do not save raw mime unconditionally in the database to save space.
259    /// The corresponding ffi-function is `dc_get_msg_html()`.
260    pub async fn get_html(self, context: &Context) -> Result<Option<String>> {
261        // If there are many concurrent db readers, going to the queue earlier makes sense.
262        let (param, rawmime) = tokio::join!(
263            self.get_param(context),
264            message::get_mime_headers(context, self)
265        );
266        if let Some(html) = param?.get(SendHtml) {
267            return Ok(Some(html.to_string()));
268        }
269
270        let rawmime = rawmime?;
271        if !rawmime.is_empty() {
272            match HtmlMsgParser::from_bytes(context, &rawmime).await {
273                Err(err) => {
274                    warn!(context, "get_html: parser error: {:#}", err);
275                    Ok(None)
276                }
277                Ok((parser, _)) => Ok(Some(parser.html)),
278            }
279        } else {
280            warn!(context, "get_html: no mime for {}", self);
281            Ok(None)
282        }
283    }
284}
285
286#[cfg(test)]
287mod tests {
288    use super::*;
289    use crate::chat::{self, Chat, forward_msgs, save_msgs};
290    use crate::config::Config;
291    use crate::constants;
292    use crate::contact::ContactId;
293    use crate::message::{MessengerMessage, Viewtype};
294    use crate::receive_imf::receive_imf;
295    use crate::test_utils::{TestContext, TestContextManager};
296
297    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
298    async fn test_htmlparse_plain_unspecified() {
299        let t = TestContext::new().await;
300        let raw = include_bytes!("../test-data/message/text_plain_unspecified.eml");
301        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
302        assert_eq!(
303            parser.html,
304            r#"<!DOCTYPE html>
305<html><head>
306<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
307<meta name="color-scheme" content="light dark" />
308</head><body>
309This message does not have Content-Type nor Subject.<br/>
310</body></html>
311"#
312        );
313    }
314
315    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
316    async fn test_htmlparse_plain_iso88591() {
317        let t = TestContext::new().await;
318        let raw = include_bytes!("../test-data/message/text_plain_iso88591.eml");
319        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
320        assert_eq!(
321            parser.html,
322            r#"<!DOCTYPE html>
323<html><head>
324<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
325<meta name="color-scheme" content="light dark" />
326</head><body>
327message with a non-UTF-8 encoding: äöüßÄÖÜ<br/>
328</body></html>
329"#
330        );
331    }
332
333    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
334    async fn test_htmlparse_plain_flowed() {
335        let t = TestContext::new().await;
336        let raw = include_bytes!("../test-data/message/text_plain_flowed.eml");
337        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
338        assert!(parser.plain.unwrap().flowed);
339        assert_eq!(
340            parser.html,
341            r#"<!DOCTYPE html>
342<html><head>
343<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
344<meta name="color-scheme" content="light dark" />
345</head><body>
346This line ends with a space and will be merged with the next one due to format=flowed.<br/>
347<br/>
348This line does not end with a space<br/>
349and will be wrapped as usual.<br/>
350</body></html>
351"#
352        );
353    }
354
355    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
356    async fn test_htmlparse_alt_plain() {
357        let t = TestContext::new().await;
358        let raw = include_bytes!("../test-data/message/text_alt_plain.eml");
359        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
360        assert_eq!(
361            parser.html,
362            r#"<!DOCTYPE html>
363<html><head>
364<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
365<meta name="color-scheme" content="light dark" />
366</head><body>
367mime-modified should not be set set as there is no html and no special stuff;<br/>
368although not being a delta-message.<br/>
369test some special html-characters as &lt; &gt; and &amp; but also &quot; and &#x27; :)<br/>
370</body></html>
371"#
372        );
373    }
374
375    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
376    async fn test_htmlparse_html() {
377        let t = TestContext::new().await;
378        let raw = include_bytes!("../test-data/message/text_html.eml");
379        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
380
381        // on windows, `\r\n` linends are returned from mimeparser,
382        // however, rust multiline-strings use just `\n`;
383        // therefore, we just remove `\r` before comparison.
384        assert_eq!(
385            parser.html.replace('\r', ""),
386            r##"
387<html>
388  <p>mime-modified <b>set</b>; simplify is always regarded as lossy.</p>
389</html>"##
390        );
391    }
392
393    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
394    async fn test_htmlparse_alt_html() {
395        let t = TestContext::new().await;
396        let raw = include_bytes!("../test-data/message/text_alt_html.eml");
397        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
398        assert_eq!(
399            parser.html.replace('\r', ""), // see comment in test_htmlparse_html()
400            r##"<html>
401  <p>mime-modified <b>set</b>; simplify is always regarded as lossy.</p>
402</html>
403"##
404        );
405    }
406
407    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
408    async fn test_htmlparse_alt_plain_html() {
409        let t = TestContext::new().await;
410        let raw = include_bytes!("../test-data/message/text_alt_plain_html.eml");
411        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
412        assert_eq!(
413            parser.html.replace('\r', ""), // see comment in test_htmlparse_html()
414            r##"<html>
415  <p>
416    this is <b>html</b>
417  </p>
418</html>
419"##
420        );
421    }
422
423    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
424    async fn test_htmlparse_apple_cid_jpg() {
425        // load raw mime html-data with related image-part (cid:)
426        // and make sure, Content-Id has angle-brackets that are removed correctly.
427        let t = TestContext::new().await;
428        let raw = include_bytes!("../test-data/message/apple_cid_jpg.eml");
429        let test = String::from_utf8_lossy(raw);
430        assert!(test.contains("Content-Id: <8AE052EF-BC90-486F-BB78-58D3590308EC@fritz.box>"));
431        assert!(test.contains("cid:8AE052EF-BC90-486F-BB78-58D3590308EC@fritz.box"));
432        assert!(test.find("data:").is_none());
433
434        // parsing converts cid: to data:
435        let (parser, _) = HtmlMsgParser::from_bytes(&t.ctx, raw).await.unwrap();
436        assert!(parser.html.contains("<html>"));
437        assert!(!parser.html.contains("Content-Id:"));
438        assert!(parser.html.contains("data:image/jpeg;base64,/9j/4AAQ"));
439        assert!(!parser.html.contains("cid:"));
440    }
441
442    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
443    async fn test_get_html_invalid_msgid() {
444        let t = TestContext::new().await;
445        let msg_id = MsgId::new(100);
446        assert!(msg_id.get_html(&t).await.is_err())
447    }
448
449    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
450    async fn test_html_forwarding() -> Result<()> {
451        // alice receives a non-delta html-message
452        let mut tcm = TestContextManager::new();
453        let alice = &tcm.alice().await;
454        let chat = alice
455            .create_chat_with_contact("", "sender@testrun.org")
456            .await;
457        let raw = include_bytes!("../test-data/message/text_alt_plain_html.eml");
458        receive_imf(alice, raw, false).await.unwrap();
459        let msg = alice.get_last_msg_in(chat.get_id()).await;
460        assert_ne!(msg.get_from_id(), ContactId::SELF);
461        assert_eq!(msg.is_dc_message, MessengerMessage::No);
462        assert!(!msg.is_forwarded());
463        assert!(msg.get_text().contains("this is plain"));
464        assert!(msg.has_html());
465        let html = msg.get_id().get_html(alice).await.unwrap().unwrap();
466        assert!(html.contains("this is <b>html</b>"));
467
468        // alice: create chat with bob and forward received html-message there
469        let chat_alice = alice.create_chat_with_contact("", "bob@example.net").await;
470        forward_msgs(alice, &[msg.get_id()], chat_alice.get_id())
471            .await
472            .unwrap();
473        async fn check_sender(ctx: &TestContext, chat: &Chat) {
474            let msg = ctx.get_last_msg_in(chat.get_id()).await;
475            assert_eq!(msg.get_from_id(), ContactId::SELF);
476            assert_eq!(msg.is_dc_message, MessengerMessage::Yes);
477            assert!(msg.is_forwarded());
478            assert!(msg.get_text().contains("this is plain"));
479            assert!(msg.has_html());
480            let html = msg.get_id().get_html(ctx).await.unwrap().unwrap();
481            assert!(html.contains("this is <b>html</b>"));
482        }
483        check_sender(alice, &chat_alice).await;
484
485        // bob: check that bob also got the html-part of the forwarded message
486        let bob = &tcm.bob().await;
487        let chat_bob = bob.create_chat_with_contact("", "alice@example.org").await;
488        async fn check_receiver(ctx: &TestContext, chat: &Chat, sender: &TestContext) {
489            let msg = ctx.recv_msg(&sender.pop_sent_msg().await).await;
490            assert_eq!(chat.id, msg.chat_id);
491            assert_ne!(msg.get_from_id(), ContactId::SELF);
492            assert_eq!(msg.is_dc_message, MessengerMessage::Yes);
493            assert!(msg.is_forwarded());
494            assert!(msg.get_text().contains("this is plain"));
495            assert!(msg.has_html());
496            let html = msg.get_id().get_html(ctx).await.unwrap().unwrap();
497            assert!(html.contains("this is <b>html</b>"));
498        }
499        check_receiver(bob, &chat_bob, alice).await;
500
501        // Let's say that the alice and bob profiles are on the same device,
502        // so alice can forward the message to herself via bob profile!
503        chat::forward_msgs_2ctx(alice, &[msg.get_id()], bob, chat_bob.get_id()).await?;
504        check_sender(bob, &chat_bob).await;
505        check_receiver(alice, &chat_alice, bob).await;
506
507        // Check cross-profile forwarding of long outgoing messages.
508        let line = "this text with 42 chars is just repeated.\n";
509        let long_txt = line.repeat(constants::DC_DESIRED_TEXT_LEN / line.len() + 2);
510        let mut msg = Message::new_text(long_txt);
511        alice.send_msg(chat_alice.id, &mut msg).await;
512        let msg = alice.get_last_msg_in(chat_alice.id).await;
513        assert!(msg.has_html());
514        let html = msg.id.get_html(alice).await?.unwrap();
515        chat::forward_msgs_2ctx(alice, &[msg.get_id()], bob, chat_bob.get_id()).await?;
516        let msg = bob.get_last_msg_in(chat_bob.id).await;
517        assert!(msg.has_html());
518        assert_eq!(msg.id.get_html(bob).await?.unwrap(), html);
519        Ok(())
520    }
521
522    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
523    async fn test_html_save_msg() -> Result<()> {
524        // Alice receives a non-delta html-message
525        let alice = TestContext::new_alice().await;
526        let chat = alice
527            .create_chat_with_contact("", "sender@testrun.org")
528            .await;
529        let raw = include_bytes!("../test-data/message/text_alt_plain_html.eml");
530        receive_imf(&alice, raw, false).await?;
531        let msg = alice.get_last_msg_in(chat.get_id()).await;
532
533        // Alice saves the message
534        let self_chat = alice.get_self_chat().await;
535        save_msgs(&alice, &[msg.id]).await?;
536        let saved_msg = alice.get_last_msg_in(self_chat.get_id()).await;
537        assert_ne!(saved_msg.id, msg.id);
538        assert_eq!(
539            saved_msg.get_original_msg_id(&alice).await?.unwrap(),
540            msg.id
541        );
542        assert!(!saved_msg.is_forwarded()); // UI should not flag "saved messages" as "forwarded"
543        assert_ne!(saved_msg.get_from_id(), ContactId::SELF);
544        assert_eq!(saved_msg.get_from_id(), msg.get_from_id());
545        assert_eq!(saved_msg.is_dc_message, MessengerMessage::No);
546        assert!(saved_msg.get_text().contains("this is plain"));
547        assert!(saved_msg.has_html());
548        let html = saved_msg.get_id().get_html(&alice).await?.unwrap();
549        assert!(html.contains("this is <b>html</b>"));
550
551        Ok(())
552    }
553
554    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
555    async fn test_html_forwarding_encrypted() {
556        let mut tcm = TestContextManager::new();
557        // Alice receives a non-delta html-message
558        // (`ShowEmails=AcceptedContacts` lets Alice actually receive non-delta messages for known
559        // contacts, the contact is marked as known by creating a chat using `chat_with_contact()`)
560        let alice = &tcm.alice().await;
561        alice
562            .set_config(Config::ShowEmails, Some("1"))
563            .await
564            .unwrap();
565        let chat = alice
566            .create_chat_with_contact("", "sender@testrun.org")
567            .await;
568        let raw = include_bytes!("../test-data/message/text_alt_plain_html.eml");
569        receive_imf(alice, raw, false).await.unwrap();
570        let msg = alice.get_last_msg_in(chat.get_id()).await;
571
572        // forward the message to saved-messages,
573        // this will encrypt the message as new_alice() has set up keys
574        let chat = alice.get_self_chat().await;
575        forward_msgs(alice, &[msg.get_id()], chat.get_id())
576            .await
577            .unwrap();
578        let msg = alice.pop_sent_msg().await;
579
580        // receive the message on another device
581        let alice = &tcm.alice().await;
582        alice
583            .set_config(Config::ShowEmails, Some("0"))
584            .await
585            .unwrap();
586        let msg = alice.recv_msg(&msg).await;
587        assert_eq!(msg.chat_id, alice.get_self_chat().await.id);
588        assert_eq!(msg.get_from_id(), ContactId::SELF);
589        assert_eq!(msg.is_dc_message, MessengerMessage::Yes);
590        assert!(msg.get_showpadlock());
591        assert!(msg.is_forwarded());
592        assert!(msg.get_text().contains("this is plain"));
593        assert!(msg.has_html());
594        let html = msg.get_id().get_html(alice).await.unwrap().unwrap();
595        assert!(html.contains("this is <b>html</b>"));
596    }
597
598    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
599    async fn test_set_html() {
600        let mut tcm = TestContextManager::new();
601        let alice = &tcm.alice().await;
602        let bob = &tcm.bob().await;
603
604        // alice sends a message with html-part to bob
605        let chat_id = alice.create_chat(bob).await.id;
606        let mut msg = Message::new_text("plain text".to_string());
607        msg.set_html(Some("<b>html</b> text".to_string()));
608        assert!(msg.mime_modified);
609        chat::send_msg(alice, chat_id, &mut msg).await.unwrap();
610
611        // check the message is written correctly to alice's db
612        let msg = alice.get_last_msg_in(chat_id).await;
613        assert_eq!(msg.get_text(), "plain text");
614        assert!(!msg.is_forwarded());
615        assert!(msg.mime_modified);
616        let html = msg.get_id().get_html(alice).await.unwrap().unwrap();
617        assert!(html.contains("<b>html</b> text"));
618
619        // let bob receive the message
620        let chat_id = bob.create_chat(alice).await.id;
621        let msg = bob.recv_msg(&alice.pop_sent_msg().await).await;
622        assert_eq!(msg.chat_id, chat_id);
623        assert_eq!(msg.get_text(), "plain text");
624        assert!(!msg.is_forwarded());
625        assert!(msg.mime_modified);
626        let html = msg.get_id().get_html(bob).await.unwrap().unwrap();
627        assert!(html.contains("<b>html</b> text"));
628    }
629
630    #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
631    async fn test_cp1252_html() -> Result<()> {
632        let t = TestContext::new_alice().await;
633        receive_imf(
634            &t,
635            include_bytes!("../test-data/message/cp1252-html.eml"),
636            false,
637        )
638        .await?;
639        let msg = t.get_last_msg().await;
640        assert_eq!(msg.viewtype, Viewtype::Text);
641        assert!(msg.text.contains("foo bar ä ö ü ß"));
642        assert!(msg.has_html());
643        let html = msg.get_id().get_html(&t).await?.unwrap();
644        println!("{html}");
645        assert!(html.contains("foo bar ä ö ü ß"));
646        Ok(())
647    }
648}