a2a-server-lf 0.5.0

A2A v1 async server framework
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

// Copyright AGNTCY Contributors (https://github.com/agntcy)
// Copyright A2A Contributors (https://github.com/a2aproject)
// SPDX-License-Identifier: Apache-2.0
mod inmemory;
mod store;

pub use inmemory::InMemoryTaskStore;
pub use store::{StoredTask, TaskStore, TaskVersion};

use a2a::Task;

/// Truncate `task.history` to the last `history_length` messages.
///
/// `None` leaves history unchanged. `Some(n)` with `n <= 0` clears it.
/// Negative values must not be cast to `usize` (that wraps and returns the
/// full history).
pub(crate) fn apply_history_length(task: &mut Task, history_length: Option<i32>) {
    let Some(requested) = history_length else {
        return;
    };
    let keep = if requested <= 0 {
        0
    } else {
        requested as usize
    };
    let Some(history) = task.history.as_mut() else {
        return;
    };
    if keep == 0 {
        history.clear();
        return;
    }
    if history.len() > keep {
        history.drain(..history.len() - keep);
    }
}