ai-dispatch 10.40.0

Multi-AI CLI team orchestrator
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

// Typed action failures and shared response mapping for web mutations.
// Exports: ActionError, action_result, and action guard helpers.
// Deps: axum JSON responses, Store task state, and command validation.

use axum::Json;
use axum::http::StatusCode;

use crate::store::Store;
use crate::types::TaskStatus;

use super::api_types::ActionResponse;

pub(crate) enum ActionError {
    NotFound(String),
    Conflict(String),
    Internal(anyhow::Error),
}

pub(crate) type ActionResponseResult = (StatusCode, Json<ActionResponse>);

pub(crate) fn internal(error: anyhow::Error) -> ActionError {
    ActionError::Internal(error)
}

pub(crate) fn not_found(message: impl Into<String>) -> ActionError {
    ActionError::NotFound(message.into())
}

pub(crate) fn action_result(result: Result<(), ActionError>) -> ActionResponseResult {
    match result {
        Ok(()) => action_ok(None),
        Err(error) => action_error(error),
    }
}

pub(crate) fn action_ok(new_task_id: Option<String>) -> ActionResponseResult {
    (
        StatusCode::OK,
        Json(ActionResponse { ok: true, new_task_id, error: None }),
    )
}

pub(crate) fn action_error(error: ActionError) -> ActionResponseResult {
    let (status, message) = match error {
        ActionError::NotFound(message) => (StatusCode::NOT_FOUND, message),
        ActionError::Conflict(message) => (StatusCode::CONFLICT, message),
        ActionError::Internal(error) => (StatusCode::INTERNAL_SERVER_ERROR, error.to_string()),
    };
    (
        status,
        Json(ActionResponse { ok: false, new_task_id: None, error: Some(message) }),
    )
}

pub(crate) fn ensure_merge_allowed(store: &Store, task_id: &str) -> Result<(), ActionError> {
    let task = store
        .get_task(task_id)
        .map_err(internal)?
        .ok_or_else(|| not_found(format!("Task {task_id} not found")))?;
    crate::cmd::merge::validate_merge_outcome(&task, task.outcome(), false)
        .map_err(|error| ActionError::Conflict(error.to_string()))
}

pub(crate) fn ensure_exists(store: &Store, task_id: &str) -> Result<(), ActionError> {
    store
        .get_task(task_id)
        .map_err(internal)?
        .ok_or_else(|| not_found(format!("Task {task_id} not found")))
        .map(|_| ())
}

pub(crate) fn ensure_terminal(store: &Store, task_id: &str) -> Result<(), ActionError> {
    let task = store
        .get_task(task_id)
        .map_err(internal)?
        .ok_or_else(|| not_found(format!("Task {task_id} not found")))?;
    if task.status.is_terminal() {
        return Ok(());
    }
    Err(ActionError::Conflict(format!(
        "Task {task_id} is not complete; principal acceptance is not allowed"
    )))
}

pub(crate) fn ensure_replyable(store: &Store, task_id: &str) -> Result<(), ActionError> {
    let task = store
        .get_task(task_id)
        .map_err(internal)?
        .ok_or_else(|| not_found(format!("Task {task_id} not found")))?;
    if matches!(task.status, TaskStatus::Running | TaskStatus::AwaitingInput | TaskStatus::Stalled) {
        return Ok(());
    }
    Err(ActionError::Conflict(format!(
        "Task {task_id} is {} — can only reply to running tasks",
        task.status.label()
    )))
}