systemprompt-agent 0.12.0

Agent-to-Agent (A2A) protocol for systemprompt.io AI governance: streaming, JSON-RPC models, task lifecycle, .well-known discovery, and governed agent orchestration.
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

//! Row -> [`ExecutionStep`] parsing helper for the execution-step repository.

use chrono::{DateTime, Utc};
use systemprompt_identifiers::TaskId;
use systemprompt_models::{ExecutionStep, StepContent, StepStatus};
use systemprompt_traits::RepositoryError;

pub(super) struct ParseStepParams {
    pub step_id: String,
    pub task_id: TaskId,
    pub status: String,
    pub content: serde_json::Value,
    pub started_at: DateTime<Utc>,
    pub completed_at: Option<DateTime<Utc>>,
    pub duration_ms: Option<i32>,
    pub error_message: Option<String>,
}

pub(super) fn parse_step(params: ParseStepParams) -> Result<ExecutionStep, RepositoryError> {
    let ParseStepParams {
        step_id,
        task_id,
        status,
        content,
        started_at,
        completed_at,
        duration_ms,
        error_message,
    } = params;
    let status = status
        .parse::<StepStatus>()
        .map_err(|e| RepositoryError::Internal(format!("Invalid status: {}", e)))?;
    let content: StepContent = serde_json::from_value(content)
        .map_err(|e| RepositoryError::Internal(format!("Invalid content: {}", e)))?;
    Ok(ExecutionStep {
        step_id: step_id.into(),
        task_id,
        status,
        started_at,
        completed_at,
        duration_ms,
        error_message,
        content,
    })
}