diff --git a/src/service/sending/mod.rs b/src/service/sending/mod.rs index 7997d5327..0e7412cf5 100644 --- a/src/service/sending/mod.rs +++ b/src/service/sending/mod.rs @@ -42,7 +42,6 @@ pub struct Service { struct Services { client: Dep, globals: Dep, - state: Dep, state_cache: Dep, user: Dep, users: Dep, @@ -86,7 +85,6 @@ impl crate::Service for Service { services: Services { client: args.depend::("client"), globals: args.depend::("globals"), - state: args.depend::("rooms::state"), state_cache: args.depend::("rooms::state_cache"), user: args.depend::("rooms::user"), users: args.depend::("users"), diff --git a/src/service/sending/sender.rs b/src/service/sending/sender.rs index 606b8f094..d453cccf7 100644 --- a/src/service/sending/sender.rs +++ b/src/service/sending/sender.rs @@ -29,7 +29,7 @@ use futures::{ }; use ruma::{ CanonicalJsonObject, MilliSecondsSinceUnixEpoch, OwnedRoomId, OwnedServerName, OwnedUserId, - RoomId, RoomVersionId, ServerName, UInt, + RoomId, ServerName, UInt, api::{ appservice::event::push_events::v1::EphemeralData, federation::transactions::{ @@ -74,12 +74,6 @@ const DEQUEUE_LIMIT: usize = 48; pub const PDU_LIMIT: usize = 50; pub const EDU_LIMIT: usize = 100; -fn is_create_event(data: &CanonicalJsonObject) -> bool { - let event_type = data.get("type").and_then(|v| v.as_str()); - let state_key = data.get("state_key").and_then(|v| v.as_str()); - event_type.is_some_and(|t| t == "m.room.create") && state_key.is_some_and(str::is_empty) -} - impl Service { #[tracing::instrument(skip(self), level = "debug")] pub(super) async fn sender(self: Arc, id: usize) -> Result {