crabmate 0.4.0

Rust AI agent: OpenAI-compatible chat/completions, function calling, HTTP serve, ops CLI
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

//! 宿主侧 [`crate::cm_llm::LlmRetryHooks`] 实现。

use crate::cm_llm::{LlmRetryDecisionPoint, LlmRetryHooks};
use crate::cm_types::{Message, message_content_as_str};

pub struct CrabmateLlmRetryHooks;

impl LlmRetryHooks for CrabmateLlmRetryHooks {
    fn append_turn_replay_json(
        &self,
        event: &str,
        model: &str,
        payload: Option<serde_json::Value>,
    ) {
        let detail = payload.as_ref();
        crate::turn_replay_dump::append_turn_replay_event_json_if_configured(event, model, detail);
    }

    fn append_decision_point(&self, decision: &LlmRetryDecisionPoint) {
        crate::turn_replay_dump::append_decision_point_event_if_configured(
            &decision.phase,
            &decision.decision_id,
            &decision.outcome,
            &decision.rationale,
            decision.detail.clone(),
            &decision.anchor_kind,
            decision.anchor.clone(),
        );
    }

    fn assistant_preview_for_log(&self, msg: &Message) -> String {
        crate::redact::assistant_message_preview_for_log(msg)
    }

    fn tool_arguments_preview_for_sse(&self, args: &str) -> String {
        crate::redact::tool_arguments_preview_for_sse(args)
    }

    fn assistant_content_for_log(&self, msg: &Message) -> String {
        message_content_as_str(&msg.content)
            .unwrap_or("")
            .to_string()
    }

    fn reasoning_content_for_log(&self, msg: &Message) -> String {
        msg.reasoning_content.clone().unwrap_or_default()
    }
}