Meteora Pools decoder

carbon-meteora-pools-decoder decodes the instructions, accounts and events of the Meteora Pools program (Eo7WjKq67rjJQSZxS6z3YkapzY3eMj6Xy8X5EQVn5UaB): 26 instructions, 3 account types, 18 events. It is generated with Codama from the program's IDL; see decoders for how decoders plug into a pipeline.

Other DEX and AMM decoders: BonkSwap, FluxBeam, Gavel, Heaven, Jupiter Limit Order, Jupiter Limit Order v2, Kamino Limit Order, Lifinity AMM v2, Meteora DAMM v2, Meteora DLMM, OpenBook v2, Orca Whirlpools, PancakeSwap, Phoenix v1, PumpSwap, Raydium AMM v4, Raydium CLMM, Raydium CPMM, Raydium Stable Swap, Stabble Stable Swap, Stabble Weighted Swap. To decode several in one pipeline, see dEX and AMM decoders.

The serde feature derives Serialize/Deserialize on every type, postgres adds tables and processors for Postgres, and graphql adds a schema for the GraphQL server.

Usage#

This program crawls recent Meteora Pools transactions from the public RPC and prints every decoded Swap instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-meteora-pools-decoder@2.0.0 carbon-rpc-transaction-crawler-datasource@2.0.0 carbon-log-metrics@2.0.0 env_logger tokio --features tokio/full

use {
    carbon_core::{
        error::CarbonResult, instruction::InstructionProcessorInputType, pipeline::Pipeline,
        processor::Processor,
    },
    carbon_log_metrics::LogMetrics,
    carbon_meteora_pools_decoder::{
        instructions::MeteoraPoolsInstruction, MeteoraPoolsDecoder, PROGRAM_ID,
    },
    carbon_rpc_transaction_crawler_datasource::{ConnectionConfig, Filters, RpcTransactionCrawler},
    std::sync::Arc,
};

#[tokio::main]
async fn main() -> CarbonResult<()> {
    env_logger::init();

    // Fetches the program's recent transactions over JSON-RPC, newest first.
    let datasource = RpcTransactionCrawler::new(
        "https://api.mainnet-beta.solana.com".to_string(),
        PROGRAM_ID,
        ConnectionConfig::default(),
        Filters::new(None, None, None),
        None,
    );

    Pipeline::builder()
        .datasource(datasource)
        .metrics(Arc::new(LogMetrics::new()))
        .instruction(MeteoraPoolsDecoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

impl Processor<InstructionProcessorInputType<'_, MeteoraPoolsInstruction>> for InstructionLogger {
    async fn process(
        &mut self,
        input: &InstructionProcessorInputType<'_, MeteoraPoolsInstruction>,
    ) -> CarbonResult<()> {
        let signature = input.metadata.transaction_metadata.signature;
        if let MeteoraPoolsInstruction::Swap { data, accounts, .. } = input.decoded_instruction {
            println!("swap {signature}: {data:?} pool={}", accounts.pool);
        }
        Ok(())
    }
}

RUST_LOG=info cargo run

Each Swap instruction prints one line with the transaction signature and the decoded Swap data. The public endpoint rate-limits requests, so the first lines can take a while; use your own RPC URL for anything beyond a test. See stream with RPC for the crawler options.

Events published with Anchor's emit_cpi! arrive as the CpiEvent instruction. Match them with MeteoraPoolsInstruction::CpiEvent { data: CpiEvent::AddLiquidity(event), .. } (import instructions::CpiEvent); see Events. If CpiEvent never arrives, the program logs its events with emit! instead: decode them with decode_log_events.

Decode accounts#

The transaction crawler emits transactions only. To decode accounts, use a datasource that emits account updates. This program subscribes to the program's accounts with programSubscribe on the public WebSocket endpoint and prints every decoded Pool account as it changes. Add the datasource and the Solana RPC types it takes:

cargo add carbon-rpc-program-subscribe-datasource@2.0.0 solana-client@4.2.2

use {
    carbon_core::{
        account::AccountProcessorInputType, error::CarbonResult, pipeline::Pipeline,
        processor::Processor,
    },
    carbon_log_metrics::LogMetrics,
    carbon_meteora_pools_decoder::{accounts::MeteoraPoolsAccount, MeteoraPoolsDecoder, PROGRAM_ID},
    carbon_rpc_program_subscribe_datasource::{Filters, RpcProgramSubscribe},
    solana_client::rpc_config::{RpcAccountInfoConfig, RpcProgramAccountsConfig, UiAccountEncoding},
    std::sync::Arc,
};

#[tokio::main]
async fn main() -> CarbonResult<()> {
    env_logger::init();

    // Streams every change to an account owned by the program (programSubscribe).
    let config = RpcProgramAccountsConfig {
        account_config: RpcAccountInfoConfig {
            encoding: Some(UiAccountEncoding::Base64),
            ..Default::default()
        },
        ..Default::default()
    };
    let datasource = RpcProgramSubscribe::new(
        "wss://api.mainnet-beta.solana.com".to_string(),
        Filters::new(PROGRAM_ID, Some(config)),
    );

    Pipeline::builder()
        .datasource(datasource)
        .metrics(Arc::new(LogMetrics::new()))
        .account(MeteoraPoolsDecoder, AccountLogger)
        .build()?
        .run()
        .await
}

struct AccountLogger;

impl Processor<AccountProcessorInputType<'_, MeteoraPoolsAccount>> for AccountLogger {
    async fn process(
        &mut self,
        input: &AccountProcessorInputType<'_, MeteoraPoolsAccount>,
    ) -> CarbonResult<()> {
        if let MeteoraPoolsAccount::Pool(pool) = &input.decoded_account.data {
            println!("pool {}: {pool:?}", input.metadata.pubkey);
        }
        Ok(())
    }
}

RUST_LOG=info cargo run

Each update to a Pool account prints its address and decoded fields; the program runs until you stop it. Cargo resolves solana-client to 4.2.2, the exact version the datasource pins, so both use the same RpcProgramAccountsConfig type. To load every existing account once instead of streaming changes, see load account state.

Instructions#

Variants of MeteoraPoolsInstruction. Each is MeteoraPoolsInstruction::<Variant> { program_id, data, accounts }, where data and accounts are the types listed under the variant, exported from carbon_meteora_pools_decoder::instructions. Discriminators are the leading bytes of the instruction data, in hex.

How an instruction decodes. The decoder returns a variant only when all of these hold; otherwise the instruction is skipped and no processor is called:

1. The instruction's program ID is Eo7WjKq67rjJQSZxS6z3YkapzY3eMj6Xy8X5EQVn5UaB.
2. The data starts with the variant's discriminator, and the rest deserializes into its data type.
3. The instruction has at least as many accounts as the variant requires (the "Required accounts" count under each variant).

Accounts. They are matched by position, in the order listed. An account marked optional is None only when the instruction ends before it; Anchor programs pass the program ID as a placeholder for an omitted optional account, so check for Some(PROGRAM_ID) too. Accounts after the listed ones are in accounts.remaining as AccountMetas. The decoder doesn't record whether an account signed or was writable: read that from input.raw_instruction.accounts[i].is_signer and .is_writable, which follow the same order. It doesn't check signer, writable, owner or PDA constraints either; the program enforced those when the transaction executed, so a decoded instruction from a successful transaction already satisfied them.

AddBalanceLiquidity#

From the program's IDL:

Deposit tokens to the pool in a balanced ratio.

Discriminator a8e3323ebdab54b0 · data AddBalanceLiquidity · accounts AddBalanceLiquidityInstructionAccounts.

Required accounts: 16; extras go to remaining.

Fields of AddBalanceLiquidityInstructionAccounts, in account order:

AddImbalanceLiquidity#

From the program's IDL:

Deposit tokens to the pool in an imbalance ratio. Only supported by pool with stable swap curve.

Discriminator 4f237a54ad0f5dbf · data AddImbalanceLiquidity · accounts AddImbalanceLiquidityInstructionAccounts.

Required accounts: 16; extras go to remaining.

Fields of AddImbalanceLiquidityInstructionAccounts, in account order:

BootstrapLiquidity#

From the program's IDL:

Bootstrap the pool when liquidity is depleted.

Discriminator 04e4d747e1fd77ce · data BootstrapLiquidity · accounts BootstrapLiquidityInstructionAccounts.

Required accounts: 16; extras go to remaining.

Fields of BootstrapLiquidityInstructionAccounts, in account order:

ClaimFee#

From the program's IDL:

Claim fee

Discriminator a9204f8988e84689 · data ClaimFee · accounts ClaimFeeInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of ClaimFeeInstructionAccounts, in account order:

CloseConfig#

From the program's IDL:

Close config

Discriminator 9109489d5f7d3d55 · data CloseConfig · accounts CloseConfigInstructionAccounts.

No data fields.

Required accounts: 3; extras go to remaining.

Fields of CloseConfigInstructionAccounts, in account order:

CreateConfig#

From the program's IDL:

Create config

Discriminator c9cff3724b6f2fbd · data CreateConfig · accounts CreateConfigInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of CreateConfigInstructionAccounts, in account order:

CreateLockEscrow#

From the program's IDL:

Create lock account

Discriminator 3657a51345e3dae0 · data CreateLockEscrow · accounts CreateLockEscrowInstructionAccounts.

No data fields.

Required accounts: 6; extras go to remaining.

Fields of CreateLockEscrowInstructionAccounts, in account order:

CreateMintMetadata#

From the program's IDL:

Create mint metadata account for old pools

Discriminator 0d46a829fa64945a · data CreateMintMetadata · accounts CreateMintMetadataInstructionAccounts.

No data fields.

Required accounts: 7; extras go to remaining.

Fields of CreateMintMetadataInstructionAccounts, in account order:

EnableOrDisablePool#

From the program's IDL:

Enable or disable a pool. A disabled pool allow only remove balanced liquidity operation.

Discriminator 8006e48337a134a9 · data EnableOrDisablePool · accounts EnableOrDisablePoolInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of EnableOrDisablePoolInstructionAccounts, in account order:

GetPoolInfo#

From the program's IDL:

Get the general information of the pool.

Discriminator 0930dc6516f04ec8 · data GetPoolInfo · accounts GetPoolInfoInstructionAccounts.

No data fields.

Required accounts: 8; extras go to remaining.

Fields of GetPoolInfoInstructionAccounts, in account order:

InitializeCustomizablePermissionlessConstantProductPool#

From the program's IDL:

Initialize permissionless pool with customizable params

Discriminator 9118acc2db7d03be · data InitializeCustomizablePermissionlessConstantProductPool · accounts InitializeCustomizablePermissionlessConstantProductPoolInstructionAccounts.

Required accounts: 25; extras go to remaining.

Fields of InitializeCustomizablePermissionlessConstantProductPoolInstructionAccounts, in account order:

InitializePermissionedPool#

From the program's IDL:

Initialize a new permissioned pool.

Discriminator 4d55b29d3230d47e · data InitializePermissionedPool · accounts InitializePermissionedPoolInstructionAccounts.

Required accounts: 24; extras go to remaining.

Fields of InitializePermissionedPoolInstructionAccounts, in account order:

InitializePermissionlessConstantProductPoolWithConfig#

From the program's IDL:

Initialize permissionless pool with config

Discriminator 07a68aabceabecf4 · data InitializePermissionlessConstantProductPoolWithConfig · accounts InitializePermissionlessConstantProductPoolWithConfigInstructionAccounts.

Required accounts: 26; extras go to remaining.

Fields of InitializePermissionlessConstantProductPoolWithConfigInstructionAccounts, in account order:

InitializePermissionlessConstantProductPoolWithConfig2#

From the program's IDL:

Initialize permissionless pool with config 2

Discriminator 3095dc823d0b09b2 · data InitializePermissionlessConstantProductPoolWithConfig2 · accounts InitializePermissionlessConstantProductPoolWithConfig2InstructionAccounts.

Required accounts: 26; extras go to remaining.

Fields of InitializePermissionlessConstantProductPoolWithConfig2InstructionAccounts, in account order:

InitializePermissionlessPool#

From the program's IDL:

Initialize a new permissionless pool.

Discriminator 76ad299dad486167 · data InitializePermissionlessPool · accounts InitializePermissionlessPoolInstructionAccounts.

Required accounts: 26; extras go to remaining.

Fields of InitializePermissionlessPoolInstructionAccounts, in account order:

InitializePermissionlessPoolWithFeeTier#

From the program's IDL:

Initialize a new permissionless pool with customized fee tier

Discriminator 06874493e552a971 · data InitializePermissionlessPoolWithFeeTier · accounts InitializePermissionlessPoolWithFeeTierInstructionAccounts.

Required accounts: 26; extras go to remaining.

Fields of InitializePermissionlessPoolWithFeeTierInstructionAccounts, in account order:

Lock#

From the program's IDL:

Lock Lp token

Discriminator 1513d02bed3eff57 · data Lock · accounts LockInstructionAccounts.

Required accounts: 13; extras go to remaining.

Fields of LockInstructionAccounts, in account order:

OverrideCurveParam#

From the program's IDL:

Update swap curve parameters. This function do not allow update of curve type. For example: stable swap curve to constant product curve. Only supported by pool with stable swap curve. Only amp is allowed to be override. The other attributes of stable swap curve will be ignored.

Discriminator 6256cc335e4745bb · data OverrideCurveParam · accounts OverrideCurveParamInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of OverrideCurveParamInstructionAccounts, in account order:

PartnerClaimFee#

From the program's IDL:

Partner claim fee

Discriminator 3935b01e7b463440 · data PartnerClaimFee · accounts PartnerClaimFeeInstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of PartnerClaimFeeInstructionAccounts, in account order:

RemoveBalanceLiquidity#

From the program's IDL:

Withdraw tokens from the pool in a balanced ratio. User will still able to withdraw from pool even the pool is disabled. This allow user to exit their liquidity when there's some unforeseen event happen.

Discriminator 856d2cb338ee7221 · data RemoveBalanceLiquidity · accounts RemoveBalanceLiquidityInstructionAccounts.

Required accounts: 16; extras go to remaining.

Fields of RemoveBalanceLiquidityInstructionAccounts, in account order:

RemoveLiquiditySingleSide#

From the program's IDL:

Withdraw only single token from the pool. Only supported by pool with stable swap curve.

Discriminator 5454b142feb90afb · data RemoveLiquiditySingleSide · accounts RemoveLiquiditySingleSideInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of RemoveLiquiditySingleSideInstructionAccounts, in account order:

SetPoolFees#

From the program's IDL:

Update trading fee charged for liquidity provider, and admin.

Discriminator 662c9e36cd257e4e · data SetPoolFees · accounts SetPoolFeesInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of SetPoolFeesInstructionAccounts, in account order:

SetWhitelistedVault#

From the program's IDL:

Set whitelisted vault

Discriminator 0c945e2a373953f7 · data SetWhitelistedVault · accounts SetWhitelistedVaultInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of SetWhitelistedVaultInstructionAccounts, in account order:

Swap#

From the program's IDL:

Swap token A to B, or vice versa. An amount of trading fee will be charged for liquidity provider, and the admin of the pool.

Discriminator f8c69e91e17587c8 · data Swap · accounts SwapInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of SwapInstructionAccounts, in account order:

UpdateActivationPoint#

From the program's IDL:

Update activation slot

Discriminator 963e7ddbabdc1aed · data UpdateActivationPoint · accounts UpdateActivationPointInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateActivationPointInstructionAccounts, in account order:

WithdrawProtocolFees#

From the program's IDL:

Withdraw protocol fee

Discriminator 0b44a56212d08649 · data WithdrawProtocolFees · accounts WithdrawProtocolFeesInstructionAccounts.

No data fields.

Required accounts: 7; extras go to remaining.

Fields of WithdrawProtocolFeesInstructionAccounts, in account order:

CpiEvent#

Anchor self-CPI that carries one of the program's events. data is the CpiEvent enum.

Discriminator e445a52e51cb9a1d · data CpiEvent · accounts CpiEventInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of CpiEventInstructionAccounts, in account order:

Accounts#

Variants of MeteoraPoolsAccount. Each wraps a boxed struct from carbon_meteora_pools_decoder::accounts::<module>. decode_account only considers accounts owned by PROGRAM_ID and returns the first variant that matches.

Config#

Discriminator 9b0caae01efacc82 · accounts::config::Config.

LockEscrow#

From the program's IDL:

State of lock escrow account

Discriminator be6a7906c8b6154b · accounts::lock_escrow::LockEscrow.

Pool#

From the program's IDL:

State of pool account

Discriminator f19a6d0411b16dbc · accounts::pool::Pool.

Events#

Variants of instructions::CpiEvent, decoded from the CpiEvent instruction. Each wraps a struct from carbon_meteora_pools_decoder::events::<module>. The discriminator is the 8-byte event discriminator that follows the e445a52e51cb9a1d CPI-event tag.

AddLiquidity#

Discriminator 1f5e7d5ae3343dba · events::add_liquidity::AddLiquidityEvent.

RemoveLiquidity#

Discriminator 74f461e8671f983a · events::remove_liquidity::RemoveLiquidityEvent.

BootstrapLiquidity#

Discriminator 797f26885c370ef7 · events::bootstrap_liquidity::BootstrapLiquidityEvent.

Swap#

Discriminator 516ce3becdd00ac4 · events::swap::SwapEvent.

SetPoolFees#

Discriminator f51ac6a458124b09 · events::set_pool_fees::SetPoolFeesEvent.

PoolInfo#

Discriminator cf145761fbd4ea2d · events::pool_info::PoolInfoEvent.

TransferAdmin#

Discriminator e4a983f43d3841fe · events::transfer_admin::TransferAdminEvent.

OverrideCurveParam#

Discriminator f714a5f84b0536f6 · events::override_curve_param::OverrideCurveParamEvent.

PoolCreated#

Discriminator ca2c295868dc9d52 · events::pool_created::PoolCreatedEvent.

PoolEnabled#

Discriminator 02971253cc865cbf · events::pool_enabled::PoolEnabledEvent.

MigrateFeeAccount#

Discriminator dfeae81afc69b47d · events::migrate_fee_account::MigrateFeeAccountEvent.

CreateLockEscrow#

Discriminator 4a5e6a8d3111626d · events::create_lock_escrow::CreateLockEscrowEvent.

Lock#

Discriminator dcb743d799cf38ea · events::lock::LockEvent.

ClaimFee#

Discriminator 4b7a9a308c4a7ba3 · events::claim_fee::ClaimFeeEvent.

CreateConfig#

Discriminator c7980a1327279d68 · events::create_config::CreateConfigEvent.

CloseConfig#

Discriminator f9b56c5904965aae · events::close_config::CloseConfigEvent.

WithdrawProtocolFees#

Discriminator 1ef0cfc48bef4f1c · events::withdraw_protocol_fees::WithdrawProtocolFeesEvent.

PartnerClaimFees#

Discriminator 87830a5e77d1ca30 · events::partner_claim_fees::PartnerClaimFeesEvent.

Types#

Types used by the instructions, accounts and events above, exported from carbon_meteora_pools_decoder::types.

ActivationType#

From the program's IDL:

Type of the activation

Enum types::ActivationType.

AddLiquidity#

Struct types::AddLiquidity. Same fields as the AddLiquidity event.

BootstrapLiquidity#

Struct types::BootstrapLiquidity. Same fields as the BootstrapLiquidity event.

Bootstrapping#

Struct types::Bootstrapping.

ClaimFee#

Struct types::ClaimFee. Same fields as the ClaimFee event.

CloseConfig#

Struct types::CloseConfig. Same fields as the CloseConfig event.

ConfigParameters#

Struct types::ConfigParameters.

CreateConfig#

Struct types::CreateConfig. Same fields as the CreateConfig event.

CreateLockEscrow#

Struct types::CreateLockEscrow. Same fields as the CreateLockEscrow event.

CurveType#

From the program's IDL:

Type of the swap curve

Enum types::CurveType.

Stable fields:

CustomizableParams#

Struct types::CustomizableParams.

Depeg#

From the program's IDL:

Contains information for depeg pool

Struct types::Depeg.

DepegType#

From the program's IDL:

Type of depeg pool

Enum types::DepegType.

Lock#

Struct types::Lock. Same fields as the Lock event.

MigrateFeeAccount#

Struct types::MigrateFeeAccount. Same fields as the MigrateFeeAccount event.

NewCurveType#

From the program's IDL:

Type of the swap curve

Enum types::NewCurveType.

Stable fields:

OverrideCurveParam#

Struct types::OverrideCurveParam. Same fields as the OverrideCurveParam event.

Padding#

From the program's IDL:

Padding for future pool fields

Struct types::Padding.

PartnerClaimFees#

Struct types::PartnerClaimFees. Same fields as the PartnerClaimFees event.

PartnerInfo#

Struct types::PartnerInfo.

PoolCreated#

Struct types::PoolCreated. Same fields as the PoolCreated event.

PoolEnabled#

Struct types::PoolEnabled. Same fields as the PoolEnabled event.

PoolFees#

From the program's IDL:

Information regarding fee charges

Struct types::PoolFees.

PoolInfo#

Struct types::PoolInfo. Same fields as the PoolInfo event.

PoolType#

From the program's IDL:

Pool type

Enum types::PoolType.

RemoveLiquidity#

Struct types::RemoveLiquidity. Same fields as the RemoveLiquidity event.

RoundDirection#

From the program's IDL:

Rounding direction

Enum types::RoundDirection.

Rounding#

From the program's IDL:

Round up, down

Enum types::Rounding.

SetPoolFees#

Struct types::SetPoolFees. Same fields as the SetPoolFees event.

Swap#

Struct types::Swap. Same fields as the Swap event.

TokenMultiplier#

From the program's IDL:

Multiplier for the pool token. Used to normalized token with different decimal into the same precision.

Struct types::TokenMultiplier.

TradeDirection#

From the program's IDL:

Trade (swap) direction

Enum types::TradeDirection.

TransferAdmin#

Struct types::TransferAdmin. Same fields as the TransferAdmin event.

WithdrawProtocolFees#

Struct types::WithdrawProtocolFees. Same fields as the WithdrawProtocolFees event.