diff --git a/src/api/client_server/media.rs b/src/api/client_server/media.rs index e0928cf2..ca9dda86 100644 --- a/src/api/client_server/media.rs +++ b/src/api/client_server/media.rs @@ -129,7 +129,7 @@ pub(crate) async fn get_media_config_legacy_route( _body: Ar, ) -> Result> { Ok(Ra(legacy_media::get_media_config::v3::Response { - upload_size: services().globals.max_request_size().into(), + upload_size: services().globals.max_request_size(), })) } @@ -140,7 +140,7 @@ pub(crate) async fn get_media_config_route( _body: Ar, ) -> Result> { Ok(Ra(authenticated_media_client::get_media_config::v1::Response { - upload_size: services().globals.max_request_size().into(), + upload_size: services().globals.max_request_size(), })) } diff --git a/src/config.rs b/src/config.rs index a440a455..d3100f41 100644 --- a/src/config.rs +++ b/src/config.rs @@ -10,7 +10,7 @@ use std::{ use reqwest::Url; use ruma::{ api::federation::discovery::OldVerifyKey, OwnedServerName, - OwnedServerSigningKeyId, RoomVersionId, + OwnedServerSigningKeyId, RoomVersionId, UInt, }; use serde::Deserialize; use strum::{Display, EnumIter, IntoEnumIterator}; @@ -51,7 +51,7 @@ pub(crate) struct Config { #[serde(default = "default_cleanup_second_interval")] pub(crate) cleanup_second_interval: u32, #[serde(default = "default_max_request_size")] - pub(crate) max_request_size: u32, + pub(crate) max_request_size: UInt, #[serde(default = "false_fn")] pub(crate) allow_registration: bool, pub(crate) registration_token: Option, @@ -466,9 +466,9 @@ fn default_cleanup_second_interval() -> u32 { 60 } -fn default_max_request_size() -> u32 { +fn default_max_request_size() -> UInt { // Default to 20 MB - 20 * 1024 * 1024 + (20_u32 * 1024 * 1024).into() } pub(crate) fn default_tracing_filter() -> EnvFilterClone { diff --git a/src/service/globals.rs b/src/service/globals.rs index 65d8b7bc..afbd9cb2 100644 --- a/src/service/globals.rs +++ b/src/service/globals.rs @@ -31,7 +31,7 @@ use ruma::{ serde::Base64, DeviceId, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedRoomAliasId, OwnedRoomId, OwnedServerName, OwnedUserId, RoomAliasId, RoomVersionId, - ServerName, UserId, + ServerName, UInt, UserId, }; use tokio::sync::{broadcast, Mutex, RwLock, Semaphore}; use tracing::{error, warn, Instrument}; @@ -381,7 +381,7 @@ impl Service { self.config.server_name.as_ref() } - pub(crate) fn max_request_size(&self) -> u32 { + pub(crate) fn max_request_size(&self) -> UInt { self.config.max_request_size }