Method get_html

src/html.rs:262–328

Get HTML by database message id. Returns `Some` at least if `Message.has_html()` is true. NB: we do not save raw mime unconditionally in the database to save space. The corresponding ffi-function is `dc_get_msg_html()`.

(self, context: &Context)

    /// NB: we do not save raw mime unconditionally in the database to save space.
    /// The corresponding ffi-function is `dc_get_msg_html()`.
    pub async fn get_html(self, context: &Context) -> Result<Option<String>> {
        let (param, headers, compressed) = context
            .sql
            .query_row(
                "SELECT param, mime_headers, mime_compressed FROM msgs WHERE id=?",
                (self,),
                |row| {
                    let param: String = row.get(0)?;
                    let param: Params = param.parse().unwrap_or_default();
                    let headers = sql::row_get_vec(row, 1)?;
                    let compressed: bool = row.get(2)?;
                    Ok((param, headers, compressed))
                },
            )
            .await?;
        if let Some(html) = param.get(SendHtml) {
            return Ok(Some(html.to_string()));
        }
        let from_rawmime = |rawmime: Vec<u8>| {
            if !rawmime.is_empty() {
                match HtmlMsgParser::from_bytes(context, &rawmime) {
                    Err(err) => {
                        warn!(context, "get_html: parser error: {:#}", err);
                        Ok(None)
                    }
                    Ok((parser, _)) => Ok(Some(parser.html)),
                }
            } else {
                warn!(context, "get_html: no mime for {}", self);
                Ok(None)
            }
        };

        if compressed {
            return from_rawmime(buf_decompress(&headers)?);
        }
        let headers2 = headers.clone();
        let compressed = match tokio::task::block_in_place(move || buf_compress(&headers2)) {
            Err(e) => {
                warn!(context, "get_mime_headers: buf_compress() failed: {}", e);
                return from_rawmime(headers);
            }
            Ok(o) => o,
        };
        let update = |conn: &mut rusqlite::Connection| {
            match conn.execute(
                "
UPDATE msgs SET mime_headers=?, mime_compressed=1
WHERE id=? AND mime_headers!='' AND mime_compressed=0",
                (compressed, self),
            ) {
                Ok(rows_updated) => ensure!(rows_updated <= 1),
                Err(e) => {
                    warn!(context, "get_mime_headers: UPDATE failed: {}", e);
                    return Err(e.into());
                }
            }
            Ok(())