Merge 0a1c51dddd into ab82a5d49a

Cargo.lock

@@ -34,6 +34,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e89da841a80418a9b391ebaea17f5c112ffaaa96f621d2c285b5174da76b9011"
 dependencies = [
  "cfg-if",
+ "getrandom",
  "once_cell",
  "version_check",
  "zerocopy",
@@ -291,15 +292,6 @@ dependencies = [
  "zeroize",
 ]
 
-[[package]]
-name = "concurrent-queue"
-version = "2.5.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "4ca0197aee26d1ae37445ee532fefce43251d24cc7c166799f4d46817f1d3973"
-dependencies = [
- "crossbeam-utils",
-]
-
 [[package]]
 name = "console_error_panic_hook"
 version = "0.1.7"
@@ -549,14 +541,9 @@ dependencies = [
 
 [[package]]
 name = "event-listener"
-version = "5.3.1"
+version = "2.5.3"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6032be9bd27023a771701cc49f9f053c751055f71efb2e0ae5c15809093675ba"
+checksum = "0206175f82b8d6bf6652ff7d71a1e27fd2e4efde587fd368662814d6ec1d9ce0"
-dependencies = [
- "concurrent-queue",
- "parking",
- "pin-project-lite",
-]
 
 [[package]]
 name = "fastrand"
@@ -786,9 +773,9 @@ dependencies = [
 
 [[package]]
 name = "hashlink"
-version = "0.9.1"
+version = "0.8.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6ba4ff7128dee98c7dc9794b6a411377e1404dba1c97deb8d1a55297bd25d8af"
+checksum = "e8094feaf31ff591f651a2664fb9cfd92bba7a60ce3197265e9482ebe753c8f7"
 dependencies = [
  "hashbrown 0.14.5",
 ]
@@ -819,9 +806,12 @@ dependencies = [
 
 [[package]]
 name = "heck"
-version = "0.5.0"
+version = "0.4.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "2304e00983f87ffb38b55b444b5e3b60a884b5d30c0fca7d82fe33449bbe55ea"
+checksum = "95505c38b4572b2d910cecb0281560f54b440a19336cbbcb27bf6ce6adc6f5a8"
+dependencies = [
+ "unicode-segmentation",
+]
 
 [[package]]
 name = "hermit-abi"
@@ -1151,9 +1141,9 @@ checksum = "4ec2a862134d2a7d32d7983ddcdd1c4923530833c9f2ea1a44fc5fa473989058"
 
 [[package]]
 name = "libsqlite3-sys"
-version = "0.28.0"
+version = "0.27.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0c10584274047cb335c23d3e61bcef8e323adae7c5c8c760540f73610177fc3f"
+checksum = "cf4e226dcd58b4be396f7bd3c20da8fdee2911400705297ba7d2d7cc2c30f716"
 dependencies = [
  "cc",
  "pkg-config",
@@ -1377,12 +1367,6 @@ version = "0.3.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "c08d65885ee38876c4f86fa503fb49d7b507c2b62552df7c70b2fce627e06381"
 
-[[package]]
-name = "parking"
-version = "2.2.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bb813b8af86854136c6922af0598d719255ecb2179515e6e7730d468f05c9cae"
-
 [[package]]
 name = "parking_lot"
 version = "0.12.3"
@@ -2075,9 +2059,6 @@ name = "smallvec"
 version = "1.13.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "3c5e1a9a646d36c3599cd173a41282daf47c44583ad367b8e6837255952e5c67"
-dependencies = [
- "serde",
-]
 
 [[package]]
 name = "socket2"
@@ -2126,9 +2107,9 @@ dependencies = [
 
 [[package]]
 name = "sqlx"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "27144619c6e5802f1380337a209d2ac1c431002dd74c6e60aebff3c506dc4f0c"
+checksum = "c9a2ccff1a000a5a59cd33da541d9f2fdcd9e6e8229cc200565942bff36d0aaa"
 dependencies = [
  "sqlx-core",
  "sqlx-macros",
@@ -2139,10 +2120,11 @@ dependencies = [
 
 [[package]]
 name = "sqlx-core"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a999083c1af5b5d6c071d34a708a19ba3e02106ad82ef7bbd69f5e48266b613b"
+checksum = "24ba59a9342a3d9bab6c56c118be528b27c9b60e490080e9711a04dccac83ef6"
 dependencies = [
+ "ahash",
  "atoi",
  "byteorder",
  "bytes",
@@ -2156,7 +2138,6 @@ dependencies = [
  "futures-intrusive",
  "futures-io",
  "futures-util",
- "hashbrown 0.14.5",
  "hashlink",
  "hex",
  "indexmap 2.2.6",
@@ -2183,22 +2164,22 @@ dependencies = [
 
 [[package]]
 name = "sqlx-macros"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "a23217eb7d86c584b8cbe0337b9eacf12ab76fe7673c513141ec42565698bb88"
+checksum = "4ea40e2345eb2faa9e1e5e326db8c34711317d2b5e08d0d5741619048a803127"
 dependencies = [
  "proc-macro2",
  "quote",
  "sqlx-core",
  "sqlx-macros-core",
- "syn 2.0.70",
+ "syn 1.0.109",
 ]
 
 [[package]]
 name = "sqlx-macros-core"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "1a099220ae541c5db479c6424bdf1b200987934033c2584f79a0e1693601e776"
+checksum = "5833ef53aaa16d860e92123292f1f6a3d53c34ba8b1969f152ef1a7bb803f3c8"
 dependencies = [
  "dotenvy",
  "either",
@@ -2214,7 +2195,7 @@ dependencies = [
  "sqlx-mysql",
  "sqlx-postgres",
  "sqlx-sqlite",
- "syn 2.0.70",
+ "syn 1.0.109",
  "tempfile",
  "tokio",
  "url",
@@ -2222,12 +2203,12 @@ dependencies = [
 
 [[package]]
 name = "sqlx-mysql"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "5afe4c38a9b417b6a9a5eeffe7235d0a106716495536e7727d1c7f4b1ff3eba6"
+checksum = "1ed31390216d20e538e447a7a9b959e06ed9fc51c37b514b46eb758016ecd418"
 dependencies = [
  "atoi",
- "base64 0.22.1",
+ "base64 0.21.7",
  "bitflags 2.6.0",
  "byteorder",
  "bytes",
@@ -2265,12 +2246,12 @@ dependencies = [
 
 [[package]]
 name = "sqlx-postgres"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "b1dbb157e65f10dbe01f729339c06d239120221c9ad9fa0ba8408c4cc18ecf21"
+checksum = "7c824eb80b894f926f89a0b9da0c7f435d27cdd35b8c655b114e58223918577e"
 dependencies = [
  "atoi",
- "base64 0.22.1",
+ "base64 0.21.7",
  "bitflags 2.6.0",
  "byteorder",
  "chrono",
@@ -2305,9 +2286,9 @@ dependencies = [
 
 [[package]]
 name = "sqlx-sqlite"
-version = "0.8.0"
+version = "0.7.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "9b2cdd83c008a622d94499c0006d8ee5f821f36c89b7d625c900e5dc30b5c5ee"
+checksum = "b244ef0a8414da0bed4bb1910426e890b19e5e9bccc27ada6b797d05c55ae0aa"
 dependencies = [
  "atoi",
  "chrono",
@@ -2321,10 +2302,10 @@ dependencies = [
  "log",
  "percent-encoding",
  "serde",
- "serde_urlencoded",
  "sqlx-core",
  "tracing",
  "url",
+ "urlencoding",
 ]
 
 [[package]]
@@ -2694,6 +2675,12 @@ version = "0.1.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e4259d9d4425d9f0661581b804cb85fe66a4c631cadd8f490d1c13a35d5d9291"
 
+[[package]]
+name = "unicode-segmentation"
+version = "1.11.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d4c87d22b6e3f4a18d4d40ef354e97c90fcb14dd91d7dc0aa9d8a1172ebf7202"
+
 [[package]]
 name = "unicode_categories"
 version = "0.1.1"
@@ -2733,6 +2720,12 @@ dependencies = [
  "percent-encoding",
 ]
 
+[[package]]
+name = "urlencoding"
+version = "2.1.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "daf8dba3b7eb870caf1ddeed7bc9d2a049f3cfdfae7cb521b087cc33ae4c49da"
+
 [[package]]
 name = "utf-8"
 version = "0.7.6"

Cargo.toml

@@ -48,7 +48,7 @@ jsonwebtoken = "8.3.0"
 log = "0.4.22"
 async-trait = "0.1.81"
 chorus-macros = { path = "./chorus-macros", version = "0" } # Note: version here is used when releasing. This will use the latest release. Make sure to republish the crate when code in macros is changed!
-sqlx = { version = "0.8.0", features = [
+sqlx = { version = "0.7.4", features = [
     "mysql",
     "sqlite",
     "json",
@@ -87,6 +87,3 @@ lazy_static = "1.5.0"
 wasm-bindgen-test = "0.3.42"
 wasm-bindgen = "0.2.92"
 simple_logger = { version = "5.0.0", default-features = false }
-
-[lints.rust]
-unexpected_cfgs = { level = "allow", check-cfg = ['cfg(tarpaulin_include)'] }

chorus-macros/src/lib.rs

@@ -156,6 +156,7 @@ pub fn composite_derive(input: TokenStream) -> TokenStream {
     }
 }
 
+
 #[proc_macro_derive(SqlxBitFlags)]
 pub fn sqlx_bitflag_derive(input: TokenStream) -> TokenStream {
     let ast: syn::DeriveInput = syn::parse(input).unwrap();
@@ -164,46 +165,25 @@ pub fn sqlx_bitflag_derive(input: TokenStream) -> TokenStream {
 
     quote!{
         #[cfg(feature = "sqlx")]
-        impl sqlx::Type<sqlx::Any> for #name {
+        impl sqlx::Type<sqlx::MySql> for #name {
-            fn type_info() -> sqlx::any::AnyTypeInfo {
+            fn type_info() -> sqlx::mysql::MySqlTypeInfo {
-                <Vec<u8> as sqlx::Type<sqlx::Any>>::type_info()
+                u64::type_info()
             }
         }
 
         #[cfg(feature = "sqlx")]
-        impl<'q> sqlx::Encode<'q, sqlx::Any> for #name {
+        impl<'q> sqlx::Encode<'q, sqlx::MySql> for #name {
-            fn encode_by_ref(&self, buf: &mut <sqlx::Any as sqlx::Database>::ArgumentBuffer<'q>) -> Result<sqlx::encode::IsNull, sqlx::error::BoxDynError> {
+            fn encode_by_ref(&self, buf: &mut <sqlx::MySql as sqlx::database::HasArguments<'q>>::ArgumentBuffer) -> sqlx::encode::IsNull {
-                <Vec<u8> as sqlx::Encode<sqlx::Any>>::encode_by_ref(&self.bits().to_be_bytes().into(), buf)
+                u64::encode_by_ref(&self.bits(), buf)
             }
         }
 
         #[cfg(feature = "sqlx")]
-        impl<'q> sqlx::Decode<'q, sqlx::Any> for #name {
+        impl<'q> sqlx::Decode<'q, sqlx::MySql> for #name {
-            fn decode(value: <sqlx::Any as sqlx::Database>::ValueRef<'q>) -> Result<Self, sqlx::error::BoxDynError> {
+            fn decode(value: <sqlx::MySql as sqlx::database::HasValueRef<'q>>::ValueRef) -> Result<Self, sqlx::error::BoxDynError> {
-                let vec = <Vec<u8> as sqlx::Decode<sqlx::Any>>::decode(value)?;
+                u64::decode(value).map(|d| #name::from_bits(d).unwrap())
-                Ok(Self::from_bits(vec_u8_to_u64(vec)).unwrap())
             }
         }
-
-        /// Converts a [Vec<u8>] to an unsigned, 64 bit integer. The [u64] is created using [u64::from_be_bytes].
-        ///
-        /// Empty vectors will result in an output of `0_u64`. Only the first 8 values from the vector are
-        /// being processed. Any additional values will be skipped.
-        ///
-        /// Vectors holding less than 8 values will be treated as a vector holding 8 values, where the
-        /// missing values are padded with `0_u8`.
-        fn vec_u8_to_u64(vec: Vec<u8>) -> u64 {
-            let mut buf: [u8; 8] = [0; 8];
-            let mut position = 0;
-            for read in vec.iter() {
-                buf[position] = *read;
-                position += 1;
-                if position > 7 {
-                    break;
-                }
-            }
-            u64::from_be_bytes(buf)
-        }
     }
     .into()
 }

src/api/users/users.rs

@@ -12,7 +12,8 @@ use crate::{
     instance::{ChorusUser, Instance},
     ratelimiter::ChorusRequest,
     types::{
-        DeleteDisableUserSchema, GetPomeloEligibilityReturn, GetPomeloSuggestionsReturn, GetUserProfileSchema, LimitType, PublicUser, Snowflake, User, UserModifyProfileSchema, UserModifySchema, UserProfile, UserProfileMetadata, UserSettings, VerifyUserEmailChangeResponse, VerifyUserEmailChangeSchema
+        DeleteDisableUserSchema, LimitType, PublicUser, Snowflake, User, UserModifyProfileSchema,
+        UserModifySchema, UserProfile, UserProfileMetadata, UserSettings, VerifyUserEmailChangeResponse, VerifyUserEmailChangeSchema,
     },
 };
 
@@ -43,11 +44,6 @@ impl ChorusUser {
     ///
     /// As of 2024/07/28, Spacebar does not yet implement this endpoint.
     ///
-    /// If fetching with a pomelo username, discriminator should be set to None.
-    ///
-    /// This route also permits fetching users with their old pre-pomelo username#discriminator
-    /// combo.
-    ///
     /// Note:
     ///
     /// "Unless the target user is a bot, you must be able to add
@@ -60,12 +56,8 @@ impl ChorusUser {
     ///
     /// # Reference
     /// See <https://docs.discord.sex/resources/user#get-user-by-username>
-    pub async fn get_user_by_username(
+    pub async fn get_user_by_username(&mut self, username: &String) -> ChorusResult<PublicUser> {
-        &mut self,
+        User::get_by_username(self, username).await
-        username: &String,
-        discriminator: Option<&String>,
-    ) -> ChorusResult<PublicUser> {
-        User::get_by_username(self, username, discriminator).await
     }
 
     /// Gets the user's settings.
@@ -172,12 +164,8 @@ impl ChorusUser {
     ///
     /// # Reference
     /// See <https://docs.discord.sex/resources/user#get-user-profile>
-    pub async fn get_user_profile(
+    pub async fn get_user_profile(&mut self, id: Snowflake) -> ChorusResult<UserProfile> {
-        &mut self,
+        User::get_profile(self, id).await
-        id: Snowflake,
-        query_parameters: GetUserProfileSchema,
-    ) -> ChorusResult<UserProfile> {
-        User::get_profile(self, id, query_parameters).await
     }
 
     /// Modifies the current user's profile.
@@ -227,10 +215,7 @@ impl ChorusUser {
     ///
     /// # Reference
     /// See <https://docs.discord.sex/resources/user#modify-user-email>
-    pub async fn verify_email_change(
+    pub async fn verify_email_change(&mut self, schema: VerifyUserEmailChangeSchema) -> ChorusResult<VerifyUserEmailChangeResponse> {
-        &mut self,
-        schema: VerifyUserEmailChangeSchema,
-    ) -> ChorusResult<VerifyUserEmailChangeResponse> {
         let request = Client::new()
             .post(format!(
                 "{}/users/@me/email/verify-code",
@@ -242,65 +227,7 @@ impl ChorusUser {
             request,
             limit_type: LimitType::default(),
         };
-        chorus_request
+        chorus_request.deserialize_response::<VerifyUserEmailChangeResponse>(self).await
-            .deserialize_response::<VerifyUserEmailChangeResponse>(self)
-            .await
-    }
-
-    /// Returns a suggested unique username based on the current user's username.
-    ///
-    /// Note:
-    ///
-    /// "This endpoint is used during the pomelo migration flow.
-    ///
-    /// The user must be in the rollout to use this endpoint."
-	 ///
-	 /// If a user has already migrated, this endpoint will likely return a 401 Unauthorized
-	 /// ([ChorusError::NoPermission])
-    ///
-    /// See <https://docs.discord.sex/resources/user#get-pomelo-suggestions>
-    pub async fn get_pomelo_suggestions(&mut self) -> ChorusResult<String> {
-        let request = Client::new()
-            .get(format!(
-                "{}/users/@me/pomelo-suggestions",
-                self.belongs_to.read().unwrap().urls.api
-            ))
-            .header("Authorization", self.token());
-
-        let chorus_request = ChorusRequest {
-            request,
-            limit_type: LimitType::default(),
-        };
-        chorus_request
-            .deserialize_response::<GetPomeloSuggestionsReturn>(self)
-            .await
-				.map(|returned| returned.username)
-    }
-
-	 /// Checks whether a unique username is available.
-	 ///
-	 /// Returns whether the username is not taken yet.
-    ///
-    /// See <https://docs.discord.sex/resources/user#get-pomelo-eligibility>
-    pub async fn get_pomelo_eligibility(&mut self, username: &String) -> ChorusResult<bool> {
-        let request = Client::new()
-            .post(format!(
-                "{}/users/@me/pomelo-attempt",
-                self.belongs_to.read().unwrap().urls.api
-            ))
-            .header("Authorization", self.token())
-				// FIXME: should we create a type for this?
-				.body(format!(r#"{{ "username": {:?} }}"#, username))
-            .header("Content-Type", "application/json");
-
-        let chorus_request = ChorusRequest {
-            request,
-            limit_type: LimitType::default(),
-        };
-        chorus_request
-            .deserialize_response::<GetPomeloEligibilityReturn>(self)
-            .await
-				.map(|returned| !returned.taken)
     }
 }
 
@@ -345,11 +272,6 @@ impl User {
     ///
     /// As of 2024/07/28, Spacebar does not yet implement this endpoint.
     ///
-    /// If fetching with a pomelo username, discriminator should be set to None.
-    ///
-    /// This route also permits fetching users with their old pre-pomelo username#discriminator
-    /// combo.
-    ///
     /// Note:
     ///
     /// "Unless the target user is a bot, you must be able to add
@@ -362,18 +284,12 @@ impl User {
     pub async fn get_by_username(
         user: &mut ChorusUser,
         username: &String,
-        discriminator: Option<&String>,
     ) -> ChorusResult<PublicUser> {
         let url_api = user.belongs_to.read().unwrap().urls.api.clone();
         let url = format!("{}/users/username/{username}", url_api);
-        let mut request = reqwest::Client::new()
+        let request = reqwest::Client::new()
             .get(url)
             .header("Authorization", user.token());
-
-        if let Some(some_discriminator) = discriminator {
-            request = request.query(&[("discriminator", some_discriminator)]);
-        }
-
         let chorus_request = ChorusRequest {
             request,
             limit_type: LimitType::Global,
@@ -413,17 +329,12 @@ impl User {
     ///
     /// # Reference
     /// See <https://docs.discord.sex/resources/user#get-user-profile>
-    pub async fn get_profile(
+    // TODO: Implement query string parameters for this endpoint
-        user: &mut ChorusUser,
+    pub async fn get_profile(user: &mut ChorusUser, id: Snowflake) -> ChorusResult<UserProfile> {
-        id: Snowflake,
-        query_parameters: GetUserProfileSchema,
-    ) -> ChorusResult<UserProfile> {
         let url_api = user.belongs_to.read().unwrap().urls.api.clone();
         let request: reqwest::RequestBuilder = Client::new()
             .get(format!("{}/users/{}/profile", url_api, id))
-            .header("Authorization", user.token())
+            .header("Authorization", user.token());
-            .query(&query_parameters);
-
         let chorus_request = ChorusRequest {
             request,
             limit_type: LimitType::Global,

src/types/config/types/guild_configuration.rs

@@ -162,11 +162,9 @@ impl Display for GuildFeaturesList {
 }
 
 #[cfg(feature = "sqlx")]
-impl<'r> sqlx::Decode<'r, sqlx::Any> for GuildFeaturesList {
+impl<'r> sqlx::Decode<'r, sqlx::MySql> for GuildFeaturesList {
-    fn decode(
+    fn decode(value: <sqlx::MySql as sqlx::database::HasValueRef<'r>>::ValueRef) -> Result<Self, sqlx::error::BoxDynError> {
-        value: <sqlx::Any as sqlx::Database>::ValueRef<'r>,
+        let v = <String as sqlx::Decode<sqlx::MySql>>::decode(value)?;
-    ) -> Result<Self, sqlx::error::BoxDynError> {
-        let v = <String as sqlx::Decode<sqlx::Any>>::decode(value)?;
         Ok(Self(
             v.split(',')
                 .filter(|f| !f.is_empty())
@@ -177,13 +175,10 @@ impl<'r> sqlx::Decode<'r, sqlx::Any> for GuildFeaturesList {
 }
 
 #[cfg(feature = "sqlx")]
-impl<'q> sqlx::Encode<'q, sqlx::Any> for GuildFeaturesList {
+impl<'q> sqlx::Encode<'q, sqlx::MySql> for GuildFeaturesList {
-    fn encode_by_ref(
+    fn encode_by_ref(&self, buf: &mut <sqlx::MySql as sqlx::database::HasArguments<'q>>::ArgumentBuffer) -> sqlx::encode::IsNull {
-        &self,
-        buf: &mut <sqlx::Any as sqlx::Database>::ArgumentBuffer<'q>,
-    ) -> Result<sqlx::encode::IsNull, Box<dyn std::error::Error + Send + Sync>> {
         if self.is_empty() {
-            return Ok(sqlx::encode::IsNull::Yes);
+            return sqlx::encode::IsNull::Yes;
         }
         let features = self
             .iter()
@@ -191,18 +186,18 @@ impl<'q> sqlx::Encode<'q, sqlx::Any> for GuildFeaturesList {
             .collect::<Vec<_>>()
             .join(",");
 
-        <String as sqlx::Encode<sqlx::Any>>::encode_by_ref(&features, buf)
+        <String as sqlx::Encode<sqlx::MySql>>::encode_by_ref(&features, buf)
     }
 }
 
 #[cfg(feature = "sqlx")]
-impl sqlx::Type<sqlx::Any> for GuildFeaturesList {
+impl sqlx::Type<sqlx::MySql> for GuildFeaturesList {
-    fn type_info() -> sqlx::any::AnyTypeInfo {
+    fn type_info() -> sqlx::mysql::MySqlTypeInfo {
-        <String as sqlx::Type<sqlx::Any>>::type_info()
+        <String as sqlx::Type<sqlx::MySql>>::type_info()
     }
 
-    fn compatible(ty: &sqlx::any::AnyTypeInfo) -> bool {
+    fn compatible(ty: &sqlx::mysql::MySqlTypeInfo) -> bool {
-        <String as sqlx::Type<sqlx::Any>>::compatible(ty)
+        <String as sqlx::Type<sqlx::MySql>>::compatible(ty)
     }
 }
 

src/types/entities/application.rs

@@ -102,10 +102,7 @@ fn compare_install_params(
     b: &Option<sqlx::types::Json<InstallParams>>,
 ) -> bool {
     match (a, b) {
-        (Some(a), Some(b)) => match (a.encode_to_string(), b.encode_to_string()) {
+        (Some(a), Some(b)) => a.encode_to_string() == b.encode_to_string(),
-            (Ok(a), Ok(b)) => a == b,
-            _ => false,
-        },
         (None, None) => true,
         _ => false,
     }

src/types/entities/audit_log.rs

@@ -51,10 +51,7 @@ fn compare_options(
     b: &Option<sqlx::types::Json<AuditEntryInfo>>,
 ) -> bool {
     match (a, b) {
-        (Some(a), Some(b)) => match (a.encode_to_string(), b.encode_to_string()) {
+        (Some(a), Some(b)) => a.encode_to_string() == b.encode_to_string(),
-            (Ok(a), Ok(b)) => a == b,
-            _ => false,
-        },
         (None, None) => true,
         _ => false,
     }
@@ -72,10 +69,7 @@ fn compare_changes(
     a: &sqlx::types::Json<Option<Vec<Shared<AuditLogChange>>>>,
     b: &sqlx::types::Json<Option<Vec<Shared<AuditLogChange>>>>,
 ) -> bool {
-    match (a.encode_to_string(), b.encode_to_string()) {
+    a.encode_to_string() == b.encode_to_string()
-        (Ok(a), Ok(b)) => a == b,
-        _ => false,
-    }
 }
 
 #[cfg(not(tarpaulin_include))]

src/types/entities/channel.rs

@@ -156,10 +156,7 @@ fn compare_permission_overwrites(
     b: &Option<Json<Vec<PermissionOverwrite>>>,
 ) -> bool {
     match (a, b) {
-        (Some(a), Some(b)) => match (a.encode_to_string(), b.encode_to_string()) {
+        (Some(a), Some(b)) => a.encode_to_string() == b.encode_to_string(),
-            (Ok(a), Ok(b)) => a == b,
-            _ => false,
-        },
         (None, None) => true,
         _ => false,
     }

src/types/entities/integration.rs

@@ -4,7 +4,6 @@
 
 use chrono::{DateTime, Utc};
 use serde::{Deserialize, Serialize};
-use serde_repr::{Deserialize_repr, Serialize_repr};
 
 use crate::types::{
     entities::{Application, User},
@@ -24,7 +23,7 @@ pub struct Integration {
     pub syncing: Option<bool>,
     pub role_id: Option<String>,
     pub enabled_emoticons: Option<bool>,
-    pub expire_behaviour: Option<IntegrationExpireBehaviour>,
+    pub expire_behaviour: Option<u8>,
     pub expire_grace_period: Option<u16>,
     #[cfg_attr(feature = "sqlx", sqlx(skip))]
     pub user: Option<Shared<User>>,
@@ -51,7 +50,6 @@ pub struct IntegrationAccount {
 #[serde(rename_all = "snake_case")]
 #[cfg_attr(feature = "sqlx", derive(sqlx::Type))]
 #[cfg_attr(feature = "sqlx", sqlx(rename_all = "snake_case"))]
-/// See <https://docs.discord.sex/resources/integration#integration-type>
 pub enum IntegrationType {
     #[default]
     Twitch,
@@ -59,32 +57,3 @@ pub enum IntegrationType {
     Discord,
     GuildSubscription,
 }
-
-#[derive(
-    Serialize_repr,
-    Deserialize_repr,
-    Debug,
-    Default,
-    Clone,
-    Eq,
-    PartialEq,
-    Hash,
-    Copy,
-    PartialOrd,
-    Ord,
-)]
-#[cfg_attr(feature = "sqlx", derive(sqlx::Type))]
-#[repr(u8)]
-#[serde(rename_all = "SCREAMING_SNAKE_CASE")]
-/// Defines the behaviour that is executed when a user's subscription to the integration expires.
-///
-/// See <https://docs.discord.sex/resources/integration#integration-expire-behavior>
-pub enum IntegrationExpireBehaviour {
-    #[default]
-	 /// Remove the subscriber role from the user
-    RemoveRole = 0,
-	 /// Kick the user from the guild
-	 Kick = 1,
-}
-
-

src/types/entities/user.rs

@@ -116,32 +116,32 @@ impl TryFrom<Vec<u8>> for ThemeColors {
 
 #[cfg(feature = "sqlx")]
 // TODO: Add tests for Encode and Decode.
-impl<'q> sqlx::Encode<'q, sqlx::Any> for ThemeColors {
+impl<'q> sqlx::Encode<'q, sqlx::MySql> for ThemeColors {
     fn encode_by_ref(
         &self,
-        buf: &mut <sqlx::Any as sqlx::Database>::ArgumentBuffer<'q>,
+        buf: &mut <sqlx::MySql as sqlx::database::HasArguments<'q>>::ArgumentBuffer,
-    ) -> Result<sqlx::encode::IsNull, Box<dyn std::error::Error + Send + Sync>> {
+    ) -> sqlx::encode::IsNull {
         let mut vec_u8 = Vec::new();
         vec_u8.extend_from_slice(&self.inner.0.to_be_bytes());
         vec_u8.extend_from_slice(&self.inner.1.to_be_bytes());
-        <Vec<u8> as sqlx::Encode<sqlx::Any>>::encode_by_ref(&vec_u8, buf)
+        <Vec<u8> as sqlx::Encode<'q, sqlx::MySql>>::encode_by_ref(&vec_u8, buf)
     }
 }
 
 #[cfg(feature = "sqlx")]
-impl<'d> sqlx::Decode<'d, sqlx::Any> for ThemeColors {
+impl<'d> sqlx::Decode<'d, sqlx::MySql> for ThemeColors {
     fn decode(
-        value: <sqlx::Any as sqlx::Database>::ValueRef<'d>,
+        value: <sqlx::MySql as sqlx::database::HasValueRef<'d>>::ValueRef,
     ) -> Result<Self, sqlx::error::BoxDynError> {
-        let value_vec = <Vec<u8> as sqlx::Decode<'d, sqlx::Any>>::decode(value)?;
+        let value_vec = <Vec<u8> as sqlx::Decode<'d, sqlx::MySql>>::decode(value)?;
         value_vec.try_into().map_err(|e: ChorusError| e.into())
     }
 }
 
 #[cfg(feature = "sqlx")]
-impl sqlx::Type<sqlx::Any> for ThemeColors {
+impl sqlx::Type<sqlx::MySql> for ThemeColors {
-    fn type_info() -> <sqlx::Any as sqlx::Database>::TypeInfo {
+    fn type_info() -> <sqlx::MySql as sqlx::Database>::TypeInfo {
-        <String as sqlx::Type<sqlx::Any>>::type_info()
+        <String as sqlx::Type<sqlx::MySql>>::type_info()
     }
 }
 

src/types/schema/user.rs

@@ -181,50 +181,3 @@ pub struct VerifyUserEmailChangeResponse {
     #[serde(rename = "token")]
     pub email_token: String,
 }
-
-#[derive(Debug, Default, Deserialize, Serialize, Clone, Copy, PartialEq, Eq)]
-/// Query string parameters for the route GET /users/{user.id}/profile
-/// ([crate::types::User::get_profile])
-///
-/// See <https://docs.discord.sex/resources/user#get-user-profile>
-pub struct GetUserProfileSchema {
-    /// Whether to include the mutual guilds between the current user.
-    ///
-    /// If unset it will default to true
-    pub with_mutual_guilds: Option<bool>,
-    /// Whether to include the mutual friends between the current user.
-    ///
-    /// If unset it will default to false
-    pub with_mutual_friends: Option<bool>,
-    /// Whether to include the number of mutual friends between the current user
-    ///
-    /// If unset it will default to false
-    pub with_mutual_friends_count: Option<bool>,
-    /// The guild id to get the user's member profile in, if any.
-    ///
-    /// Note:
-    ///
-    /// when you click on a user in the member list in the discord client, a request is sent with
-    /// this property set to the selected guild id.
-    ///
-    /// This makes the request include fields such as guild_member and guild_member_profile
-    pub guild_id: Option<Snowflake>,
-    /// The role id to get the user's application role connection metadata in, if any.
-    pub connections_role_id: Option<Snowflake>,
-}
-
-#[derive(Debug, Deserialize, Serialize, Clone, PartialEq, Eq)]
-/// Internal type for the [crate::instance::ChorusUser::get_pomelo_suggestions] endpoint.
-///
-/// See <https://docs.discord.sex/resources/user#get-pomelo-suggestions>
-pub(crate) struct GetPomeloSuggestionsReturn {
-	pub username: String
-}
-
-#[derive(Debug, Deserialize, Serialize, Clone, PartialEq, Eq)]
-/// Internal type for the [crate::instance::ChorusUser::get_pomelo_eligibility] endpoint.
-///
-/// See <https://docs.discord.sex/resources/user#get-pomelo-eligibility>
-pub(crate) struct GetPomeloEligibilityReturn {
-	pub taken: bool
-}

src/types/utils/snowflake.rs

@@ -99,29 +99,23 @@ impl<'de> serde::Deserialize<'de> for Snowflake {
 }
 
 #[cfg(feature = "sqlx")]
-impl sqlx::Type<sqlx::Any> for Snowflake {
+impl sqlx::Type<sqlx::MySql> for Snowflake {
-    fn type_info() -> <sqlx::Any as sqlx::Database>::TypeInfo {
+    fn type_info() -> <sqlx::MySql as sqlx::Database>::TypeInfo {
-        <String as sqlx::Type<sqlx::Any>>::type_info()
+        <String as sqlx::Type<sqlx::MySql>>::type_info()
     }
 }
 
 #[cfg(feature = "sqlx")]
-impl<'q> sqlx::Encode<'q, sqlx::Any> for Snowflake {
+impl<'q> sqlx::Encode<'q, sqlx::MySql> for Snowflake {
-    fn encode_by_ref(
+    fn encode_by_ref(&self, buf: &mut <sqlx::MySql as sqlx::database::HasArguments<'q>>::ArgumentBuffer) -> sqlx::encode::IsNull {
-        &self,
+        <String as sqlx::Encode<'q, sqlx::MySql>>::encode_by_ref(&self.0.to_string(), buf)
-        buf: &mut <sqlx::Any as sqlx::Database>::ArgumentBuffer<'q>,
-    ) -> Result<sqlx::encode::IsNull, sqlx::error::BoxDynError> {
-        <String as sqlx::Encode<'q, sqlx::Any>>::encode_by_ref(&self.0.to_string(), buf)
     }
 }
 
 #[cfg(feature = "sqlx")]
-impl<'d> sqlx::Decode<'d, sqlx::Any> for Snowflake {
+impl<'d> sqlx::Decode<'d, sqlx::MySql> for Snowflake {
-    fn decode(
+    fn decode(value: <sqlx::MySql as sqlx::database::HasValueRef<'d>>::ValueRef) -> Result<Self, sqlx::error::BoxDynError> {
-        value: <sqlx::Any as sqlx::Database>::ValueRef<'d>,
+        <String as sqlx::Decode<'d, sqlx::MySql>>::decode(value).map(|s| s.parse::<u64>().map(Snowflake).unwrap())
-    ) -> Result<Self, sqlx::error::BoxDynError> {
-        <String as sqlx::Decode<'d, sqlx::Any>>::decode(value)
-            .map(|s| s.parse::<u64>().map(Snowflake).unwrap())
     }
 }