Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-17 05:46:30 +03:00
Code Issues Packages Projects Releases Wiki Activity

Serialize uid

Browse Source
This commit is contained in:
link2xt
2024-04-06 15:54:12 +00:00
parent 60a7bbc9b5
commit 12ba33d9d4
2 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/deserialize.rs
View File

@@ -1074,9 +1074,11 @@ VALUES (:id,
INSERT INTO INSERT INTO
msgs_status_updates (id, msgs_status_updates (id,
msg_id, msg_id,
uid,
update_item) update_item)
VALUES (:id, VALUES (:id,
:msg_id, :msg_id,
:uid
:update_item)", :update_item)",
)?; )?;
@@ -1089,6 +1091,9 @@ VALUES (:id,
self.expect_key("msg_id").await?; self.expect_key("msg_id").await?;
let msg_id = self.expect_i64().await?; let msg_id = self.expect_i64().await?;
self.expect_key("uid").await?;
let uid = self.expect_string().await?;
self.expect_key("update_item").await?; self.expect_key("update_item").await?;
let update_item = self.expect_u32().await?; let update_item = self.expect_u32().await?;
@@ -1097,6 +1102,7 @@ VALUES (:id,
stmt.execute(named_params! { stmt.execute(named_params! {
":id": id, ":id": id,
":msg_id": msg_id, ":msg_id": msg_id,
":uid": uid,
":update_item": update_item, ":update_item": update_item,
})?; })?;
} }

6
src/sql/serialize.rs
View File

@@ -726,13 +726,14 @@ impl<'a, W: AsyncWrite + Unpin> Encoder<'a, W> {
async fn serialize_msgs_status_updates(&mut self) -> Result<()> { async fn serialize_msgs_status_updates(&mut self) -> Result<()> {
let mut stmt = self let mut stmt = self
.tx .tx
.prepare("SELECT id, msg_id, update_item FROM msgs_status_updates")?; .prepare("SELECT id, msg_id, uid, update_item FROM msgs_status_updates")?;
let mut rows = stmt.query(())?; let mut rows = stmt.query(())?;
self.w.write_all(b"l").await?; self.w.write_all(b"l").await?;
while let Some(row) = rows.next()? { while let Some(row) = rows.next()? {
let id: i64 = row.get("id")?; let id: i64 = row.get("id")?;
let msg_id: i64 = row.get("msg_id")?; let msg_id: i64 = row.get("msg_id")?;
let uid: String = row.get("uid")?;
let update_item: String = row.get("update_item")?; let update_item: String = row.get("update_item")?;
self.w.write_all(b"d").await?; self.w.write_all(b"d").await?;
@@ -743,6 +744,9 @@ impl<'a, W: AsyncWrite + Unpin> Encoder<'a, W> {
write_str(&mut self.w, "msg_id").await?; write_str(&mut self.w, "msg_id").await?;
write_i64(&mut self.w, msg_id).await?; write_i64(&mut self.w, msg_id).await?;
write_str(&mut self.w, "uid").await?;
write_str(&mut self.w, &uid).await?;
write_str(&mut self.w, "update_item").await?; write_str(&mut self.w, "update_item").await?;
write_str(&mut self.w, &update_item).await?; write_str(&mut self.w, &update_item).await?;