turns out we need debug_warn

adjust log volume

demote a bunch of logs

src/api/server/send.rs

@@ -3,7 +3,7 @@ use std::{collections::BTreeMap, net::IpAddr, time::Instant};
 use axum::extract::State;
 use axum_client_ip::InsecureClientIp;
 use conduwuit::{
-	Err, Error, Result, debug,
+	Err, Error, Result,
 	debug::INFO_SPAN_LEVEL,
 	debug_warn, err, error, info,
 	result::LogErr,
@@ -79,7 +79,7 @@ pub(crate) async fn send_transaction_message_route(
 	}
 
 	let txn_start_time = Instant::now();
-	info!(
+	trace!(
 		pdus = body.pdus.len(),
 		edus = body.edus.len(),
 		id = ?body.transaction_id,
@@ -102,7 +102,7 @@ pub(crate) async fn send_transaction_message_route(
 		.filter_map(Result::ok)
 		.stream();
 
-	info!(
+	trace!(
 		pdus = body.pdus.len(),
 		edus = body.edus.len(),
 		elapsed = ?txn_start_time.elapsed(),
@@ -198,7 +198,7 @@ async fn handle_room(
 		.and_then(|(_, event_id, value)| async move {
 			services.server.check_running()?;
 			let pdu_start_time = Instant::now();
-			info!(
+			trace!(
 				%room_id,
 				%event_id,
 				pdu = n + 1,

src/service/federation/execute.rs

@@ -5,10 +5,7 @@ use std::{
 };
 
 use bytes::Bytes;
-use conduwuit::{
+use conduwuit::{Err, Error, Result, debug, debug::INFO_SPAN_LEVEL, err, error::inspect_debug_log, implement, trace, utils::string::EMPTY, info};
-	Err, Error, Result, debug, debug::INFO_SPAN_LEVEL, err,
-	error::inspect_debug_log, implement, trace, utils::string::EMPTY, warn,
-};
 use http::{HeaderValue, header::AUTHORIZATION};
 use ipaddress::IPAddress;
 use reqwest::{Client, Method, Request, Response, Url};
@@ -197,9 +194,9 @@ fn handle_error(
 ) -> Result {
 	if e.is_timeout() || e.is_connect() {
 		e = e.without_url();
-		warn!(?url, "network error while sending federation request: {e:?}");
+		trace!(?url, "network error while sending federation request: {e:?}");
 	} else if e.is_redirect() {
-		warn!(
+		trace!(
 			method = ?method,
 			url = ?url,
 			final_url = ?e.url(),
@@ -208,7 +205,7 @@ fn handle_error(
 			e,
 		);
 	} else {
-		warn!(?url, "failed to send federation request: {e:?}");
+		trace!(?url, "failed to send federation request: {e:?}");
 	}
 
 	let mut nice_error = "Request failed".to_owned();
@@ -217,7 +214,7 @@ fn handle_error(
 		write!(nice_error, ": {source:?}").expect("writing to string should not fail");
 		src = source.source();
 	}
-	warn!(nice_error, "Federation request error");
+	info!(nice_error, "Federation request error");
 
 	Err(e.into())
 }

src/service/rooms/event_handler/fetch_and_handle_outliers.rs

@@ -3,11 +3,7 @@ use std::{
 	time::Instant,
 };
 
-use conduwuit::{
+use conduwuit::{Event, PduEvent, debug, debug_error, implement, matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs, warn, debug_warn};
-	Event, PduEvent, debug, debug_error, debug_warn, implement,
-	matrix::event::gen_event_id_canonical_json, trace, utils::continue_exponential_backoff_secs,
-	warn,
-};
 use ruma::{
 	CanonicalJsonValue, EventId, OwnedEventId, RoomId, ServerName,
 	api::federation::event::get_event,

src/service/rooms/event_handler/handle_outlier_pdu.rs

@@ -123,7 +123,7 @@ where
 
 	// The original create event must be in the auth events
 	if !auth_events.contains_key(&(StateEventType::RoomCreate, String::new().into())) {
-		return Err!(Request(InvalidParam("Incoming event refers to wrong create event.")));
+		return Err!(Request(InvalidParam("Incoming event refers to wrong create event. event_id={event_id}")));
 	}
 
 	let state_fetch = |ty: &StateEventType, sk: &str| {

src/service/rooms/timeline/backfill.rs

@@ -1,13 +1,13 @@
 use std::iter::once;
 
 use conduwuit_core::{
-	Result, debug, debug_warn, implement, info,
+	Result, debug, implement, info,
 	matrix::{
 		event::Event,
 		pdu::{PduCount, PduId, RawPduId},
 	},
 	utils::{IterStream, ReadyExt},
-	validated, warn,
+	validated,
 };
 use futures::{FutureExt, StreamExt};
 use ruma::{
@@ -15,9 +15,7 @@ use ruma::{
 	api::federation,
 	events::{
 		StateEventType, TimelineEventType, room::power_levels::RoomPowerLevelsEventContent,
-	},
+	}, UInt};
-	uint,
-};
 use serde_json::value::RawValue as RawJsonValue;
 
 use super::ExtractBody;
@@ -100,7 +98,7 @@ pub async fn backfill_if_required(&self, room_id: &RoomId, from: PduCount) -> Re
 		.boxed();
 
 	while let Some(ref backfill_server) = servers.next().await {
-		info!("Asking {backfill_server} for backfill");
+		info!("Asking {backfill_server} for backfill of room {room_id}");
 		let response = self
 			.services
 			.sending
@@ -109,7 +107,7 @@ pub async fn backfill_if_required(&self, room_id: &RoomId, from: PduCount) -> Re
 				federation::backfill::get_backfill::v1::Request {
 					room_id: room_id.to_owned(),
 					v: vec![first_pdu.1.event_id().to_owned()],
-					limit: uint!(100),
+					limit: UInt::from(self.services.server.config.max_fetch_prev_events),
 				},
 			)
 			.await;
@@ -117,13 +115,13 @@ pub async fn backfill_if_required(&self, room_id: &RoomId, from: PduCount) -> Re
 			| Ok(response) => {
 				for pdu in response.pdus {
 					if let Err(e) = self.backfill_pdu(backfill_server, pdu).boxed().await {
-						debug_warn!("Failed to add backfilled pdu in room {room_id}: {e}");
+						info!("Failed to add backfilled pdu in room {room_id}: {e}");
 					}
 				}
 				return Ok(());
 			},
 			| Err(e) => {
-				warn!("{backfill_server} failed to provide backfill for room {room_id}: {e}");
+				info!("{backfill_server} failed to provide backfill for room {room_id}: {e}");
 			},
 		}
 	}

src/service/sending/sender.rs

@@ -882,7 +882,7 @@ impl Service {
 			.execute_on(&self.services.client.sender, &server, request)
 			.await
 			.inspect(|_| {
-				info!(%txn_id, %server, "Sent {} PDUs, {} EDUs", pdu_count, edu_count);
+				trace!(%txn_id, %server, "Sent {} PDUs, {} EDUs", pdu_count, edu_count);
 			})
 			.inspect_err(|e| {
 				info!(%txn_id, %server, "Failed to send transaction ({} PDUs, {} EDUs): {e:?}", pdu_count, edu_count);
@@ -890,7 +890,7 @@ impl Service {
 
 		for (event_id, result) in result.iter().flat_map(|resp| resp.pdus.iter()) {
 			if let Err(e) = result {
-				warn!(
+				trace!(
 					%txn_id, %server,
 					"error sending PDU {event_id} to remote server: {e:?}"
 				);