sidereon 1.3.1

Thin ergonomic API over sidereon-core: SP3 loading and SPP/RTK/PPP positioning solves with rich result structs and one error enum
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

use sidereon::ntrip::{
    format_gga, parse_sourcetable, ChunkedDecoder, GgaPosition, NtripClientMachine, NtripConfig,
    NtripCredentials, NtripEvent, NtripHandshake, NtripState, NtripVersion, StrAuth,
};

fn config(version: NtripVersion) -> NtripConfig {
    NtripConfig {
        host: "caster.example.test".into(),
        port: 2101,
        mountpoint: "MOUNT".into(),
        version,
        credentials: None,
        user_agent_product: "sidereon-test/0".into(),
        gga_interval_s: None,
    }
}

#[test]
fn facade_exposes_ntrip_request_stream_and_gga_behavior() {
    assert_eq!(
        config(NtripVersion::Rev1).request_bytes().expect("request"),
        b"GET /MOUNT HTTP/1.0\r\nUser-Agent: NTRIP sidereon-test/0\r\n\r\n"
    );

    let table = parse_sourcetable(
        "STR;MOUNT;ID;RTCM;1004;2;GPS;NET;USA;40.1;-105.2;1;0;gen;none;B;N;9600;misc\r\n\
         ENDSOURCETABLE\r\n",
    )
    .expect("sourcetable");
    let stream = table.streams().next().expect("stream record");
    assert_eq!(stream.mountpoint, "MOUNT");
    assert_eq!(stream.authentication, StrAuth::Basic);

    let mut decoder = ChunkedDecoder::new();
    assert_eq!(decoder.push(b"4\r\nWi").expect("chunk prefix"), b"Wi");
    assert_eq!(decoder.push(b"ki\r\n0\r\n\r\n").expect("chunk tail"), b"ki");
    assert!(decoder.finished());

    let mut machine = NtripClientMachine::new(config(NtripVersion::Rev2));
    assert_eq!(machine.state(), NtripState::Idle);
    machine.connection_request().expect("connection request");
    let events = machine.push(b"HTTP/1.1 200 OK\r\nContent-Type: gnss/data\r\n\r\nabc");
    assert_eq!(
        events,
        vec![
            NtripEvent::Connected(NtripHandshake {
                version: NtripVersion::Rev2,
                chunked: false,
                headers: vec![("Content-Type".into(), "gnss/data".into())],
            }),
            NtripEvent::Payload(b"abc".to_vec()),
        ]
    );
    assert_eq!(machine.state(), NtripState::Streaming);

    let sentence = format_gga(
        &GgaPosition {
            lat_deg: 40.0,
            lon_deg: -105.0,
            height_m: 1600.0,
            ..GgaPosition::default()
        },
        3661.239,
    )
    .expect("GGA sentence");
    assert_eq!(
        sentence,
        b"$GPGGA,010101.23,4000.0000000,N,10500.0000000,W,1,10,1.00,1600.0,M,,,,*2A\r\n"
    );
}

#[test]
fn facade_exposes_rev2_headers_and_chunked_machine() {
    let mut config = config(NtripVersion::Rev2);
    config.credentials = Some(NtripCredentials {
        username: "user".into(),
        password: "pass".into(),
    });
    assert_eq!(
        config.request_headers().expect("request headers"),
        (
            "/MOUNT".into(),
            vec![
                ("Host".into(), "caster.example.test:2101".into()),
                ("Ntrip-Version".into(), "Ntrip/2.0".into()),
                ("User-Agent".into(), "NTRIP sidereon-test/0".into()),
                ("Authorization".into(), "Basic dXNlcjpwYXNz".into()),
                ("Connection".into(), "close".into()),
            ],
        )
    );

    let mut machine = NtripClientMachine::new(config);
    machine.connection_request().expect("connection request");
    let events = machine.push(
        b"HTTP/1.1 200 OK\r\nContent-Type: gnss/data\r\nTransfer-Encoding: chunked\r\n\r\n3\r\nabc\r\n0\r\n\r\n",
    );
    assert_eq!(
        events,
        vec![
            NtripEvent::Connected(NtripHandshake {
                version: NtripVersion::Rev2,
                chunked: true,
                headers: vec![
                    ("Content-Type".into(), "gnss/data".into()),
                    ("Transfer-Encoding".into(), "chunked".into()),
                ],
            }),
            NtripEvent::Payload(b"abc".to_vec()),
            NtripEvent::StreamEnded,
        ]
    );
    assert_eq!(machine.state(), NtripState::Closed);
}