keel-events 0.1.0

Core event system for AI agent desktop apps — unified input queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

use crate::types::{InputType, KeelInput};

/// Result of handling an input.
#[derive(Debug)]
pub enum HandlerResponse {
    /// Input was processed successfully.
    Processed,
    /// Input was suppressed (e.g., heartbeat "all clear" response).
    Suppressed,
    /// Input should be forwarded to another handler or agent.
    Forward {
        to: String,
        payload: serde_json::Value,
    },
    /// Handler encountered an error.
    Error(String),
}

/// Trait for handling inputs from the event queue.
///
/// Implement this for each kind of processor (message handler, heartbeat
/// handler, webhook handler, etc.).
#[async_trait::async_trait]
pub trait InputHandler: Send + Sync {
    /// Process a single input, returning the outcome.
    async fn handle(&self, input: &KeelInput) -> anyhow::Result<HandlerResponse>;

    /// Return true if this handler should receive the given input type.
    fn handles(&self, input_type: &InputType) -> bool;
}