diff --git a/src/chat.rs b/src/chat.rs index a4df4f8b9..9924e1e5c 100644 --- a/src/chat.rs +++ b/src/chat.rs @@ -1465,7 +1465,7 @@ pub(crate) fn add_contact_to_chat_ex( let contact = Contact::get_by_id(context, contact_id)?; let mut msg = Message::default(); - reset_gossiped_timestamp(context, chat_id); + reset_gossiped_timestamp(context, chat_id)?; /*this also makes sure, not contacts are added to special or normal chats*/ let mut chat = Chat::load_from_db(context, chat_id)?; @@ -1563,12 +1563,15 @@ fn real_group_exists(context: &Context, chat_id: u32) -> bool { .unwrap_or_default() } -pub fn reset_gossiped_timestamp(context: &Context, chat_id: u32) { - set_gossiped_timestamp(context, chat_id, 0); +pub fn reset_gossiped_timestamp(context: &Context, chat_id: u32) -> crate::sql::Result<()> { + set_gossiped_timestamp(context, chat_id, 0) } -// Should return Result -pub fn set_gossiped_timestamp(context: &Context, chat_id: u32, timestamp: i64) { +pub fn set_gossiped_timestamp( + context: &Context, + chat_id: u32, + timestamp: i64, +) -> crate::sql::Result<()> { if 0 != chat_id { info!( context, @@ -1581,7 +1584,6 @@ pub fn set_gossiped_timestamp(context: &Context, chat_id: u32, timestamp: i64) { "UPDATE chats SET gossiped_timestamp=? WHERE id=?;", params![timestamp, chat_id as i32], ) - .ok(); } else { info!( context, @@ -1593,7 +1595,6 @@ pub fn set_gossiped_timestamp(context: &Context, chat_id: u32, timestamp: i64) { "UPDATE chats SET gossiped_timestamp=?;", params![timestamp], ) - .ok(); } } diff --git a/src/dc_receive_imf.rs b/src/dc_receive_imf.rs index 414d4ba79..dbcdfb4d0 100644 --- a/src/dc_receive_imf.rs +++ b/src/dc_receive_imf.rs @@ -1085,7 +1085,7 @@ fn create_or_lookup_group( } } send_EVENT_CHAT_MODIFIED = true; - chat::reset_gossiped_timestamp(context, chat_id); + chat::reset_gossiped_timestamp(context, chat_id)?; } if send_EVENT_CHAT_MODIFIED { diff --git a/src/job.rs b/src/job.rs index 6115de4c9..5f651e0a3 100644 --- a/src/job.rs +++ b/src/job.rs @@ -678,7 +678,7 @@ pub fn job_send_msg(context: &Context, msg_id: MsgId) -> Result<(), Error> { } if rendered_msg.is_gossiped { - chat::set_gossiped_timestamp(context, msg.chat_id, time()); + chat::set_gossiped_timestamp(context, msg.chat_id, time())?; } if 0 != rendered_msg.last_added_location_id { diff --git a/src/peerstate.rs b/src/peerstate.rs index 76a9d6774..ad879bf1a 100644 --- a/src/peerstate.rs +++ b/src/peerstate.rs @@ -417,7 +417,7 @@ impl<'a> Peerstate<'a> { &self.addr, ], )?; - reset_gossiped_timestamp(self.context, 0); + reset_gossiped_timestamp(self.context, 0)?; } else if self.to_save == Some(ToSave::Timestamps) { sql::execute( self.context,