raydium-sdk 0.2.6

raydium sdk
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

pub mod launchpad;
pub mod liquidity;
pub mod typs;

use solana_network_client::SolanaClient;
use solana_sdk::pubkey::Pubkey;

use std::{str::FromStr, sync::Arc};

use crate::{
    launchpad::{LaunchpadPool, LaunchpadPoolData},
    liquidity::{
        clmm::{RaydiumLiquidityPoolCLMM, RaydiumLiquidityPoolCLMMData},
        cpmm::{RaydiumLiquidityPoolCPMM, RaydiumLiquidityPoolCPMMData},
        v4::{RaydiumLiquidityPoolData, RaydiumLiquidityPoolV4},
    },
};

/// raydium data structure
pub struct Raydium {
    pub solana_client: Arc<SolanaClient>,
}

impl Raydium {
    /// crreate raydium
    /// Example
    /// ```rust
    /// let sol = Solana::new(solana_network_sdk::types::Mode::MAIN);
    /// let raydium = Raydium::new(Arc::new(sol));
    /// ```
    pub fn new(solana_client: Arc<SolanaClient>) -> Self {
        Self {
            solana_client: solana_client,
        }
    }
    /// get v4 raydium liquidity pool
    /// Example
    /// ```rust
    /// let sol = Solana::new(solana_network_sdk::types::Mode::MAIN);
    /// let raydium = Raydium::new(Arc::new(sol));
    /// // 58oQChx4yWmvKdwLLZzBi4ChoCc2fqCUWBkwMihLYQo2 SOL-USDC pool
    /// let pool_data = raydium.get_liquidity_pool_v4("58oQChx4yWmvKdwLLZzBi4ChoCc2fqCUWBkwMihLYQo2").await;
    /// ```
    pub async fn get_liquidity_pool_v4(
        &self,
        address: &str,
    ) -> Result<RaydiumLiquidityPoolData, String> {
        let v = self
            .solana_client
            .client_arc()
            .get_account_data(
                &Pubkey::from_str(address)
                    .map_err(|e| format!("{:?}", e))
                    .unwrap(),
            )
            .await
            .map_err(|e| format!("{:?}", e))?;
        let pool =
            RaydiumLiquidityPoolV4::get_liquidity_pool_info(&v).map_err(|e| format!("{:?}", e))?;
        Ok(pool)
    }

    pub async fn get_liquidity_pool_cpmm(
        &self,
        address: &str,
    ) -> Result<RaydiumLiquidityPoolCPMMData, String> {
        let v = self
            .solana_client
            .client_arc()
            .get_account_data(
                &Pubkey::from_str(address)
                    .map_err(|e| format!("{:?}", e))
                    .unwrap(),
            )
            .await
            .map_err(|e| format!("{:?}", e))?;
        let pool = RaydiumLiquidityPoolCPMM::get_liquidity_pool_info(&v)
            .map_err(|e| format!("{:?}", e))?;
        Ok(pool)
    }

    pub async fn get_liquidity_pool_clmm(
        &self,
        address: &str,
    ) -> Result<RaydiumLiquidityPoolCLMMData, String> {
        let v = self
            .solana_client
            .client_arc()
            .get_account_data(
                &Pubkey::from_str(address)
                    .map_err(|e| format!("{:?}", e))
                    .unwrap(),
            )
            .await
            .map_err(|e| format!("{:?}", e))?;
        let pool = RaydiumLiquidityPoolCLMM::get_liquidity_pool_info(&v)
            .map_err(|e| format!("{:?}", e))?;
        Ok(pool)
    }

    pub async fn get_liquidity_pool_launchpad(
        &self,
        address: &str,
    ) -> Result<LaunchpadPoolData, String> {
        let v = self
            .solana_client
            .client_arc()
            .get_account_data(
                &Pubkey::from_str(address)
                    .map_err(|e| format!("{:?}", e))
                    .unwrap(),
            )
            .await
            .map_err(|e| format!("{:?}", e))?;
        let pool = LaunchpadPool::get_liquidity_pool_info(&v).map_err(|e| format!("{:?}", e))?;
        Ok(pool)
    }
    // get token price by address
    pub async fn get_token_price_by_address(&self) {}
}