zaaarf/upub
1
0
Fork 0
forked from alemi/upub
Code Pull requests Activity

fix: trait signatures

Browse source
This commit is contained in:
əlemi 2024-05-31 00:11:03 +02:00
parent 3a6e632448
commit 3c50dba3f8
Signed by: alemi
GPG key ID: A4895B84D311642C
1 changed files with 1 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/server/fetcher.rs
View file

@ -16,14 +16,6 @@ pub enum PullResult<T> {
Object(T), Object(T),
} }
impl<T> PullResult<T> {
pub fn inner(self) -> T {
match self {
Self::Actor(x) | Self::Activity(x) | Self::Object(x) => x
}
}
}
impl PullResult<serde_json::Value> { impl PullResult<serde_json::Value> {
pub fn actor(self) -> crate::Result<serde_json::Value> { pub fn actor(self) -> crate::Result<serde_json::Value> {
match self { match self {
@ -48,21 +40,12 @@ impl PullResult<serde_json::Value> {
Self::Object(x) => Ok(x), Self::Object(x) => Ok(x),
} }
} }
pub async fn resolve(self, ctx: &(impl Fetcher + Sync)) -> crate::Result<()> {
match self {
Self::Actor(x) => { ctx.resolve_user(x).await?; },
Self::Object(x) => { ctx.resolve_object(x).await?; },
Self::Activity(x) => { ctx.resolve_activity(x).await?; },
}
Ok(())
}
} }
#[axum::async_trait] #[axum::async_trait]
pub trait Fetcher { pub trait Fetcher {
async fn pull(&self, id: &str) -> crate::Result<PullResult<serde_json::Value>> { self.pull_r(id, 0).await } async fn pull(&self, id: &str) -> crate::Result<PullResult<serde_json::Value>> { self.pull_r(id, 0).await }
async fn pull_r(&self, id: &str, depth: i32) -> crate::Result<PullResult<serde_json::Value>>; async fn pull_r(&self, id: &str, depth: u32) -> crate::Result<PullResult<serde_json::Value>>;
async fn webfinger(&self, user: &str, host: &str) -> crate::Result<String>; async fn webfinger(&self, user: &str, host: &str) -> crate::Result<String>;