Raydium AMM v4 decoder

carbon-raydium-amm-v4-decoder decodes the instructions and accounts of the Raydium AMM v4 program (675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8): 18 instructions, 3 account types. 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, Meteora Pools, OpenBook v2, Orca Whirlpools, PancakeSwap, Phoenix v1, PumpSwap, 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 Raydium AMM v4 transactions from the public RPC and prints every decoded SwapBaseIn instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-raydium-amm-v4-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_raydium_amm_v4_decoder::{
        instructions::RaydiumAmmV4Instruction, RaydiumAmmV4Decoder, 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(RaydiumAmmV4Decoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

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

RUST_LOG=info cargo run

Each SwapBaseIn instruction prints one line with the transaction signature and the decoded SwapBaseIn 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.

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 AmmInfo 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_raydium_amm_v4_decoder::{accounts::RaydiumAmmV4Account, RaydiumAmmV4Decoder, 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(RaydiumAmmV4Decoder, AccountLogger)
        .build()?
        .run()
        .await
}

struct AccountLogger;

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

RUST_LOG=info cargo run

Each update to a AmmInfo 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 RaydiumAmmV4Instruction. Each is RaydiumAmmV4Instruction::<Variant> { program_id, data, accounts }, where data and accounts are the types listed under the variant, exported from carbon_raydium_amm_v4_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 675kPX9MHTjS2zt1qfr1NYHuzeLXfQM9H24wFSUt1Mp8.
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.

AdminCancelOrders#

From the program's IDL:

Admin: cancel up to limit of the pool's open orders.

Discriminator 0d · data AdminCancelOrders · accounts AdminCancelOrdersInstructionAccounts.

Required accounts: 17 (18 listed); extras go to remaining.

Fields of AdminCancelOrdersInstructionAccounts, in account order:

CreateConfigAccount#

From the program's IDL:

Admin: create the singleton AmmConfig account.

Discriminator 0e · data CreateConfigAccount · accounts CreateConfigAccountInstructionAccounts.

No data fields.

Required accounts: 5; extras go to remaining.

Fields of CreateConfigAccountInstructionAccounts, in account order:

Deposit#

From the program's IDL:

Deposit tokens into the pool. Mints LP tokens to the user.

Discriminator 03 · data Deposit · accounts DepositInstructionAccounts.

Required accounts: 14; extras go to remaining.

Fields of DepositInstructionAccounts, in account order:

Initialize#

From the program's IDL:

Deprecated. Use initialize2.

Discriminator 00 · data Initialize · accounts InitializeInstructionAccounts.

Required accounts: 16; extras go to remaining.

Fields of InitializeInstructionAccounts, in account order:

Initialize2#

From the program's IDL:

Initializes a new AMM pool.

Discriminator 01 · data Initialize2 · accounts Initialize2InstructionAccounts.

Required accounts: 21; extras go to remaining.

Fields of Initialize2InstructionAccounts, in account order:

MigrateToOpenBook#

From the program's IDL:

Migrate the associated market from Serum to OpenBook.

Discriminator 05 · data MigrateToOpenBook · accounts MigrateToOpenBookInstructionAccounts.

No data fields.

Required accounts: 21; extras go to remaining.

Fields of MigrateToOpenBookInstructionAccounts, in account order:

MonitorStep#

From the program's IDL:

Step the AMM order-book state machine.

Discriminator 02 · data MonitorStep · accounts MonitorStepInstructionAccounts.

Required accounts: 18 (20 listed); extras go to remaining.

Fields of MonitorStepInstructionAccounts, in account order:

PreInitialize#

From the program's IDL:

Deprecated. Use initialize2.

Discriminator 0a · data PreInitialize · accounts PreInitializeInstructionAccounts.

Required accounts: 14; extras go to remaining.

Fields of PreInitializeInstructionAccounts, in account order:

SetParams#

From the program's IDL:

Admin: set an AMM parameter. The payload after param depends on the variant:

• ammOwner: 32-byte Pubkey
• fees: 64-byte Fees struct
• lastOrderDistance: numerator(u64) + denominator(u64)
• all other variants: value(u64)

Only value, newPubkey, fees, or lastOrderDistance is populated based on param.

Discriminator 06 · data SetParams · accounts SetParamsInstructionAccounts.

Required accounts: 16 (17 listed); extras go to remaining.

Fields of SetParamsInstructionAccounts, in account order:

SimulateInfo#

From the program's IDL:

Simulation-only instruction (used via simulateTransaction).
Payload after param depends on the variant:

• poolInfo / runCrankInfo: no extra payload
• swapBaseInInfo: amountIn(u64) + minimumAmountOut(u64)
• swapBaseOutInfo: maxAmountIn(u64) + amountOut(u64)

Discriminator 0c · data SimulateInfo · accounts SimulateInfoInstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of SimulateInfoInstructionAccounts, in account order:

SwapBaseIn#

From the program's IDL:

Swap a fixed input amount with a slippage-bounded output.

Discriminator 09 · data SwapBaseIn · accounts SwapBaseInInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of SwapBaseInInstructionAccounts, in account order:

SwapBaseInV2#

From the program's IDL:

Order-book-disabled swap with fixed input amount.

Discriminator 10 · data SwapBaseInV2 · accounts SwapBaseInV2InstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of SwapBaseInV2InstructionAccounts, in account order:

SwapBaseOut#

From the program's IDL:

Swap to receive a fixed output amount with a slippage-bounded input.

Discriminator 0b · data SwapBaseOut · accounts SwapBaseOutInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of SwapBaseOutInstructionAccounts, in account order:

SwapBaseOutV2#

From the program's IDL:

Order-book-disabled swap with fixed output amount.

Discriminator 11 · data SwapBaseOutV2 · accounts SwapBaseOutV2InstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of SwapBaseOutV2InstructionAccounts, in account order:

UpdateConfigAccount#

From the program's IDL:

Admin: update the AmmConfig. Payload after param depends on the variant:

• pnlOwner / cancelOrderOwner: 32-byte Pubkey
• createPoolFee: u64

Discriminator 0f · data UpdateConfigAccount · accounts UpdateConfigAccountInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateConfigAccountInstructionAccounts, in account order:

Withdraw#

From the program's IDL:

Burn LP tokens and withdraw the underlying assets.

Discriminator 04 · data Withdraw · accounts WithdrawInstructionAccounts.

Required accounts: 20; extras go to remaining.

Fields of WithdrawInstructionAccounts, in account order:

WithdrawPnl#

From the program's IDL:

Protocol: withdraw accrued PnL from the pool.

Discriminator 07 · data WithdrawPnl · accounts WithdrawPnlInstructionAccounts.

No data fields.

Required accounts: 17 (18 listed); extras go to remaining.

Fields of WithdrawPnlInstructionAccounts, in account order:

WithdrawSrm#

From the program's IDL:

Admin: withdraw (M)SRM held for fee discounts.

Discriminator 08 · data WithdrawSrm · accounts WithdrawSrmInstructionAccounts.

Required accounts: 6; extras go to remaining.

Fields of WithdrawSrmInstructionAccounts, in account order:

Accounts#

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

AmmConfig#

From the program's IDL:

Global program config account.

Matched by data length (544 bytes) · accounts::amm_config::AmmConfig.

AmmInfo#

From the program's IDL:

On-chain state of a single AMM pool.

Matched by data length (752 bytes) · accounts::amm_info::AmmInfo.

TargetOrders#

From the program's IDL:

Per-pool target orders book.

No discriminator (matched by Borsh layout) · accounts::target_orders::TargetOrders.

Types#

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

AmmParams#

From the program's IDL:

SetParams.param values.

Enum types::AmmParams.

AmmResetFlag#

Enum types::AmmResetFlag.

AmmState#

From the program's IDL:

AmmInfo.state machine (stored as u64).

Enum types::AmmState.

AmmStatus#

From the program's IDL:

AmmInfo.status discriminator (stored as u64).

Enum types::AmmStatus.

ConfigParam#

From the program's IDL:

UpdateConfigAccount.param values.

Enum types::ConfigParam.

Fees#

From the program's IDL:

Fee parameters for a pool.

Struct types::Fees.

LastOrderDistance#

Struct types::LastOrderDistance.

SimulateParams#

From the program's IDL:

SimulateInfo.param values.

Enum types::SimulateParams.

StateData#

From the program's IDL:

Mutable pool statistics embedded in AmmInfo.

Struct types::StateData.

SwapInstructionBaseIn#

Struct types::SwapInstructionBaseIn.

SwapInstructionBaseOut#

Struct types::SwapInstructionBaseOut.

TargetOrder#

Struct types::TargetOrder.