lha 1.0.2

Long-Horizon Agent command-line package that installs the lha binary.
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

use std::collections::HashSet;

use crate::product::protocol::models::TranscriptItem;
use lha_llm::ToolCallPayload;
use lha_llm::ToolResultPayload;

use crate::product::agent::util::error_or_panic;
use tracing::info;

pub(crate) fn ensure_call_outputs_present(items: &mut Vec<TranscriptItem>) {
    let mut missing_outputs_to_insert: Vec<(usize, TranscriptItem)> = Vec::new();

    for (idx, item) in items.iter().enumerate() {
        if let TranscriptItem::ToolCall {
            call_id,
            tool_name,
            payload,
            ..
        } = item
        {
            let has_output = items.iter().any(
                |i| matches!(i, TranscriptItem::ToolResult { call_id: existing, .. } if existing == call_id),
            );

            if !has_output {
                let result = match payload {
                    ToolCallPayload::JsonArguments { .. } => {
                        info!("Tool result is missing for call id: {call_id}");
                        TranscriptItem::ToolResult {
                            call_id: call_id.clone(),
                            tool_name: tool_name.clone(),
                            payload: ToolResultPayload::Structured {
                                content: "aborted".to_string(),
                                content_items: None,
                                success: None,
                            },
                        }
                    }
                    ToolCallPayload::TextInput { .. } => {
                        error_or_panic(format!(
                            "Custom tool call output is missing for call id: {call_id}"
                        ));
                        TranscriptItem::ToolResult {
                            call_id: call_id.clone(),
                            tool_name: tool_name.clone(),
                            payload: ToolResultPayload::Text {
                                output: "aborted".to_string(),
                            },
                        }
                    }
                };
                missing_outputs_to_insert.push((idx, result));
            }
        }
    }

    for (idx, output_item) in missing_outputs_to_insert.into_iter().rev() {
        items.insert(idx + 1, output_item);
    }
}

pub(crate) fn remove_orphan_outputs(items: &mut Vec<TranscriptItem>) {
    let tool_call_ids: HashSet<String> = items
        .iter()
        .filter_map(|i| match i {
            TranscriptItem::ToolCall { call_id, .. } => Some(call_id.clone()),
            _ => None,
        })
        .collect();

    items.retain(|item| match item {
        TranscriptItem::ToolResult { call_id, .. } => {
            if call_id.is_empty() {
                return false;
            }
            let has_match = tool_call_ids.contains(call_id);
            if !has_match {
                error_or_panic(format!("Orphan tool result for call id: {call_id}"));
            }
            has_match
        }
        _ => true,
    });
}

pub(crate) fn remove_corresponding_for(items: &mut Vec<TranscriptItem>, item: &TranscriptItem) {
    match item {
        TranscriptItem::ToolCall { call_id, .. } => {
            remove_first_matching(items, |i| {
                matches!(
                    i,
                    TranscriptItem::ToolResult {
                        call_id: existing, ..
                    } if existing == call_id
                )
            });
        }
        TranscriptItem::ToolResult { call_id, .. } => {
            remove_first_matching(items, |i| {
                matches!(
                    i,
                    TranscriptItem::ToolCall {
                        call_id: existing, ..
                    } if existing == call_id
                )
            });
        }
        _ => {}
    }
}

fn remove_first_matching<F>(items: &mut Vec<TranscriptItem>, predicate: F)
where
    F: Fn(&TranscriptItem) -> bool,
{
    if let Some(pos) = items.iter().position(predicate) {
        items.remove(pos);
    }
}