dx-driven 0.1.0

Professional AI-assisted development orchestrator with binary-first architecture
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

use crate::{DrivenError, Result};
use serde::{Deserialize, Serialize};
use std::path::Path;

pub const COMMAND_EVIDENCE_CAPTURED_BY: &str = "driven.strategy.command_evidence.v1";

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct CommandEvidence {
    pub cwd: String,
    pub stdout_digest: String,
    pub stderr_digest: String,
    pub stdout_bytes: u64,
    pub stderr_bytes: u64,
    #[serde(default)]
    pub stdout_truncated: bool,
    #[serde(default)]
    pub stderr_truncated: bool,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub output_limit_bytes: Option<u64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub duration_ms: Option<u64>,
    pub started_unix_seconds: u64,
    pub finished_unix_seconds: u64,
    pub captured_by: String,
}

impl CommandEvidence {
    pub fn from_streams(
        cwd: &Path,
        stdout: &[u8],
        stderr: &[u8],
        started_unix_seconds: u64,
        finished_unix_seconds: u64,
    ) -> Result<Self> {
        let evidence = Self {
            cwd: normalize_path(cwd.display().to_string()),
            stdout_digest: digest_bytes(stdout),
            stderr_digest: digest_bytes(stderr),
            stdout_bytes: stdout.len() as u64,
            stderr_bytes: stderr.len() as u64,
            stdout_truncated: false,
            stderr_truncated: false,
            output_limit_bytes: None,
            duration_ms: None,
            started_unix_seconds,
            finished_unix_seconds,
            captured_by: COMMAND_EVIDENCE_CAPTURED_BY.to_string(),
        };
        evidence.validate()?;
        Ok(evidence)
    }

    #[allow(clippy::too_many_arguments)]
    pub fn from_captured_streams(
        cwd: &Path,
        stdout_digest: impl Into<String>,
        stderr_digest: impl Into<String>,
        stdout_bytes: u64,
        stderr_bytes: u64,
        stdout_truncated: bool,
        stderr_truncated: bool,
        output_limit_bytes: u64,
        duration_ms: u64,
        started_unix_seconds: u64,
        finished_unix_seconds: u64,
    ) -> Result<Self> {
        let evidence = Self {
            cwd: normalize_path(cwd.display().to_string()),
            stdout_digest: stdout_digest.into(),
            stderr_digest: stderr_digest.into(),
            stdout_bytes,
            stderr_bytes,
            stdout_truncated,
            stderr_truncated,
            output_limit_bytes: Some(output_limit_bytes),
            duration_ms: Some(duration_ms),
            started_unix_seconds,
            finished_unix_seconds,
            captured_by: COMMAND_EVIDENCE_CAPTURED_BY.to_string(),
        };
        evidence.validate()?;
        Ok(evidence)
    }

    pub fn validate(&self) -> Result<()> {
        if self.cwd.trim().is_empty() {
            return Err(DrivenError::Validation(
                "command evidence cwd cannot be empty".to_string(),
            ));
        }
        if self.finished_unix_seconds < self.started_unix_seconds {
            return Err(DrivenError::Validation(
                "command evidence finish time cannot precede start time".to_string(),
            ));
        }
        if self.captured_by != COMMAND_EVIDENCE_CAPTURED_BY {
            return Err(DrivenError::Validation(format!(
                "command evidence captured_by must be {}",
                COMMAND_EVIDENCE_CAPTURED_BY
            )));
        }
        if (self.stdout_truncated || self.stderr_truncated) && self.output_limit_bytes.is_none() {
            return Err(DrivenError::Validation(
                "truncated command evidence requires an output limit".to_string(),
            ));
        }
        Ok(())
    }
}

fn digest_bytes(bytes: &[u8]) -> String {
    blake3::hash(bytes).to_hex().to_string()
}

fn normalize_path(path: String) -> String {
    path.replace('\\', "/")
}