a3s-ahp 2.4.0

Agent Harness Protocol v2.4 — Universal, transport-agnostic protocol for supervising autonomous AI agents
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

//! Transport layer abstractions

use crate::{AhpNotification, AhpRequest, AhpResponse, Result};
use async_trait::async_trait;
use serde::{Deserialize, Serialize};

#[cfg(any(feature = "http", feature = "websocket", feature = "grpc"))]
use crate::AuthConfig;

/// Transport configuration
#[derive(Debug, Clone)]
pub enum Transport {
    /// stdio transport (local child process)
    Stdio { program: String, args: Vec<String> },

    /// HTTP transport (remote harness server)
    #[cfg(feature = "http")]
    Http {
        url: String,
        auth: Option<AuthConfig>,
    },

    /// WebSocket transport (bidirectional streaming)
    #[cfg(feature = "websocket")]
    WebSocket {
        url: String,
        auth: Option<AuthConfig>,
    },

    /// gRPC transport (high-performance RPC)
    #[cfg(feature = "grpc")]
    Grpc {
        endpoint: String,
        auth: Option<AuthConfig>,
    },

    /// Unix socket transport (local IPC)
    #[cfg(feature = "unix-socket")]
    UnixSocket { path: String },
}

/// Transport configuration
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct TransportConfig {
    pub timeout_ms: u64,
    pub max_retries: u32,
    pub retry_delay_ms: u64,
}

impl Default for TransportConfig {
    fn default() -> Self {
        Self {
            timeout_ms: 10_000,
            max_retries: 3,
            retry_delay_ms: 1_000,
        }
    }
}

/// Transport trait - all transports must implement this
#[async_trait]
pub trait TransportLayer: Send + Sync {
    /// Send a request and wait for response
    async fn send_request(&self, request: AhpRequest) -> Result<AhpResponse>;

    /// Send a notification (fire-and-forget, no response expected)
    async fn send_notification(&self, notification: AhpNotification) -> Result<()>;

    /// Close the transport connection
    async fn close(&self) -> Result<()>;
}

// Module declarations for different transport implementations
#[cfg(feature = "stdio")]
pub mod stdio;

#[cfg(feature = "http")]
pub mod http;

#[cfg(feature = "websocket")]
pub mod websocket;

#[cfg(feature = "grpc")]
pub mod grpc;

#[cfg(feature = "unix-socket")]
pub mod unix_socket;