Pump Fees decoder

carbon-pump-fees-decoder decodes the instructions, accounts and events of the Pump Fees program (pfeeUxB6jkeY1Hxd7CsFCAjcbHA9rWtchMGdZ6VojVZ): 17 instructions, 7 account types, 14 events. It is generated with Codama from the program's IDL; see decoders for how decoders plug into a pipeline.

More program decoders without a category: Jupiter DCA, Kamino Farms, Raydium Liquidity Locking, Swig. To decode several in one pipeline, see other program 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 Pump Fees transactions from the public RPC and prints every decoded ClaimSocialFeePda instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-pump-fees-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_pump_fees_decoder::{instructions::PumpFeesInstruction, PumpFeesDecoder, 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(PumpFeesDecoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

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

RUST_LOG=info cargo run

Each ClaimSocialFeePda instruction prints one line with the transaction signature and the decoded ClaimSocialFeePda 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 PumpFeesInstruction::CpiEvent { data: CpiEvent::CreateFeeSharingConfigEvent(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_pump_fees_decoder::{accounts::PumpFeesAccount, PumpFeesDecoder, 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(PumpFeesDecoder, AccountLogger)
        .build()?
        .run()
        .await
}

struct AccountLogger;

impl Processor<AccountProcessorInputType<'_, PumpFeesAccount>> for AccountLogger {
    async fn process(
        &mut self,
        input: &AccountProcessorInputType<'_, PumpFeesAccount>,
    ) -> CarbonResult<()> {
        if let PumpFeesAccount::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 PumpFeesInstruction. Each is PumpFeesInstruction::<Variant> { program_id, data, accounts }, where data and accounts are the types listed under the variant, exported from carbon_pump_fees_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 pfeeUxB6jkeY1Hxd7CsFCAjcbHA9rWtchMGdZ6VojVZ.
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.

ClaimSocialFeePda#

Discriminator e115fb85a11ec7e2 · data ClaimSocialFeePda · accounts ClaimSocialFeePdaInstructionAccounts.

Required accounts: 6; extras go to remaining.

Fields of ClaimSocialFeePdaInstructionAccounts, in account order:

CreateFeeSharingConfig#

From the program's IDL:

Create Fee Sharing Config

Discriminator c34e564c6f34fbd5 · data CreateFeeSharingConfig · accounts CreateFeeSharingConfigInstructionAccounts.

No data fields.

Required accounts: 10 (13 listed); extras go to remaining.

Fields of CreateFeeSharingConfigInstructionAccounts, in account order:

CreateSocialFeePda#

Discriminator 90e03bd34ef8cadc · data CreateSocialFeePda · accounts CreateSocialFeePdaInstructionAccounts.

Required accounts: 6; extras go to remaining.

Fields of CreateSocialFeePdaInstructionAccounts, in account order:

GetFees#

From the program's IDL:

Get Fees

Discriminator e7257e55cf5b3f34 · data GetFees · accounts GetFeesInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of GetFeesInstructionAccounts, in account order:

InitializeFeeConfig#

From the program's IDL:

Initialize FeeConfig admin

Discriminator 3ea214857941911b · data InitializeFeeConfig · accounts InitializeFeeConfigInstructionAccounts.

No data fields.

Required accounts: 6; extras go to remaining.

Fields of InitializeFeeConfigInstructionAccounts, in account order:

InitializeFeeProgramGlobal#

Discriminator 23d78254e9387ca7 · data InitializeFeeProgramGlobal · accounts InitializeFeeProgramGlobalInstructionAccounts.

Required accounts: 6; extras go to remaining.

Fields of InitializeFeeProgramGlobalInstructionAccounts, in account order:

ResetFeeSharingConfig#

From the program's IDL:

Reset Fee Sharing Config and distribute pending fees first

Discriminator 0a02b65f107f81ba · data ResetFeeSharingConfig · accounts ResetFeeSharingConfigInstructionAccounts.

No data fields.

Required accounts: 19; extras go to remaining.

Fields of ResetFeeSharingConfigInstructionAccounts, in account order:

RevokeFeeSharingAuthority#

From the program's IDL:

Revoke Fee Sharing Authority

Discriminator 12e99e27b9cf3a68 · data RevokeFeeSharingAuthority · accounts RevokeFeeSharingAuthorityInstructionAccounts.

No data fields.

No named accounts.

SetAuthority#

Discriminator 85fa25156ea31a79 · data SetAuthority · accounts SetAuthorityInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of SetAuthorityInstructionAccounts, in account order:

SetClaimRateLimit#

Discriminator b9d39faed4315804 · data SetClaimRateLimit · accounts SetClaimRateLimitInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of SetClaimRateLimitInstructionAccounts, in account order:

SetDisableFlags#

Discriminator c2d9702372de33be · data SetDisableFlags · accounts SetDisableFlagsInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of SetDisableFlagsInstructionAccounts, in account order:

SetSocialClaimAuthority#

Discriminator 9336b89a88edb999 · data SetSocialClaimAuthority · accounts SetSocialClaimAuthorityInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of SetSocialClaimAuthorityInstructionAccounts, in account order:

TransferFeeSharingAuthority#

From the program's IDL:

Transfer Fee Sharing Authority

Discriminator ca0a4bc8a422d260 · data TransferFeeSharingAuthority · accounts TransferFeeSharingAuthorityInstructionAccounts.

No data fields.

No named accounts.

UpdateAdmin#

From the program's IDL:

Update admin (only callable by admin)

Discriminator a1b028d53cb8b3e4 · data UpdateAdmin · accounts UpdateAdminInstructionAccounts.

No data fields.

Required accounts: 6; extras go to remaining.

Fields of UpdateAdminInstructionAccounts, in account order:

UpdateFeeConfig#

From the program's IDL:

Set/Replace fee parameters entirely (only callable by admin)

Discriminator 68b867f258976b14 · data UpdateFeeConfig · accounts UpdateFeeConfigInstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of UpdateFeeConfigInstructionAccounts, in account order:

UpdateFeeShares#

From the program's IDL:

Update Fee Shares, make sure to distribute all the fees before calling this

Discriminator bd0d8863bba4ed23 · data UpdateFeeShares · accounts UpdateFeeSharesInstructionAccounts.

Required accounts: 18; extras go to remaining.

Fields of UpdateFeeSharesInstructionAccounts, in account order:

UpsertFeeTiers#

From the program's IDL:

Update or expand fee tiers (only callable by admin)

Discriminator e317960c4d565e04 · data UpsertFeeTiers · accounts UpsertFeeTiersInstructionAccounts.

Required accounts: 5; extras go to remaining.

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

BondingCurve#

Discriminator 17b7f83760d8ac60 · accounts::bonding_curve::BondingCurve.

FeeConfig#

Discriminator 8f3492bbdb7b4c9b · accounts::fee_config::FeeConfig.

FeeProgramGlobal#

Discriminator a2a5f5311d2537f2 · accounts::fee_program_global::FeeProgramGlobal.

Global#

Discriminator a7e8e8b1c86c727f · accounts::global::Global.

Pool#

Discriminator f19a6d0411b16dbc · accounts::pool::Pool.

SharingConfig#

Discriminator d84a0900388c5d4b · accounts::sharing_config::SharingConfig.

SocialFeePda#

Discriminator 8b6035112aa9ce96 · accounts::social_fee_pda::SocialFeePda.

Events#

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

CreateFeeSharingConfigEvent#

Discriminator 8569aac8b874fb58 · events::create_fee_sharing_config_event::CreateFeeSharingConfigEventEvent.

InitializeFeeConfigEvent#

Discriminator 598af4e60a38e27e · events::initialize_fee_config_event::InitializeFeeConfigEventEvent.

InitializeFeeProgramGlobalEvent#

Discriminator 28e99c4e5f0008c7 · events::initialize_fee_program_global_event::InitializeFeeProgramGlobalEventEvent.

ResetFeeSharingConfigEvent#

Discriminator cbcc97e27837d6f3 · events::reset_fee_sharing_config_event::ResetFeeSharingConfigEventEvent.

SetAuthorityEvent#

Discriminator 12af8442d0c957f2 · events::set_authority_event::SetAuthorityEventEvent.

SetClaimRateLimitEvent#

Discriminator 0d8f8febb5133328 · events::set_claim_rate_limit_event::SetClaimRateLimitEventEvent.

SetDisableFlagsEvent#

Discriminator 0508b3413137917e · events::set_disable_flags_event::SetDisableFlagsEventEvent.

SetSocialClaimAuthorityEvent#

Discriminator 3c767f84ef34fe0e · events::set_social_claim_authority_event::SetSocialClaimAuthorityEventEvent.

SocialFeePdaClaimed#

Discriminator 3212c141edd2eaec · events::social_fee_pda_claimed::SocialFeePdaClaimedEvent.

SocialFeePdaCreated#

Discriminator b7b7da93187c89a9 · events::social_fee_pda_created::SocialFeePdaCreatedEvent.

UpdateAdminEvent#

Discriminator e198ab57f63f42ea · events::update_admin_event::UpdateAdminEventEvent.

UpdateFeeConfigEvent#

Discriminator 5a1741233ef4bcd0 · events::update_fee_config_event::UpdateFeeConfigEventEvent.

UpdateFeeSharesEvent#

Discriminator 15bac4b85be4e1cb · events::update_fee_shares_event::UpdateFeeSharesEventEvent.

UpsertFeeTiersEvent#

Discriminator ab59a9bb7aba21cc · events::upsert_fee_tiers_event::UpsertFeeTiersEventEvent.

Types#

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

ConfigStatus#

Enum types::ConfigStatus.

CreateFeeSharingConfigEvent#

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

Fees#

Struct types::Fees.

FeeTier#

Struct types::FeeTier.

InitializeFeeConfigEvent#

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

InitializeFeeProgramGlobalEvent#

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

ResetFeeSharingConfigEvent#

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

SetAuthorityEvent#

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

SetClaimRateLimitEvent#

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

SetDisableFlagsEvent#

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

SetSocialClaimAuthorityEvent#

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

Shareholder#

Struct types::Shareholder.

SocialFeePdaClaimed#

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

SocialFeePdaCreated#

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

UpdateAdminEvent#

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

UpdateFeeConfigEvent#

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

UpdateFeeSharesEvent#

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

UpsertFeeTiersEvent#

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