Struct TestJobContext 

pub struct TestJobContext {
    pub job_id: Uuid,
    pub job_type: String,
    pub attempt: u32,
    pub max_attempts: u32,
    pub auth: AuthContext,
    /* private fields */
}

Test context for job functions.

Provides an isolated testing environment for jobs with progress tracking, retry simulation, and HTTP mocking.

Example

let ctx = TestJobContext::builder("export_users")
    .with_job_id(Uuid::new_v4())
    .build();

// Simulate progress
ctx.progress(50, "Halfway there")?;

// Verify progress was recorded
assert_eq!(ctx.progress_updates().len(), 1);

Fields

job_id: Uuid

Job ID.

job_type: String

Job type name.

attempt: u32

Current attempt number (1-based).

max_attempts: u32

Maximum attempts allowed.

auth: AuthContext

Authentication context.

Implementations

impl TestJobContext

pub fn builder(job_type: impl Into<String>) -> TestJobContextBuilder

Create a new builder.

pub fn db(&self) -> Option<&Pool<Postgres>>

Get the database pool (if available).

pub fn http(&self) -> &MockHttp

Get the mock HTTP client.

pub fn progress( &self, percent: u8, message: impl Into<String>, ) -> Result<(), ForgeError>

Report job progress.

pub fn progress_updates(&self) -> Vec<TestProgressUpdate>

Get all progress updates.

pub fn is_retry(&self) -> bool

Check if this is a retry attempt.

pub fn is_last_attempt(&self) -> bool

Check if this is the last attempt.

pub async fn heartbeat(&self) -> Result<(), ForgeError>

Simulate heartbeat (no-op in tests, but records the intent).

pub fn env_mock(&self) -> &MockEnvProvider

Get the mock env provider for verification.

Trait Implementations

impl EnvAccess for TestJobContext

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, ForgeError>

Get a required environment variable.

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

where T: FromStr, <T as FromStr>::Err: Display,

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

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

where T: FromStr, <T as FromStr>::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.