Shredstream

use std::net::UdpSocket;
use solana_ledger::shred::{
    merkle::Shred, ShredType,
};

fn main() -> std::io::Result<()> {
    let socket = UdpSocket::bind("0.0.0.0:9000")?;
    let mut buf = [0u8; 1232];

    loop {
        let (len, _src) = socket.recv_from(&mut buf)?;
        let raw = buf[..len].to_vec();

        let shred = match Shred::from_payload(raw) {
            Ok(s) => s,
            Err(_) => continue,
        };

        let hdr = shred.common_header();
        let kind = match shred.shred_type() {
            ShredType::Data => "DATA",
            ShredType::Code => "CODE",
        };

        println!(
            "[{kind}] slot={} idx={} fec={} {len}B",
            hdr.slot, shred.index(), shred.fec_set_index(),
        );
    }
}