unimore/tirocinio-canali-steffo-acrate
unimore/tirocinio-canali-steffo-acrate
1
Fork 0
Code Pull requests 1 Activity

Compare commits

base: unimore:b0bb31bba0cd32ba2efedb9f2ca39998b2c5e818
Branches Tags
unimore:main
unimore:feature/apub-inbox
..
compare: unimore:fa699ed380e528d2343d2138a4736162e98970df
Branches Tags
unimore:feature/apub-inbox
unimore:main

No commits in common. "b0bb31bba0cd32ba2efedb9f2ca39998b2c5e818" and "fa699ed380e528d2343d2138a4736162e98970df" have entirely different histories.
b0bb31bba0 ... fa699ed380

4 changed files with 123 additions and 43 deletions
Show stats Expand all files Collapse all files

22
acrate_nodeinfo/tests/integration_tests.rs
View file

@ -24,9 +24,9 @@ fn make_client() -> reqwest::Client {
}
macro_rules! test_version {
macro_rules! test {
($id:ident, $url:literal, $version:literal) => {
test_version!($id, $url, $version,);
test!($id, $url, $version,);
};
($id:ident, $url:literal, $version:literal, $($tag:meta),*) => {
mod $id {
@ -59,12 +59,12 @@ macro_rules! test_version {
};
}
test_version!(akkoma, "https://junimo.party", "2.1");
test_version!(mastodon, "https://mastodon.social", "2.0");
test_version!(misskey, "https://misskey.io", "2.1");
test_version!(iceshrimpnet, "https://meow.company", "2.1");
test_version!(gotosocial, "https://alpha.polymaths.social", "2.0");
test_version!(bridgyfed, "https://fed.brid.gy", "2.1");
test_version!(threads, "https://threads.net", "", ignore = "does not support NodeInfo");
test_version!(snac, "https://ngoa.giao.loan", "2.0");
test_version!(hollo, "https://hollo.social", "2.1");
test!(akkoma, "https://junimo.party", "2.1");
test!(mastodon, "https://mastodon.social", "2.0");
test!(misskey, "https://misskey.io", "2.1");
test!(iceshrimpnet, "https://ice.frieren.quest", "2.1");
test!(gotosocial, "https://alpha.polymaths.social", "2.0");
test!(bridgyfed, "https://fed.brid.gy", "2.1");
test!(threads, "https://threads.net", "", ignore = "does not support NodeInfo");
test!(snac, "https://ngoa.giao.loan", "2.0");
test!(hollo, "https://hollo.social", "2.1");

140
acrate_rd/src/any.rs
View file

@ -15,16 +15,17 @@ impl ResourceDescriptor {
///
/// In order, this method attempts:
///
/// 1. [XRD](ResourceDescriptorJRD::get)
/// 2. [JRD](ResourceDescriptorJRD::get)
/// 3. [JRD](ResourceDescriptorJRD::get) with .json path suffix
/// 1. HTTPS [XRD](ResourceDescriptorJRD::get)
/// 2. HTTPS [JRD](ResourceDescriptorJRD::get)
/// 3. HTTPS [JRD](ResourceDescriptorJRD::get) with .json path suffix
/// 4. HTTP [XRD](ResourceDescriptorJRD::get)
/// 5. HTTP [JRD](ResourceDescriptorJRD::get)
/// 6. HTTP [JRD](ResourceDescriptorJRD::get) with .json path suffix
///
/// # Notes
///
/// This follows redirects until the redirect chain is 10 hops; see [`reqwest::redirect`] for more info.
///
/// Only the protocol specified in the passed [`reqwest::Url`] is used to fetch the [`ResourceDescriptor`]; despite the specification allowing servers to use only one between HTTP and HTTPS, no implicit downgrade is ever performed to prevent MITM attacks.
///
/// # Examples
///
/// ```
@ -52,51 +53,121 @@ impl ResourceDescriptor {
log::trace!("Unsetting URL fragment...");
url.set_fragment(None);
log::trace!("Attempting XRD retrieval...");
let xrd = match ResourceDescriptorXRD::get(client, url.clone()).await {
log::trace!("Setting URL scheme to HTTPS...");
url.set_scheme("https")
.map_err(UrlManipulation)?;
log::trace!("Cloning URL for HTTPS XRD retrieval...");
let https_xrd_url = url.clone();
log::trace!("Attempting HTTPS XRD retrieval...");
let https_xrd = match ResourceDescriptorXRD::get(client, https_xrd_url).await {
Ok(data) => {
log::trace!("XRD retrieval was successful, returning...");
log::trace!("HTTPS XRD retrieval was successful, returning...");
return Ok(Self::XRD(data))
}
Err(err) => {
log::warn!("XRD retrieval failed.");
log::warn!("HTTPS XRD retrieval failed.");
err
}
};
log::trace!("Attempting JRD retrieval...");
let jrd = match ResourceDescriptorJRD::get(client, url.clone()).await {
log::trace!("Cloning URL for HTTPS JRD retrieval...");
let https_jrd_url = url.clone();
log::trace!("Attempting HTTPS JRD retrieval...");
let https_jrd = match ResourceDescriptorJRD::get(client, https_jrd_url).await {
Ok(data) => {
log::trace!("JRD retrieval was successful, returning...");
log::trace!("HTTPS JRD retrieval was successful, returning...");
return Ok(Self::JRD(data))
}
Err(err) => {
log::warn!("JRD retrieval failed.");
log::warn!("HTTPS JRD retrieval failed.");
err
}
};
log::trace!("Altering URL path for JRD .json retrieval...");
url.set_path(
&format!("{}.json", url.path())
log::trace!("Cloning URL for HTTPS JRD .json retrieval...");
let mut https_jrdj_url = url.clone();
log::trace!("Altering URL path for HTTPS JRD .json retrieval...");
https_jrdj_url.set_path(
&format!("{}.json", https_jrdj_url.path())
);
log::trace!("Attempting JRD .json retrieval...");
let jrdj = match ResourceDescriptorJRD::get(client, url.clone()).await {
log::trace!("Attempting HTTPS JRD .json retrieval...");
let https_jrdj = match ResourceDescriptorJRD::get(client, https_jrdj_url).await {
Ok(data) => {
log::trace!("JRD .json retrieval was successful, returning...");
log::trace!("HTTPS JRD .json retrieval was successful, returning...");
return Ok(Self::JRD(data))
}
Err(err) => {
log::warn!("JRD .json retrieval failed.");
log::warn!("HTTPS JRD .json retrieval failed.");
err
}
};
log::trace!("Setting URL scheme to HTTP...");
url.set_scheme("http")
.map_err(UrlManipulation)?;
log::trace!("Cloning URL for HTTP XRD retrieval...");
let http_xrd_url = url.clone();
log::trace!("Attempting HTTP XRD retrieval...");
let http_xrd = match ResourceDescriptorXRD::get(client, http_xrd_url).await {
Ok(data) => {
log::trace!("HTTP XRD retrieval was successful, returning...");
return Ok(Self::XRD(data))
}
Err(err) => {
log::warn!("HTTP XRD retrieval failed.");
err
}
};
log::trace!("Cloning URL for HTTP JRD retrieval...");
let http_jrd_url = url.clone();
log::trace!("Attempting HTTP JRD retrieval...");
let http_jrd = match ResourceDescriptorJRD::get(client, http_jrd_url).await {
Ok(data) => {
log::trace!("HTTP JRD retrieval was successful, returning...");
return Ok(Self::JRD(data))
}
Err(err) => {
log::warn!("HTTP JRD retrieval failed.");
err
}
};
log::trace!("Cloning URL for HTTP JRD .json retrieval...");
let mut http_jrdj_url = url.clone();
log::trace!("Altering URL path for HTTPS JRD .json retrieval...");
http_jrdj_url.set_path(
&format!("{}.json", http_jrdj_url.path())
);
log::trace!("Attempting HTTP JRD .json retrieval...");
let http_jrdj = match ResourceDescriptorJRD::get(client, http_jrdj_url).await {
Ok(data) => {
log::trace!("HTTP JRD .json retrieval was successful, returning...");
return Ok(Self::JRD(data))
}
Err(err) => {
log::warn!("HTTP JRD .json retrieval failed.");
err
}
};
Err(Fetch(GetFetchFailures {
xrd,
jrd,
jrdj,
https_xrd,
https_jrd,
https_jrdj,
http_xrd,
http_jrd,
http_jrdj,
}))
}
@ -191,16 +262,25 @@ pub enum GetError {
Fetch(GetFetchFailures),
}
/// Request errors occurred during [`ResourceDescriptor::get`].
/// Request errors occurred during [`ResourceDescriptor::discover`].
#[derive(Debug, Error)]
#[error("all attempts of fetching the resource descriptor document failed")]
pub struct GetFetchFailures {
/// XRD retrieval.
pub xrd: GetXRDError,
/// HTTPS XRD retrieval.
pub https_xrd: GetXRDError,
/// JRD retrieval.
pub jrd: GetJRDError,
/// HTTPS JRD retrieval.
pub https_jrd: GetJRDError,
/// JRD with .json extension retrieval.
pub jrdj: GetJRDError,
/// HTTPS JRD with .json extension retrieval.
pub https_jrdj: GetJRDError,
/// HTTPS XRD retrieval.
pub http_xrd: GetXRDError,
/// HTTP JRD retrieval.
pub http_jrd: GetJRDError,
/// HTTP JRD with .json extension retrieval.
pub http_jrdj: GetJRDError,
}

2
acrate_rd/src/xrd.rs
View file

@ -181,7 +181,7 @@ impl ResourceDescriptorXRD {
pub async fn get(client: &reqwest::Client, url: reqwest::Url) -> Result<Self, GetXRDError> {
use GetXRDError::*;
log::debug!("Getting XRD document at: {url}");
log::debug!("Getting host-meta XRD document at: {url}");
log::trace!("Building request...");
let request = {

2
acrate_rd/tests/integration_tests.rs
View file

@ -105,7 +105,7 @@ macro_rules! test_de_ser_xrd {
test_discover_hostmeta!(test_discover_hostmeta_junimo_party, "https://junimo.party");
test_discover_hostmeta!(test_discover_hostmeta_mastodon_social, "https://mastodon.social");
test_discover_hostmeta!(test_discover_hostmeta_misskey_io, "https://misskey.io");
test_discover_hostmeta!(test_discover_hostmeta_meow_company, "https://meow.company");
test_discover_hostmeta!(test_discover_hostmeta_ice_frieren_quest, "https://ice.frieren.quest");
test_discover_hostmeta!(test_discover_hostmeta_alpha_polymaths_social, "https://alpha.polymaths.social");
test_discover_hostmeta!(test_discover_hostmeta_fed_brid_gy, "https://fed.brid.gy");
test_discover_hostmeta!(test_discover_hostmeta_threads_net, "https://threads.net", ignore = "does not support host-meta");