mirror of
https://github.com/LemmyNet/activitypub-federation-rust.git
synced 2024-05-05 10:48:44 +00:00
636b47c8b2
* Add back activity send queue as optional feature * fix port collision in tests * improve docs * serialize fn * deduplicate * more dedup * more dedup * dedupupup * test cleanup * remove fn
94 lines
3.4 KiB
Rust
94 lines
3.4 KiB
Rust
//! Error messages returned by this library
|
|
|
|
use crate::fetch::webfinger::WebFingerError;
|
|
use http_signature_normalization_reqwest::SignError;
|
|
use openssl::error::ErrorStack;
|
|
use std::string::FromUtf8Error;
|
|
use tokio::task::JoinError;
|
|
use url::Url;
|
|
|
|
/// Error messages returned by this library
|
|
#[derive(thiserror::Error, Debug)]
|
|
pub enum Error {
|
|
/// Object was not found in local database
|
|
#[error("Object was not found in local database")]
|
|
NotFound,
|
|
/// Request limit was reached during fetch
|
|
#[error("Request limit was reached during fetch")]
|
|
RequestLimit,
|
|
/// Response body limit was reached during fetch
|
|
#[error("Response body limit was reached during fetch")]
|
|
ResponseBodyLimit,
|
|
/// Object to be fetched was deleted
|
|
#[error("Fetched remote object {0} which was deleted")]
|
|
ObjectDeleted(Url),
|
|
/// url verification error
|
|
#[error("URL failed verification: {0}")]
|
|
UrlVerificationError(&'static str),
|
|
/// Incoming activity has invalid digest for body
|
|
#[error("Incoming activity has invalid digest for body")]
|
|
ActivityBodyDigestInvalid,
|
|
/// Incoming activity has invalid signature
|
|
#[error("Incoming activity has invalid signature")]
|
|
ActivitySignatureInvalid,
|
|
/// Failed to resolve actor via webfinger
|
|
#[error("Failed to resolve actor via webfinger")]
|
|
WebfingerResolveFailed(#[from] WebFingerError),
|
|
/// Failed to serialize outgoing activity
|
|
#[error("Failed to serialize outgoing activity {1}: {0}")]
|
|
SerializeOutgoingActivity(serde_json::Error, String),
|
|
/// Failed to parse an object fetched from url
|
|
#[error("Failed to parse object {1} with content {2}: {0}")]
|
|
ParseFetchedObject(serde_json::Error, Url, String),
|
|
/// Failed to parse an activity received from another instance
|
|
#[error("Failed to parse incoming activity {}: {0}", match .1 {
|
|
Some(t) => format!("with id {t}"),
|
|
None => String::new(),
|
|
})]
|
|
ParseReceivedActivity(serde_json::Error, Option<Url>),
|
|
/// Reqwest Middleware Error
|
|
#[error(transparent)]
|
|
ReqwestMiddleware(#[from] reqwest_middleware::Error),
|
|
/// Reqwest Error
|
|
#[error(transparent)]
|
|
Reqwest(#[from] reqwest::Error),
|
|
/// UTF-8 error
|
|
#[error(transparent)]
|
|
Utf8(#[from] FromUtf8Error),
|
|
/// Url Parse
|
|
#[error(transparent)]
|
|
UrlParse(#[from] url::ParseError),
|
|
/// Signing errors
|
|
#[error(transparent)]
|
|
SignError(#[from] SignError),
|
|
/// Failed to queue activity for sending
|
|
#[error("Failed to queue activity {0} for sending")]
|
|
ActivityQueueError(Url),
|
|
/// Stop activity queue
|
|
#[error(transparent)]
|
|
StopActivityQueue(#[from] JoinError),
|
|
/// Attempted to fetch object which doesn't have valid ActivityPub Content-Type
|
|
#[error(
|
|
"Attempted to fetch object from {0} which doesn't have valid ActivityPub Content-Type"
|
|
)]
|
|
FetchInvalidContentType(Url),
|
|
/// Attempted to fetch object but the response's id field doesn't match
|
|
#[error("Attempted to fetch object from {0} but the response's id field doesn't match")]
|
|
FetchWrongId(Url),
|
|
/// Other generic errors
|
|
#[error("{0}")]
|
|
Other(String),
|
|
}
|
|
|
|
impl From<ErrorStack> for Error {
|
|
fn from(value: ErrorStack) -> Self {
|
|
Error::Other(value.to_string())
|
|
}
|
|
}
|
|
|
|
impl PartialEq for Error {
|
|
fn eq(&self, other: &Self) -> bool {
|
|
std::mem::discriminant(self) == std::mem::discriminant(other)
|
|
}
|
|
}
|