solana-streamer-sdk 1.5.6

A low-latency Solana DEX event streaming facade over sol-parser-sdk with Yellowstone gRPC, ShredStream, and RPC parsing helpers.
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

//! Public extension bridge for advanced `sol-parser-sdk` interop.
//!
//! Existing streamer subscription APIs remain unchanged. Use this module when code needs direct
//! access to raw SDK parsers/events but still wants streamer `DexEvent` compatibility.
use prost_types::Timestamp;

use crate::streaming::event_parser::common::filter::{
    build_sdk_parse_event_filter, EventTypeFilter,
};
use crate::streaming::event_parser::{DexEvent, Protocol};
use crate::streaming::grpc::AccountPretty;

pub use sol_parser_sdk as raw;

pub type SdkClientConfig = sol_parser_sdk::grpc::types::ClientConfig;
pub type SdkDexEvent = sol_parser_sdk::DexEvent;
pub type SdkEventType = sol_parser_sdk::grpc::types::EventType;
pub type SdkEventTypeFilter = sol_parser_sdk::grpc::types::EventTypeFilter;
pub type SdkOrderMode = sol_parser_sdk::grpc::types::OrderMode;
pub type SdkProtocol = sol_parser_sdk::grpc::types::Protocol;

pub fn event_type_filter_to_sdk(filter: Option<&EventTypeFilter>) -> Option<SdkEventTypeFilter> {
    build_sdk_parse_event_filter(filter)
}

pub fn adapt_event(
    sdk_event: SdkDexEvent,
    block_time: Option<&Timestamp>,
    recv_wall_us: i64,
    protocols: &[Protocol],
    event_type_filter: Option<&EventTypeFilter>,
) -> Option<DexEvent> {
    crate::streaming::parser_sdk_bridge::adapt_parser_event(
        sdk_event,
        block_time,
        recv_wall_us,
        protocols,
        event_type_filter,
    )
}

pub fn adapt_events(
    sdk_events: Vec<SdkDexEvent>,
    block_time: Option<&Timestamp>,
    recv_wall_us: i64,
    protocols: &[Protocol],
    event_type_filter: Option<&EventTypeFilter>,
) -> Vec<DexEvent> {
    crate::streaming::parser_sdk_bridge::adapt_parser_events_list(
        sdk_events,
        block_time,
        recv_wall_us,
        protocols,
        event_type_filter,
    )
}

pub fn parse_account_event(
    account: &AccountPretty,
    protocols: &[Protocol],
    event_type_filter: Option<&EventTypeFilter>,
) -> Option<DexEvent> {
    crate::streaming::parser_sdk_bridge::parse_sdk_account_event(
        account,
        protocols,
        event_type_filter,
    )
}