Meteora Substreams

Real-time analytics for Meteora protocol on Solana — covering DLMM, Dynamic AMM, and DAMM v2.

v2.2.0 — Adds DAMM v2 (cpamdpZCGKUy5JxQXB4dcpGPiikHawvSWAd6mEn1sGG) with concentrated liquidity and compounding fee pool support. All three Meteora programs indexed with proper Anchor discriminators and CPI parsing.

What It Tracks

Every Meteora DLMM and Dynamic AMM instruction, classified into four categories:

Category	DLMM Instructions	Dynamic AMM Instructions
Swaps	swap, swap_exact_out, swap_with_price_impact	swap
Liquidity Adds	add_liquidity, add_liquidity_by_weight, add_liquidity_by_strategy, add_liquidity_by_strategy_one_side, add_liquidity_one_side	add_balance_liquidity, add_imbalance_liquidity, bootstrap_liquidity
Liquidity Removes	remove_liquidity, remove_all_liquidity, remove_liquidity_by_range, remove_liquidity_single_side	remove_balance_liquidity, remove_liquidity_single_side
Fee Claims	claim_fee, claim_reward	claim_fee, partner_claim_fee
Pool Creations	initialize_lb_pair, initialize_position, initialize_position_pda	initialize_permissioned_pool, initialize_permissionless_pool, + 4 more variants

Programs Indexed

Program	Address	Type
DLMM	LBUZKhRxPF3XUpBCjp4YzTKgLccjZhTSDM9YuVaPwxo	Concentrated liquidity with bins
Dynamic AMM	Eo7WjKq67rjJQSZxS6z3YkapzY3eMj6Xy8X5EQVn5UaB	Constant product + stable swap
DAMM v2	cpamdpZCGKUy5JxQXB4dcpGPiikHawvSWAd6mEn1sGG	Concentrated liquidity + compounding fees

Architecture

Layer 1: map_meteora_events
  Anchor discriminator decoding → Swap, LiquidityChange, FeeClaim, PoolCreation

Layer 2: State Stores (8 stores)
  pool swap/add/remove/fee counts, user swap/liquidity/fee counts, first-seen timestamps

Layer 3: Analytics
  map_pool_stats → aggregated pool metrics
  map_user_stats → aggregated user metrics

Layer 4: SQL Sink
  db_out → PostgreSQL (swaps, liquidity_changes, fee_claims, pool_creations, pools, users)

Modules

Module	Kind	Description
map_meteora_events	Map	Classifies all DLMM + Dynamic AMM instructions using Anchor discriminators
store_pool_swap_count	Store	Swap count per pool
store_pool_add_count	Store	Liquidity add count per pool
store_pool_remove_count	Store	Liquidity remove count per pool
store_pool_fee_count	Store	Fee claim count per pool
store_user_swap_count	Store	Swap count per user
store_user_liquidity_count	Store	Liquidity op count per user
store_user_fee_count	Store	Fee claim count per user
store_first_seen	Store	First-seen timestamp per pool and user
map_pool_stats	Map	Aggregated pool statistics
map_user_stats	Map	Aggregated user statistics
db_out	Map	PostgreSQL database changes

Quick Start

# Stream Meteora events
substreams run meteora-substreams@v2.2.0 map_meteora_events \
  -e mainnet.sol.streamingfast.io:443 \
  -s 310000000 -t +1000

# GUI mode
substreams gui meteora-substreams@v2.2.0 map_meteora_events \
  -e mainnet.sol.streamingfast.io:443 \
  -s 310000000

# Sink to PostgreSQL
substreams-sink-sql run "psql://localhost/meteora" \
  meteora-substreams-v2.2.0.spkg \
  -e mainnet.sol.streamingfast.io:443

SQL Output

Tables

Table	Key	Description
swaps	tx_id-instruction_index	Every swap with pool, user, program, instruction type
liquidity_changes	tx_id-instruction_index	Add/remove liquidity with direction flag
fee_claims	tx_id-instruction_index	Fee and reward claims
pool_creations	tx_id-instruction_index	New pool/position initialization
pools	pool_address	Aggregated: total swaps, adds, removes, fee claims
users	user_address	Aggregated: total swaps, liquidity ops, fee claims

Views

View	Description
top_pools	Pools ranked by swap count
top_users	Users ranked by swap count
daily_stats	Daily swap count, active pools, unique users, DLMM vs AMM breakdown
recent_swaps	Latest 100 swaps

Sample Output (200 blocks from slot 310M)

Instruction	Count
swap	995
claim_fee	53
swap_exact_out	47
add_liquidity_by_strategy	35
initialize_position	31
remove_liquidity_by_range	21
add_liquidity_by_weight	1
initialize_lb_pair	1
Total	1,184

Inner Instruction / CPI Support

Most Meteora swap volume goes through aggregators like Jupiter via CPI (Cross-Program Invocation). This Substreams parses both top-level and inner instructions, capturing 6.3x more events than top-level only. Without CPI parsing, ~84% of swap volume is missed.

Anchor Discriminators

Instructions are decoded using proper 8-byte Anchor discriminators (SHA256("global:{instruction_name}")[0..8]), verified against the official Meteora IDLs. This replaces the v1 approach of guessing instruction types from single-byte indices.

Build

git clone https://github.com/PaulieB14/Meteroa-Substreams.git
cd Meteroa-Substreams
substreams build
substreams pack substreams.yaml

Network

• Chain: Solana
• Start Block: 245,000,000
• Endpoint: mainnet.sol.streamingfast.io:443

References

• Meteora — Protocol homepage
• DLMM Docs — Dynamic Liquidity Market Maker
• Meteora IDLs — Official SDK with Anchor IDLs