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

use std::env;
use std::time::{SystemTime, UNIX_EPOCH};
use takproto::helpers::{color, colors, remarks_with_formatted_urls, remarks_with_urls};
use takproto::proto::{CotEvent, Detail};
use takproto::{TakClient, TlsConfig};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = env::args().collect();

    if args.len() < 6 {
        eprintln!(
            "Usage: {} <server_addr> <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_path = &args[3];
    let client_cert_path = &args[4];
    let client_key_path = &args[5];

    let tls_config =
        TlsConfig::new_with_client_cert(ca_cert_path, client_cert_path, client_key_path)?;

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

    let now_ms = SystemTime::now().duration_since(UNIX_EPOCH)?.as_millis() as u64;

    // Example 1: Using remarks_with_urls helper
    println!("Sending marker with remarks_with_urls helper...");
    let event1 = CotEvent {
        r#type: "b-m-p-s-m".to_string(),
        uid: "SIMPLE-LINKS".to_string(),
        send_time: now_ms,
        start_time: now_ms,
        stale_time: now_ms + 300_000,
        how: "h-e".to_string(),
        lat: 39.377445,
        lon: -76.832160,
        hae: 10.0,
        ce: 9.9,
        le: 9.9,

        detail: Some(Detail {
            xml_detail: format!(
                "{}\n{}",
                remarks_with_urls(
                    "📊 Mission Resources",
                    &[
                        ("Homepage", "https://www.rust-lang.org"),
                        ("Documentation", "https://doc.rust-lang.org/book/"),
                    ]
                ),
                color(colors::RED)
            ),
            ..Default::default()
        }),

        ..Default::default()
    };

    client.send_cot_event_xml(event1).await?;
    println!("✓ RED marker: SIMPLE-LINKS\n");

    // Example 2: Using remarks_with_formatted_urls helper
    println!("Sending marker with formatted URLs and icons...");
    let event2 = CotEvent {
        r#type: "b-m-p-s-m".to_string(),
        uid: "FORMATTED-LINKS".to_string(),
        send_time: now_ms + 1000,
        start_time: now_ms + 1000,
        stale_time: now_ms + 301_000,
        how: "h-e".to_string(),
        lat: 39.380000,
        lon: -76.835000,
        hae: 10.0,
        ce: 9.9,
        le: 9.9,

        detail: Some(Detail {
            xml_detail: format!(
                "{}\n{}",
                remarks_with_formatted_urls(
                    "📚 Intelligence Resources",
                    &[
                        ("🌐", "Rust Website", "https://www.rust-lang.org"),
                        ("📦", "GitHub Repo", "https://github.com/rust-lang/rust"),
                        ("📖", "The Rust Book", "https://doc.rust-lang.org/book/"),
                    ]
                ),
                color(colors::GREEN)
            ),
            ..Default::default()
        }),

        ..Default::default()
    };

    client.send_cot_event_xml(event2).await?;
    println!("✓ GREEN marker: FORMATTED-LINKS\n");

    println!("=== ✅ SUCCESS ===\n");
    println!("Check iTAK for 2 markers:");
    println!("  🔴 RED:   SIMPLE-LINKS");
    println!("  🟢 GREEN: FORMATTED-LINKS");
    println!();
    println!("In iTAK:");
    println!("  1. Tap a marker");
    println!("  2. Tap '...' for Details");
    println!("  3. See URLs in Remarks field");
    println!("  4. Long-press URL to copy or open");
    println!();
    println!("💡 This works on iTAK 2.12.3 and all versions!");

    client.close().await?;
    Ok(())
}