sof 0.17.1

Solana Observer Framework for low-latency shred ingestion and plugin-driven transaction observation
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

use super::ParseError;

#[inline]
pub(super) const fn ensure_len(packet: &[u8], minimum: usize) -> Result<(), ParseError> {
    if packet.len() < minimum {
        return Err(ParseError::PacketTooShort {
            actual: packet.len(),
            minimum,
        });
    }
    Ok(())
}

#[inline]
pub(super) fn read_u8(packet: &[u8], offset: usize) -> Result<u8, ParseError> {
    packet
        .get(offset)
        .copied()
        .ok_or_else(|| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(1),
        })
}

#[inline]
pub(super) fn read_u16_le(packet: &[u8], offset: usize) -> Result<u16, ParseError> {
    let bytes = packet
        .get(offset..offset.saturating_add(2))
        .ok_or_else(|| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(2),
        })?;
    let bytes: [u8; 2] = bytes
        .try_into()
        .map_err(|_error| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(2),
        })?;
    Ok(u16::from_le_bytes(bytes))
}

#[inline]
pub(super) fn read_u32_le(packet: &[u8], offset: usize) -> Result<u32, ParseError> {
    let bytes = packet
        .get(offset..offset.saturating_add(4))
        .ok_or_else(|| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(4),
        })?;
    let bytes: [u8; 4] = bytes
        .try_into()
        .map_err(|_error| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(4),
        })?;
    Ok(u32::from_le_bytes(bytes))
}

#[inline]
pub(super) fn read_u64_le(packet: &[u8], offset: usize) -> Result<u64, ParseError> {
    let bytes = packet
        .get(offset..offset.saturating_add(8))
        .ok_or_else(|| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(8),
        })?;
    let bytes: [u8; 8] = bytes
        .try_into()
        .map_err(|_error| ParseError::PacketTooShort {
            actual: packet.len(),
            minimum: offset.saturating_add(8),
        })?;
    Ok(u64::from_le_bytes(bytes))
}