add published_in_epoch to group message

Author: insipx

bindings_wasm/src/conversation.rs

@@ -808,6 +808,7 @@ mod tests {
       originator_id: 0,
       sequence_id: 0,
       expire_at_ns: None,
+      published_in_epoch: None,
     };
     crate::to_value(&stored_message).unwrap();
   }

xmtp_db/migrations/.diesel_lock

@@ -0,0 +1,2 @@
+-- This file should undo anything in `up.sql`
+ALTER TABLE group_messages DROP COLUMN published_in_epoch;

xmtp_db/migrations/2025-11-18-174226-0000_group_message_epoch/down.sql

@@ -0,0 +1,3 @@
+-- Your SQL goes here
+ALTER TABLE group_messages ADD COLUMN published_in_epoch BIGINT;
+

xmtp_db/migrations/2025-11-18-174226-0000_group_message_epoch/up.sql

@@ -76,6 +76,8 @@ pub struct StoredGroupMessage {
     pub inserted_at_ns: i64,
     /// Timestamp (in NS) after which the message must be deleted
     pub expire_at_ns: Option<i64>,
+    /// the epoch this message was published in
+    pub published_in_epoch: Option<i64>,
 }
 
 impl StoredGroupMessage {
@@ -108,6 +110,8 @@ struct NewStoredGroupMessage {
     pub sequence_id: i64,
     // inserted_at_ns is NOT included - let database set it
     pub expire_at_ns: Option<i64>,
+    /// the epoch this message was published in
+    pub published_in_epoch: Option<i64>,
 }
 
 impl From<&StoredGroupMessage> for NewStoredGroupMessage {
@@ -129,6 +133,7 @@ impl From<&StoredGroupMessage> for NewStoredGroupMessage {
             originator_id: msg.originator_id,
             sequence_id: msg.sequence_id,
             expire_at_ns: msg.expire_at_ns,
+            published_in_epoch: msg.published_in_epoch,
         }
     }
 }

xmtp_db/src/encrypted_store/group_message.rs

@@ -32,6 +32,7 @@ impl TryFrom<GroupMessageSave> for StoredGroupMessage {
                 .unwrap_or(Originators::APPLICATION_MESSAGES.into()),
             expire_at_ns: None,
             inserted_at_ns: 0, // Will be set by database
+            published_in_epoch: value.published_in_epoch,
         })
     }
 }
@@ -109,6 +110,7 @@ impl From<StoredGroupMessage> for GroupMessageSave {
             reference_id: value.reference_id,
             sequence_id: Some(value.sequence_id),
             originator_id: Some(value.originator_id),
+            published_in_epoch: value.published_in_epoch,
         }
     }
 }

xmtp_db/src/encrypted_store/group_message/convert.rs

@@ -30,6 +30,7 @@ fn generate_message_with_cursor(
         sequence_id,
         originator_id,
         expire_at_ns: None,
+        published_in_epoch: None,
     }
 }
 

xmtp_db/src/encrypted_store/group_message/messages_newer_than_tests.rs

@@ -31,6 +31,7 @@ pub(crate) fn generate_message(
         originator_id: 0,
         expire_at_ns,
         inserted_at_ns: 0, // Will be set by database
+        published_in_epoch: None,
     }
 }
 
@@ -608,6 +609,7 @@ pub(crate) fn generate_message_with_reference<C: ConnectionExt>(
         originator_id: 0,
         expire_at_ns: None,
         inserted_at_ns: 0, // Will be set by database
+        published_in_epoch: None,
     };
     message.store(conn).unwrap();
     message

xmtp_db/src/encrypted_store/group_message/tests.rs

@@ -66,6 +66,7 @@ diesel::table! {
         sequence_id -> BigInt,
         inserted_at_ns -> BigInt,
         expire_at_ns -> Nullable<BigInt>,
+        published_in_epoch -> Nullable<BigInt>,
     }
 }
 

xmtp_db/src/encrypted_store/schema_gen.rs

@@ -797,6 +797,7 @@ where
                         originator_id: conversation_item.originator_id?,
                         expire_at_ns: None, //Question: do we need to include this in conversation last message?
                         inserted_at_ns: 0, // Not used for conversation list display
+                        published_in_epoch: None
                     });
                     if msg.is_none() {
                         tracing::warn!("tried listing message, but message had missing fields so it was skipped");