takproto 0.4.2

Rust library for TAK (Team Awareness Kit) Protocol - send CoT messages to TAK servers with mTLS support
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

//! Simple test using XML mode instead of protobuf
//!
//! Usage:
//! ```
//! cargo run --example simple_test_xml -- \
//!     <server:port> <server_name> <ca_cert> <client_cert> <client_key>
//! ```

use takproto::helpers::{contact, precision_location, status};
use takproto::{CotEventBuilder, TakClient, TlsConfig};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = std::env::args().collect();
    if args.len() < 6 {
        eprintln!(
            "Usage: {} <server:port> <server_name> <ca_cert> <client_cert> <client_key>",
            args[0]
        );
        std::process::exit(1);
    }

    let server_addr = &args[1];
    let server_name = &args[2];
    let ca_cert = &args[3];
    let client_cert = &args[4];
    let client_key = &args[5];

    println!("Loading certificates...");
    let tls_config = TlsConfig::new_with_client_cert(ca_cert, client_cert, client_key)?;
    println!("✓ Certificates loaded\n");

    println!("Connecting to {}...", server_addr);
    let mut client = TakClient::connect_tls(server_addr, server_name, tls_config).await?;
    println!("✓ Connected\n");

    println!("⚠️  NOT negotiating protocol - staying in XML mode");
    println!("   (This tests if the issue is protobuf-specific)\n");

    // Test 1: Minimal event (no detail)
    println!("Test 1: Sending minimal event (no detail fields) [XML]...");
    let minimal = CotEventBuilder::new()
        .uid("TEST-MINIMAL-XML")
        .cot_type("a-f-G-U-C")
        .lat_lon(37.7749, -122.4194)
        .hae(10.0)
        .ce_le(9.9, 9.9)
        .how("m-g")
        .stale_minutes(5)
        .build()?;

    println!("Sending as XML...");
    client.send_cot_event_xml(minimal).await?;
    println!("✓ Sent\n");

    tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;

    // Test 2: Event with contact
    println!("Test 2: Sending event with contact [XML]...");
    let with_contact = CotEventBuilder::new()
        .uid("TEST-CONTACT-XML")
        .cot_type("a-f-G-U-C")
        .lat_lon(37.7750, -122.4195)
        .hae(10.0)
        .ce_le(9.9, 9.9)
        .how("m-g")
        .stale_minutes(5)
        .with_contact(contact("TestUser", Some("192.168.1.100:4242")))
        .build()?;

    client.send_cot_event_xml(with_contact).await?;
    println!("✓ Sent\n");

    tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;

    // Test 3: Event with status
    println!("Test 3: Sending event with status [XML]...");
    let with_status = CotEventBuilder::new()
        .uid("TEST-STATUS-XML")
        .cot_type("a-f-G-U-C")
        .lat_lon(37.7751, -122.4196)
        .hae(10.0)
        .ce_le(9.9, 9.9)
        .how("m-g")
        .stale_minutes(5)
        .with_status(status(85))
        .build()?;

    client.send_cot_event_xml(with_status).await?;
    println!("✓ Sent\n");

    tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;

    // Test 4: Event with precision_location
    println!("Test 4: Sending event with precision_location [XML]...");
    let with_prec = CotEventBuilder::new()
        .uid("TEST-PRECISION-XML")
        .cot_type("a-f-G-U-C")
        .lat_lon(37.7752, -122.4197)
        .hae(10.0)
        .ce_le(9.9, 9.9)
        .how("m-g")
        .stale_minutes(5)
        .with_precision_location(precision_location("GPS", "GPS"))
        .build()?;

    client.send_cot_event_xml(with_prec).await?;
    println!("✓ Sent\n");

    tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;

    // Test 5: Event with all fields
    println!("Test 5: Sending event with all fields [XML]...");
    let with_all = CotEventBuilder::new()
        .uid("TEST-ALL-XML")
        .cot_type("a-f-G-U-C")
        .lat_lon(37.7753, -122.4198)
        .hae(10.0)
        .ce_le(9.9, 9.9)
        .how("m-g")
        .stale_minutes(5)
        .with_contact(contact("AllFields", Some("192.168.1.100:4242")))
        .with_status(status(90))
        .with_precision_location(precision_location("GPS", "BARO"))
        .build()?;

    client.send_cot_event_xml(with_all).await?;
    println!("✓ Sent\n");

    println!("=================================");
    println!("✅ All 5 XML events sent!");
    println!("=================================");
    println!("\nCheck iTAK. You should see 5 markers with '-XML' suffix:");
    println!("  1. TEST-MINIMAL-XML");
    println!("  2. TEST-CONTACT-XML");
    println!("  3. TEST-STATUS-XML");
    println!("  4. TEST-PRECISION-XML");
    println!("  5. TEST-ALL-XML");
    println!("\nIf XML events show but protobuf events don't,");
    println!("we have a protobuf serialization issue.");

    Ok(())
}