json deserialization for legacy reactions

xmtp_content_types/Cargo.toml

@@ -8,6 +8,8 @@ license.workspace = true
 thiserror = { workspace = true }
 prost = { workspace = true, features = ["prost-derive"] }
 rand = { workspace = true }
+serde = { workspace = true, features = ["derive"] }
+serde_json = { workspace = true }
 
 # XMTP/Local
 xmtp_proto = { workspace = true, features = ["convert"] }

xmtp_content_types/src/reaction.rs

@@ -3,6 +3,7 @@ use std::collections::HashMap;
 use crate::{CodecError, ContentCodec};
 use prost::Message;
 
+use serde::{Deserialize, Serialize};
 use xmtp_proto::xmtp::mls::message_contents::{
     content_types::ReactionV2, ContentTypeId, EncodedContent,
 };
@@ -47,6 +48,21 @@ impl ContentCodec<ReactionV2> for ReactionCodec {
     }
 }
 
+#[derive(Debug, Serialize, Deserialize)]
+pub struct LegacyReaction {
+    /// The message ID for the message that is being reacted to
+    pub reference: String,
+    /// The inbox ID of the user who sent the message that is being reacted to
+    #[serde(rename = "referenceInboxId", skip_serializing_if = "Option::is_none")]
+    pub reference_inbox_id: Option<String>,
+    /// The action of the reaction ("added" or "removed")
+    pub action: String,
+    /// The content of the reaction
+    pub content: String,
+    /// The schema of the content ("unicode", "shortcode", or "custom")
+    pub schema: String,
+}
+
 #[cfg(test)]
 pub(crate) mod tests {
     #[cfg(target_arch = "wasm32")]

xmtp_mls/src/groups/mod.rs

@@ -33,9 +33,10 @@ use openmls::{
 };
 use openmls_traits::OpenMlsProvider;
 use prost::Message;
+use serde::{Deserialize, Serialize};
 use thiserror::Error;
 use tokio::sync::Mutex;
-use xmtp_content_types::reaction::ReactionCodec;
+use xmtp_content_types::reaction::{LegacyReaction, ReactionCodec};
 
 use self::device_sync::DeviceSyncError;
 pub use self::group_permissions::PreconfiguredPolicies;
@@ -357,8 +358,21 @@ impl TryFrom<EncodedContent> for QueryableContentFields {
                 hex::decode(reaction.reference).ok()
             }
             (ReactionCodec::TYPE_ID, _) => {
-                // TODO: Implement JSON deserialization for legacy reaction format
-                None
+                // Try to decode the content as UTF-8 string first
+                if let Ok(decoded_content) = String::from_utf8(content.content) {
+                    tracing::info!("attempting legacy json deserialization: {}", decoded_content);
+                    // Try parsing as canonical JSON format first
+                    if let Ok(reaction) = serde_json::from_str::<LegacyReaction>(&decoded_content) {
+                        hex::decode(reaction.reference).ok()
+                    } else {
+                        tracing::error!("legacy json deserialization failed");
+                        // If canonical format fails, try legacy format using parameters
+                        None
+                    }
+                } else {
+                    tracing::error!("utf-8 deserialization failed");
+                    None
+                }
             }
             _ => None,
         };