Struct WebhookContext 

pub struct WebhookContext {
    pub webhook_name: String,
    pub request_id: String,
    pub idempotency_key: Option<String>,
    /* private fields */
}

Context available to webhook handlers.

Fields

webhook_name: String

Webhook name.

request_id: String

Unique request ID for this webhook invocation.

idempotency_key: Option<String>

Idempotency key if extracted from request.

Implementations

impl WebhookContext

pub fn new( webhook_name: String, request_id: String, headers: HashMap<String, String>, db_pool: PgPool, http_client: Client, ) -> Self

Create a new webhook context.

pub fn with_idempotency_key(self, key: Option<String>) -> Self

Set idempotency key.

pub fn with_job_dispatch(self, dispatcher: Arc<dyn JobDispatch>) -> Self

Set job dispatcher.

pub fn with_env_provider(self, provider: Arc<dyn EnvProvider>) -> Self

Set environment provider.

pub fn db(&self) -> &PgPool

Get database pool.

pub fn http(&self) -> &Client

Get HTTP client.

pub fn header(&self, name: &str) -> Option<&str>

Get a request header value.

Header names are case-insensitive.

pub fn headers(&self) -> &HashMap<String, String>

Get all headers.

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

Dispatch a background job for async processing.

This is the recommended way to handle webhook events:

1. Validate the webhook signature
2. Dispatch a job to process the event
3. Return 202 Accepted immediately

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 cancel_job( &self, job_id: Uuid, reason: Option<String>, ) -> Result<bool>

Request cancellation for a job.

Trait Implementations

impl EnvAccess for WebhookContext

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.