feat: Instrument API for observability (#45)

boltapi/src/instrument.rs

@@ -0,0 +1,34 @@
+/// Wire format for instrumentation data.
+#[derive(Debug, Clone)]
+pub struct InstrumentData {
+    /// Unique identifier for the instrument.
+    pub id: u64,
+    /// Message to be sent.
+    pub message: String,
+}
+
+impl InstrumentData {
+    pub fn encode_string(&self) -> String {
+        format!("{}:{}", self.id, self.message)
+    }
+
+    pub fn decode_string(encoded: &str) -> Option<Self> {
+        let mut parts = encoded.splitn(2, ':');
+        let id = parts.next()?.parse::<u64>().ok()?;
+        let message = parts.next()?.to_string();
+        Some(Self { id, message })
+    }
+}
+
+#[test]
+fn test_instrument_data() {
+    let data = InstrumentData {
+        id: 1234,
+        message: "hello".to_string(),
+    };
+    let encoded = data.encode_string();
+    assert_eq!(encoded, "1234:hello");
+    let decoded = InstrumentData::decode_string(&encoded).unwrap();
+    assert_eq!(decoded.id, data.id);
+    assert_eq!(decoded.message, data.message);
+}

boltapi/src/lib.rs

@@ -1,3 +1,4 @@
+pub mod instrument;
 pub mod multiplex;
 pub mod rpc;
 mod schema;

boltconn/Cargo.toml

@@ -73,6 +73,7 @@ rusqlite = { version = "0.29.0", features = ["bundled"] }
 rustls-pemfile = "2.1.1"
 webpki-roots = "0.26.1"
 x25519-dalek = "2.0.0-pre.1"
+interpolator = "0.5.0"
 # Proxies
 fast-socks5 = "0.9.1"
 boringtun = "0.6.0"