Struct MutationContext 

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

Context for mutation functions (transactional database access).

Fields

auth: AuthContext

Authentication context.

request: RequestMetadata

Request metadata.

Implementations

impl MutationContext

pub fn new( db_pool: Pool<Postgres>, auth: AuthContext, request: RequestMetadata, ) -> MutationContext

Create a new mutation context.

pub fn with_dispatch( db_pool: Pool<Postgres>, auth: AuthContext, request: RequestMetadata, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, ) -> MutationContext

Create a mutation context with dispatch capabilities.

pub fn with_env( db_pool: Pool<Postgres>, auth: AuthContext, request: RequestMetadata, job_dispatch: Option<Arc<dyn JobDispatch>>, workflow_dispatch: Option<Arc<dyn WorkflowDispatch>>, env_provider: Arc<dyn EnvProvider>, ) -> MutationContext

Create a mutation context with a custom environment provider.

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

Get a reference to the database pool.

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

Get the authenticated user ID or return an error.

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

where T: Serialize,

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>( &self, workflow_name: &str, input: T, ) -> Result<Uuid, ForgeError>

where T: Serialize,

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 MutationContext

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.