Struct TestMutationContext 

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

Test context for mutation functions.

Provides an isolated testing environment for mutations with configurable authentication, optional database access, and mock job/workflow dispatch.

Example

let ctx = TestMutationContext::builder()
    .as_user(Uuid::new_v4())
    .build();

// Dispatch a job
ctx.dispatch_job("send_email", json!({"to": "test@example.com"})).await?;

// Verify job was dispatched
ctx.job_dispatch().assert_dispatched("send_email");

Fields

auth: AuthContext

Authentication context.

request: RequestMetadata

Request metadata.

Implementations

impl TestMutationContext

pub fn builder() -> TestMutationContextBuilder

Create a new builder.

pub fn minimal() -> Self

Create a minimal unauthenticated context.

pub fn authenticated(user_id: Uuid) -> Self

Create an authenticated context.

pub fn db(&self) -> Option<&PgPool>

Get the database pool (if available).

pub fn http(&self) -> &MockHttp

Get the mock HTTP client.

pub fn job_dispatch(&self) -> &MockJobDispatch

Get the mock job dispatch for verification.

pub fn workflow_dispatch(&self) -> &MockWorkflowDispatch

Get the mock workflow dispatch for verification.

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

Get the authenticated user ID or return an error.

pub fn require_subject(&self) -> Result<&str>

Like require_user_id() but for non-UUID auth providers.

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

Dispatch a job (records for later verification).

pub async fn cancel_job( &self, job_id: Uuid, reason: Option<String>, ) -> Result<bool>

Cancel a job (records for later verification).

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

Start a workflow (records for later verification).

pub fn env_mock(&self) -> &MockEnvProvider

Get the mock env provider for verification.

pub fn pending_jobs(&self) -> Vec<PendingJob>

Get pending jobs from the outbox buffer.

pub fn pending_workflows(&self) -> Vec<PendingWorkflow>

Get pending workflows from the outbox buffer.

pub fn assert_job_buffered(&self, job_type: &str)

Assert that a job was buffered in the outbox.

pub fn assert_workflow_buffered(&self, workflow_name: &str)

Assert that a workflow was buffered in the outbox.

Trait Implementations

impl EnvAccess for TestMutationContext

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.