k256-sdk 0.1.0

Official Rust SDK for K256 - the gateway to Solana's liquidity ecosystem
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

//! WebSocket message type constants.

/// WebSocket binary message type identifiers.
///
/// These correspond to the first byte of each binary message.
#[repr(u8)]
#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
pub enum MessageType {
    /// Server → Client: Single pool update
    PoolUpdate = 0x01,
    /// Client → Server: Subscribe request (JSON)
    Subscribe = 0x02,
    /// Server → Client: Subscription confirmed (JSON)
    Subscribed = 0x03,
    /// Client → Server: Unsubscribe all
    Unsubscribe = 0x04,
    /// Server → Client: Priority fee update
    PriorityFees = 0x05,
    /// Server → Client: Recent blockhash
    Blockhash = 0x06,
    /// Server → Client: Streaming quote update
    Quote = 0x07,
    /// Server → Client: Quote subscription confirmed
    QuoteSubscribed = 0x08,
    /// Client → Server: Subscribe to quote stream
    SubscribeQuote = 0x09,
    /// Client → Server: Unsubscribe from quote
    UnsubscribeQuote = 0x0A,
    /// Client → Server: Ping (keepalive)
    Ping = 0x0B,
    /// Server → Client: Pong response
    Pong = 0x0C,
    /// Server → Client: Connection stats (JSON)
    Heartbeat = 0x0D,
    /// Server → Client: Batched pool updates
    PoolUpdateBatch = 0x0E,
    /// Server → Client: Error message (UTF-8)
    Error = 0xFF,
}

impl TryFrom<u8> for MessageType {
    type Error = u8;

    fn try_from(value: u8) -> Result<Self, <Self as TryFrom<u8>>::Error> {
        match value {
            0x01 => Ok(Self::PoolUpdate),
            0x02 => Ok(Self::Subscribe),
            0x03 => Ok(Self::Subscribed),
            0x04 => Ok(Self::Unsubscribe),
            0x05 => Ok(Self::PriorityFees),
            0x06 => Ok(Self::Blockhash),
            0x07 => Ok(Self::Quote),
            0x08 => Ok(Self::QuoteSubscribed),
            0x09 => Ok(Self::SubscribeQuote),
            0x0A => Ok(Self::UnsubscribeQuote),
            0x0B => Ok(Self::Ping),
            0x0C => Ok(Self::Pong),
            0x0D => Ok(Self::Heartbeat),
            0x0E => Ok(Self::PoolUpdateBatch),
            0xFF => Ok(Self::Error),
            other => Err(other),
        }
    }
}