open-pincery 1.0.1

Multi-agent platform for durable, event-driven AI agents
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

use axum::{
    extract::{Extension, Path, Query, State},
    routing::get,
    Json, Router,
};
use serde::{Deserialize, Serialize};
use uuid::Uuid;

use super::{scoped_agent, AppState, AuthUser};
use crate::error::AppError;
use crate::models::event::{self, Event};

#[derive(Deserialize)]
struct EventQuery {
    limit: Option<i64>,
    since: Option<Uuid>,
}

#[derive(Serialize)]
struct EventsResponse {
    events: Vec<Event>,
    total: i64,
}

pub fn router() -> Router<AppState> {
    Router::new().route("/agents/{id}/events", get(get_events))
}

async fn get_events(
    State(state): State<AppState>,
    Path(agent_id): Path<Uuid>,
    Extension(auth): Extension<AuthUser>,
    Query(params): Query<EventQuery>,
) -> Result<Json<EventsResponse>, AppError> {
    scoped_agent(&state, &auth, agent_id).await?;

    let limit = params.limit.unwrap_or(100).min(1000);
    let events = if let Some(since_id) = params.since {
        event::events_since_id(&state.pool, agent_id, since_id, limit).await?
    } else {
        event::recent_events(&state.pool, agent_id, limit).await?
    };
    let total = events.len() as i64;
    Ok(Json(EventsResponse { events, total }))
}