Jupiter Lend decoder

carbon-jupiter-lend-decoder decodes the instructions, accounts and events of the Jupiter Lend program (jupeiUmn818Jg1ekPURTpr4mFo29p46vygyykFJ3wZC): 24 instructions, 7 account types, 19 events. It is generated with Codama from the program's IDL; see decoders for how decoders plug into a pipeline.

Other lending decoders: Kamino Lending, Kamino Vault, marginfi v2, Meteora Vault, Sharky. To decode several in one pipeline, see lending 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 Jupiter Lend transactions from the public RPC and prints every decoded ChangeStatus instruction. Add the dependencies:

cargo add carbon-core@2.0.0 carbon-jupiter-lend-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_jupiter_lend_decoder::{
        instructions::JupiterLendInstruction, JupiterLendDecoder, 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(JupiterLendDecoder, InstructionLogger)
        .build()?
        .run()
        .await
}

struct InstructionLogger;

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

RUST_LOG=info cargo run

Each ChangeStatus instruction prints one line with the transaction signature and the decoded ChangeStatus 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 JupiterLendInstruction::CpiEvent { data: CpiEvent::LogBorrowRateCap(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 AuthorizationList 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_jupiter_lend_decoder::{accounts::JupiterLendAccount, JupiterLendDecoder, 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(JupiterLendDecoder, AccountLogger)
        .build()?
        .run()
        .await
}

struct AccountLogger;

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

RUST_LOG=info cargo run

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

ChangeStatus#

Discriminator ec9183e4e311c0ff · data ChangeStatus · accounts ChangeStatusInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of ChangeStatusInstructionAccounts, in account order:

Claim#

Discriminator 3ec6d6c1d59f6cd2 · data Claim · accounts ClaimInstructionAccounts.

Required accounts: 9; extras go to remaining.

Fields of ClaimInstructionAccounts, in account order:

CloseClaimAccount#

Discriminator f192cbd83ade5b76 · data CloseClaimAccount · accounts CloseClaimAccountInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of CloseClaimAccountInstructionAccounts, in account order:

CollectRevenue#

Discriminator 5760d324f02bf657 · data CollectRevenue · accounts CollectRevenueInstructionAccounts.

No data fields.

Required accounts: 11; extras go to remaining.

Fields of CollectRevenueInstructionAccounts, in account order:

InitClaimAccount#

Discriminator 708d2faa2a639091 · data InitClaimAccount · accounts InitClaimAccountInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of InitClaimAccountInstructionAccounts, in account order:

InitLiquidity#

Discriminator 5fbdd8b7bc3ef46c · data InitLiquidity · accounts InitLiquidityInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of InitLiquidityInstructionAccounts, in account order:

InitNewProtocol#

Discriminator c19305208a87d59e · data InitNewProtocol · accounts InitNewProtocolInstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of InitNewProtocolInstructionAccounts, in account order:

InitTokenReserve#

Discriminator e4eb41819f0f0654 · data InitTokenReserve · accounts InitTokenReserveInstructionAccounts.

No data fields.

Required accounts: 10; extras go to remaining.

Fields of InitTokenReserveInstructionAccounts, in account order:

Operate#

Discriminator d96ad06374972a87 · data Operate · accounts OperateInstructionAccounts.

Required accounts: 14; extras go to remaining.

Fields of OperateInstructionAccounts, in account order:

PauseUser#

Discriminator 123f2b5eef35650e · data PauseUser · accounts PauseUserInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of PauseUserInstructionAccounts, in account order:

PreOperate#

Discriminator 81cd9e9bc69b4885 · data PreOperate · accounts PreOperateInstructionAccounts.

Required accounts: 8; extras go to remaining.

Fields of PreOperateInstructionAccounts, in account order:

UnpauseUser#

Discriminator 477380fcb67eea3e · data UnpauseUser · accounts UnpauseUserInstructionAccounts.

Required accounts: 4; extras go to remaining.

Fields of UnpauseUserInstructionAccounts, in account order:

UpdateAuthority#

Discriminator 202e401c954bf358 · data UpdateAuthority · accounts UpdateAuthorityInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of UpdateAuthorityInstructionAccounts, in account order:

UpdateAuths#

Discriminator 5d60b29c3975fdd1 · data UpdateAuths · accounts UpdateAuthsInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of UpdateAuthsInstructionAccounts, in account order:

UpdateExchangePrice#

Discriminator eff40af874193596 · data UpdateExchangePrice · accounts UpdateExchangePriceInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateExchangePriceInstructionAccounts, in account order:

UpdateGuardians#

Discriminator 2b3efa8a8d758461 · data UpdateGuardians · accounts UpdateGuardiansInstructionAccounts.

Required accounts: 3; extras go to remaining.

Fields of UpdateGuardiansInstructionAccounts, in account order:

UpdateRateDataV1#

Discriminator 0614227a1696b416 · data UpdateRateDataV1 · accounts UpdateRateDataV1InstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of UpdateRateDataV1InstructionAccounts, in account order:

UpdateRateDataV2#

Discriminator 74493592d82de47c · data UpdateRateDataV2 · accounts UpdateRateDataV2InstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of UpdateRateDataV2InstructionAccounts, in account order:

UpdateRevenueCollector#

Discriminator a78e7cf0dc718d3b · data UpdateRevenueCollector · accounts UpdateRevenueCollectorInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateRevenueCollectorInstructionAccounts, in account order:

UpdateTokenConfig#

Discriminator e77ab54fff4f90a7 · data UpdateTokenConfig · accounts UpdateTokenConfigInstructionAccounts.

Required accounts: 5; extras go to remaining.

Fields of UpdateTokenConfigInstructionAccounts, in account order:

UpdateUserBorrowConfig#

Discriminator 64b0c9aef70236a8 · data UpdateUserBorrowConfig · accounts UpdateUserBorrowConfigInstructionAccounts.

Required accounts: 7; extras go to remaining.

Fields of UpdateUserBorrowConfigInstructionAccounts, in account order:

UpdateUserClass#

Discriminator 0cce44873fd43077 · data UpdateUserClass · accounts UpdateUserClassInstructionAccounts.

Required accounts: 2; extras go to remaining.

Fields of UpdateUserClassInstructionAccounts, in account order:

UpdateUserSupplyConfig#

Discriminator d9efe1da2131eab7 · data UpdateUserSupplyConfig · accounts UpdateUserSupplyConfigInstructionAccounts.

Required accounts: 7; extras go to remaining.

Fields of UpdateUserSupplyConfigInstructionAccounts, in account order:

UpdateUserWithdrawalLimit#

Discriminator a209ba09d51ead4e · data UpdateUserWithdrawalLimit · accounts UpdateUserWithdrawalLimitInstructionAccounts.

Required accounts: 3; extras go to remaining.

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

AuthorizationList#

Discriminator 139d752beca7fb45 · accounts::authorization_list::AuthorizationList.

Liquidity#

Discriminator 36fcf9e289ac793a · accounts::liquidity::Liquidity.

RateModel#

Discriminator 5e03cbdb6b8904a2 · accounts::rate_model::RateModel.

TokenReserve#

Discriminator 15123b8778141f0c · accounts::token_reserve::TokenReserve.

UserBorrowPosition#

Discriminator 497e417bdc7ec518 · accounts::user_borrow_position::UserBorrowPosition.

UserClaim#

Discriminator e48ec3b5e49320d1 · accounts::user_claim::UserClaim.

UserSupplyPosition#

Discriminator cadb88763db11592 · accounts::user_supply_position::UserSupplyPosition.

Events#

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

LogBorrowRateCap#

Discriminator 9c83e85efe9c0e75 · events::log_borrow_rate_cap::LogBorrowRateCapEvent.

LogChangeStatus#

Discriminator 594d25ac8d1f4a2a · events::log_change_status::LogChangeStatusEvent.

LogClaim#

Discriminator ee329d55973ae72d · events::log_claim::LogClaimEvent.

LogCollectRevenue#

Discriminator 40c616c27b57a652 · events::log_collect_revenue::LogCollectRevenueEvent.

LogOperate#

Discriminator b40851471384ad08 · events::log_operate::LogOperateEvent.

LogPauseUser#

Discriminator 641172e0b41e34aa · events::log_pause_user::LogPauseUserEvent.

LogUnpauseUser#

Discriminator aa5b8460b34da81a · events::log_unpause_user::LogUnpauseUserEvent.

LogUpdateAuthority#

Discriminator 96989d8f0687c165 · events::log_update_authority::LogUpdateAuthorityEvent.

LogUpdateAuths#

Discriminator 58506d306fcb4cfb · events::log_update_auths::LogUpdateAuthsEvent.

LogUpdateExchangePrices#

Discriminator bec245cc1e56b5a3 · events::log_update_exchange_prices::LogUpdateExchangePricesEvent.

LogUpdateGuardians#

Discriminator e71cbf33358c4f8e · events::log_update_guardians::LogUpdateGuardiansEvent.

LogUpdateRateDataV1#

Discriminator 1e6683c0001e55df · events::log_update_rate_data_v1::LogUpdateRateDataV1Event.

LogUpdateRateDataV2#

Discriminator ce35c34671d35c81 · events::log_update_rate_data_v2::LogUpdateRateDataV2Event.

LogUpdateRevenueCollector#

Discriminator 2c8f50fad393b49f · events::log_update_revenue_collector::LogUpdateRevenueCollectorEvent.

LogUpdateTokenConfigs#

Discriminator 18cdbf822f28e9da · events::log_update_token_configs::LogUpdateTokenConfigsEvent.

LogUpdateUserBorrowConfigs#

Discriminator d2fbf29fcd219a4a · events::log_update_user_borrow_configs::LogUpdateUserBorrowConfigsEvent.

LogUpdateUserClass#

Discriminator b9c16af80b350088 · events::log_update_user_class::LogUpdateUserClassEvent.

LogUpdateUserSupplyConfigs#

Discriminator 8ea0155a57581233 · events::log_update_user_supply_configs::LogUpdateUserSupplyConfigsEvent.

LogUpdateUserWithdrawalLimit#

Discriminator 728398bd78fd5869 · events::log_update_user_withdrawal_limit::LogUpdateUserWithdrawalLimitEvent.

Types#

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

AddressBool#

Struct types::AddressBool.

AddressU8#

Struct types::AddressU8.

LogBorrowRateCap#

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

LogChangeStatus#

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

LogClaim#

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

LogCollectRevenue#

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

LogOperate#

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

LogPauseUser#

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

LogUnpauseUser#

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

LogUpdateAuthority#

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

LogUpdateAuths#

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

LogUpdateExchangePrices#

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

LogUpdateGuardians#

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

LogUpdateRateDataV1#

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

LogUpdateRateDataV2#

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

LogUpdateRevenueCollector#

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

LogUpdateTokenConfigs#

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

LogUpdateUserBorrowConfigs#

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

LogUpdateUserClass#

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

LogUpdateUserSupplyConfigs#

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

LogUpdateUserWithdrawalLimit#

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

RateDataV1Params#

From the program's IDL:

@notice struct to set borrow rate data for version 1

Struct types::RateDataV1Params.

RateDataV2Params#

From the program's IDL:

@notice struct to set borrow rate data for version 2

Struct types::RateDataV2Params.

TokenConfig#

From the program's IDL:

@notice struct to set token config

Struct types::TokenConfig.

TransferType#

Enum types::TransferType.

UserBorrowConfig#

From the program's IDL:

@notice struct to set user borrow & payback config

Struct types::UserBorrowConfig.

UserClass#

Struct types::UserClass.

UserSupplyConfig#

From the program's IDL:

@notice struct to set user supply & withdrawal config

Struct types::UserSupplyConfig.