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: PgPool, auth: AuthContext, request: RequestMetadata) -> Self

Create a new mutation context.

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

Create a mutation context with dispatch capabilities.

pub fn db(&self) -> &PgPool

Get a reference to the database pool.

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.