Skip to main content

systemprompt_agent/services/a2a_server/processing/
mod.rs

1//! Request-processing pipeline for the A2A server.
2//!
3//! Turns an inbound A2A [`Message`](crate::models::a2a::Message) into a
4//! persisted [`Task`](crate::models::a2a::Task): validation,
5//! conversation-history assembly, LLM execution (via [`ExecutionStrategy`]),
6//! artifact construction, response synthesis, and persistence. The entry point
7//! is [`MessageProcessor`]; [`StreamProcessor`] drives the streaming variant
8//! and emits [`StreamEvent`]s.
9//!
10//! Copyright (c) systemprompt.io — Business Source License 1.1.
11//! See <https://systemprompt.io> for licensing details.
12
13pub mod ai_executor;
14pub mod artifact;
15pub mod conversation_service;
16pub mod message;
17pub mod persistence_service;
18pub mod strategies;
19pub mod task_builder;
20
21pub use artifact::ArtifactBuilder;
22pub use conversation_service::ConversationService;
23pub use message::{MessageProcessor, StreamEvent, StreamProcessor};
24pub use persistence_service::PersistenceService;
25pub use strategies::{
26    ExecutionContext, ExecutionResult, ExecutionStrategy, ExecutionStrategySelector,
27};
28pub use task_builder::{
29    TaskBuilder, build_canceled_task, build_completed_task, build_mock_task, build_multiturn_task,
30};