ironclad-api 0.9.8

HTTP routes, WebSocket, auth, rate limiting, and dashboard for the Ironclad agent runtime
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
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

//! Agent message, channel processing, and Telegram poll.

mod bot_commands;
mod channel_helpers;
mod channel_message;
mod core;
mod decomposition;
mod delegation;
mod diagnostics;
mod guard_registry;
mod guards;
mod handlers;
mod intent_registry;
mod intents;
mod orchestration;
mod pipeline;
mod poll_loops;
mod routing;
mod scheduled_tasks;
mod shortcuts;
mod streaming;
#[cfg(test)]
mod tests;
mod tools;

use serde::Deserialize;

pub(crate) use self::bot_commands::handle_bot_command;
pub(crate) use self::channel_helpers::channel_chat_id_for_inbound;
#[cfg(test)]
use self::channel_helpers::{metadata_str, resolve_channel_is_group};
use self::channel_helpers::{parse_skills_json, resolve_channel_chat_id, resolve_channel_scope};
pub use self::channel_message::process_channel_message;
use self::decomposition::capability_tokens;
#[cfg(test)]
use self::decomposition::{
    SpecialistProposal, proposal_to_json, split_subtasks, utility_margin_for_delegation,
};
use self::delegation::{execute_virtual_subagent_tool_call, is_virtual_delegation_tool};
pub use self::diagnostics::agent_status;
use self::diagnostics::is_model_proxy_role;
#[cfg(test)]
use self::diagnostics::{RuntimeDiagnostics, diagnostics_system_note, sanitize_diag_token};
#[cfg(test)]
use self::guards::{
    MAX_SCOPE_ID, common_prefix_ratio, enforce_current_events_truth_guard, repeat_tokens,
};
use self::guards::{resolve_web_scope, strip_internal_delegation_metadata};
pub use self::handlers::agent_message;
use self::orchestration::{execute_virtual_orchestration_tool, is_virtual_orchestration_tool};
pub(crate) use self::poll_loops::CHANNEL_PROCESSING_ERROR_REPLY;
pub use self::poll_loops::{
    discord_poll_loop, email_poll_loop, signal_poll_loop, telegram_poll_loop,
};
use self::routing::{delegated_inference_budget, infer_with_fallback_with_budget_and_preferred};
#[cfg(test)]
use self::routing::{estimate_cost_from_provider, fallback_candidates, summarize_user_excerpt};
pub(crate) use self::routing::{infer_content_with_fallback, select_routed_model};
pub(crate) use self::scheduled_tasks::execute_scheduled_agent_task;
pub use self::streaming::agent_message_stream;
pub(crate) use self::tools::{
    check_tool_policy, classify_provider_error, execute_tool_call, execute_tool_call_after_approval,
};
#[cfg(test)]
use self::tools::{parse_tool_call, provider_failure_user_message};
use super::AppState;
#[cfg(test)]
use super::JsonError;
#[cfg(test)]
use axum::http::StatusCode;

#[derive(Deserialize)]
pub struct AgentMessageRequest {
    content: String,
    #[serde(default)]
    session_id: Option<String>,
    #[serde(default)]
    channel: Option<String>,
    #[serde(default)]
    sender_id: Option<String>,
    #[serde(default)]
    peer_id: Option<String>,
    #[serde(default)]
    group_id: Option<String>,
    #[serde(default)]
    is_group: Option<bool>,
}