🗄️Rocksdb states
1. Token
1.1 Token info
Column family: token
Query key:
t:{mint}
pub struct Token {
pub id: String, // internal identifier for this token (typically equal to mint)
pub program: String, // origin program/launchpad or DEX program
pub signature: String, // creation transaction signature
pub mint: String, // token mint address
pub quote_mint: String, // quote token mint (e.g., WSOL or USD1)
pub bonding_curve: Option<String>,// optional bonding curve id/address (pre-migration)
pub name: String, // token display name
pub symbol: String, // token ticker symbol
pub uri: String, // metadata URI
pub creator: String, // creator address (string)
pub creator_balance: f64, // creator SOL balance
pub creation_time: i64, // unix timestamp when created
pub creation_slot: u64, // slot when created
pub total_supply: f64, // total minted supply (UI units)
pub decimals: u8, // number of decimal places
pub quote_decimals: u8, // decimals for quote token (e.g., 9 for WSOL)
// Prices and liquidities are in QUOTE units; u_* are USD equivalents
pub price: f64, // price per token in quote units
pub u_price: f64, // price per token in USD
pub market_cap: f64, // market cap in quote units
pub u_market_cap: f64, // market cap in USD
pub liquidity: f64, // current liquidity (quote units)
pub u_liquidity: f64, // current liquidity (USD)
pub token_liquidity: f64, // token-side liquidity (token units)
pub u_token_liquidity: f64, // token-side liquidity (USD)
pub ath_liquidity: f64, // ath liquidity (quote units)
pub u_ath_liquidity: f64, // ath liquidity (USD)
pub ath_liq_ts: Option<i64>, // ath liquidity timestamp
pub ath_price: f64, // ath price (quote units)
pub u_ath_price: f64, // ath price (USD)
pub ath_price_ts: Option<i64>, // ath price timestamp
pub bonding_progress: f64, // progress along bonding curve (0–100)
pub curve_type: u8, // encoded bonding curve type id
// Initial reserves at creation (if available)
pub init_liq: f64, // initial quote reserves
pub u_init_liq: f64, // initial quote reserves (USD)
pub init_token_liq: f64, // initial token reserves
pub u_init_token_liq: f64, // initial token reserves (USD)
// Migration
pub migrated: bool, // whether token migrated to DEX pool
pub migrated_at: Option<i64>, // unix timestamp when migration happened
// Pool info
pub pool: Option<PoolInfo>, // pool details after migration
// Holders
pub holders_count: usize, // cached number of unique holders
pub top10_holder_percent: f64, // Top 10 holder % of total supply
pub top100_holder_percent: f64, // Top 100 holder % of total supply
pub top_holders: Vec<(String, String)>, // top holders with classification
// Trades
pub trades: u64, // total number of trades observed
pub large_trades: u64, // large trades (e.g., ≥ threshold)
// Aggregated fees (in SOL)
pub total_fee: f64,
pub priority_fee: f64,
pub tip_fee: f64,
pub trade_fee: f64,
}
pub struct PoolInfo {
pub pool_program: String, // program id of the pool
pub pool_address: String, // pool account address
pub pool_authority: String, // authority account for the pool
pub pool_mint_account: String,// token mint account for pool token
pub pool_quote_account: String,// quote token account for the pool
}1.1.1 Example: Simple
The following request retrieves data for the $TRUMP token:
Token Symbol: $TRUMP
Contract Address: 6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Human-readable name for the stream
"description": "string (required)", // Short description of what the stream does
"state": [ // List of state lookups used by the stream
{
"state_name": "my_custom_state", // Local alias to reference this state in conditions/actions
"source": "rocksdb", // Source type: use RocksDB as the backing store
"key": "token#t:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN" // Full RocksDB key to fetch token
}
],
"topic_subscription": {}, // TopicSubscription (configure topics to listen to)
"conditions": [...], // ConditionGroup[] (optional guards/filters)
"actions": [...] // Action[] (what to execute when conditions pass)
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"bonding_curve": null,
"bonding_progress": 100,
"creation_slot": 364149397,
"creation_time": 1756809830,
"creator": "BW3Nq9RDEhAs6BEXNLXfYgBdHotJLDsJ457RkTSQFZEV",
"curve_type": 1,
"decimals": 6,
"half_sol_trades": 10,
"holders_count": 3,
"id": "t:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"init_sol_liq": 0.0151156,
"init_token_liq": 1000000000,
"liquidity": 0.017251154,
"ath_liquidity": 10,
"ath_liq_ts": 1756810830,
"market_cap": 27.99115770937219,
"migrated": false,
"migrated_at": null,
"mint": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"name": "OFFICIAL TRUMP",
"pool": null,
"price": 2.7991157709372193e-8,
"program": "6EF8rrecthR5Dkzon8Nwu78hRvfCKubJ14M5uBEwF6P",
"signature": "5b2EKsK4cizCjCUHsdboebyx8iHrbr6HnmFxDRdd8pLLp3ucCXFkyFVK2Q8jQsGYs381xEPHxjJe94c6CWGpTEEX",
"symbol": "TRUMP",
"token_liquidity": 999383338.54085,
"total_supply": 1000000000,
"trades": 24,
"uri": "https://ipfs.io/ipfs/trump..."
}1.1.2 Example: Combining event topics and token state
To resolve dynamic keys (like mint) from incoming events and then fetch the corresponding token state from RocksDB, use a two-step state definition: first derive mint from event payload, then interpolate it in the RocksDB key. See Topics specification for event schemas in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
"name": "string (required)", // Name of the stream
"description": "string (required)", // Description of the stream
"state": [ // States resolved at runtime
{
"state_name": "mint", // Alias for the event-derived mint value
"source": "event_data", // Use event payload from WASM topics
"key": "mint" // JSON path to the mint field in event data
},
{
"state_name": "holder_after", // Alias for the event-derived mint value
"source": "event_data", // Use event payload from WASM topics
"key": "after" // JSON path to the mint field in event data
},
{
"state_name": "token_state", // Alias for the fetched token state
"source": "rocksdb", // Source from RocksDB
"key": "token#t:{mint}" // Interpolate the above `mint` into the RocksDB key
},
{
"state_name": "total_supply",
"source": "state_data",
"key": "token_state.total_supply"
},
{
"state_name": "total_supply",
"source": "state_data",
"key": "token_state.total_supply"
},
{
"state_name": "bonding_progress",
"source": "state_data",
"key": "token_state.bonding_progress"
}
],
"topic_subscriptions": {
"topic": "wasm.token.holder-pulse"
},
"conditions": {
"type": "all",
"rules": [
{
"field": "bonding_progress",
"operator": "greater_than",
"value": 60
},
{
"field": "holder_after",
"operator": "greater_than",
"value": 4
},
]
}, // ConditionGroup[]
"actions": [...] // Action[]
}
}Explanation: This rule triggers only for tokens with bonding_progress > 60 (near/after bonding completion) and a post-window holder count greater than 4. The holder_after state is mapped from the holder-pulse event’s after field (holder count after the 2-slot window), while bonding_progress is read from token_state in RocksDB.
1.2 Holders
Column family: token
Query key:
h:{mint}
pub struct TokenHolders {
pub id: String, // record id (typically mint)
pub last_updated_slot: u64, // slot when this snapshot was updated
pub mint: String, // token mint address
pub top_holders: HashMap<String, f64>, // top 100 holders: address -> balance (token units)
pub holders_count: usize, // total unique holders
}1. Example:
The following request retrieves top holders for the $TRUMP token:
Token Symbol: $TRUMP
Contract Address: 6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Human-readable name
"description": "string (required)", // What this stream retrieves
"state": [ // Resolved states
{
"state_name": "my_custom_state", // Alias for holders snapshot
"source": "rocksdb", // Read from RocksDB
"key": "token#h:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN" // Holders by mint
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // Optional conditions
"actions": [...] // Actions to execute
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"holders_count": 3,
"id": "h:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"last_updated_slot": 364150769,
"mint": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"top_holders": {
"C7EyMJaVjYbE5mVkACs3zW1pw2fstNBuHFBeWMAHaeep": 225852.76396,
"ZG98FUCjb8mJ824Gbs6RsgVmr1FhXb2oNiJHa2dwmPd": 390808.69519,
"oEHZTYgMuApm3puxjysha1AFaaocjDxSvVtXgziciYq": 999383338.54085
}
}Example 2: Combining event topics and holders state
Use event payload to derive mint and interpolate it in the RocksDB key. See Topics specification in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "mint", // Alias for mint from event
"source": "event_data", // Pull from incoming event
"key": "mint" // JSON path to mint field
},
{
"state_name": "token_holders", // Alias for holders snapshot
"source": "rocksdb", // Read from RocksDB
"key": "token#h:{mint}" // Interpolate `mint` into RocksDB key
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}1.3 Stats
Column family: token_stats
Query key:
s:{mint}
pub struct TokenTradeStats {
pub id: String, // record id (typically mint)
pub mint: String, // token mint address
pub last_updated_timestamp: i64, // unix time of last update
pub last_updated_slot: u64, // slot of last update
pub price_1m: f64, // price over last 1 minute (USD)
pub price_5m: f64, // price over last 5 minutes (USD)
pub price_1h: f64, // price over last 1 hour (USD)
pub price_6h: f64, // price over last 6 hours (USD)
pub price_24h: f64, // price over last 24 hours (USD)
pub buys_1m: u64, // number of buys in last 1 minute
pub buys_5m: u64, // number of buys in last 5 minutes
pub buys_1h: u64, // number of buys in last 1 hour
pub buys_6h: u64, // number of buys in last 6 hours
pub buys_24h: u64, // number of buys in last 24 hours
pub sells_1m: u64, // number of sells in last 1 minute
pub sells_5m: u64, // number of sells in last 5 minutes
pub sells_1h: u64, // number of sells in last 1 hour
pub sells_6h: u64, // number of sells in last 6 hours
pub sells_24h: u64, // number of sells in last 24 hours
pub volume_1m: f64, // total volume (buy+sell) (USD)
pub volume_5m: f64,
pub volume_1h: f64,
pub volume_6h: f64,
pub volume_24h: f64,
pub buy_volume_1m: f64,
pub buy_volume_5m: f64,
pub buy_volume_1h: f64,
pub buy_volume_6h: f64,
pub buy_volume_24h: f64,
pub sell_volume_1m: f64,
pub sell_volume_5m: f64,
pub sell_volume_1h: f64,
pub sell_volume_6h: f64,
pub sell_volume_24h: f64,
}Example 1:
The following request retrieves 1m/5m/1h/6h/24h stats for the $TRUMP token:
Token Symbol: $TRUMP
Contract Address: 6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "my_custom_state", // Alias for stats
"source": "rocksdb", // Read from RocksDB
"key": "token#s:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN" // Stats by mint
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"buy_volume_1h": 4.718555248,
"buy_volume_1m": 0,
"buy_volume_24h": 4.718555248,
"buy_volume_5m": 0,
"buy_volume_6h": 4.718555248,
"buys_1h": 12,
"buys_1m": 0,
"buys_24h": 12,
"buys_5m": 0,
"buys_6h": 12,
"id": "s:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"last_updated_slot": 364150769,
"last_updated_timestamp": 1756810374,
"mint": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"price_1h": 2.8604910816402695e-8,
"price_1m": 3.0423194405359663e-8,
"price_24h": 2.8604910816402695e-8,
"price_5m": 3.2340664773397386e-8,
"price_6h": 2.8604910816402695e-8,
"sell_volume_1h": 4.701304094,
"sell_volume_1m": 0.693875836,
"sell_volume_24h": 4.701304094,
"sell_volume_5m": 1.872001151,
"sell_volume_6h": 4.701304094,
"sells_1h": 12,
"sells_1m": 1,
"sells_24h": 12,
"sells_5m": 5,
"sells_6h": 12,
"volume_1h": 9.419859342,
"volume_1m": 0.693875836,
"volume_24h": 9.419859342,
"volume_5m": 1.872001151,
"volume_6h": 9.419859342
}Example 2: Combining event topics and trade stats state
Use event payload to derive mint and interpolate it in the RocksDB key. See Topics specification in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "mint", // Alias for mint from event
"source": "event_data", // Use event payload
"key": "mint" // JSON path to mint
},
{
"state_name": "token_stats", // Alias for stats record
"source": "rocksdb", // Read from RocksDB
"key": "token_stats#s:{mint}" // Interpolate `mint`
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}1.4 100 first buy txs
Column family: token
Query key:
eb:{mint}
pub struct TokenEarlyBuyers {
pub id: String, // Same as mint
pub mint: String, // Token mint address
pub buy_txs: Vec<FirstBuyTx>, // Up to 100 early buy transactions
pub last_updated_time: i64, // Unix timestamp
pub count: usize, // Cached length to avoid counting the vec
}
pub struct FirstBuyTx {
pub payer: String, // Buyer address (payer of the transaction)
pub signature: String, // Solana transaction signature
pub volume: f64, // Quote volume (amount_in in quote units)
pub timestamp: i64, // When the trade happened
}Example 1:
The following request retrieves up to 100 earliest buy transactions for the $TRUMP token:
Token Symbol: $TRUMP
Contract Address: 6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "my_custom_state", // Alias for early buyers set
"source": "rocksdb", // Read from RocksDB
"key": "token_stats#eb:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN" // Early buyers by mint
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"buy_txs": [
{
"payer": "BW3Nq9RDEhAs6BEXNLXfYgBdHotJLDsJ457RkTSQFZEV",
"signature": "5b2EKsK4cizCjCUHsdboebyx8iHrbr6HnmFxDRdd8pLLp3ucCXFkyFVK2Q8jQsGYs381xEPHxjJe94c6CWGpTEEX",
"timestamp": 1756809830,
"volume": 0.693069306
},
{
"payer": "39H3DGBpHpffjTuwQDR9yv9AgbK4U4hesLdsVZ9yDDc9",
"signature": "3dJKzqJtJN1B1yL4vrdxz59SzQSdeGPbmg8LWsrDJuP3aAFxA3wJj3wJyKgPoJeBeYuh6Mnsfh17C7pLgNEK4qfm",
"timestamp": 1756809830,
"volume": 0.96
},
...
],
"count": 12,
"id": "eb:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"last_updated_time": 1756809911,
"mint": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN"
}Example 2: Combining event topics and early buyers state
Use event payload to derive mint and interpolate it in the RocksDB key. See Topics specification in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "mint", // Alias for mint from event
"source": "event_data", // Use event payload
"key": "mint" // JSON path to mint
},
{
"state_name": "token_early_buyers", // Alias for early buyers set
"source": "rocksdb", // Read from RocksDB
"key": "token#eb:{mint}" // Interpolate `mint`
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}1.5 Holders Analytics
Column family: holders_analytics
Query key:
ha:{mint}Note: Metrics are computed from the top 20 largest holders (by token balance)
#[cf = "holders_analytics"]
pub struct HoldersAnalyticsModel {
pub id: String, // record id (typically mint)
pub mint: String, // token mint address
pub slot: u64, // slot when this analytics snapshot was taken
pub pct_fresh: f64, // percentage of fresh holders (new/inexperienced)
pub pct_bot: f64, // percentage of bot holders (automated accounts)
pub pct_fish: f64, // percentage of fish holders (small retail)
pub pct_shrimp: f64, // percentage of shrimp holders (very small retail)
pub pct_shark: f64, // percentage of shark holders (medium-sized traders)
pub pct_whale: f64, // percentage of whale holders (large traders)
pub count_fresh: u64, // absolute count of fresh holders
pub count_bot: u64, // absolute count of bot holders
pub count_fish: u64, // absolute count of fish holders
pub count_shrimp: u64, // absolute count of shrimp holders
pub count_shark: u64, // absolute count of shark holders
pub count_whale: u64, // absolute count of whale holders
pub supply_pct_fresh: f64, // percentage of total supply held by fresh holders
pub supply_pct_bot: f64, // percentage of total supply held by bot holders
pub supply_pct_fish: f64, // percentage of total supply held by fish holders
pub supply_pct_shrimp: f64, // percentage of total supply held by shrimp holders
pub supply_pct_shark: f64, // percentage of total supply held by shark holders
pub supply_pct_whale: f64, // percentage of total supply held by whale holders
}
1.5.1 Example: Simple
The following request retrieves holder analytics for the $TRUMP token:
Token Symbol: $TRUMP
Contract Address: 6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Human-readable name
"description": "string (required)", // Description of what this stream retrieves
"state": [ // List of state lookups used by the stream
{
"state_name": "my_custom_state", // Local alias to reference this state in conditions/actions
"source": "rocksdb", // Source type: use RocksDB as the backing store
"key": "holders_analytics#ha:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN" // Full RocksDB key to fetch holder analytics
}
],
"topic_subscription": {}, // TopicSubscription (configure topics to listen to)
"conditions": [...], // ConditionGroup[] (optional guards/filters)
"actions": [...] // Action[] (what to execute when conditions pass)
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"id": "ha:6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"mint": "6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN",
"slot": 364150769,
"pct_fresh": 15.5,
"pct_bot": 25.0,
"pct_fish": 35.0,
"pct_shrimp": 20.0,
"pct_shark": 3.5,
"pct_whale": 1.0,
"count_fresh": 12,
"count_bot": 8,
"count_fish": 18,
"count_shrimp": 10,
"count_shark": 2,
"count_whale": 1,
"supply_pct_fresh": 5.2,
"supply_pct_bot": 45.8,
"supply_pct_fish": 25.0,
"supply_pct_shrimp": 8.5,
"supply_pct_shark": 12.0,
"supply_pct_whale": 3.5
}1.5.2 Example: Combining event topics and holder analytics state
To resolve dynamic keys (like mint) from incoming events and then fetch the corresponding holder analytics from RocksDB, use a two-step state definition: first derive mint from event payload, then interpolate it in the RocksDB key. See Topics specification for event schemas in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
"name": "string (required)", // Name of the stream
"description": "string (required)", // Description of the stream
"state": [ // States resolved at runtime
{
"state_name": "mint", // Alias for the event-derived mint value
"source": "event_data", // Use event payload from WASM topics
"key": "mint" // JSON path to the mint field in event data
},
{
"state_name": "holder_analytics", // Alias for the fetched holder analytics state
"source": "rocksdb", // Source from RocksDB
"key": "holders_analytics#ha:{mint}" // Interpolate the above `mint` into the RocksDB key
},
{
"state_name": "whale_percentage",
"source": "state_data",
"key": "holder_analytics.pct_whale"
},
{
"state_name": "bot_supply_percentage",
"source": "state_data",
"key": "holder_analytics.supply_pct_bot"
}
],
"topic_subscriptions": {
"topic": "wasm.token.holder-pulse"
},
"conditions": {
"type": "all",
"rules": [
{
"field": "whale_percentage",
"operator": "greater_than",
"value": 5.0
},
{
"field": "bot_supply_percentage",
"operator": "less_than",
"value": 30.0
}
]
}, // ConditionGroup[]
"actions": [...] // Action[]
}
}Explanation: This rule triggers only for tokens where whale holders represent more than 5% of total holders and bot holders control less than 30% of the total supply. The whale_percentage and bot_supply_percentage states are derived from the holder_analytics state in RocksDB, while the mint is extracted from the holder-pulse event.
2. Creator / Trader
2.1 Creator
Column family: creator
Query key:
c:{creator}
pub struct CreatorTokenStats {
pub id: String, // creator id (pubkey as string)
pub last_updated_slot: u64, // slot when last updated
pub tokens_created_by_creator: BTreeSet<String>, // set of token mints created
pub tokens_created_count: usize, // number of tokens created
pub tokens_migrated_by_creator: BTreeSet<String>, // set of token mints migrated
pub tokens_migrated_count: usize, // number migrated
pub tokens_with_mc_over_1m: BTreeSet<String>, // tokens with market cap > 1M USD
pub tokens_with_mc_1m_count: usize, // count for > 1M
pub tokens_with_mc_over_5m: BTreeSet<String>, // tokens with market cap > 5M USD
pub tokens_with_mc_5m_count: usize, // count for > 5M
pub tokens_with_mc_over_10m: BTreeSet<String>, // tokens with market cap > 10M USD
pub tokens_with_mc_10m_count: usize, // count for > 10M
}Example 1:
The following request retrieves aggregated stats for a creator address:
Creator Address: 3f3YEGW9Qyq4h8AxhV24o3t8xPzYz1w6o7wH7kHcCrea
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "my_custom_state", // Alias for creator stats
"source": "rocksdb", // Read from RocksDB
"key": "creator#c:3f3YEGW9Qyq4h8AxhV24o3t8xPzYz1w6o7wH7kHcCrea" // Creator stats by pubkey
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"id": "c:3f3YEGW9Qyq4h8AxhV24o3t8xPzYz1w6o7wH7kHcCrea",
"last_updated_slot": 364646343,
"tokens_created_by_creator": [
"12WVbEz3t8AfhWCYCGd3ehg3oAgFBBaYgQnQd2Sx8aqz",
"149vMDcnu1HRZnoQwaXyz16XiiYTdT5PUxn2sE8gTGqd",
"21STjfK3ASMxyahTLktGSgacXdYaV45LFXBK36b2tdzM",
"21wzT4fM7XnBNrX4z8wxSEB2tWiu8MoUxFHPC8Asw9FN"
],
"tokens_created_count": 3,
"tokens_migrated_by_creator": [
"4z48SRbosA2fP27X9GG22B1aQwYtDQnpfMt9aVPACUoz"
],
"tokens_migrated_count": 5,
"tokens_with_mc_10m_count": 1,
"tokens_with_mc_1m_count": 0,
"tokens_with_mc_5m_count": 0,
"tokens_with_mc_over_10m": ["149vMDcnu1HRZnoQwaXyz16XiiYTdT5PUxn2sE8gTGqd"],
"tokens_with_mc_over_1m": [],
"tokens_with_mc_over_5m": []
}Example 2: Combining event topics and creator state
Use event payload to derive pubkey and interpolate it in the RocksDB key. See Topics specification in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "pubkey", // Alias for creator public key
"source": "event_data", // Use event payload
"key": "pubkey" // JSON path to public key
},
{
"state_name": "creator_stats", // Alias for creator stats record
"source": "rocksdb", // Read from RocksDB
"key": "creator#c:{pubkey}" // Interpolate `pubkey`
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}2.2 Trader
Column family: trader
Query key:
t:{trader}
pub struct Trader {
pub id: String, // record id (pubkey as string)
pub pubkey: String, // trader public key
pub deposit_time: i64, // latest deposit time
pub deposit_details: HashMap<String, f64>, // payer -> amount deposited
pub deposit_exchange: Option<String>, // inferred exchange (e.g., OKX)
pub deposit_label: Option<String>, // additional label (e.g., "OKX: Hot Wallet")
pub last_trade_time: i64, // latest trade time
pub last_updated_timestamp: i64, // when this record last updated
// Total statistics (since account creation)
pub total_volume: u64, // cumulative traded volume
pub total_trades: u64, // cumulative number of trades
pub activity: VecDeque<TraderActivityEvent>, // last 20 buy/sell activity
}
pub struct TraderActivityEvent {
pub slot: u64, // slot when activity occurred
pub timestamp: i64, // unix time of activity
pub mint: String, // token mint traded
pub is_buy: bool, // true if buy, false if sell
pub amount_in: u64, // input amount
pub amount_out: u64, // output amount
}Example 1:
The following request retrieves trader profile and recent activities:
Trader Address: 8h1TrDRP5pTQ1mKq8iXK7H2jvQvRk2m6sDfN9TrAdEr
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "my_custom_state", // Alias for trader state
"source": "rocksdb", // Read from RocksDB
"key": "trader#t:8h1TrDRP5pTQ1mKq8iXK7H2jvQvRk2m6sDfN9TrAdEr" // Trader by pubkey
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}The WASM function returns the following data structure: This is an example response object. Values are illustrative (not live).
{
"activity": [
{
"amount_in": 89683582.089552,
"amount_out": 2.88955017,
"is_buy": false,
"mint": "7fYXJyjP668CofJ92dNCdfCQg2MVVhqWTnS8p471wHc3",
"slot": 364646356,
"timestamp": 1757006662
},
{
"amount_in": 22420895.522388,
"amount_out": 0.818639533,
"is_buy": false,
"mint": "7fYXJyjP668CofJ92dNCdfCQg2MVVhqWTnS8p471wHc3",
"slot": 364646353,
"timestamp": 1757006661
},
{
"amount_in": 3.5,
"amount_out": 112104477.61194,
"is_buy": true,
"mint": "7fYXJyjP668CofJ92dNCdfCQg2MVVhqWTnS8p471wHc3",
"slot": 364646343,
"timestamp": 1757006657
}
],
"deposit_details": {
"GYAmP7BLzUpgmT4yR3uDcwuixdj6845XGHMiyWUha4pP": 0.620005
},
"deposit_exchange": "Okx",
"deposit_label": "Okx: Hot wallet",
"deposit_time": 1757005680,
"id": "tr:8h1TrDRP5pTQ1mKq8iXK7H2jvQvRk2m6sDfN9TrAdEr",
"last_trade_time": 1757006662,
"last_updated_slot": 364646356,
"last_updated_timestamp": 1757006662,
"pubkey": "8h1TrDRP5pTQ1mKq8iXK7H2jvQvRk2m6sDfN9TrAdEr",
"total_trades": 1486,
"total_volume": 62788.25699238607
}Example 2: Combining event topics and trader state
Use event payload to derive pubkey and interpolate it in the RocksDB key. See Topics specification in dsl-system/main-topics.md.
{
"stream_definition": { // StreamDefinition
{
"name": "string (required)", // Name
"description": "string (required)", // Description
"state": [ // States
{
"state_name": "pubkey", // Alias for trader public key
"source": "event_data", // Use event payload
"key": "pubkey" // JSON path to public key
},
{
"state_name": "trader_state", // Alias for trader state record
"source": "rocksdb", // Read from RocksDB
"key": "trader#t:{pubkey}" // Interpolate `pubkey`
}
],
"topic_subscription": {}, // TopicSubscription
"conditions": [...], // ConditionGroup[]
"actions": [...] // Action[]
}
}
}Last updated