🗄️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[]
    }
  }
}