raydium-sdk 0.1.9

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

pub mod liquidity;
pub mod typs;

use solana_client::nonblocking::rpc_client::RpcClient;
use solana_network_sdk::{
    Solana,
    types::{UnifiedError, UnifiedResult},
};
use solana_sdk::pubkey::Pubkey;
use std::{str::FromStr, sync::Arc};

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

/// raydium data structure
pub struct Raydium {
    pub solana: Arc<Solana>,
}

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: Arc<Solana>) -> Self {
        Self { solana: solana }
    }
    /// 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,
    ) -> UnifiedResult<RaydiumLiquidityPoolData, String> {
        let v = self
            .solana
            .get_account_data(address)
            .await
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        let pool = RaydiumLiquidityPoolV4::get_liquidity_pool_info(&v)
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        Ok(pool)
    }
    pub async fn get_liquidity_pool_cpmm(
        &self,
        address: &str,
    ) -> UnifiedResult<RaydiumLiquidityPoolCPMMData, String> {
        let v = self
            .solana
            .get_account_data(address)
            .await
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        let pool = RaydiumLiquidityPoolCPMM::get_liquidity_pool_info(&v)
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        Ok(pool)
    }
    pub async fn get_liquidity_pool_clmm(
        &self,
        address: &str,
    ) -> UnifiedResult<RaydiumLiquidityPoolCLMMData, String> {
        let v = self
            .solana
            .get_account_data(address)
            .await
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        let pool = RaydiumLiquidityPoolCLMM::get_liquidity_pool_info(&v)
            .map_err(|e| UnifiedError::Error(format!("{:?}", e)))?;
        Ok(pool)
    }
    // get token price by address
    pub async fn get_token_price_by_address(&self) {}
}