Struct IncomingBundle

pub struct IncomingBundle {
    pub origin: Origin,
    pub bundle: MessageBundle,
    pub action: MessageAction,
}

A bundle of cross-chain messages.

Fields

origin: Origin

The origin of the messages (chain and channel if any).

bundle: MessageBundle

The messages to be delivered to the inbox identified by origin.

action: MessageAction

What to do with the message.

Implementations

impl IncomingBundle

pub async fn origin(&self, ctx: &Context<'_>) -> Result<&Origin>

pub async fn bundle(&self, ctx: &Context<'_>) -> Result<&MessageBundle>

pub async fn action(&self, ctx: &Context<'_>) -> Result<&MessageAction>

impl IncomingBundle

pub fn messages_and_ids( &self, ) -> impl Iterator<Item = (MessageId, &PostedMessage)>

Returns an iterator over all posted messages in this bundle, together with their ID.

pub fn put_openchain_at_front(bundles: &mut [IncomingBundle]) -> bool

Rearranges the messages in the bundle so that the first message is an OpenChain message. Returns whether the OpenChain message was found at all.

Trait Implementations

impl Clone for IncomingBundle

fn clone(&self) -> IncomingBundle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ContainerType for IncomingBundle

async fn resolve_field(&self, ctx: &Context<'_>) -> ServerResult<Option<Value>>

Resolves a field value and outputs it as a json value async_graphql::Value.

fn collect_all_fields<'a>( &'a self, ctx: &ContextBase<'a, &'a Positioned<SelectionSet>>, fields: &mut Fields<'a>, ) -> Result<(), ServerError>

where Self: Send + Sync,

Collect all the fields of the container that are queried in the selection set.

fn find_entity( &self, _: &ContextBase<'_, &Positioned<Field>>, _params: &ConstValue, ) -> impl Future<Output = Result<Option<ConstValue>, ServerError>> + Send

Find the GraphQL entity with the given name from the parameter.

impl Debug for IncomingBundle

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IncomingBundle

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Hash for IncomingBundle

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl OutputType for IncomingBundle

fn type_name() -> Cow<'static, str>

Type the name.

fn create_type_info(registry: &mut Registry) -> String

Create type information in the registry and return qualified typename.

async fn resolve( &self, ctx: &ContextSelectionSet<'_>, _field: &Positioned<Field>, ) -> ServerResult<Value>

Resolve an output value to async_graphql::Value.

fn qualified_type_name() -> String

Qualified typename.

fn introspection_type_name(&self) -> Cow<'static, str>

Introspection type name

impl PartialEq for IncomingBundle

fn eq(&self, other: &IncomingBundle) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for IncomingBundle

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for IncomingBundle

impl ObjectType for IncomingBundle

impl StructuralPartialEq for IncomingBundle