Struct IdempotencyMiddleware 

pub struct IdempotencyMiddleware<S: IdempotencyStore> { /* private fields */ }

Idempotency middleware that wraps event processing

Implementations

impl<S: IdempotencyStore> IdempotencyMiddleware<S>

pub fn new(store: Arc<S>) -> Self

Create new middleware

pub async fn should_process(&self, event_id: &str) -> StripeWebhookResult<bool>

Check if event should be processed

Returns

• Ok(true) if event should be processed (new event)
• Ok(false) if event was already processed (return 202)
• Err for already-processed events that need special handling

pub async fn complete(&self, event_id: &str) -> StripeWebhookResult<()>

Mark event processing as complete

pub async fn fail(&self, event_id: &str, error: &str) -> StripeWebhookResult<()>

Mark event processing as failed