diff --git a/src/service/federation/execute.rs b/src/service/federation/execute.rs index 33c6d292a..2f6355036 100644 --- a/src/service/federation/execute.rs +++ b/src/service/federation/execute.rs @@ -3,7 +3,7 @@ use bytes::Bytes; use conduwuit::{ Err, Error, Result, debug, debug::INFO_SPAN_LEVEL, debug_error, debug_warn, err, - error::inspect_debug_log, implement, trace, utils::string::EMPTY, + error::inspect_debug_log, implement, trace, }; use http::{HeaderValue, header::AUTHORIZATION}; use ipaddress::IPAddress; @@ -289,10 +289,13 @@ fn into_http_request(actual: &ActualDest, request: T) -> Result = SendAccessToken::IfRequired(EMPTY); let http_request = request - .try_into_http_request::>(actual.string().as_str(), SATIR, &VERSIONS) + .try_into_http_request::>( + actual.string().as_str(), + SendAccessToken::None, + &VERSIONS, + ) .map_err(|e| err!(BadServerResponse("Invalid destination: {e:?}")))?; Ok(http_request) diff --git a/src/service/pusher/mod.rs b/src/service/pusher/mod.rs index 10090f8d4..1af64e600 100644 --- a/src/service/pusher/mod.rs +++ b/src/service/pusher/mod.rs @@ -198,7 +198,7 @@ pub async fn send_request(&self, dest: &str, request: T) -> Result(&dest, SendAccessToken::IfRequired(""), &VERSIONS) + .try_into_http_request::(&dest, SendAccessToken::None, &VERSIONS) .map_err(|e| { err!(BadServerResponse(warn!( "Failed to find destination {dest} for push gateway: {e}" diff --git a/src/service/sending/appservice.rs b/src/service/sending/appservice.rs index dcaf33d50..6a92b6be2 100644 --- a/src/service/sending/appservice.rs +++ b/src/service/sending/appservice.rs @@ -35,7 +35,7 @@ pub async fn send_appservice_request( let mut http_request = request .try_into_http_request::( &dest, - SendAccessToken::IfRequired(hs_token), + SendAccessToken::Appservice(hs_token), &VERSIONS, ) .map_err(|e| {