elisym-client 0.4.8

CLI agent runner for the elisym protocol
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

use serde::{Deserialize, Serialize};

/// Heartbeat message for ping/pong liveness checks over NIP-17 encrypted DMs.
///
/// Before submitting a job, the customer pings candidate providers to verify
/// they are online. A provider that responds with a matching pong (same nonce)
/// is considered live and eligible for job selection.
///
/// Wire format (JSON inside NIP-17 envelope):
/// ```json
/// { "type": "elisym_ping", "nonce": "<random_bs58>" }
/// { "type": "elisym_pong", "nonce": "<echo_back_same_nonce>" }
/// ```
#[allow(dead_code)]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct HeartbeatMessage {
    #[serde(rename = "type")]
    pub msg_type: String,
    pub nonce: String,
}

#[allow(dead_code)]
impl HeartbeatMessage {
    pub fn ping(nonce: String) -> Self {
        Self {
            msg_type: "elisym_ping".into(),
            nonce,
        }
    }

    pub fn pong(nonce: String) -> Self {
        Self {
            msg_type: "elisym_pong".into(),
            nonce,
        }
    }

    pub fn is_ping(&self) -> bool {
        self.msg_type == "elisym_ping"
    }

    pub fn is_pong(&self) -> bool {
        self.msg_type == "elisym_pong"
    }
}

/// Generate a cryptographically random nonce using OS entropy.
#[allow(dead_code)]
pub fn random_nonce() -> String {
    let mut buf = [0u8; 16];
    getrandom::getrandom(&mut buf).expect("failed to generate random bytes");
    bs58::encode(&buf).into_string()
}