Move content types to new crate

Cargo.toml

@@ -15,6 +15,7 @@ members = [
   "bindings_ffi",
   "xtask",
   "xmtp_debug",
+  "xmtp_content_types",
 ]
 
 # Make the feature resolver explicit.
@@ -102,6 +103,7 @@ xmtp_cryptography = { path = "xmtp_cryptography" }
 xmtp_id = { path = "xmtp_id" }
 xmtp_mls = { path = "xmtp_mls" }
 xmtp_proto = { path = "xmtp_proto" }
+xmtp_content_types = { path = "xmtp_content_types" }
 
 [profile.dev]
 # Disabling debug info speeds up builds a bunch,

examples/cli/Cargo.toml

@@ -39,6 +39,7 @@ valuable = { version = "0.1", features = ["derive"] }
 valuable-serde = "0.1"
 xmtp_api_grpc = { path = "../../xmtp_api_grpc" }
 xmtp_cryptography = { path = "../../xmtp_cryptography" }
+xmtp_content_types = { path = "../../xmtp_content_types" }
 xmtp_id = { path = "../../xmtp_id" }
 xmtp_mls = { path = "../../xmtp_mls" }
 xmtp_proto = { path = "../../xmtp_proto", features = ["proto_full"] }

examples/cli/cli-client.rs

@@ -32,6 +32,7 @@ use tracing_subscriber::{
 use valuable::Valuable;
 use xmtp_api_grpc::grpc_api_helper::Client as ClientV3;
 use xmtp_api_grpc::replication_client::ClientV4;
+use xmtp_content_types::{text::TextCodec, ContentCodec};
 use xmtp_cryptography::{
     signature::{RecoverableSignature, SignatureError},
     utils::rng,
@@ -47,7 +48,6 @@ use xmtp_mls::XmtpApi;
 use xmtp_mls::{
     builder::ClientBuilderError,
     client::ClientError,
-    codecs::{text::TextCodec, ContentCodec},
     groups::{device_sync::MessageHistoryUrls, GroupMetadataOptions},
     identity::IdentityStrategy,
     storage::{

examples/cli/serializable.rs

@@ -1,12 +1,8 @@
 use prost::Message;
 use serde::Serialize;
 use valuable::Valuable;
-use xmtp_mls::{
-    codecs::{text::TextCodec, ContentCodec},
-    groups::MlsGroup,
-    storage::group_message::StoredGroupMessage,
-    XmtpApi,
-};
+use xmtp_content_types::{text::TextCodec, ContentCodec};
+use xmtp_mls::{groups::MlsGroup, storage::group_message::StoredGroupMessage, XmtpApi};
 use xmtp_proto::xmtp::mls::message_contents::EncodedContent;
 
 #[derive(Serialize, Debug, Valuable)]

xmtp_content_types/Cargo.toml

@@ -0,0 +1,16 @@
+[package]
+edition = "2021"
+name = "xmtp_content_types"
+version.workspace = true
+license.workspace = true
+
+[dependencies]
+thiserror = { workspace = true }
+prost = { workspace = true, features = ["prost-derive"] }
+rand = { workspace = true }
+
+# XMTP/Local
+xmtp_proto = { workspace = true, features = ["convert"] }
+
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+tonic = { version = "0.12", features = ["transport"] }

xmtp_mls/src/codecs/group_updated.rs → xmtp_content_types/src/group_updated.rs

@@ -52,7 +52,7 @@ pub(crate) mod tests {
 
     use xmtp_proto::xmtp::mls::message_contents::{group_updated::Inbox, GroupUpdated};
 
-    use crate::utils::test::rand_string;
+    use crate::test_utils::rand_string;
 
     use super::*;
 

xmtp_mls/src/codecs/mod.rs → xmtp_content_types/src/lib.rs

@@ -1,11 +1,18 @@
 pub mod group_updated;
 pub mod membership_change;
+#[cfg(test)]
+mod test_utils;
 pub mod text;
 
 use thiserror::Error;
-
 use xmtp_proto::xmtp::mls::message_contents::{ContentTypeId, EncodedContent};
 
+pub enum ContentType {
+    GroupMembershipChange,
+    GroupUpdated,
+    Text,
+}
+
 #[derive(Debug, Error)]
 pub enum CodecError {
     #[error("encode error {0}")]

xmtp_mls/src/codecs/membership_change.rs → xmtp_content_types/src/membership_change.rs

@@ -54,7 +54,7 @@ pub(crate) mod tests {
 
     use xmtp_proto::xmtp::mls::message_contents::MembershipChange;
 
-    use crate::utils::test::{rand_string, rand_vec};
+    use crate::test_utils::{rand_string, rand_vec};
 
     use super::*;
 

xmtp_content_types/src/test_utils.rs

@@ -0,0 +1,15 @@
+#[cfg(test)]
+use rand::{
+    distributions::{Alphanumeric, DistString},
+    Rng,
+};
+
+#[cfg(test)]
+pub(crate) fn rand_string() -> String {
+    Alphanumeric.sample_string(&mut rand::thread_rng(), 24)
+}
+
+#[cfg(test)]
+pub(crate) fn rand_vec() -> Vec<u8> {
+    rand::thread_rng().gen::<[u8; 24]>().to_vec()
+}

xmtp_mls/src/codecs/text.rs → xmtp_content_types/src/text.rs

@@ -58,7 +58,7 @@ pub(crate) mod tests {
     #[cfg(target_arch = "wasm32")]
     wasm_bindgen_test::wasm_bindgen_test_configure!(run_in_dedicated_worker);
 
-    use crate::codecs::{text::TextCodec, ContentCodec};
+    use crate::{text::TextCodec, ContentCodec};
 
     #[cfg_attr(target_arch = "wasm32", wasm_bindgen_test::wasm_bindgen_test)]
     #[cfg_attr(not(target_arch = "wasm32"), test)]

xmtp_mls/Cargo.toml

@@ -73,6 +73,7 @@ web-time.workspace = true
 zeroize.workspace = true
 
 # XMTP/Local
+xmtp_content_types = { path = "../xmtp_content_types" }
 xmtp_cryptography = { workspace = true }
 xmtp_id = { path = "../xmtp_id" }
 xmtp_proto = { workspace = true, features = ["convert"] }

xmtp_mls/src/groups/mls_sync.rs

@@ -9,7 +9,6 @@ use super::{
     GroupError, HmacKey, IntentError, MlsGroup, ScopedGroupClient,
 };
 use crate::{
-    codecs::{group_updated::GroupUpdatedCodec, ContentCodec},
     configuration::{
         GRPC_DATA_LIMIT, HMAC_SALT, MAX_GROUP_SIZE, MAX_INTENT_PUBLISH_ATTEMPTS, MAX_PAST_EPOCHS,
         SYNC_UPDATE_INSTALLATIONS_INTERVAL_NS,
@@ -64,6 +63,7 @@ use std::{
     ops::RangeInclusive,
 };
 use thiserror::Error;
+use xmtp_content_types::{group_updated::GroupUpdatedCodec, CodecError, ContentCodec};
 use xmtp_id::{InboxId, InboxIdRef};
 use xmtp_proto::xmtp::mls::{
     api::v1::{
@@ -122,7 +122,7 @@ pub enum GroupMessageProcessingError {
     #[error(transparent)]
     Intent(#[from] IntentError),
     #[error(transparent)]
-    Codec(#[from] crate::codecs::CodecError),
+    Codec(#[from] CodecError),
     #[error("wrong credential type")]
     WrongCredentialType(#[from] BasicCredentialError),
     #[error(transparent)]

xmtp_mls/src/groups/mod.rs

@@ -1609,14 +1609,14 @@ pub(crate) mod tests {
     use openmls::prelude::Member;
     use prost::Message;
     use std::sync::Arc;
+    use xmtp_content_types::{group_updated::GroupUpdatedCodec, ContentCodec};
     use xmtp_cryptography::utils::generate_local_wallet;
     use xmtp_proto::xmtp::mls::api::v1::group_message::Version;
     use xmtp_proto::xmtp::mls::message_contents::EncodedContent;
 
     use crate::{
         assert_err,
         builder::ClientBuilder,
-        codecs::{group_updated::GroupUpdatedCodec, ContentCodec},
         groups::{
             build_dm_protected_metadata_extension, build_mutable_metadata_extension_default,
             build_protected_metadata_extension,

xmtp_mls/src/lib.rs

@@ -4,7 +4,6 @@
 pub mod api;
 pub mod builder;
 pub mod client;
-pub mod codecs;
 pub mod configuration;
 pub mod groups;
 mod hpke;