decision_cockpit 0.1.0

Layer — product decision memory with MCP tools and an embedded review dashboard
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

use axum::extract::{Path, Query, State};
use axum::Json;
use serde::Deserialize;
use uuid::Uuid;

use crate::domain::drift::DriftSignal;
use crate::error::AppResult;
use crate::services::drift as svc;
use crate::state::AppState;

#[derive(Debug, Deserialize)]
pub struct ListQuery {
    pub status: Option<String>,
    pub limit: Option<i64>,
}

pub async fn list(
    State(state): State<AppState>,
    Query(q): Query<ListQuery>,
) -> AppResult<Json<Vec<DriftSignal>>> {
    let signals = svc::list_drift_signals(&state.pool, q.status.as_deref(), q.limit).await?;
    Ok(Json(signals))
}

pub async fn accept(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
) -> AppResult<Json<DriftSignal>> {
    let signal = svc::accept_drift_signal(&state.pool, id).await?;
    Ok(Json(signal))
}

pub async fn dismiss(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
) -> AppResult<Json<DriftSignal>> {
    let signal = svc::dismiss_drift_signal(&state.pool, id).await?;
    Ok(Json(signal))
}