pass timestamp to update_chat_contacts_table

Author: link2xt

src/chat.rs

@@ -3588,10 +3588,10 @@ pub(crate) async fn create_broadcast_list_ex(
 /// Set chat contacts in the `chats_contacts` table.
 pub(crate) async fn update_chat_contacts_table(
     context: &Context,
+    timestamp: i64,
     id: ChatId,
     contacts: &HashSet<ContactId>,
 ) -> Result<()> {
-    let now = time();
     context
         .sql
         .transaction(move |transaction| {
@@ -3600,21 +3600,21 @@ pub(crate) async fn update_chat_contacts_table(
             // We add members from `contacts` back below.
             transaction.execute(
                 "UPDATE chats_contacts
-                                 SET remove_timestamp=MAX(add_timestamp+1, ?)
-                                 WHERE chat_id=?",
-                (now, id),
+                 SET remove_timestamp=MAX(add_timestamp+1, ?)
+                 WHERE chat_id=?",
+                (timestamp, id),
             )?;
 
             for contact_id in contacts {
                 // We bumped `add_timestamp` for existing rows above,
                 // so on conflict it is enough to set `add_timestamp = remove_timestamp`
-                // and this guarantees that `add_timestamp` is no less than `now`.
+                // and this guarantees that `add_timestamp` is no less than `timestamp`.
                 transaction.execute(
                     "INSERT INTO chats_contacts (chat_id, contact_id, add_timestamp)
                      VALUES                     (?1,      ?2,         ?3)
                      ON CONFLICT (chat_id, contact_id)
                      DO UPDATE SET add_timestamp=remove_timestamp",
-                    (id, contact_id, now),
+                    (id, contact_id, timestamp),
                 )?;
             }
             Ok(())
@@ -4578,7 +4578,7 @@ async fn set_contacts_by_addrs(context: &Context, id: ChatId, addrs: &[String])
     if contacts == contacts_old {
         return Ok(());
     }
-    update_chat_contacts_table(context, id, &contacts).await?;
+    update_chat_contacts_table(context, time(), id, &contacts).await?;
     context.emit_event(EventType::ChatModified(id));
     Ok(())
 }

src/receive_imf.rs

@@ -2387,7 +2387,13 @@ async fn apply_group_changes(
         }
 
         if new_members != chat_contacts {
-            chat::update_chat_contacts_table(context, chat_id, &new_members).await?;
+            chat::update_chat_contacts_table(
+                context,
+                mime_parser.timestamp_sent,
+                chat_id,
+                &new_members,
+            )
+            .await?;
             chat_contacts = new_members;
             send_event_chat_modified = true;
         }