rs162 0.1.2

NMEA AIS Message Parser and Decoder with deku-based AIS message structures
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

use desperado::{rtlsdr::DeviceSelector, Result};
use futures::StreamExt; // for .next().await
use rs162::{dsp::ais::AIS_SAMPLE_RATE_288K, sources::iq::AisAsyncIqSource};
use serde_json::json;

#[tokio::main]
async fn main() -> Result<()> {
    let mut receiver =
        AisAsyncIqSource::from_rtlsdr(DeviceSelector::Index(0), AIS_SAMPLE_RATE_288K, None, false)
            .await?;

    while let Some(msg_res) = receiver.next().await {
        match msg_res {
            Ok(msg) => {
                if let Some(ais_msg) = msg.decode() {
                    let output = json!({
                        "signal_level": msg.signal_level,
                        "timestamp": msg.timestamp,
                        "channel": msg.channel,
                        "message": ais_msg
                    });
                    println!("{}", serde_json::to_string(&output).unwrap());
                }
            }
            Err(e) => {
                eprintln!("I/O error reading samples: {e}");
                continue;
            }
        }
    }
    println!("Stream returned None, exiting loop"); // Debug log

    Ok(())
}