Struct Context 

pub struct Context<'a, D> { /* private fields */ }

The context passed to every handler.

Generic over D (the service dependency type) so handlers can access the repository, read-model store, or custom dependencies the service is configured with.

Example

pub async fn handle(
    ctx: &Context<'_, Repo>,
) -> Result<Value, HandlerError> {
    let user_id = ctx.user_id()?;
    let input = ctx.input::<CreateOrderInput>()?;
    let repo = ctx.repo();
    // ... commit via repo.commit(&mut agg).await? ...
}

Implementations

impl<'a, D> Context<'a, D>

pub fn input<T: DeserializeOwned>(&self) -> Result<T, HandlerError>

Deserialize the input payload into a typed struct.

pub fn raw_input(&self) -> &Value

Get the raw JSON input.

pub fn command_name(&self) -> &str

Get the command name.

pub fn message_name(&self) -> &str

Get the message name.

pub fn message(&self) -> &Message

Get the full message, including id, raw payload bytes, and metadata.

pub fn session(&self) -> &Session

Get the session.

pub fn user_id(&self) -> Result<&str, HandlerError>

Get the user ID from the session. Returns Unauthorized if not present.

pub fn role(&self) -> Option<&str>

Get the user role from the session.

pub fn dependencies(&self) -> &D

Get a reference to the service dependencies.

pub fn repo(&self) -> &D::Repo

where D: HasRepo,

Get the aggregate repository for handlers whose dependencies expose one.

pub fn read_model_store(&self) -> &D::ReadModelStore

where D: HasReadModelStore,

Get the read-model store for handlers whose dependencies expose one.

pub fn has_field(&self, field: &str) -> bool

Check if the raw input contains a field.

pub fn has_fields(&self, fields: &[&str]) -> bool

Check if the raw input contains all specified fields.