feat: carbon-heaven-decoder

Author: technoch1ef

Cargo.lock

@@ -0,0 +1,21 @@
+[package]
+name = "carbon-heaven-decoder"
+version = "0.9.1"
+description = "Heaven DEX Program Decoder"
+edition = { workspace = true }
+license = { workspace = true }
+readme = "README.md"
+repository = { workspace = true }
+keywords = ["solana", "decoder", "heaven"]
+categories = ["encoding"]
+
+[lib]
+crate-type = ["rlib"]
+
+[dependencies]
+carbon-core = { workspace = true }
+serde = { workspace = true }
+solana-account = { workspace = true }
+serde-big-array = { workspace = true }
+solana-instruction = { workspace = true, default-features = false }
+solana-pubkey = { workspace = true }

decoders/heaven-decoder/Cargo.toml

@@ -0,0 +1,40 @@
+use super::super::types::*;
+
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize)]
+#[carbon(discriminator = "0xbe9edc820fa284fc")]
+pub struct LiquidityPoolState {
+    pub info: LiquidityPoolInfo,
+    pub market_cap_based_fees: LiquidityPoolMarketCapBasedFees,
+    pub reserve: LiquidityPoolReserve,
+    pub lp_token: LiquidityPoolLpTokenInfo,
+    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: solana_pubkey::Pubkey,
+    pub token_b_vault: solana_pubkey::Pubkey,
+    pub protocol_config: solana_pubkey::Pubkey,
+    pub key: solana_pubkey::Pubkey,
+    pub token_a: LiquidityPoolTokenInfo,
+    pub token_b: LiquidityPoolTokenInfo,
+    pub allowlist: LiquidityPoolAllowlist,
+    pub feature_flags: LiquidityPoolFeatureFlags,
+    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: [u8; 13],
+    pub slot_offset_based_fees: LiquidityPoolSlotOffsetBasedFees,
+    pub creator_trading_fee_receiver: solana_pubkey::Pubkey,
+}

decoders/heaven-decoder/README.md

@@ -0,0 +1,87 @@
+use carbon_core::account::AccountDecoder;
+use carbon_core::deserialize::CarbonDeserialize;
+
+use super::HeavenDecoder;
+pub mod liquidity_pool_state;
+pub mod msol_ticket_sol_spent;
+pub mod protocol_admin_state;
+pub mod protocol_config;
+pub mod protocol_owner_state;
+
+pub enum HeavenAccount {
+    LiquidityPoolState(liquidity_pool_state::LiquidityPoolState),
+    MsolTicketSolSpent(msol_ticket_sol_spent::MsolTicketSolSpent),
+    ProtocolAdminState(protocol_admin_state::ProtocolAdminState),
+    ProtocolConfig(protocol_config::ProtocolConfig),
+    ProtocolOwnerState(protocol_owner_state::ProtocolOwnerState),
+}
+
+impl AccountDecoder<'_> for HeavenDecoder {
+    type AccountType = HeavenAccount;
+    fn decode_account(
+        &self,
+        account: &solana_account::Account,
+    ) -> Option<carbon_core::account::DecodedAccount<Self::AccountType>> {
+        if let Some(decoded_account) =
+            liquidity_pool_state::LiquidityPoolState::deserialize(account.data.as_slice())
+        {
+            return Some(carbon_core::account::DecodedAccount {
+                lamports: account.lamports,
+                data: HeavenAccount::LiquidityPoolState(decoded_account),
+                owner: account.owner,
+                executable: account.executable,
+                rent_epoch: account.rent_epoch,
+            });
+        }
+
+        if let Some(decoded_account) =
+            msol_ticket_sol_spent::MsolTicketSolSpent::deserialize(account.data.as_slice())
+        {
+            return Some(carbon_core::account::DecodedAccount {
+                lamports: account.lamports,
+                data: HeavenAccount::MsolTicketSolSpent(decoded_account),
+                owner: account.owner,
+                executable: account.executable,
+                rent_epoch: account.rent_epoch,
+            });
+        }
+
+        if let Some(decoded_account) =
+            protocol_admin_state::ProtocolAdminState::deserialize(account.data.as_slice())
+        {
+            return Some(carbon_core::account::DecodedAccount {
+                lamports: account.lamports,
+                data: HeavenAccount::ProtocolAdminState(decoded_account),
+                owner: account.owner,
+                executable: account.executable,
+                rent_epoch: account.rent_epoch,
+            });
+        }
+
+        if let Some(decoded_account) =
+            protocol_config::ProtocolConfig::deserialize(account.data.as_slice())
+        {
+            return Some(carbon_core::account::DecodedAccount {
+                lamports: account.lamports,
+                data: HeavenAccount::ProtocolConfig(decoded_account),
+                owner: account.owner,
+                executable: account.executable,
+                rent_epoch: account.rent_epoch,
+            });
+        }
+
+        if let Some(decoded_account) =
+            protocol_owner_state::ProtocolOwnerState::deserialize(account.data.as_slice())
+        {
+            return Some(carbon_core::account::DecodedAccount {
+                lamports: account.lamports,
+                data: HeavenAccount::ProtocolOwnerState(decoded_account),
+                owner: account.owner,
+                executable: account.executable,
+                rent_epoch: account.rent_epoch,
+            });
+        }
+
+        None
+    }
+}

decoders/heaven-decoder/src/accounts/liquidity_pool_state.rs

@@ -0,0 +1,8 @@
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize)]
+#[carbon(discriminator = "0x42c43e867c95fa42")]
+pub struct MsolTicketSolSpent {
+    pub cost_basis: u64,
+    pub msol_unstaked: u64,
+}

decoders/heaven-decoder/src/accounts/mod.rs

@@ -0,0 +1,7 @@
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize)]
+#[carbon(discriminator = "0x187caee1e81e73c0")]
+pub struct ProtocolAdminState {
+    pub current_protocol_admin: solana_pubkey::Pubkey,
+}

decoders/heaven-decoder/src/accounts/msol_ticket_sol_spent.rs

@@ -0,0 +1,34 @@
+use super::super::types::*;
+
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize)]
+#[carbon(discriminator = "0xcf5bfa1c98b3d7d1")]
+pub struct ProtocolConfig {
+    pub create_pool_fee: u64,
+    pub initial_token_b_amount: f64,
+    pub initial_token_a_amount: u64,
+    pub unstaked_wsol_reserve: u64,
+    pub total_sol_spent: u64,
+    pub total_msol_received: u64,
+    pub total_realized_profit: u64,
+    pub pool_count: u64,
+    pub max_supply_per_wallet: u64,
+    pub creator_trading_fee_trading_volume_threshold: f64,
+    pub market_cap_based_fees: LiquidityPoolMarketCapBasedFees,
+    pub buffer_bps: u16,
+    pub auto_staking_threshold_bps: u16,
+    pub version: u16,
+    pub protocol_config_state_bump: u8,
+    pub allow_create_pool: u8,
+    pub supported_pool_type: u8,
+    pub default_leader_slot_window: u8,
+    pub auto_staking_enabled: u8,
+    pub leader_slot_window: u8,
+    pub sandwich_resistence_enabled: u8,
+    pub token_a_decimals: u8,
+    pub migration_market_cap_threshold: u16,
+    pub pad: [u8; 8],
+    pub max_creator_trading_fee: u32,
+    pub slot_offset_based_fees: LiquidityPoolSlotOffsetBasedFees,
+}

decoders/heaven-decoder/src/accounts/protocol_admin_state.rs

@@ -0,0 +1,7 @@
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize)]
+#[carbon(discriminator = "0xd040d1cc71e21662")]
+pub struct ProtocolOwnerState {
+    pub current_protocol_owner: solana_pubkey::Pubkey,
+}

decoders/heaven-decoder/src/accounts/protocol_config.rs

@@ -0,0 +1,51 @@
+use carbon_core::{borsh, CarbonDeserialize};
+
+#[derive(
+    CarbonDeserialize, Debug, serde::Serialize, serde::Deserialize, PartialEq, Eq, Clone, Hash,
+)]
+#[carbon(discriminator = "0xcc485fd7acc089fc")]
+pub struct AdminBorrowSol {
+    pub version: u16,
+    pub amount: u64,
+}
+
+#[derive(Debug, PartialEq, Eq, Clone, Hash, serde::Serialize, serde::Deserialize)]
+pub struct AdminBorrowSolInstructionAccounts {
+    pub token_program: solana_pubkey::Pubkey,
+    pub associated_token_program: solana_pubkey::Pubkey,
+    pub payer: solana_pubkey::Pubkey,
+    pub admin: solana_pubkey::Pubkey,
+    pub protocol_config_state: solana_pubkey::Pubkey,
+    pub system_program: solana_pubkey::Pubkey,
+    pub protocol_staking_admin_state: solana_pubkey::Pubkey,
+    pub address_lookup_program: solana_pubkey::Pubkey,
+    pub instruction_sysvar_account_info: solana_pubkey::Pubkey,
+    pub temp_sol_holder: solana_pubkey::Pubkey,
+}
+
+impl carbon_core::deserialize::ArrangeAccounts for AdminBorrowSol {
+    type ArrangedAccounts = AdminBorrowSolInstructionAccounts;
+
+    fn arrange_accounts(
+        accounts: &[solana_instruction::AccountMeta],
+    ) -> Option<Self::ArrangedAccounts> {
+        let [token_program, associated_token_program, payer, admin, protocol_config_state, system_program, protocol_staking_admin_state, address_lookup_program, instruction_sysvar_account_info, temp_sol_holder, _remaining @ ..] =
+            accounts
+        else {
+            return None;
+        };
+
+        Some(AdminBorrowSolInstructionAccounts {
+            token_program: token_program.pubkey,
+            associated_token_program: associated_token_program.pubkey,
+            payer: payer.pubkey,
+            admin: admin.pubkey,
+            protocol_config_state: protocol_config_state.pubkey,
+            system_program: system_program.pubkey,
+            protocol_staking_admin_state: protocol_staking_admin_state.pubkey,
+            address_lookup_program: address_lookup_program.pubkey,
+            instruction_sysvar_account_info: instruction_sysvar_account_info.pubkey,
+            temp_sol_holder: temp_sol_holder.pubkey,
+        })
+    }
+}