onFilterTokensUpdated

Subscriptions use wss://graphql.mobula.io/graphql with the graphql-transport-ws protocol. wss://graphql.mobula.io/graphql/subscriptions is also supported for backwards compatibility.

Overview

Stream the current page of a filterTokens query in real time. The same filters, rankings, and pagination arguments accepted by filterTokens are accepted here — the server re-evaluates them on every tick and pushes the full current page.

First message is the full filtered set for the supplied arguments.
Subsequent messages re-run the filter every updatePeriod ms and yield the full current set (not a delta).
updatePeriod defaults to 500 ms and is capped at 60000 ms.

Returns

FilterTokenUpdates!

Current page of matching tokens for the supplied filters. See FilterTokenUpdates.

Arguments

TokenFilters

Filter conditions. See TokenFilters.

[TokenRanking]

Sorting criteria. See TokenRanking and TokenRankingAttribute.

TokenPairStatisticsType

FILTERED or UNFILTERED. See TokenPairStatisticsType.

String

Search phrase to match against token name or symbol.

[String]

Array of specific token selectors in "address:networkId" format.

[String]

Array of token addresses to exclude from results.

Int

Maximum number of results to return (default: 25, max: 200).

Int

Pagination offset (default: 0).

Int

Update interval in milliseconds (default: 500, max: 60000).

Example

subscription {
  onFilterTokensUpdated(
    filters: {
      network: [1]
      liquidity: { gte: 10000 }
      volume24: { gte: 50000 }
    }
    rankings: [{ attribute: volume24, direction: DESC }]
    updatePeriod: 1000
    limit: 10
  ) {
    updates {
      priceUSD
      liquidity
      marketCap
      volume24
      change24
      buyCount24
      sellCount24
      holders
      token { name symbol address networkId }
    }
  }
}

Open a graphql-transport-ws WebSocket to wss://api.mobula.io/graphql/subscriptions, complete the connection_init handshake, then send a subscribe message:

{
  "id": "1",
  "type": "subscribe",
  "payload": {
    "query": "subscription ($filters: TokenFilters, $period: Int, $limit: Int) { onFilterTokensUpdated(filters: $filters, updatePeriod: $period, limit: $limit) { updates { priceUSD liquidity volume24 change24 token { name symbol address networkId } } } }",
    "variables": {
      "filters": { "network": [1], "liquidity": { "gte": 10000 }, "volume24": { "gte": 50000 } },
      "period": 1000,
      "limit": 10
    }
  }
}

GraphQL API Reference

Queries (Alpha Preview)

Mutations (Alpha Preview)

Subscriptions (Alpha Preview)

Types

onFilterTokensUpdated

Overview

Returns

Arguments

Example

​Overview

​Returns

​Arguments

​Example

​Subscribe example

Overview

Returns

Arguments

Example

Subscribe example