use std::collections::HashMap;
use std::time::Instant;
use a2a_protocol_types::params::ListTasksParams;
use a2a_protocol_types::responses::TaskListResponse;
use crate::error::ServerResult;
use super::super::helpers::build_call_context;
use super::super::RequestHandler;
impl RequestHandler {
pub async fn on_list_tasks(
&self,
params: ListTasksParams,
headers: Option<&HashMap<String, String>>,
) -> ServerResult<TaskListResponse> {
let start = Instant::now();
trace_info!(method = "ListTasks", "handling list tasks");
self.metrics.on_request("ListTasks");
let tenant = params.tenant.clone().unwrap_or_default();
let mut params = params;
if let Some(ps) = params.page_size {
params.page_size = Some(ps.min(1000));
}
let history_length = params.history_length;
let include_artifacts = params.include_artifacts;
let result: ServerResult<_> = crate::store::tenant::TenantContext::scope(tenant, async {
let call_ctx = build_call_context("ListTasks", headers);
self.interceptors.run_before(&call_ctx).await?;
let mut result = self.task_store.list(¶ms).await?;
if let Some(hl) = history_length {
for task in &mut result.tasks {
task.history = match (task.history.take(), hl) {
(Some(msgs), n) if n > 0 => {
let n = n as usize;
if msgs.len() > n {
Some(msgs[msgs.len() - n..].to_vec())
} else {
Some(msgs)
}
}
_ => None,
};
}
}
if !include_artifacts.unwrap_or(false) {
for task in &mut result.tasks {
task.artifacts = None;
}
}
self.interceptors.run_after(&call_ctx).await?;
Ok(result)
})
.await;
let elapsed = start.elapsed();
match &result {
Ok(_) => {
self.metrics.on_response("ListTasks");
self.metrics.on_latency("ListTasks", elapsed);
}
Err(e) => {
self.metrics.on_error("ListTasks", &e.to_string());
self.metrics.on_latency("ListTasks", elapsed);
}
}
result
}
}
#[cfg(test)]
mod tests {
use a2a_protocol_types::params::ListTasksParams;
use a2a_protocol_types::task::{ContextId, Task, TaskId, TaskState, TaskStatus};
use crate::agent_executor;
use crate::builder::RequestHandlerBuilder;
struct DummyExecutor;
agent_executor!(DummyExecutor, |_ctx, _queue| async { Ok(()) });
fn make_completed_task(id: &str) -> Task {
Task {
id: TaskId::new(id),
context_id: ContextId::new("ctx-1"),
status: TaskStatus::new(TaskState::Completed),
history: None,
artifacts: None,
metadata: None,
}
}
#[tokio::test]
async fn list_tasks_empty_store_returns_empty() {
let handler = RequestHandlerBuilder::new(DummyExecutor).build().unwrap();
let params = ListTasksParams::default();
let result = handler
.on_list_tasks(params, None)
.await
.expect("list_tasks should succeed on empty store");
assert!(
result.tasks.is_empty(),
"listing tasks on an empty store should return an empty list"
);
}
#[tokio::test]
async fn list_tasks_returns_saved_task() {
let handler = RequestHandlerBuilder::new(DummyExecutor).build().unwrap();
let task = make_completed_task("t-list-1");
handler.task_store.save(task).await.unwrap();
let params = ListTasksParams::default();
let result = handler
.on_list_tasks(params, None)
.await
.expect("list_tasks should succeed");
assert_eq!(result.tasks.len(), 1, "should return the one saved task");
}
#[tokio::test]
async fn list_tasks_with_tenant() {
let handler = RequestHandlerBuilder::new(DummyExecutor).build().unwrap();
let params = ListTasksParams {
tenant: Some("test-tenant".to_string()),
..Default::default()
};
let result = handler
.on_list_tasks(params, None)
.await
.expect("list_tasks with tenant should succeed");
assert!(result.tasks.is_empty());
}
#[tokio::test]
async fn list_tasks_with_headers() {
let handler = RequestHandlerBuilder::new(DummyExecutor).build().unwrap();
let params = ListTasksParams::default();
let mut headers = std::collections::HashMap::new();
headers.insert("authorization".to_string(), "Bearer tok".to_string());
let result = handler
.on_list_tasks(params, Some(&headers))
.await
.expect("list_tasks with headers should succeed");
assert!(result.tasks.is_empty());
}
#[tokio::test]
async fn list_tasks_error_path_records_metrics() {
use crate::call_context::CallContext;
use crate::interceptor::ServerInterceptor;
use std::future::Future;
use std::pin::Pin;
struct FailInterceptor;
impl ServerInterceptor for FailInterceptor {
fn before<'a>(
&'a self,
_ctx: &'a CallContext,
) -> Pin<Box<dyn Future<Output = a2a_protocol_types::error::A2aResult<()>> + Send + 'a>>
{
Box::pin(async {
Err(a2a_protocol_types::error::A2aError::internal(
"forced failure",
))
})
}
fn after<'a>(
&'a self,
_ctx: &'a CallContext,
) -> Pin<Box<dyn Future<Output = a2a_protocol_types::error::A2aResult<()>> + Send + 'a>>
{
Box::pin(async { Ok(()) })
}
}
let handler = RequestHandlerBuilder::new(DummyExecutor)
.with_interceptor(FailInterceptor)
.build()
.unwrap();
let params = ListTasksParams::default();
let result = handler.on_list_tasks(params, None).await;
assert!(
result.is_err(),
"list_tasks should fail when interceptor rejects, got: {result:?}"
);
}
}