systemprompt-agent 0.1.22

Core Agent protocol module for systemprompt.io
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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146

use anyhow::Result;
use chrono::{DateTime, Utc};
use std::sync::Arc;
use systemprompt_identifiers::{SkillId, TaskId};
use systemprompt_models::{ExecutionStep, PlannedTool, StepContent, StepId, TrackedStep};

use crate::repository::execution::ExecutionStepRepository;

#[derive(Debug, Clone)]
pub struct ExecutionTrackingService {
    repository: Arc<ExecutionStepRepository>,
}

impl ExecutionTrackingService {
    pub const fn new(repository: Arc<ExecutionStepRepository>) -> Self {
        Self { repository }
    }

    pub async fn track(&self, task_id: TaskId, content: StepContent) -> Result<ExecutionStep> {
        let step = ExecutionStep::new(task_id, content);
        self.repository.create(&step).await?;
        Ok(step)
    }

    pub async fn track_async(
        &self,
        task_id: TaskId,
        content: StepContent,
    ) -> Result<(TrackedStep, ExecutionStep)> {
        let step = ExecutionStep::new(task_id, content);
        self.repository.create(&step).await?;

        let tracked = TrackedStep {
            step_id: step.step_id.clone(),
            started_at: step.started_at,
        };

        Ok((tracked, step))
    }

    pub async fn complete(
        &self,
        tracked: TrackedStep,
        result: Option<serde_json::Value>,
    ) -> Result<()> {
        self.repository
            .complete_step(&tracked.step_id, tracked.started_at, result)
            .await
    }

    pub async fn complete_planning(
        &self,
        tracked: TrackedStep,
        reasoning: Option<String>,
        planned_tools: Option<Vec<PlannedTool>>,
    ) -> Result<ExecutionStep> {
        self.repository
            .complete_planning_step(
                &tracked.step_id,
                tracked.started_at,
                reasoning,
                planned_tools,
            )
            .await
    }

    pub async fn fail(&self, tracked: &TrackedStep, error: String) -> Result<()> {
        self.repository
            .fail_step(&tracked.step_id, tracked.started_at, &error)
            .await
    }

    pub async fn fail_step(
        &self,
        step_id: &StepId,
        started_at: DateTime<Utc>,
        error: String,
    ) -> Result<()> {
        self.repository.fail_step(step_id, started_at, &error).await
    }

    pub async fn get_steps_by_task(&self, task_id: &TaskId) -> Result<Vec<ExecutionStep>> {
        self.repository.list_by_task(task_id).await
    }

    pub async fn get_step(&self, step_id: &StepId) -> Result<Option<ExecutionStep>> {
        self.repository.get(step_id).await
    }

    pub async fn fail_in_progress_steps(&self, task_id: &TaskId, error: &str) -> Result<u64> {
        self.repository
            .fail_in_progress_steps_for_task(task_id, error)
            .await
    }

    pub async fn track_understanding(&self, task_id: TaskId) -> Result<ExecutionStep> {
        self.track(task_id, StepContent::understanding()).await
    }

    pub async fn track_planning(
        &self,
        task_id: TaskId,
        reasoning: Option<String>,
        planned_tools: Option<Vec<PlannedTool>>,
    ) -> Result<ExecutionStep> {
        self.track(task_id, StepContent::planning(reasoning, planned_tools))
            .await
    }

    pub async fn track_planning_async(
        &self,
        task_id: TaskId,
        reasoning: Option<String>,
        planned_tools: Option<Vec<PlannedTool>>,
    ) -> Result<(TrackedStep, ExecutionStep)> {
        self.track_async(task_id, StepContent::planning(reasoning, planned_tools))
            .await
    }

    pub async fn track_skill_usage(
        &self,
        task_id: TaskId,
        skill_id: SkillId,
        skill_name: impl Into<String>,
    ) -> Result<ExecutionStep> {
        self.track(task_id, StepContent::skill_usage(skill_id, skill_name))
            .await
    }

    pub async fn track_tool_execution(
        &self,
        task_id: TaskId,
        tool_name: impl Into<String>,
        tool_arguments: serde_json::Value,
    ) -> Result<(TrackedStep, ExecutionStep)> {
        self.track_async(
            task_id,
            StepContent::tool_execution(tool_name, tool_arguments),
        )
        .await
    }

    pub async fn track_completion(&self, task_id: TaskId) -> Result<ExecutionStep> {
        self.track(task_id, StepContent::completion()).await
    }
}