solana-trading-sdk 1.0.6

A Rust SDK for trading on Solana
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

pub mod blox;
pub mod default;
pub mod jito;
pub mod nextblock;
pub mod swqos_rpc;
pub mod temporal;
pub mod zeroslot;

use blox::BloxClient;
use default::DefaultSWQoSClient;
use jito::JitoClient;
use nextblock::NextBlockClient;
use solana_client::nonblocking::rpc_client::RpcClient;
use solana_sdk::{pubkey::Pubkey, transaction::VersionedTransaction};
use std::{any::Any, sync::Arc};
use temporal::TEMPORAL_TIP_ACCOUNTS;
use zeroslot::ZEROSLOT_TIP_ACCOUNTS;

// (endpoint, auth_token)
#[derive(Debug, Clone, PartialEq, Eq, Hash)]
pub enum SWQoSType {
    Default(String, Option<(String, String)>),
    Jito(String),
    NextBlock(String, String),
    Blox(String, String),
    Temporal(String, String),
    ZeroSlot(String, String),
}

#[async_trait::async_trait]
pub trait SWQoSTrait: Send + Sync + Any {
    async fn send_transaction(&self, transaction: VersionedTransaction) -> anyhow::Result<()>;
    async fn send_transactions(&self, transactions: Vec<VersionedTransaction>) -> anyhow::Result<()>;
    fn get_tip_account(&self) -> Option<Pubkey>;
    fn get_name(&self) -> &str;
}

impl SWQoSType {
    pub fn instantiate(&self, rpc_client: Arc<RpcClient>) -> Arc<dyn SWQoSTrait> {
        match self {
            SWQoSType::Default(endpoint, header) => Arc::new(DefaultSWQoSClient::new("default", rpc_client, endpoint.to_string(), header.clone(), vec![])),
            SWQoSType::Jito(endpoint) => Arc::new(JitoClient::new(rpc_client, endpoint.to_string())),
            SWQoSType::NextBlock(endpoint, auth_token) => Arc::new(NextBlockClient::new(rpc_client, endpoint.to_string(), auth_token.to_string())),
            SWQoSType::Blox(endpoint, auth_token) => Arc::new(BloxClient::new(rpc_client, endpoint.to_string(), auth_token.to_string())),
            SWQoSType::ZeroSlot(endpoint, auth_token) => Arc::new(DefaultSWQoSClient::new(
                "0slot",
                rpc_client,
                format!("{}?api-key={}", endpoint, auth_token),
                None,
                ZEROSLOT_TIP_ACCOUNTS.into(),
            )),

            SWQoSType::Temporal(endpoint, auth_token) => Arc::new(DefaultSWQoSClient::new(
                "temporal",
                rpc_client,
                format!("{}?c={}", endpoint, auth_token),
                None,
                TEMPORAL_TIP_ACCOUNTS.into(),
            )),
        }
    }
}