Struct ValidateInbox 

pub struct ValidateInbox<I> { /* private fields */ }

Rejects if a public message was not sent to a shared inbox Rejects if a private message was sent to a shared inbox

Trait Implementations

impl<I: Clone> Clone for ValidateInbox<I>

fn clone(&self) -> ValidateInbox<I>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I: Debug> Debug for ValidateInbox<I>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<A, I> Ingest<A> for ValidateInbox<I>

where A: DeliverableObject + 'static, I: Ingest<A>, I::Error: From<InboxError>, I::ActorId: InboxType,

type Local = <I as Ingest<A>>::Local

The local repository

type ActorId = <I as Ingest<A>>::ActorId

The actor that is receiving the activity

type Error = <I as Ingest<A>>::Error

The error produced when ingesting activities

fn local_repo(&self) -> &Self::Local

Get the local repository

fn is_local(&self, url: &Url) -> bool

Determine if a given URL is local

fn ingest<'life0, 'life1, 'async_trait, R, S>( &'life0 self, authority: Authority, actor_id: Self::ActorId, activity: &'life1 A, remote_repo: R, session: S, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + 'async_trait>>

where Self::Error: From<R::Error>, R: 'async_trait + Repo, S: 'async_trait + Session, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Accept and process a given activity

fn fetch<'life0, 'async_trait, D, Remote, S>( &'life0 self, id: D, actor_id: Self::ActorId, remote_repo: Remote, session: S, ) -> Pin<Box<dyn Future<Output = Result<Option<<D as Dereference>::Output>, Self::Error>> + 'async_trait>>

where 'life0: 'async_trait, Self::ActorId: 'static, Self::Error: From<<Remote as Repo>::Error>, D: 'async_trait + Dereference<Output = Object>, Remote: 'async_trait + Repo, S: 'async_trait + Session, Self: 'async_trait,

Dereference an ID from the local or remote repo