orion-server 0.1.0

Declarative services runtime powered by dataflow-rs
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

use axum::Json;
use axum::extract::{Query, State};
use serde::Deserialize;
use serde_json::{Value, json};

use crate::errors::OrionError;
use crate::server::state::AppState;

// ============================================================
// Audit Logs
// ============================================================

#[derive(Debug, Deserialize)]
pub(crate) struct AuditLogQuery {
    #[serde(default)]
    offset: Option<i64>,
    #[serde(default)]
    limit: Option<i64>,
}

pub(crate) async fn list_audit_logs(
    State(state): State<AppState>,
    Query(params): Query<AuditLogQuery>,
) -> Result<Json<Value>, OrionError> {
    let offset = params.offset.unwrap_or(0).max(0);
    let limit = params.limit.unwrap_or(50).clamp(1, 1000);

    let entries = state.audit_log_repo.list_paginated(offset, limit).await?;
    let total = state.audit_log_repo.count().await?;

    Ok(Json(json!({
        "data": entries,
        "pagination": {
            "offset": offset,
            "limit": limit,
            "total": total,
        }
    })))
}