cot_publisher

Crates.iocot_publisher
lib.rscot_publisher
version1.0.0-rc.1
sourcesrc
created_at2023-05-29 08:15:59.214498
updated_at2023-05-29 08:15:59.214498
descriptionCursor On Target (COT) Publisher for multicast or TakServer Data Stream
homepagehttps://github.com/martynp/cot_publisher
repositoryhttps://github.com/martynp/cot_publisher
max_upload_size
id877000
size46,380
Martyn P (martynp)

documentation

https://github.com/martynp/cot_publisher

README

A Cursor-On-Target generator for multicast and streaming data interfaces (TakServer).

TakServer Setup

Add a new streaming data field, go Configuration -> Inputs and Data Feeds -> Add Streaming Data Feed.

Give the interface a name and select Secure Streaming TCP (TLS) CoT or Protobuf as the protocol. Select a port and select Save.

Create a user in the TakServer UI, then in the takserver console use the makeCert script:

cd /opt/tak/certs
sh -c "source ./makeCert.sh client [username]"

(replace [username] with the user just created)

The key and certificate for the user will be in the /opt/tag/cert/files directory.

TakServer generates user keys which are protected by the atakatak password, this can be removed using:

openssl rsa -in user.key -out user-nopass.key

Example - Multicast Only

let mut publisher = CotPublisher::new(
    "test-uid-1234",
    "a-f-G-U-C",
    Some("239.2.3.1:6969"),
    None,
);
publisher.publish();

Example - TakServer stream using TLS credentials from files

let mut publisher = CotPublisher::new(
    "test-uid-1234",
    "a-f-G-U-C",
    None,
    Some(("192.168.0.2", 9000)),
);

let ca_file = "[path_to]/truststore-intermediate-CA.pem";
let client_cert = "[path_to]/user.pem";
let client_key = "[path_to]/user-nopass.key";

publisher.set_tak_server_tls_settings(Some(TakServerSettings {
    tls: true,
    client_key: PEM::File(client_key.into()),
    client_cert: PEM::File(client_cert.into()),
    root_cert: PEM::File(ca_file.into()),
    ignore_invalid: false,
    verify_hostname: false,
}));

publisher.connect();
publisher.publish();

// Required if `publisher` is dropped to ensure message is actually sent
//std::thread::sleep(std::time::Duration::from_millis(100));

Example - TakServer stream using TLS credentials from strings

let mut publisher = CotPublisher::new(
    "test-uid-1234",
    "a-f-G-U-C",
    None,
    Some(("192.168.0.2", 9000)),
);

let ca_file = r#"
Bag Attributes
    friendlyName: intermediate-CA
subject=C = US, ST = STATE, L = CITY, O = TAK, OU = ORG_UNIT, CN = intermediate-CA
issuer=C = US, ST = STATE, L = CITY, O = TAK, OU = ORG_UNIT, CN = takserver-CA
-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----
        "#;

let key = r#"
-----BEGIN PRIVATE KEY-----
...
-----END PRIVATE KEY-----
"#;

let cert = r#"
-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----
"#;

publisher.set_tak_server_tls_settings(Some(TakServerSettings {
    tls: true,
    client_key: PEM::String(key.into()),
    client_cert: PEM::String(cert.into()),
    root_cert: PEM::String(ca_file_content.into()),
    ignore_invalid: false,
    verify_hostname: false,
}));

publisher.connect();
publisher.publish();

// Required if `publisher` is dropped to ensure message is actually sent
//std::thread::sleep(std::time::Duration::from_millis(100));

Example - Set position


let mut publisher = CotPublisher::new(
    "test-uid-1234",
    "a-f-G-U-C",
    Some("239.2.3.1:6969"),
    None,
);

publisher.set_contact(Some("MYTHING"), None);
publisher.set_position(10.0, 10.0);
publisher.set_xml_detail(Some("<custom somekey='somevalue'/>"));
publisher.publish();

Commit count: 4

cargo fmt