npm install @covalenthq/client-sdk

yarn add @covalenthq/client-sdk

import {
  GoldRushClient,
  StreamingChain,
  StreamingInterval,
  StreamingTimeframe
} from "@covalenthq/client-sdk";

const client = new GoldRushClient(
  "",
  {},
  {
    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");
    },
  }
);

import { createClient } from "graphql-ws";

const CONNECTION_URL = "wss://gr-staging-v2.streaming.covalenthq.com/graphql";

// Define your API key
const API_KEY = "";

const client = createClient({
  url: CONNECTION_URL,
  connectionParams: {
    GOLDRUSH_API_KEY: API_KEY,
  },
  shouldRetry: (retries) => retries  {
      console.log("⏳ WebSocket connecting...");
    },
    opened: () => {
      console.log("✅ WebSocket connection established");
    },
    closed: () => {
      console.log("❌ WebSocket connection closed");
    },
    error: (err) => {
      console.error("⚠️ WebSocket error:", err);
    },
  },
});

const SUBSCRIPTION_QUERY = `
  subscription {
    ohlcvCandlesForToken(
      chain_name: BASE_MAINNET
      token_addresses: ["0x0b3e328455c4059EEb9e3f84b5543F74E24e7E1b"]
      interval: ONE_MINUTE
      timeframe: ONE_HOUR
    ) {
      chain_name
      interval
      timeframe
      timestamp
      open
      high
      low
      close
      volume
      volume_usd
      quote_rate
      quote_rate_usd
      base_token {
        contract_name
        contract_address
        contract_decimals
        contract_ticker_symbol
      }
    }
  }
`;

client.subscribe(
  {
    query: SUBSCRIPTION_QUERY,
  },
  {
    next: (data) => {
      console.log("Received data:");
      console.log(JSON.stringify(data, null, 2));
    },
    error: (err) => {
      console.error("Subscription error:", err);
    },
    complete: () => {
      console.log("Subscription completed");
    },
  }
);

import asyncio
from gql import gql, Client
from gql.transport.websockets import WebsocketsTransport

# Replace with your actual API key
GOLDRUSH_API_KEY = ""

# GraphQL WebSocket endpoint
WS_URL = "wss://gr-staging-v2.streaming.covalenthq.com/graphql"

# Define the subscription query
SUBSCRIPTION_QUERY = gql("""
subscription {
  ohlcvCandlesForToken(
    chain_name: BASE_MAINNET
    token_addresses: ["0x0b3e328455c4059EEb9e3f84b5543F74E24e7E1b"]
    interval: ONE_MINUTE
    timeframe: ONE_HOUR
  ) {
    chain_name
    interval
    timeframe
    timestamp
    open
    high
    low
    close
    volume
    volume_usd
    quote_rate
    quote_rate_usd
    base_token {
      contract_name
      contract_address
      contract_decimals
      contract_ticker_symbol
    }
  }
}
""")

async def main():
    # Set up WebSocket transport with API key in connection init payload
    transport = WebsocketsTransport(
        url=WS_URL,
        init_payload={"apiKey": API_KEY}
    )

    # Create GraphQL client
    async with Client(
        transport=transport,
        fetch_schema_from_transport=False,
    ) as session:
        # Subscribe and print data
        async for result in session.subscribe(SUBSCRIPTION_QUERY):
            print("📡 Received data:")
            print(result)

# Run the async main function
asyncio.run(main())

( echo '{"type":"connection_init","payload":{"GOLDRUSH_API_KEY":""}}'; \
  echo '{"type":"start","id":"1","payload":{"query":"subscription { ohlcvCandlesForToken(chain_name: BASE_MAINNET, token_addresses: [\"0x0b3e328455c4059EEb9e3f84b5543F74E24e7E1b\"], interval: ONE_MINUTE, timeframe: ONE_HOUR) { timestamp open high low close volume volume_usd quote_rate quote_rate_usd base_token { contract_name contract_address contract_decimals contract_ticker_symbol } } }"}}' \
) | websocat --header="Sec-WebSocket-Protocol: graphql-ws" wss://gr-staging-v2.streaming.covalenthq.com/graphql | jq