use {
crate::types::graphql::{
LiquidityPoolAllowlistGraphQL, LiquidityPoolFeatureFlagsGraphQL, LiquidityPoolInfoGraphQL,
LiquidityPoolLpTokenInfoGraphQL, LiquidityPoolMarketCapBasedFeesGraphQL,
LiquidityPoolReserveGraphQL, LiquidityPoolSlotOffsetBasedFeesGraphQL,
LiquidityPoolTokenInfoGraphQL,
},
carbon_core::graphql::primitives::{Pubkey, U64, U8},
juniper::GraphQLObject,
};
#[derive(Debug, Clone, GraphQLObject)]
#[graphql(name = "LiquidityPoolState")]
pub struct LiquidityPoolStateGraphQL {
pub account_metadata: crate::accounts::graphql::AccountMetadataGraphQL,
pub info: LiquidityPoolInfoGraphQL,
pub market_cap_based_fees: LiquidityPoolMarketCapBasedFeesGraphQL,
pub reserve: LiquidityPoolReserveGraphQL,
pub lp_token: LiquidityPoolLpTokenInfoGraphQL,
pub protocol_trading_fees: U64,
pub creator_trading_fees: U64,
pub creator_trading_fees_claimed_by_creator: U64,
pub creator_trading_fees_claimed_by_others: U64,
pub liquidity_provider_trading_fees: U64,
pub creator_trading_fee_protocol_fees: U64,
pub reflection_trading_fees: U64,
pub created_at_slot: U64,
pub trading_volume_usd: f64,
pub creator_trading_fee_trading_volume_threshold: f64,
pub creator_trading_fee_trading_volume_threshold_reached_unix_timestamp: U64,
pub token_a_vault: Pubkey,
pub token_b_vault: Pubkey,
pub protocol_config: Pubkey,
pub key: Pubkey,
pub token_a: LiquidityPoolTokenInfoGraphQL,
pub token_b: LiquidityPoolTokenInfoGraphQL,
pub allowlist: LiquidityPoolAllowlistGraphQL,
pub feature_flags: LiquidityPoolFeatureFlagsGraphQL,
pub taxable_side: U8,
pub taxable_side_type: U8,
pub creator_trading_fee_distribution: U8,
pub creator_trading_fee_claim_status: U8,
pub fee_configuration_mode: U8,
pub is_migrated: U8,
pub pad: Vec<U8>,
pub slot_offset_based_fees: LiquidityPoolSlotOffsetBasedFeesGraphQL,
pub creator_trading_fee_receiver: Pubkey,
}
impl TryFrom<crate::accounts::postgres::LiquidityPoolStateRow> for LiquidityPoolStateGraphQL {
type Error = carbon_core::error::Error;
fn try_from(
row: crate::accounts::postgres::LiquidityPoolStateRow,
) -> Result<Self, Self::Error> {
Ok(Self {
account_metadata: row.account_metadata.into(),
info: row.info.0.into(),
market_cap_based_fees: row.market_cap_based_fees.0.into(),
reserve: row.reserve.0.into(),
lp_token: row.lp_token.0.into(),
protocol_trading_fees: carbon_core::graphql::primitives::U64(
*row.protocol_trading_fees,
),
creator_trading_fees: carbon_core::graphql::primitives::U64(*row.creator_trading_fees),
creator_trading_fees_claimed_by_creator: carbon_core::graphql::primitives::U64(
*row.creator_trading_fees_claimed_by_creator,
),
creator_trading_fees_claimed_by_others: carbon_core::graphql::primitives::U64(
*row.creator_trading_fees_claimed_by_others,
),
liquidity_provider_trading_fees: carbon_core::graphql::primitives::U64(
*row.liquidity_provider_trading_fees,
),
creator_trading_fee_protocol_fees: carbon_core::graphql::primitives::U64(
*row.creator_trading_fee_protocol_fees,
),
reflection_trading_fees: carbon_core::graphql::primitives::U64(
*row.reflection_trading_fees,
),
created_at_slot: carbon_core::graphql::primitives::U64(*row.created_at_slot),
trading_volume_usd: row.trading_volume_usd,
creator_trading_fee_trading_volume_threshold: row
.creator_trading_fee_trading_volume_threshold,
creator_trading_fee_trading_volume_threshold_reached_unix_timestamp:
carbon_core::graphql::primitives::U64(
*row.creator_trading_fee_trading_volume_threshold_reached_unix_timestamp,
),
token_a_vault: carbon_core::graphql::primitives::Pubkey(row.token_a_vault.0),
token_b_vault: carbon_core::graphql::primitives::Pubkey(row.token_b_vault.0),
protocol_config: carbon_core::graphql::primitives::Pubkey(row.protocol_config.0),
key: carbon_core::graphql::primitives::Pubkey(row.key.0),
token_a: row.token_a.0.into(),
token_b: row.token_b.0.into(),
allowlist: row.allowlist.0.into(),
feature_flags: row.feature_flags.0.into(),
taxable_side: carbon_core::graphql::primitives::U8((*row.taxable_side) as u8),
taxable_side_type: carbon_core::graphql::primitives::U8((*row.taxable_side_type) as u8),
creator_trading_fee_distribution: carbon_core::graphql::primitives::U8(
(*row.creator_trading_fee_distribution) as u8,
),
creator_trading_fee_claim_status: carbon_core::graphql::primitives::U8(
(*row.creator_trading_fee_claim_status) as u8,
),
fee_configuration_mode: carbon_core::graphql::primitives::U8(
(*row.fee_configuration_mode) as u8,
),
is_migrated: carbon_core::graphql::primitives::U8((*row.is_migrated) as u8),
pad: row
.pad
.into_iter()
.map(carbon_core::graphql::primitives::U8)
.collect(),
slot_offset_based_fees: row.slot_offset_based_fees.0.into(),
creator_trading_fee_receiver: carbon_core::graphql::primitives::Pubkey(
row.creator_trading_fee_receiver.0,
),
})
}
}