Raydium Launchpad decoder

carbon-raydium-launchpad-decoder decodes the instructions, accounts and events of the Raydium Launchpad program (LanMV9sAd7wArD4vJFi2qDdfnVhFxYSUg6eADduJ3uj): 25 instructions, 5 account types, 4 events. It is generated with Codama from the program's IDL; see decoders for how decoders plug into a pipeline.

Other launchpad decoders: Boop, Meteora DBC, Moonshot, Pump.fun, Vertigo, Virtuals, Wavebreak. To decode several in one pipeline, see launchpad 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 Launchpad transactions from the public RPC and prints every decoded BuyExactIn instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-raydium-launchpad-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_launchpad_decoder::{
        instructions::RaydiumLaunchpadInstruction, RaydiumLaunchpadDecoder, 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(RaydiumLaunchpadDecoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

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

RUST_LOG=info cargo run

Each BuyExactIn instruction prints one line with the transaction signature and the decoded BuyExactIn 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 RaydiumLaunchpadInstruction::CpiEvent { data: CpiEvent::ClaimVestedEvent(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 PoolState 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_launchpad_decoder::{
        accounts::RaydiumLaunchpadAccount, RaydiumLaunchpadDecoder, 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(RaydiumLaunchpadDecoder, AccountLogger)
        .build()?
        .run()
        .await
}

struct AccountLogger;

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

RUST_LOG=info cargo run

Each update to a PoolState 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 RaydiumLaunchpadInstruction. Each is RaydiumLaunchpadInstruction::<Variant> { program_id, data, accounts }, where data and accounts are the types listed under the variant, exported from carbon_raydium_launchpad_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 LanMV9sAd7wArD4vJFi2qDdfnVhFxYSUg6eADduJ3uj.
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.

BuyExactIn#

From the program's IDL:

Use the given amount of quote tokens to purchase base tokens.

Arguments

• ctx - The context of accounts
• amount_in - Amount of quote token to purchase
• minimum_amount_out - Minimum amount of base token to receive (slippage protection)
• share_fee_rate - Fee rate for the share

Discriminator faea0d7bd59c13ec · data BuyExactIn · accounts BuyExactInInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of BuyExactInInstructionAccounts, in account order:

BuyExactOut#

From the program's IDL:

Use quote tokens to purchase the given amount of base tokens.

Arguments

• ctx - The context of accounts
• amount_out - Amount of base token to receive
• maximum_amount_in - Maximum amount of quote token to purchase (slippage protection)
• share_fee_rate - Fee rate for the share

Discriminator 18d3742869039938 · data BuyExactOut · accounts BuyExactOutInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of BuyExactOutInstructionAccounts, in account order:

ClaimCreatorFee#

From the program's IDL:

Claim the fee from the exclusive creator fee vault.

Arguments

• ctx - The context of accounts

Discriminator 1a618acb84ab8dfc · data ClaimCreatorFee · accounts ClaimCreatorFeeInstructionAccounts.

No data fields.

Required accounts: 8; extras go to remaining.

Fields of ClaimCreatorFeeInstructionAccounts, in account order:

ClaimPlatformFee#

From the program's IDL:

Claim platform fee

Arguments

• ctx - The context of accounts

Discriminator 9c27d0874ced3d48 · data ClaimPlatformFee · accounts ClaimPlatformFeeInstructionAccounts.

No data fields.

Required accounts: 10; extras go to remaining.

Fields of ClaimPlatformFeeInstructionAccounts, in account order:

ClaimPlatformFeeFromVault#

From the program's IDL:

Claim the fee from the exclusive platform fee vault.

Arguments

• ctx - The context of accounts

Discriminator 75f1c6a8f8da501d · data ClaimPlatformFeeFromVault · accounts ClaimPlatformFeeFromVaultInstructionAccounts.

No data fields.

Required accounts: 9; extras go to remaining.

Fields of ClaimPlatformFeeFromVaultInstructionAccounts, in account order:

ClaimVestedToken#

From the program's IDL:

Claim vested token

Arguments

Discriminator 3121681ebd9d4f23 · data ClaimVestedToken · accounts ClaimVestedTokenInstructionAccounts.

No data fields.

Required accounts: 10; extras go to remaining.

Fields of ClaimVestedTokenInstructionAccounts, in account order:

ClosePlatformGlobalAccess#

From the program's IDL:

Close a platform's permission to use a global config.

Discriminator 7bb4b8816fb9bb3b · data ClosePlatformGlobalAccess · accounts ClosePlatformGlobalAccessInstructionAccounts.

No data fields.

Required accounts: 4; extras go to remaining.

Fields of ClosePlatformGlobalAccessInstructionAccounts, in account order:

CollectFee#

From the program's IDL:

Collects accumulated fees from the pool

Arguments

• ctx - The context of accounts

Discriminator 3cadf767045d8230 · data CollectFee · accounts CollectFeeInstructionAccounts.

No data fields.

Required accounts: 8; extras go to remaining.

Fields of CollectFeeInstructionAccounts, in account order:

CollectMigrateFee#

From the program's IDL:

Collects migrate fees from the pool

Arguments

• ctx - The context of accounts

Discriminator ffba96dfeb76c9ba · data CollectMigrateFee · accounts CollectMigrateFeeInstructionAccounts.

No data fields.

Required accounts: 8; extras go to remaining.

Fields of CollectMigrateFeeInstructionAccounts, in account order:

CreateConfig#

From the program's IDL:

Creates a new configuration

Arguments

• ctx - The accounts needed by instruction
• curve_type - The type of bonding curve (0: ConstantProduct)
• index - The index of config, there may be multiple config with the same curve type.
• trade_fee_rate - Trade fee rate, must be less than
  RATE_DENOMINATOR_VALUE

Discriminator c9cff3724b6f2fbd · data CreateConfig · accounts CreateConfigInstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of CreateConfigInstructionAccounts, in account order:

CreatePlatformConfig#

From the program's IDL:

Create platform config account

Arguments

• ctx - The context of accounts

Fields

• fee_rate - Fee rate of the platform
• name - Name of the platform
• web - Website of the platform
• img - Image link of the platform

Discriminator b05ac4affd71dc14 · data CreatePlatformConfig · accounts CreatePlatformConfigInstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of CreatePlatformConfigInstructionAccounts, in account order:

CreatePlatformGlobalAccess#

From the program's IDL:

Create a platform permission to use a global config when authorization is enabled.

Discriminator a25b92c75d85eaed · data CreatePlatformGlobalAccess · accounts CreatePlatformGlobalAccessInstructionAccounts.

No data fields.

Required accounts: 5; extras go to remaining.

Fields of CreatePlatformGlobalAccessInstructionAccounts, in account order:

CreatePlatformVestingAccount#

From the program's IDL:

Create vesting account

Arguments

• ctx - The context of accounts
• share - The share amount of base token to be vested

Discriminator 9247ad4562130f6a · data CreatePlatformVestingAccount · accounts CreatePlatformVestingAccountInstructionAccounts.

No data fields.

Required accounts: 6; extras go to remaining.

Fields of CreatePlatformVestingAccountInstructionAccounts, in account order:

CreateVestingAccount#

From the program's IDL:

Create vesting account

Arguments

• ctx - The context of accounts
• share - The share amount of base token to be vested

Discriminator 81b2020dd9ace6da · data CreateVestingAccount · accounts CreateVestingAccountInstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of CreateVestingAccountInstructionAccounts, in account order:

Initialize#

From the program's IDL:

Initializes a new trading pool

Arguments

• ctx - The context of accounts containing pool and token information

Discriminator afaf6d1f0d989bed · data Initialize · accounts InitializeInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of InitializeInstructionAccounts, in account order:

InitializeV2#

From the program's IDL:

Initializes a new trading pool

Arguments

• ctx - The context of accounts containing pool and token information

Discriminator 4399af27da102620 · data InitializeV2 · accounts InitializeV2InstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of InitializeV2InstructionAccounts, in account order:

InitializeWithToken2022#

From the program's IDL:

Initializes a new trading pool with base token belongs to spl-token-2022, pool created by this instruction must be migrated to cpswap after fundraising ends, i.e., curve_param.migrate_type = 1 # Arguments

• ctx - The context of accounts containing pool and token information

Discriminator 25be7ede2c9aab11 · data InitializeWithToken2022 · accounts InitializeWithToken2022InstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of InitializeWithToken2022InstructionAccounts, in account order:

MigrateToAmm#

From the program's IDL:

Arguments

• ctx - The context of accounts

Discriminator cf52c091fecf91df · data MigrateToAmm · accounts MigrateToAmmInstructionAccounts.

Required accounts: 32; extras go to remaining.

Fields of MigrateToAmmInstructionAccounts, in account order:

MigrateToCpswap#

From the program's IDL:

Arguments

• ctx - The context of accounts

Discriminator 885cc8671cda908c · data MigrateToCpswap · accounts MigrateToCpswapInstructionAccounts.

No data fields.

Required accounts: 28; extras go to remaining.

Fields of MigrateToCpswapInstructionAccounts, in account order:

RemovePlatformCurveParam#

From the program's IDL:

Remove platform launch param

Arguments

• ctx - The context of accounts
• index - The index of the curve param to remove

Discriminator 1b1e3ea95de01891 · data RemovePlatformCurveParam · accounts RemovePlatformCurveParamInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of RemovePlatformCurveParamInstructionAccounts, in account order:

SellExactIn#

From the program's IDL:

Use the given amount of base tokens to sell for quote tokens.

Arguments

• ctx - The context of accounts
• amount_in - Amount of base token to sell
• minimum_amount_out - Minimum amount of quote token to receive (slippage protection)
• share_fee_rate - Fee rate for the share

Discriminator 9527de9bd37c981a · data SellExactIn · accounts SellExactInInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of SellExactInInstructionAccounts, in account order:

SellExactOut#

From the program's IDL:

Sell base tokens for the given amount of quote tokens.

Arguments

• ctx - The context of accounts
• amount_out - Amount of quote token to receive
• maximum_amount_in - Maximum amount of base token to purchase (slippage protection)
• share_fee_rate - Fee rate for the share

Discriminator 5fc8472208090ba6 · data SellExactOut · accounts SellExactOutInstructionAccounts.

Required accounts: 15; extras go to remaining.

Fields of SellExactOutInstructionAccounts, in account order:

UpdateConfig#

From the program's IDL:

Updates configuration parameters

Arguments

• ctx - The context of accounts
• param - Parameter to update:

• 0: Update trade_fee_rate
• 1: Update fee owner
• 12: Toggle whether explicit platform authorization is required

• value - New value for the selected parameter

Discriminator 1d9efcbf0a53db63 · data UpdateConfig · accounts UpdateConfigInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateConfigInstructionAccounts, in account order:

UpdatePlatformConfig#

From the program's IDL:

Update platform config

Arguments

• ctx - The context of accounts
• param - Parameter to update

Discriminator c33c4c81922d438f · data UpdatePlatformConfig · accounts UpdatePlatformConfigInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdatePlatformConfigInstructionAccounts, in account order:

UpdatePlatformCurveParam#

From the program's IDL:

Update platform launch param

Arguments

• ctx - The context of accounts
• bonding_curve_param - Parameter to update

Discriminator 8a908afadc800439 · data UpdatePlatformCurveParam · accounts UpdatePlatformCurveParamInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of UpdatePlatformCurveParamInstructionAccounts, 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 RaydiumLaunchpadAccount. Each wraps a boxed struct from carbon_raydium_launchpad_decoder::accounts::<module>. decode_account only considers accounts owned by PROGRAM_ID and returns the first variant that matches.

GlobalConfig#

Discriminator 95089ccaa0fcb0d9 · accounts::global_config::GlobalConfig.

PlatformConfig#

Discriminator a04e8000f853e6a0 · accounts::platform_config::PlatformConfig.

PlatformGlobalAccess#

Discriminator ae9384f089dbf310 · accounts::platform_global_access::PlatformGlobalAccess.

PoolState#

Discriminator f7ede3f5d7c3de46 · accounts::pool_state::PoolState.

VestingRecord#

Discriminator 6af3ddcde67e5553 · accounts::vesting_record::VestingRecord.

Events#

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

ClaimVestedEvent#

Discriminator 15c2725778d3e220 · events::claim_vested_event::ClaimVestedEventEvent.

CreateVestingEvent#

Discriminator 96980bb334d2bf7d · events::create_vesting_event::CreateVestingEventEvent.

PoolCreateEvent#

Discriminator 97d7e20976a173ae · events::pool_create_event::PoolCreateEventEvent.

TradeEvent#

Discriminator bddb7fd34ee661ee · events::trade_event::TradeEventEvent.

Types#

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

AmmCreatorFeeOn#

From the program's IDL:

migrate to cpmm, creator fee on quote token or both token

Enum types::AmmCreatorFeeOn.

BondingCurveParam#

Struct types::BondingCurveParam.

ClaimVestedEvent#

From the program's IDL:

Emitted when vesting token claimed by beneficiary

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

ConstantCurve#

Struct types::ConstantCurve.

CreateVestingEvent#

From the program's IDL:

Emitted when vest_account created

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

CurveParams#

Enum types::CurveParams.

FixedCurve#

Struct types::FixedCurve.

LinearCurve#

Struct types::LinearCurve.

MigrateNftInfo#

From the program's IDL:

Represents the parameters for initializing a platform config account(Only support MigrateType::CPSWAP) # Fields

• platform_scale - Scale of the platform liquidity quantity rights will be converted into NFT
• creator_scale - Scale of the token creator liquidity quantity rights will be converted into NFT
• burn_scale - Scale of liquidity directly to burn
• platform_scale + creator_scale + burn_scale = RATE_DENOMINATOR_VALUE

Struct types::MigrateNftInfo.

MintParams#

From the program's IDL:

Represents the parameters for initializing a new token mint

Fields

• decimals - Number of decimal places for the token
• name - Name of the token
• symbol - Symbol/ticker of the token
• uri - URI pointing to token metadata

Struct types::MintParams.

PlatformConfigInfo#

Struct types::PlatformConfigInfo.

PlatformConfigParam#

Enum types::PlatformConfigParam.

PlatformCurveParam#

Struct types::PlatformCurveParam.

PlatformParams#

From the program's IDL:

Represents the parameters for initializing a platform config account

Fields

• migrate_nft_info - The platform configures liquidity info during migration(Only support MigrateType::CPSWAP)
• fee_rate - Fee rate of the platform
• name - Name of the platform
• web - Website of the platform
• img - Image link of the platform

/// * creator_fee_rate - The fee rate charged by the creator for each transaction.

Struct types::PlatformParams.

PoolCreateEvent#

From the program's IDL:

Emitted when pool created

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

PoolStatus#

From the program's IDL:

Represents the different states a pool can be in

• Fund - Initial state where pool is accepting funds
• Migrate - Pool funding has ended and waiting for migration
• Trade - Pool migration is complete and amm trading is enabled

Enum types::PoolStatus.

TradeDirection#

From the program's IDL:

Specifies the direction of a trade in the bonding curve
This is important because curves can treat tokens differently through weights or offsets

Enum types::TradeDirection.

TradeEvent#

From the program's IDL:

Emitted when trade process

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

TransferFeeExtensionParams#

Struct types::TransferFeeExtensionParams.

VestingParams#

Struct types::VestingParams.

VestingSchedule#

Struct types::VestingSchedule.