Struct ParsedPacket 

pub struct ParsedPacket { /* private fields */ }

Structured packet view backed by the preserved raw packet bytes.

Implementations

impl ParsedPacket

pub fn raw(&self) -> &RawPacket

Returns the preserved raw packet.

pub fn source(&self) -> &[u8]

Returns the source callsign bytes before the > separator.

Examples found in repository

examples/parse_packet.rs (line 6)

fn main() -> Result<(), libaprs_engine::ParseError> {
    let packet = parse_packet(b"N0CALL>APRS:>hello")?;

    println!("source={}", String::from_utf8_lossy(packet.source()));
    println!(
        "destination={}",
        String::from_utf8_lossy(packet.destination())
    );

    if let AprsData::Status { text } = packet.aprs_data() {
        println!("status={}", String::from_utf8_lossy(text));
    }

    Ok(())
}

pub fn path(&self) -> &[u8]

Returns the destination/path bytes between > and :.

pub fn destination(&self) -> &[u8]

Returns the destination bytes, which are the first path component.

Examples found in repository

examples/parse_packet.rs (line 9)

fn main() -> Result<(), libaprs_engine::ParseError> {
    let packet = parse_packet(b"N0CALL>APRS:>hello")?;

    println!("source={}", String::from_utf8_lossy(packet.source()));
    println!(
        "destination={}",
        String::from_utf8_lossy(packet.destination())
    );

    if let AprsData::Status { text } = packet.aprs_data() {
        println!("status={}", String::from_utf8_lossy(text));
    }

    Ok(())
}

pub fn digipeaters(&self) -> Vec<&[u8]>

Returns digipeater path component byte views after the destination.

pub fn path_components(&self) -> Vec<&[u8]>

Returns all path component byte views, including destination first.

pub fn payload(&self) -> &[u8]

Returns the payload bytes after the : separator.

pub fn data_type_identifier(&self) -> DataTypeIdentifier

Returns the APRS data type identifier from the first payload byte.

pub fn information(&self) -> &[u8]

Returns payload bytes after the data type identifier.

pub fn aprs_data(&self) -> AprsData<'_>

Returns a semantic view of the APRS information field.

Examples found in repository

examples/parse_packet.rs (line 12)

fn main() -> Result<(), libaprs_engine::ParseError> {
    let packet = parse_packet(b"N0CALL>APRS:>hello")?;

    println!("source={}", String::from_utf8_lossy(packet.source()));
    println!(
        "destination={}",
        String::from_utf8_lossy(packet.destination())
    );

    if let AprsData::Status { text } = packet.aprs_data() {
        println!("status={}", String::from_utf8_lossy(text));
    }

    Ok(())
}

pub fn summary(&self) -> PacketSummary<'_>

Returns a structured diagnostic summary for observability.

Examples found in repository

examples/service_ingest.rs (line 17)

fn main() -> Result<(), std::io::Error> {
    let input = b"N0CALL>APRS:>service online\nN1CALL>APRS:~opaque\nbad packet\n";
    let mut engine = Engine::new(Policy::strict());

    let packets = LineTransport::new(input).packets_with_limit(MAX_PACKET_LEN)?;

    for packet in packets {
        match engine.process_event(packet) {
            EngineEvent::Accepted(event) => {
                println!(
                    "event={} semantic={}",
                    event.kind().code(),
                    event.packet.summary().semantic
                );
            }
            EngineEvent::Rejected(event) => {
                println!(
                    "event={} code={} remediation={}",
                    event.kind().code(),
                    event.diagnostic.code,
                    event.diagnostic.remediation
                );
            }
            EngineEvent::Malformed(event) => {
                println!(
                    "event={} code={} raw_len={} raw_truncated={} remediation={}",
                    event.kind().code(),
                    event.diagnostic.code,
                    event.raw.len(),
                    event.raw_truncated,
                    event.diagnostic.remediation
                );
            }
        }
    }

    let counters = engine.counters();
    println!(
        "summary accepted={} rejected={} malformed={}",
        counters.accepted, counters.rejected, counters.malformed
    );

    Ok(())
}

pub fn to_json(&self) -> String

Serializes the parsed packet into a compact JSON diagnostic string.

Examples found in repository

examples/process_file.rs (line 18)

fn main() -> std::io::Result<()> {
    let Some(path) = std::env::args().nth(1) else {
        eprintln!("usage: process_file <packets.aprs>");
        std::process::exit(2);
    };

    let input = read_all_with_limit(File::open(path)?, DEFAULT_TRANSPORT_READ_LIMIT)?;
    let mut engine = Engine::new(Policy::strict());

    for packet_bytes in LineTransport::new(&input).packets() {
        match engine.process(packet_bytes) {
            EngineResult::Accepted { packet } => println!("{}", packet.to_json()),
            EngineResult::Rejected { reason, .. } => eprintln!("rejected: {}", reason.code()),
            EngineResult::ParseError(error) => eprintln!("malformed: {}", error.code()),
        }
    }

    Ok(())
}

Trait Implementations

impl Clone for ParsedPacket

fn clone(&self) -> ParsedPacket

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParsedPacket

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for ParsedPacket

fn eq(&self, other: &ParsedPacket) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ParsedPacket

impl StructuralPartialEq for ParsedPacket