orion-server 1.0.0

Turn business logic into live REST/Kafka services. Declare workflows as JSON and Orion runs them, with rate limiting, circuit breakers, versioning, and observability built in
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

use axum::Json;
use axum::extract::State;
use serde_json::Value;

use crate::errors::OrionError;
use crate::server::extract::OrionQuery;
use crate::server::routes::openapi::PaginatedEnvelope;
use crate::server::routes::response_helpers::paginated_response;
use crate::server::state::AppState;
use crate::storage::models::AuditLogEntryResponse;
use crate::storage::repositories::audit_logs::AuditLogFilter;

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

#[utoipa::path(
    get,
    path = "/api/v1/admin/audit-logs",
    tag = "Audit",
    params(AuditLogFilter),
    responses(
        (status = 200, description = "Paginated audit log entries", body = PaginatedEnvelope<AuditLogEntryResponse>),
        (status = 400, description = "Unknown query parameter or malformed timestamp"),
    )
)]
#[tracing::instrument(skip(state))]
pub(crate) async fn list_audit_logs(
    State(state): State<AppState>,
    OrionQuery(filter): OrionQuery<AuditLogFilter>,
) -> Result<Json<Value>, OrionError> {
    let page = state.repos.audit_logs.list_paginated(&filter).await?;
    let rows: Vec<AuditLogEntryResponse> =
        page.data.iter().map(AuditLogEntryResponse::from).collect();

    Ok(paginated_response(
        rows,
        page.total,
        page.limit,
        page.offset,
    ))
}