Struct WebhookRouter 

pub struct WebhookRouter { /* private fields */ }

Routes incoming HTTP POST webhooks to the matching registered workflow IDs.

This is an in-process routing layer. Callers are expected to extract the HTTP path, raw body bytes, and optional signature header, then call WebhookRouter::route to obtain the list of matching workflow IDs.

Implementations

impl WebhookRouter

pub fn new() -> Self

Create an empty router.

pub fn register( &mut self, workflow_id: impl Into<String>, trigger: WebhookTrigger, )

Register a webhook trigger for a workflow.

pub fn remove(&mut self, workflow_id: &str)

Remove all webhook triggers for a workflow.

pub fn route( &self, path: &str, body_bytes: &[u8], body_json: &Value, signature: Option<&str>, ) -> Vec<String>

Evaluate an incoming HTTP POST and return workflow IDs that should be triggered.

Parameters

• path: The URL path of the request (e.g. "/webhooks/ingest-ready").
• body_bytes: Raw request body bytes (used for HMAC verification).
• body_json: Parsed JSON body (used for field matching).
• signature: Optional value of the X-Hub-Signature-256 header.

A workflow is triggered when at least one of its webhook triggers matches the path, passes signature verification, and satisfies all required body fields.

pub fn workflow_ids(&self) -> Vec<&str>

List all registered workflow IDs.

pub fn trigger_count(&self) -> usize

Count total registered triggers across all workflows.

Trait Implementations

impl Debug for WebhookRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WebhookRouter

fn default() -> WebhookRouter

Returns the “default value” for a type.