Skip to main content

​
Prerequisites

Using any of the GoldRush developer tools requires an API key.

Vibe Coders

$10/mo — Built for solo builders and AI-native workflows.

Teams

$250/mo — Production-grade with 50 RPS and priority support.

​
Connection

The Streaming API supports GraphQL subscriptions over WebSocket, using the GraphQL over WebSocket protocol. The recommended approach is to use the official TypeScript Client SDK which supports the Streaming API and manages all WebSocket connections. 
npm install @covalenthq/client-sdk
You can also use a GraphQL over WebSocket protocol npm package like graphql-ws.
If you’re not using the graphql-ws package, you must set the WebSocket protocol header:"Sec-WebSocket-Protocol" : "graphql-transport-ws"This header is required for the server to properly recognize and handle your GraphQL subscription requests.

​
OHLCV Token Stream Code Samples

The following examples show how to connect and subscribe to the OHLCV Token stream using your preferred language or tool. Each sample connects to the WebSocket endpoint, authenticates with your API key, and streams real-time OHLCV updates for a token on Base Mainnet. 
import {
  GoldRushClient,
  StreamingChain,
  StreamingInterval,
  StreamingTimeframe
} from "@covalenthq/client-sdk";

const client = new GoldRushClient(
  "<GOLDRUSH_API_KEY>",
  {},
  {
    onConnecting: () => console.log("Connecting to streaming service..."),
    onOpened: () => console.log("Connected to streaming service!"),
    onClosed: () => console.log("Disconnected from streaming service"),
    onError: (error) => console.error("Streaming error:", error),
  }
);

client.StreamingService.subscribeToOHLCVTokens(
  {
    chain_name: StreamingChain.BASE_MAINNET,
    token_addresses: ["0x0b3e328455c4059EEb9e3f84b5543F74E24e7E1b"],
    interval: StreamingInterval.ONE_MINUTE,
    timeframe: StreamingTimeframe.ONE_HOUR,
  },
  {
    next: (data) => {
      console.log("Received OHLCV token data:", data);
    },
    error: (error) => {
      console.error("Streaming error:", error);
    },
    complete: () => {
      console.log("Stream completed");
    },
  }
);

​
Response Format

Here is an example of the response you should receive from the above code samples: 
{
  "data": {
    "ohlcvCandlesForToken": [
      {
        "chain_name": "BASE_MAINNET",
        "interval": "ONE_MINUTE",
        "timeframe": "ONE_HOUR",
        "timestamp": "2025-06-27T22:24:00Z",
        "open": 0.000604418526534047,
        "high": 0.000604638206820701,
        "low": 0.000604013151624892,
        "close": 0.000604638206820701,
        "volume": 1.4980526133065126,
        "volume_usd": 6004669.256018968,
        "quote_rate": 0.000604638206820701,
        "quote_rate_usd": 4007551.6142841205,
        "base_token": {
          "contract_name": "Virtual Protocol",
          "contract_address": "0x0b3e328455c4059eeb9e3f84b5543f74e24e7e1b",
          "contract_decimals": 18,
          "contract_ticker_symbol": "VIRTUAL"
        }
      }
    ]
  }
}

​
GraphQL Playground