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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

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

use crate::domain::documents::{Document, DocumentSummary};
use crate::error::AppResult;
use crate::services::documents as svc;
use crate::state::AppState;

#[derive(Debug, Deserialize)]
pub struct CreateDocumentBody {
    pub title: String,
    pub source_type: String,
    pub raw_text: String,
}

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

#[derive(Debug, Deserialize)]
pub struct SetStatusBody {
    pub status: String,
}

pub async fn create(
    State(state): State<AppState>,
    Json(body): Json<CreateDocumentBody>,
) -> AppResult<Json<Document>> {
    let doc =
        svc::create_document(&state.pool, &body.title, &body.source_type, &body.raw_text).await?;
    Ok(Json(doc))
}

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

pub async fn get_one(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
) -> AppResult<Json<Document>> {
    let doc = svc::get_document(&state.pool, id).await?;
    Ok(Json(doc))
}

pub async fn set_status(
    State(state): State<AppState>,
    Path(id): Path<Uuid>,
    Json(body): Json<SetStatusBody>,
) -> AppResult<Json<Document>> {
    let doc = svc::set_document_status(&state.pool, id, &body.status).await?;
    Ok(Json(doc))
}