rs162 0.1.3

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
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

//! Digital Signal Processing (DSP) module for AIS signal processing.
//!
//! This module provides a streaming architecture for composing and testing DSP blocks independently.
//! Each DSP block implements the [`Stream`] trait, allowing flexible chaining and integration.
//!
//! The main entry point for AIS signal processing is the [`ais`] submodule, which contains
//! the core logic for decoding AIS messages from IQ sample streams.
//!
//! Utility functions are provided for converting raw IQ samples from various formats
//! (`u8`, `i8`, `i16`, `f32`) into `Complex<f32>` for further processing.
//!
use num_complex::Complex;

pub mod afc;
pub mod ais;
pub mod cic5;
pub mod ema;
pub mod fir;
pub mod rotate;
pub mod sample_rate;
pub mod scatter;
pub mod upsampler;

/// Tag structure passed along with samples through the DSP chain
#[derive(Debug, Clone, Default)]
pub struct Tag {
    pub sample_idx: usize,
    pub sample_lvl: f32,
    pub ppm: f32,
    pub mode: u32,
    pub group: u64,
    pub level: f32,
}

/// Core streaming trait for DSP blocks
pub trait Stream<TIn, TOut> {
    /// Process input samples and produce output samples
    fn receive(&mut self, data: &[TIn], tag: &mut Tag) -> Vec<TOut>;

    /// Reset internal state (optional)
    fn reset(&mut self) {}
}

/// Helper trait for stateless transformations
pub trait StreamStateless<TIn, TOut> {
    fn process(&self, data: &[TIn], tag: &mut Tag) -> Vec<TOut>;
}

// Implement Stream for any StreamStateless
impl<T, TIn, TOut> Stream<TIn, TOut> for T
where
    T: StreamStateless<TIn, TOut>,
{
    fn receive(&mut self, data: &[TIn], tag: &mut Tag) -> Vec<TOut> {
        self.process(data, tag)
    }
}

/// Convert IQ samples from u8 format (RTL-SDR) to `Complex<f32>`
pub fn convert_samples_cu8(samples: &[u8]) -> Vec<Complex<f32>> {
    samples
        .chunks_exact(2)
        .map(|chunk| {
            let i = (chunk[0] as f32 - 127.5) / 128.0;
            let q = (chunk[1] as f32 - 127.5) / 128.0;
            Complex::new(i, q)
        })
        .collect()
}

/// Convert IQ samples from i8 format to `Complex<f32>`
pub fn convert_samples_cs8(samples: &[i8]) -> Vec<Complex<f32>> {
    samples
        .chunks_exact(2)
        .map(|chunk| {
            let i = chunk[0] as f32 / 128.0;
            let q = chunk[1] as f32 / 128.0;
            Complex::new(i, q)
        })
        .collect()
}

/// Convert IQ samples from i16 format to `Complex<f32>`
pub fn convert_samples_cs16(samples: &[i16]) -> Vec<Complex<f32>> {
    samples
        .chunks_exact(2)
        .map(|chunk| {
            let i = chunk[0] as f32 / 32768.0;
            let q = chunk[1] as f32 / 32768.0;
            Complex::new(i, q)
        })
        .collect()
}

/// Convert IQ samples from f32 (GQRX) format to `Complex<f32>`
pub fn convert_samples_cf32(samples: &[f32]) -> Vec<Complex<f32>> {
    samples
        .chunks_exact(2)
        .map(|chunk| Complex::new(chunk[0], chunk[1]))
        .collect()
}