inbox: Add empty /inbox handler

acrate-hostmeta/Cargo.toml

@@ -9,6 +9,7 @@ quick-xml = { version = "0.37.0", features = ["overlapped-lists", "serialize"] }
 reqwest = { version = "0.12.9", features = ["json", "stream"] }
 serde = { version = "1.0.214", features = ["derive"] }
 serde_json = "1.0.132"
+thiserror = "2.0.3"
 
 [dev-dependencies]
 pretty_env_logger = "0.5.0"

acrate-hostmeta/src/lib.rs

@@ -8,6 +8,7 @@
 use std::collections::HashMap;
 
 use serde::Deserialize;
+use thiserror::Error;
 
 /// A resource descriptor object.
 /// 
@@ -477,19 +478,22 @@ impl ResourceDescriptor {
 }
 
 /// Error occurred during [`ResourceDescriptor::discover`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
 pub enum ResourceDescriptorDiscoveryError {
 	/// Manipulation of the provided base [`reqwest::Url`] failed.
 	/// 
 	/// See [reqwest::Url::set_scheme] for possible causes.
+	#[error("manipulation of the provided URL failed")]
 	UrlManipulation(()),
 
 	/// All attempts of fetching a resource descriptor document failed.
+	#[error("fetchign the resource descriptor document failed")]
 	Fetch(ResourceDescriptorDiscoveryFailures),
 }
 
 /// Request errors occurred during [`ResourceDescriptor::discover`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
+#[error("all attempts of fetching the resource descriptor document failed")]
 pub struct ResourceDescriptorDiscoveryFailures {
 	/// HTTPS XRD retrieval.
 	pub https_xrd: GetXRDError,
@@ -511,30 +515,46 @@ pub struct ResourceDescriptorDiscoveryFailures {
 }
 
 /// Error occurred during [`ResourceDescriptor::get_xrd`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
 pub enum GetXRDError {
 	/// The HTTP request failed.
+	#[error("the HTTP request failed")]
 	Request(reqwest::Error),
+
 	/// The `Content-Type` header of the response is missing.
+	#[error("the Content-Type header of the response is missing")]
 	ContentTypeMissing,
+	
 	/// The `Content-Type` header of the response is invalid.
+	#[error("the Content-Type header of the response is invalid")]
 	ContentTypeInvalid,
-	/// The document failed to be read as text.
+
+	/// The document failed to be decoded as text.
+	#[error("the document failed to be decoded as text")]
 	Decode(reqwest::Error),
+
 	/// The document failed to be parsed as XML by [`quick_xml`].
+	#[error("the document failed to be parsed as XML")]
 	Parse(quick_xml::DeError),
 }
 
 /// Error occurred during [`ResourceDescriptor::get_jrd`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
 pub enum GetJRDError {
 	/// The HTTP request failed.
+	#[error("the HTTP request failed")]
 	Request(reqwest::Error),
+
 	/// The `Content-Type` header of the response is missing.
+	#[error("the Content-Type header of the response is missing")]
 	ContentTypeMissing,
+
 	/// The `Content-Type` header of the response is invalid.
+	#[error("the Content-Type header of the response is invalid")]
 	ContentTypeInvalid,
+
 	/// The document failed to be parsed as JSON by [`reqwest`].
+	#[error("the document failed to be parsed as JSON")]
 	Parse(reqwest::Error),
 }
 

acrate-inbox/src/main.rs

@@ -1,6 +1,7 @@
 use anyhow::Context;
 
 mod config;
+mod route;
 
 
 #[tokio::main]
@@ -9,7 +10,8 @@ async fn main() -> anyhow::Result<std::convert::Infallible> {
 	log::debug!("Logging initialized!");
 
 	log::trace!("Creating Axum router...");
-	let app = axum::Router::new();
+	let app = axum::Router::new()
+		.route("/inbox", axum::routing::post(route::inbox_handler));
 	log::trace!("Axum router created successfully!");
 
 	log::trace!("Creating Tokio listener...");

acrate-inbox/src/route.rs

@@ -0,0 +1,8 @@
+#[allow(unreachable_code)]
+pub async fn inbox_handler() {
+	todo!("pre-validation hook");
+	todo!("validate signature");
+	todo!("post-validation hook");
+	todo!("database storage");
+	todo!("post-storage hook");
+}

acrate-nodeinfo/Cargo.toml

@@ -9,6 +9,7 @@ log = "0.4.22"
 reqwest = { version = "0.12.9", features = ["json", "stream"] }
 serde = { version = "1.0.214", features = ["derive"] }
 serde_json = "1.0.132"
+thiserror = "2.0.3"
 
 [dev-dependencies]
 pretty_env_logger = "0.5.0"

acrate-nodeinfo/src/lib.rs

@@ -8,6 +8,7 @@
 //! - <https://codeberg.org/fediverse/fep/src/branch/main/fep/f1d5/fep-f1d5.md>
 
 use serde::Deserialize;
+use thiserror::Error;
 
 /// A variant of a NodeInfo document.
 /// 
@@ -309,11 +310,13 @@ impl NodeInfo {
 }
 
 /// An error occurred during [`NodeInfo::get_latest_wellknown`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
 pub enum NodeInfoGetWellknownError {
 	/// The discovery of possible locations for NodeInfo documents failed.
+	#[error("the discovery of possible locations for NodeInfo documents failed")]
 	Discovery(acrate_hostmeta::ResourceDescriptorDiscoveryError),
 	/// No compatible NodeInfo documents were detected at the given URL.
+	#[error("no compatible NodeInfo documents were detected at the given URL")]
 	Unsupported,
 }
 
@@ -446,17 +449,26 @@ impl NodeInfo2 {
 }
 
 /// An error encountered during [`NodeInfo1::get`] or [`NodeInfo2::get`].
-#[derive(Debug)]
+#[derive(Debug, Error)]
 pub enum NodeInfoGetError {
 	/// The HTTP request failed.
+	#[error("the HTTP request failed")]
 	Request(reqwest::Error),
+
 	/// The `Content-Type` header of the response is missing.
+	#[error("the Content-Type header of the response is missing")]
 	ContentTypeMissing,
+
 	/// The `Content-Type` header of the response is invalid.
+	#[error("the Content-Type header of the response is invalid")]
 	ContentTypeInvalid,
+
 	/// The document failed to be parsed as JSON by [`reqwest`].
+	#[error("the document failed to be parsed as JSON")]
 	Parse(reqwest::Error),
-	/// The returned version does not match the version of the created struct.
+
+	/// The returned NodeInfo version would not match the version of the called method.
+	#[error("the returned NodeInfo version would not match the version of the called method")]
 	Version,
 }