Trait IntegrationEventHandler

Source

pub trait IntegrationEventHandler: Send + Sync {
    // Required methods
    fn handle<'life0, 'async_trait>(
        &'life0 self,
        envelope: IntegrationEventEnvelope,
    ) -> Pin<Box<dyn Future<Output = Result<(), EventError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn event_patterns(&self) -> Vec<&'static str>;
    fn name(&self) -> &'static str;

    // Provided methods
    fn should_retry(&self) -> bool { ... }
    fn max_retries(&self) -> u32 { ... }
}

Expand description

§Pattern Matching

Handlers specify which events they’re interested in via event_patterns(). Patterns support:

Exact match: "sapiens.user.created"
Wildcard suffix: "sapiens.user.*" matches all user events
Global wildcard: "*" matches all events

§Example

struct EmailNotificationHandler {
    email_service: Arc<EmailService>,
}

#[async_trait]
impl IntegrationEventHandler for EmailNotificationHandler {
    async fn handle(&self, envelope: IntegrationEventEnvelope) -> Result<(), EventError> {
        match envelope.event_type.as_str() {
            "sapiens.user.created" => {
                // Deserialize and send welcome email
                let event: UserCreatedEvent = envelope.deserialize()?;
                self.email_service.send_welcome(&event.email).await?;
            }
            _ => {}
        }
        Ok(())
    }

    fn event_patterns(&self) -> Vec<&'static str> {
        vec!["sapiens.user.*"]
    }

    fn name(&self) -> &'static str {
        "EmailNotificationHandler"
    }
}