defituna_client/gpa/
tuna_lp_position.rs

1use std::error::Error;
2
3use solana_client::{
4    rpc_client::RpcClient,
5    rpc_filter::{Memcmp, RpcFilterType},
6};
7use solana_pubkey::Pubkey;
8
9use crate::accounts::{TunaLpPosition, TUNA_LP_POSITION_DISCRIMINATOR};
10use crate::generated::shared::DecodedAccount;
11use crate::gpa::utils::fetch_decoded_program_accounts;
12
13#[derive(Debug, Clone)]
14pub enum TunaLpPositionFilter {
15    Authority(Pubkey),
16    Pool(Pubkey),
17    MintA(Pubkey),
18    MintB(Pubkey),
19    Mint(Pubkey),
20}
21
22impl From<TunaLpPositionFilter> for RpcFilterType {
23    fn from(val: TunaLpPositionFilter) -> Self {
24        match val {
25            TunaLpPositionFilter::Authority(address) => RpcFilterType::Memcmp(Memcmp::new_base58_encoded(11, &address.to_bytes())),
26            TunaLpPositionFilter::Pool(address) => RpcFilterType::Memcmp(Memcmp::new_base58_encoded(43, &address.to_bytes())),
27            TunaLpPositionFilter::MintA(address) => RpcFilterType::Memcmp(Memcmp::new_base58_encoded(75, &address.to_bytes())),
28            TunaLpPositionFilter::MintB(address) => RpcFilterType::Memcmp(Memcmp::new_base58_encoded(107, &address.to_bytes())),
29            TunaLpPositionFilter::Mint(address) => RpcFilterType::Memcmp(Memcmp::new_base58_encoded(139, &address.to_bytes())),
30        }
31    }
32}
33
34pub fn fetch_all_tuna_lp_position_with_filter(
35    rpc: &RpcClient,
36    filters: Vec<TunaLpPositionFilter>,
37) -> Result<Vec<DecodedAccount<TunaLpPosition>>, Box<dyn Error>> {
38    let mut filters: Vec<RpcFilterType> = filters.into_iter().map(|filter| filter.into()).collect();
39    filters.push(RpcFilterType::Memcmp(Memcmp::new_base58_encoded(0, &TUNA_LP_POSITION_DISCRIMINATOR)));
40    fetch_decoded_program_accounts(rpc, filters)
41}
defituna_client/gpa/tuna_lp_position.rs

defituna_client/gpa/
tuna_lp_position.rs
