Mirrors/continuwuity
1
0
Fork 0
mirror of https://forgejo.ellis.link/continuwuation/continuwuity.git synced 2026-05-26 20:49:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

style: Run linter

Browse Source
This commit is contained in:
timedout
2026-03-29 15:16:54 +01:00
parent 8b206564aa
commit 422db2105c
2 changed files with 1 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/sending/mod.rs
-2
View File
@@ -42,7 +42,6 @@ pub struct Service {
struct Services { struct Services {
client: Dep<client::Service>, client: Dep<client::Service>,
globals: Dep<globals::Service>, globals: Dep<globals::Service>,
state: Dep<rooms::state::Service>,
state_cache: Dep<rooms::state_cache::Service>, state_cache: Dep<rooms::state_cache::Service>,
user: Dep<rooms::user::Service>, user: Dep<rooms::user::Service>,
users: Dep<users::Service>, users: Dep<users::Service>,
@@ -86,7 +85,6 @@ impl crate::Service for Service {
services: Services { services: Services {
client: args.depend::<client::Service>("client"), client: args.depend::<client::Service>("client"),
globals: args.depend::<globals::Service>("globals"), globals: args.depend::<globals::Service>("globals"),
state: args.depend::<rooms::state::Service>("rooms::state"),
state_cache: args.depend::<rooms::state_cache::Service>("rooms::state_cache"), state_cache: args.depend::<rooms::state_cache::Service>("rooms::state_cache"),
user: args.depend::<rooms::user::Service>("rooms::user"), user: args.depend::<rooms::user::Service>("rooms::user"),
users: args.depend::<users::Service>("users"), users: args.depend::<users::Service>("users"),
src/service/sending/sender.rs
+1 -7
View File
@@ -29,7 +29,7 @@ use futures::{
}; };
use ruma::{ use ruma::{
CanonicalJsonObject, MilliSecondsSinceUnixEpoch, OwnedRoomId, OwnedServerName, OwnedUserId, CanonicalJsonObject, MilliSecondsSinceUnixEpoch, OwnedRoomId, OwnedServerName, OwnedUserId,
RoomId, RoomVersionId, ServerName, UInt, RoomId, ServerName, UInt,
api::{ api::{
appservice::event::push_events::v1::EphemeralData, appservice::event::push_events::v1::EphemeralData,
federation::transactions::{ federation::transactions::{
@@ -74,12 +74,6 @@ const DEQUEUE_LIMIT: usize = 48;
pub const PDU_LIMIT: usize = 50; pub const PDU_LIMIT: usize = 50;
pub const EDU_LIMIT: usize = 100; 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 { impl Service {
#[tracing::instrument(skip(self), level = "debug")] #[tracing::instrument(skip(self), level = "debug")]
pub(super) async fn sender(self: Arc<Self>, id: usize) -> Result { pub(super) async fn sender(self: Arc<Self>, id: usize) -> Result {