Raydium Stable Swap decoder

carbon-raydium-stable-swap-decoder decodes the instructions of the Raydium Stable Swap program (5quBtoiQqxF9Jv6KYKctB59NT3gtJD2Y65kdnB1Uev3h): 6 instructions. It decodes no accounts: RaydiumStableSwapAccount has no variants. 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 AMM v4, Raydium CLMM, Raydium CPMM, 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 Stable Swap transactions from the public RPC and prints every decoded SwapBaseIn instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-raydium-stable-swap-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_stable_swap_decoder::{
        instructions::RaydiumStableSwapInstruction, RaydiumStableSwapDecoder, 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(RaydiumStableSwapDecoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

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

Instructions#

Variants of RaydiumStableSwapInstruction. Each is RaydiumStableSwapInstruction::<Variant> { program_id, data, accounts }, where data and accounts are the types listed under the variant, exported from carbon_raydium_stable_swap_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 5quBtoiQqxF9Jv6KYKctB59NT3gtJD2Y65kdnB1Uev3h.
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.

Deposit#

From the program's IDL:

Deposit liquidity into the stable AMM pool

Discriminator f223c68952e1f2b6 · data Deposit · accounts DepositInstructionAccounts.

Required accounts: 14; extras go to remaining.

Fields of DepositInstructionAccounts, in account order:

Initialize#

From the program's IDL:

Initialize a stable AMM pool

Discriminator afaf6d1f0d989bed · data Initialize · accounts InitializeInstructionAccounts.

Required accounts: 17; extras go to remaining.

Fields of InitializeInstructionAccounts, in account order:

PreInitialize#

From the program's IDL:

Pre-initialize a stable AMM pool

Discriminator ff5c572dc6acec02 · data PreInitialize · accounts PreInitializeInstructionAccounts.

Required accounts: 12; extras go to remaining.

Fields of PreInitializeInstructionAccounts, in account order:

SwapBaseIn#

From the program's IDL:

Swap with exact input amount

Discriminator 2aec48a2f2182754 · data SwapBaseIn · accounts SwapBaseInInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of SwapBaseInInstructionAccounts, in account order:

SwapBaseOut#

From the program's IDL:

Swap with exact output amount

Discriminator a3d29bd0af92d596 · data SwapBaseOut · accounts SwapBaseOutInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of SwapBaseOutInstructionAccounts, in account order:

Withdraw#

From the program's IDL:

Withdraw liquidity from the stable AMM pool

Discriminator b712469c946da122 · data Withdraw · accounts WithdrawInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of WithdrawInstructionAccounts, in account order: