Struct ActionContext 

pub struct ActionContext {
    pub auth: AuthContext,
    pub request: RequestMetadata,
    /* private fields */
}

Context for action functions (can call external APIs).

Fields

auth: AuthContext

Authentication context.

request: RequestMetadata

Request metadata.

Implementations

impl ActionContext

pub fn new( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, http_client: Client, ) -> Self

Create a new action context.

pub fn with_dispatch( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, http_client: Client, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, ) -> Self

Create an action context with dispatch capabilities.

pub fn with_env( db_pool: PgPool, auth: AuthContext, request: RequestMetadata, http_client: Client, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, env_provider: Arc<dyn EnvProvider>, ) -> Self

Create an action context with a custom environment provider.

pub fn db(&self) -> &PgPool

Get a reference to the database pool.

pub fn http(&self) -> &Client

Get a reference to the HTTP client.

pub fn require_user_id(&self) -> Result<Uuid>

Get the authenticated user ID or return an error.

pub async fn dispatch_job<T: Serialize>( &self, job_type: &str, args: T, ) -> Result<Uuid>

Dispatch a background job.

Arguments

• job_type - The registered name of the job type
• args - The arguments for the job (will be serialized to JSON)

Returns

The UUID of the dispatched job, or an error if dispatch is not available.

pub async fn start_workflow<T: Serialize>( &self, workflow_name: &str, input: T, ) -> Result<Uuid>

Start a workflow.

Arguments

• workflow_name - The registered name of the workflow
• input - The input for the workflow (will be serialized to JSON)

Returns

The UUID of the started workflow run, or an error if dispatch is not available.

Trait Implementations

impl EnvAccess for ActionContext

fn env_provider(&self) -> &dyn EnvProvider

Get the environment provider.

fn env(&self, key: &str) -> Option<String>

Get an environment variable.

fn env_or(&self, key: &str, default: &str) -> String

Get an environment variable with a default value.

fn env_require(&self, key: &str) -> Result<String>

Get a required environment variable.

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it to the specified type.

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it, with a default.

fn env_contains(&self, key: &str) -> bool

Check if an environment variable is set.