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: Clippy conflicts with cargo fmt, apparently

Browse Source
This commit is contained in:
timedout
2026-04-27 22:15:52 +00:00
committed by Ellis Git
parent 0924b7d27e
commit f3fb218652
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/api/server/send.rs
+14 -14
View File
@@ -7,24 +7,26 @@ use std::{
use axum::extract::State; use axum::extract::State;
use axum_client_ip::ClientIp; use axum_client_ip::ClientIp;
use conduwuit::{ use conduwuit::{
debug, debug_warn, err, error, result::LogErr, state_res::lexicographical_topological_sort, trace, Err, Error, Result, debug, debug_warn, err, error,
result::LogErr,
state_res::lexicographical_topological_sort,
trace,
utils::{ utils::{
millis_since_unix_epoch, stream::{automatic_width, BroadbandExt, TryBroadbandExt}, IterStream, IterStream, ReadyExt, millis_since_unix_epoch,
ReadyExt, stream::{BroadbandExt, TryBroadbandExt, automatic_width},
}, },
warn, warn,
Err,
Error,
Result,
}; };
use conduwuit_service::{ use conduwuit_service::{
sending::{EDU_LIMIT, PDU_LIMIT},
Services, Services,
sending::{EDU_LIMIT, PDU_LIMIT},
}; };
use futures::{FutureExt, Stream, StreamExt, TryFutureExt, TryStreamExt}; use futures::{FutureExt, Stream, StreamExt, TryFutureExt, TryStreamExt};
use http::StatusCode; use http::StatusCode;
use itertools::Itertools; use itertools::Itertools;
use ruma::{ use ruma::{
CanonicalJsonObject, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedRoomId, OwnedUserId,
RoomId, ServerName, UInt, UserId,
api::{ api::{
client::error::{ErrorKind, ErrorKind::LimitExceeded}, client::error::{ErrorKind, ErrorKind::LimitExceeded},
federation::transactions::{ federation::transactions::{
@@ -35,13 +37,11 @@ use ruma::{
}, },
send_transaction_message, send_transaction_message,
}, },
}, events::receipt::{ReceiptEvent, ReceiptEventContent, ReceiptType}, int, serde::Raw, to_device::DeviceIdOrAllDevices, },
CanonicalJsonObject, MilliSecondsSinceUnixEpoch, OwnedEventId, OwnedRoomId, events::receipt::{ReceiptEvent, ReceiptEventContent, ReceiptType},
OwnedUserId, int,
RoomId, serde::Raw,
ServerName, to_device::DeviceIdOrAllDevices,
UInt,
UserId,
}; };
use service::transactions::{ use service::transactions::{
FederationTxnState, TransactionError, TxnKey, WrappedTransactionResponse, FederationTxnState, TransactionError, TxnKey, WrappedTransactionResponse,