From 5820c4ce954f19ad3ea7ca1ce2434065ae738b3f Mon Sep 17 00:00:00 2001 From: link2xt Date: Sat, 6 Apr 2024 16:37:51 +0000 Subject: [PATCH] Serialize mime_compressed --- src/sql/deserialize.rs | 6 ++++++ src/sql/serialize.rs | 5 +++++ 2 files changed, 11 insertions(+) diff --git a/src/sql/deserialize.rs b/src/sql/deserialize.rs index 5293a20b7..6085f8c91 100644 --- a/src/sql/deserialize.rs +++ b/src/sql/deserialize.rs @@ -945,6 +945,7 @@ msgs (id, timestamp_sent, timestamp_rcvd, hidden, + mime_compressed, mime_headers, mime_in_reply_to, mime_references, @@ -964,6 +965,7 @@ VALUES (:id, :timestamp_sent, :timestamp_rcvd, :hidden, + :mime_compressed :mime_headers, :mime_in_reply_to, :mime_references, @@ -991,6 +993,9 @@ VALUES (:id, self.expect_key("location_id").await?; let location_id = self.expect_i64().await?; + self.expect_key("mime_compressed").await?; + let mime_compressed = self.expect_i64().await?; + self.expect_key("mime_headers").await?; let mime_headers = self.expect_blob().await?; @@ -1058,6 +1063,7 @@ VALUES (:id, ":timestamp_sent": timestamp_sent, ":timestamp_rcvd": timestamp_rcvd, ":hidden": hidden, + ":mime_compressed": mime_compressed, ":mime_headers": mime_headers, ":mime_in_reply_to": mime_in_reply_to, ":mime_references": mime_references, diff --git a/src/sql/serialize.rs b/src/sql/serialize.rs index 64df630f9..52b99cc65 100644 --- a/src/sql/serialize.rs +++ b/src/sql/serialize.rs @@ -614,6 +614,7 @@ impl<'a, W: AsyncWrite + Unpin> Encoder<'a, W> { timestamp_sent, timestamp_rcvd, hidden, + mime_compressed, mime_headers, mime_in_reply_to, mime_references, @@ -639,6 +640,7 @@ impl<'a, W: AsyncWrite + Unpin> Encoder<'a, W> { let timestamp_sent: i64 = row.get("timestamp_sent")?; let timestamp_rcvd: i64 = row.get("timestamp_rcvd")?; let hidden: i64 = row.get("hidden")?; + let mime_compressed: i64 = row.get("mime_compressed")?; let mime_headers: Vec = row.get("mime_headers") .or_else(|err| match row.get_ref("mime_headers")? { @@ -671,6 +673,9 @@ impl<'a, W: AsyncWrite + Unpin> Encoder<'a, W> { write_str(&mut self.w, "location_id").await?; write_i64(&mut self.w, location_id).await?; + write_str(&mut self.w, "mime_compressed").await?; + write_i64(&mut self.w, mime_compressed).await?; + write_str(&mut self.w, "mime_headers").await?; write_bytes(&mut self.w, &mime_headers).await?;