WebSocket API - ChainStream

概要

ChainStream DEX WebSocket APIは、以下のデータタイプをサポートするリアルタイムデータサブスクリプションサービスを提供します：

ローソク足データ (Candles)
トークン関連 (Token Series)
ウォレット関連 (Wallet Series)
ランキング関連 (Ranking Series)
取引関連 (Trade Series)
DEXプール関連 (DexPool Series)

ベースURL

wss://realtime-dex.chainstream.io/connection/websocket

クイックスタート

1. 接続の確立

まず、WebSocket接続を作成します。WebSocket接続はURL内のtokenクエリパラメータによる認証が必要です。

SDK使用（推奨）
ネイティブWebSocket使用
コマンドラインテスト

GoまたはJavaScript SDKを使用する場合、認証は自動的に処理されます：

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接サブスクライブするだけで、SDKがWebSocket接続と認証を自動処理
client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('受信データ:', data);
  }
});

subscribeXXXメソッドを呼び出す際、SDKは自動的に接続状態を確認し、未接続の場合は自動的に接続を確立します。手動でconnect()を呼び出す必要はありません。

SDKインストール：

TypeScript/JavaScript: npm install @chainstream-io/sdk (npm)
Python: pip install chainstream-sdk (PyPI)
Go: go get github.com/chainstream-io/chainstream-go-sdk (GitHub)
Rust: Cargo.tomlにchainstream-sdkを追加 (crates.io)

ブラウザネイティブWebSocketまたはその他のWebSocketライブラリを使用する場合、URLにtokenパラメータを追加します：

// ブラウザとNode.jsの両方で使用可能
const token = 'YOUR_ACCESS_TOKEN';
const ws = new WebSocket(
  `wss://realtime-dex.chainstream.io/connection/websocket?token=${token}`
);

ws.onopen = () => {
  console.log('接続確立');
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('受信データ:', data);
};

URLパラメータでtokenを渡すことで、ブラウザネイティブWebSocketや各種サードパーティライブラリを、ヘッダーの特別な処理なしに使用できます。

wscatを使用したテスト：

$ wscat -c "wss://realtime-dex.chainstream.io/connection/websocket?token=YOUR_ACCESS_TOKEN"

2. データのサブスクライブ

サブスクライブしたいデータタイプを選択します：

// ローソク足データのサブスクライブ例
ws.send(JSON.stringify({
  type: "subscribe",
  channel: "dex-candle:sol_6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN_1m"
}));

3. データの処理

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('受信データ:', data);
};

データサブスクリプション

ローソク足

ローソク足データ

トークンの価格推移データをリアルタイムで取得します。 サブスクリプション形式

dex-candle:{chain}_{tokenAddress}_{resolution}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス、例：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

resolution

string

必須

ローソク足期間、対応：1m, 5m, 15m, 1h, 4h, 1d

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：volume > 1000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "o": number,    // Open price
  "c": number,    // Close price
  "h": number,    // High price
  "l": number,    // Low price
  "v": number,    // Volume
  "r": string,    // Resolution
  "t": number     // Timestamp
}

{
  "open": number,       // Open price
  "close": number,      // Close price
  "high": number,       // High price
  "low": number,        // Low price
  "volume": number,     // Volume
  "resolution": string, // Resolution
  "time": number       // Timestamp
}

トークン関連

トークン統計

トークンのリアルタイム市場統計データを取得します。 サブスクリプション形式

dex-token-stats:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス、例：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：price > 0.01

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,      // Token address
  "t": number,      // Timestamp
  "b1m": number,    // Buys in 1m
  "s1m": number,    // Sells in 1m
  "be1m": number,   // Buyers in 1m
  "se1m": number,   // Sellers in 1m
  "bviu1m": number, // Buy volume in USD 1m
  "sviu1m": number, // Sell volume in USD 1m
  "p1m": number,    // Price 1m
  "oiu1m": number,  // Open price in USD 1m
  "ciu1m": number,  // Close price in USD 1m
  "b5m": number,    // Buys in 5m
  "s5m": number,    // Sells in 5m
  "be5m": number,   // Buyers in 5m
  "se5m": number,   // Sellers in 5m
  "bviu5m": number, // Buy volume in USD 5m
  "sviu5m": number, // Sell volume in USD 5m
  "p5m": number,    // Price 5m
  "oiu5m": number,  // Open price in USD 5m
  "ciu5m": number,  // Close price in USD 5m
  "b15m": number,   // Buys in 15m
  "s15m": number,   // Sells in 15m
  "be15m": number,  // Buyers in 15m
  "se15m": number,  // Sellers in 15m
  "bviu15m": number,// Buy volume in USD 15m
  "sviu15m": number,// Sell volume in USD 15m
  "p15m": number,   // Price 15m
  "oiu15m": number, // Open price in USD 15m
  "ciu15m": number, // Close price in USD 15m
  "b30m": number,   // Buys in 30m
  "s30m": number,   // Sells in 30m
  "be30m": number,  // Buyers in 30m
  "se30m": number,  // Sellers in 30m
  "bviu30m": number,// Buy volume in USD 30m
  "sviu30m": number,// Sell volume in USD 30m
  "p30m": number,   // Price 30m
  "oiu30m": number, // Open price in USD 30m
  "ciu30m": number, // Close price in USD 30m
  "b1h": number,    // Buys in 1h
  "s1h": number,    // Sells in 1h
  "be1h": number,   // Buyers in 1h
  "se1h": number,   // Sellers in 1h
  "bviu1h": number, // Buy volume in USD 1h
  "sviu1h": number, // Sell volume in USD 1h
  "p1h": number,    // Price 1h
  "oiu1h": number,  // Open price in USD 1h
  "ciu1h": number,  // Close price in USD 1h
  "b4h": number,    // Buys in 4h
  "s4h": number,    // Sells in 4h
  "be4h": number,   // Buyers in 4h
  "se4h": number,   // Sellers in 4h
  "bviu4h": number, // Buy volume in USD 4h
  "sviu4h": number, // Sell volume in USD 4h
  "p4h": number,    // Price 4h
  "oiu4h": number,  // Open price in USD 4h
  "ciu4h": number,  // Close price in USD 4h
  "b24h": number,   // Buys in 24h
  "s24h": number,   // Sells in 24h
  "be24h": number,  // Buyers in 24h
  "se24h": number,  // Sellers in 24h
  "bviu24h": number,// Buy volume in USD 24h
  "sviu24h": number,// Sell volume in USD 24h
  "p24h": number,   // Price 24h
  "oiu24h": number, // Open price in USD 24h
  "ciu24h": number, // Close price in USD 24h
  "p": number       // Current price
}

{
  "address": string,           // Token address
  "timestamp": number,         // Timestamp
  "buys1m": number,           // Buys in 1m
  "sells1m": number,          // Sells in 1m
  "buyers1m": number,         // Buyers in 1m
  "sellers1m": number,        // Sellers in 1m
  "buyVolumeInUsd1m": number, // Buy volume in USD 1m
  "sellVolumeInUsd1m": number,// Sell volume in USD 1m
  "price1m": number,          // Price 1m
  "openInUsd1m": number,      // Open price in USD 1m
  "closeInUsd1m": number,     // Close price in USD 1m
  "buys5m": number,           // Buys in 5m
  "sells5m": number,          // Sells in 5m
  "buyers5m": number,         // Buyers in 5m
  "sellers5m": number,        // Sellers in 5m
  "buyVolumeInUsd5m": number, // Buy volume in USD 5m
  "sellVolumeInUsd5m": number,// Sell volume in USD 5m
  "price5m": number,          // Price 5m
  "openInUsd5m": number,      // Open price in USD 5m
  "closeInUsd5m": number,     // Close price in USD 5m
  "buys15m": number,          // Buys in 15m
  "sells15m": number,         // Sells in 15m
  "buyers15m": number,        // Buyers in 15m
  "sellers15m": number,       // Sellers in 15m
  "buyVolumeInUsd15m": number,// Buy volume in USD 15m
  "sellVolumeInUsd15m": number,// Sell volume in USD 15m
  "price15m": number,         // Price 15m
  "openInUsd15m": number,     // Open price in USD 15m
  "closeInUsd15m": number,    // Close price in USD 15m
  "buys30m": number,          // Buys in 30m
  "sells30m": number,         // Sells in 30m
  "buyers30m": number,        // Buyers in 30m
  "sellers30m": number,       // Sellers in 30m
  "buyVolumeInUsd30m": number,// Buy volume in USD 30m
  "sellVolumeInUsd30m": number,// Sell volume in USD 30m
  "price30m": number,         // Price 30m
  "openInUsd30m": number,     // Open price in USD 30m
  "closeInUsd30m": number,    // Close price in USD 30m
  "buys1h": number,           // Buys in 1h
  "sells1h": number,          // Sells in 1h
  "buyers1h": number,         // Buyers in 1h
  "sellers1h": number,        // Sellers in 1h
  "buyVolumeInUsd1h": number, // Buy volume in USD 1h
  "sellVolumeInUsd1h": number,// Sell volume in USD 1h
  "price1h": number,          // Price 1h
  "openInUsd1h": number,      // Open price in USD 1h
  "closeInUsd1h": number,     // Close price in USD 1h
  "buys4h": number,           // Buys in 4h
  "sells4h": number,          // Sells in 4h
  "buyers4h": number,         // Buyers in 4h
  "sellers4h": number,        // Sellers in 4h
  "buyVolumeInUsd4h": number, // Buy volume in USD 4h
  "sellVolumeInUsd4h": number,// Sell volume in USD 4h
  "price4h": number,          // Price 4h
  "openInUsd4h": number,      // Open price in USD 4h
  "closeInUsd4h": number,     // Close price in USD 4h
  "buys24h": number,          // Buys in 24h
  "sells24h": number,         // Sells in 24h
  "buyers24h": number,        // Buyers in 24h
  "sellers24h": number,       // Sellers in 24h
  "buyVolumeInUsd24h": number,// Buy volume in USD 24h
  "sellVolumeInUsd24h": number,// Sell volume in USD 24h
  "price24h": number,         // Price 24h
  "openInUsd24h": number,     // Open price in USD 24h
  "closeInUsd24h": number,    // Close price in USD 24h
  "price": number            // Current price
}

トークン保有者統計

トークン保有者のリアルタイム統計情報を取得します。 サブスクリプション形式

dex-token-holding:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス、例：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：holders > 200

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,      // Token address
  "h": number,      // Number of holders
  "t100a": number,  // Top 100 holders total amount
  "t10a": number,   // Top 10 holders total amount
  "t100h": number,  // Top 100 holders count
  "t10h": number,   // Top 10 holders count
  "t100r": number,  // Top 100 holders ratio
  "t10r": number,   // Top 10 holders ratio
  "ch": number,     // Creators holders count
  "ca": number,     // Creators amount
  "cr": number,     // Creators ratio
  "ts": number      // Timestamp
}

{
  "tokenAddress": string,    // Token address
  "holders": number,         // Number of holders
  "top100Amount": number,    // Top 100 holders total amount
  "top10Amount": number,     // Top 10 holders total amount
  "top100Holders": number,   // Top 100 holders count
  "top10Holders": number,    // Top 10 holders count
  "top100Ratio": number,     // Top 100 holders ratio
  "top10Ratio": number,      // Top 10 holders ratio
  "creatorsHolders": number, // Creators holders count
  "creatorsAmount": number,  // Creators amount
  "creatorsRatio": number,   // Creators ratio
  "timestamp": number        // Timestamp
}

新規トークンメタデータ

新規上場トークンのリアルタイムメタデータを取得します。 サブスクリプション形式

dex-new-tokens-metadata:{chain}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：name == “USDC”

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

[
  {
    "a": string,      // Token address
    "n": string,      // Name
    "s": string,      // Symbol
    "iu": string,     // Image URL
    "de": string,     // Description
    "sm": {           // Social media
      "tw": string,   // Twitter
      "tg": string,   // Telegram
      "w": string,    // Website
      "tt": string,   // TikTok
      "dc": string,   // Discord
      "fb": string,   // Facebook
      "gh": string,   // GitHub
      "ig": string,   // Instagram
      "li": string,   // LinkedIn
      "md": string,   // Medium
      "rd": string,   // Reddit
      "yt": string,   // YouTube
      "bb": string    // BitBucket
    },
    "cts": number     // Created timestamp (ms)
  }
]

[
  {
    "tokenAddress": string,     // Token address
    "name": string,             // Name
    "symbol": string,           // Symbol
    "imageUrl": string,         // Image URL
    "description": string,      // Description
    "socialMedia": {            // Social media
      "twitter": string,        // Twitter
      "telegram": string,       // Telegram
      "website": string,        // Website
      "tiktok": string,         // TikTok
      "discord": string,        // Discord
      "facebook": string,       // Facebook
      "github": string,         // GitHub
      "instagram": string,      // Instagram
      "linkedin": string,       // LinkedIn
      "medium": string,         // Medium
      "reddit": string,         // Reddit
      "youtube": string,        // YouTube
      "bitbucket": string       // BitBucket
    },
    "createdAtMs": number       // Created timestamp (ms)
  }
]

新規トークン

新しく作成されたトークンの情報を取得します。 サブスクリプション形式

dex-new-token:{chain}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,      // Token address
  "n": string,      // Name
  "s": string,      // Symbol
  "dec": number,    // Decimals
  "cts": number,    // Created timestamp (ms)
  "lf": {           // Launch from information
    "pa": string,   // Program address
    "pf": string,   // Protocol family
    "pn": string    // Protocol name
  }
}

{
  "tokenAddress": string,     // Token address
  "name": string,             // Name
  "symbol": string,           // Symbol
  "decimals": number,         // Decimals
  "createdAtMs": number,      // Created timestamp (ms)
  "launchFrom": {             // Launch from information
    "programAddress": string, // Program address
    "protocolFamily": string, // Protocol family
    "protocolName": string    // Protocol name
  }
}

トークン供給量

トークンの供給量と時価総額のリアルタイム情報を取得します。 サブスクリプション形式

dex-token-supply:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス、例：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：supply > 1000000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,    // Token address
  "s": number,    // Supply
  "mc": number,   // Market cap in USD
  "ts": number    // Timestamp
}

{
  "tokenAddress": string,    // Token address
  "supply": number,          // Supply
  "marketCapInUsd": number,  // Market cap in USD
  "timestamp": number        // Timestamp
}

トークン流動性

トークンのリアルタイム流動性統計を取得します。 サブスクリプション形式

dex-token-general-stat-num:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：value > 1000000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,    // Token address
  "t": string,    // Metric type
  "v": number,    // Value
  "ts": number    // Timestamp
}

{
  "tokenAddress": string,  // Token address
  "metricType": string,    // Metric type
  "value": number,         // Value
  "timestamp": number      // Timestamp
}

トークン最大流動性

単一プール内のトークンのリアルタイム最大流動性情報を取得します。 サブスクリプション形式

dex-token-liquidity:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：liquidityInUsd > 10000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,     // Token address
  "p": string,     // Pool address
  "liu": string,   // Liquidity in USD
  "lin": string,   // Liquidity in native token
  "ts": number     // Timestamp
}

{
  "tokenAddress": string,       // Token address
  "poolAddress": string,        // Pool address
  "liquidityInUsd": string,     // Liquidity in USD
  "liquidityInNative": string,  // Liquidity in native token
  "timestamp": number           // Timestamp
}

トークン合計流動性

全プールにわたるトークンのリアルタイム合計流動性情報を取得します。 サブスクリプション形式

dex-token-total-liquidity:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：liquidityInUsd > 50000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,     // Token address
  "liu": string,   // Total liquidity in USD
  "lin": string,   // Total liquidity in native token
  "pc": number,    // Pool count
  "ts": number     // Timestamp
}

{
  "tokenAddress": string,       // Token address
  "liquidityInUsd": string,     // Total liquidity in USD
  "liquidityInNative": string,  // Total liquidity in native token
  "poolCount": number,          // Pool count
  "timestamp": number           // Timestamp
}

ランキング関連

ウォレット関連

ウォレット残高

ウォレットのリアルタイム残高情報を取得します。 サブスクリプション形式

dex-wallet-balance:{chain}_{walletAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

walletAddress

string

必須

ウォレットアドレス、例：HN7cABqLq46Es1jh92dQQisAq662SmxELLLsHHe4YWrH

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：balance > 1000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

[
  {
    "a": string,      // Wallet address
    "ta": string,     // Token address
    "tpiu": number,   // Token price in USD
    "b": number,      // Balance
    "t": number       // Timestamp
  }
]

[
  {
    "walletAddress": string,    // Wallet address
    "tokenAddress": string,     // Token address
    "tokenPriceInUsd": number, // Token price in USD
    "balance": number,          // Balance
    "timestamp": number         // Timestamp
  }
]

ウォレットPnLデータ（トークンレベル）

ウォレットのリアルタイム損益（PnL）統計を取得します。 サブスクリプション形式

dex-wallet-token-pnl:{chain}_{walletAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

walletAddress

string

必須

ウォレットアドレス

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：buyAmount > 1000

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,      // Wallet address
  "ta": string,     // Token address
  "tpiu": number,   // Token price in USD
  "t": number,      // Timestamp
  "ot": number,     // Open time
  "lt": number,     // Last time
  "ct": number,     // Close time
  "ba": number,     // Buy amount
  "baiu": number,   // Buy amount in USD
  "bs": number,     // Buy count
  "bs30d": number,  // Buy count 30d
  "bs7d": number,   // Buy count 7d
  "sa": number,     // Sell amount
  "saiu": number,   // Sell amount in USD
  "ss": number,     // Sell count
  "ss30d": number,  // Sell count 30d
  "ss7d": number,   // Sell count 7d
  "hdts": number,   // Held duration timestamp
  "abpiu": number,  // Average buy price in USD
  "aspiu": number,  // Average sell price in USD
  "upiu": number,   // Unrealized profit in USD
  "upr": number,    // Unrealized profit ratio
  "rpiu": number,   // Realized profit in USD
  "rpr": number,    // Realized profit ratio
  "trpiu": number,  // Total realized profit in USD
  "trr": number     // Total realized profit ratio
}

{
  "walletAddress": string,         // Wallet address
  "tokenAddress": string,          // Token address
  "tokenPriceInUsd": number,       // Token price in USD
  "timestamp": number,             // Timestamp
  "opentime": number,              // Open time
  "lasttime": number,              // Last time
  "closetime": number,             // Close time
  "buyAmount": number,             // Buy amount
  "buyAmountInUsd": number,        // Buy amount in USD
  "buyCount": number,              // Buy count
  "buyCount30d": number,           // Buy count 30d
  "buyCount7d": number,            // Buy count 7d
  "sellAmount": number,            // Sell amount
  "sellAmountInUsd": number,       // Sell amount in USD
  "sellCount": number,             // Sell count
  "sellCount30d": number,          // Sell count 30d
  "sellCount7d": number,           // Sell count 7d
  "heldDurationTimestamp": number, // Held duration timestamp
  "averageBuyPriceInUsd": number,  // Average buy price in USD
  "averageSellPriceInUsd": number, // Average sell price in USD
  "unrealizedProfitInUsd": number, // Unrealized profit in USD
  "unrealizedProfitRatio": number, // Unrealized profit ratio
  "realizedProfitInUsd": number,   // Realized profit in USD
  "realizedProfitRatio": number,   // Realized profit ratio
  "totalRealizedProfitInUsd": number, // Total realized profit in USD
  "totalRealizedProfitRatio": number  // Total realized profit ratio
}

ウォレットPnLデータ（ウォレットレベル）

ウォレットのリアルタイム全体損益統計を取得します。 サブスクリプション形式

dex-wallet-pnl-list:{chain}_{walletAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

walletAddress

string

必須

ウォレットアドレス

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

[
  {
    "a": string,     // Wallet address
    "bs": number,    // Number of buys
    "ba": number,    // Buy amount
    "baiu": number,  // Buy amount in USD
    "abpiu": number, // Average buy price in USD
    "sa": number,    // Sell amount
    "saiu": number,  // Sell amount in USD
    "ss": number,    // Number of sells
    "ws": number,    // Number of wins
    "wr": number,    // Win ratio
    "piu": number,   // PnL in USD
    "apiu": number,  // Average PnL in USD
    "pr": number,    // PnL ratio
    "pd": number,    // Profitable days
    "ld": number,    // Losing days
    "ts": number,    // Number of tokens traded
    "r": string      // Resolution
  }
]

[
  {
    "walletAddress": string,         // Wallet address
    "buys": number,                  // Number of buys
    "buyAmount": number,             // Buy amount
    "buyAmountInUsd": number,        // Buy amount in USD
    "averageBuyPriceInUsd": number,  // Average buy price in USD
    "sellAmount": number,            // Sell amount
    "sellAmountInUsd": number,       // Sell amount in USD
    "sells": number,                 // Number of sells
    "wins": number,                  // Number of wins
    "winRatio": number,              // Win ratio
    "pnlInUsd": number,              // PnL in USD
    "averagePnlInUsd": number,       // Average PnL in USD
    "pnlRatio": number,              // PnL ratio
    "profitableDays": number,        // Profitable days
    "losingDays": number,            // Losing days
    "tokens": number,                // Number of tokens traded
    "resolution": string             // Resolution
  }
]

取引関連

トークン取引

トークンのリアルタイム取引イベントを取得します。 サブスクリプション形式

dex-trade:{chain}_{tokenAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

tokenAddress

string

必須

トークンコントラクトアドレス、例：6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN

filter

string

オプションのフィルター条件。Google Common Expression Language（CEL）構文を使用。例：buyAmount > 100

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,      // Token address
  "t": number,      // Timestamp
  "k": string,      // Trade type
  "ba": number,     // Buy amount
  "baiu": number,   // Buy amount in USD
  "btma": string,   // Buy token address
  "btn": string,    // Buy token name
  "bts": string,    // Buy token symbol
  "bwa": string,    // Buy wallet address
  "sa": number,     // Sell amount
  "saiu": number,   // Sell amount in USD
  "stma": string,   // Sell token address
  "stn": string,    // Sell token name
  "sts": string,    // Sell token symbol
  "swa": string,    // Sell wallet address
  "h": string       // Transaction hash
}

{
  "tokenAddress": string,    // Token address
  "timestamp": number,       // Timestamp
  "kind": string,            // Trade type
  "buyAmount": number,       // Buy amount
  "buyAmountInUsd": number,  // Buy amount in USD
  "buyTokenAddress": string, // Buy token address
  "buyTokenName": string,    // Buy token name
  "buyTokenSymbol": string,  // Buy token symbol
  "buyWalletAddress": string,// Buy wallet address
  "sellAmount": number,      // Sell amount
  "sellAmountInUsd": number,// Sell amount in USD
  "sellTokenAddress": string,// Sell token address
  "sellTokenName": string,   // Sell token name
  "sellTokenSymbol": string,// Sell token symbol
  "sellWalletAddress": string,// Sell wallet address
  "txHash": string          // Transaction hash
}

ウォレット取引

ウォレットのリアルタイム取引イベントを取得します。 サブスクリプション形式

dex-wallet-trade:{chain}_{walletAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

walletAddress

string

必須

ウォレットアドレス、例：GDekof7TtgeBKJtoVpkvzPin5mvhxSDyoUY2c1FK1T3i

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "bwa": string,     // Maker address
  "ba": number,      // Base token amount
  "sa": number,      // Quote token amount
  "swa": string,     // Quote token address
  "bais": number,    // USD amount
  "t": number,       // Timestamp
  "k": string,       // Event type
  "h": string,       // Transaction hash
  "a": string        // Token address
}

{
  "maker": string,        // Maker address
  "baseAmount": number,   // Base token amount
  "quoteAmount": number,  // Quote token amount
  "quoteAddress": string, // Quote token address
  "amountInUsd": number,  // USD amount
  "timestamp": number,    // Timestamp
  "event": string,       // Event type
  "txHash": string,      // Transaction hash
  "tokenAddress": string  // Token address
}

DEXプール関連

DEXプール残高

DEXプールのリアルタイム残高情報を取得します。 サブスクリプション形式

dex-pool-balance:{chain}_{poolAddress}

パラメータ

chain

string

必須

ブロックチェーン名、例：sol

poolAddress

string

必須

プールアドレス

レスポンスデータ形式

WebSocket APIは転送効率を最適化するために短縮フィールド名を返し、SDKはコードの可読性を向上させるために完全なフィールド名を返します。

WebSocket API
SDK

{
  "a": string,     // Pool address
  "taa": string,   // Token A address
  "taliu": number, // Token A liquidity in USD
  "tba": string,   // Token B address
  "tbliu": number  // Token B liquidity in USD
}

{
  "poolAddress": string,           // Pool address
  "tokenAAddress": string,         // Token A address
  "tokenALiquidityInUsd": number,  // Token A liquidity in USD
  "tokenBAddress": string,         // Token B address
  "tokenBLiquidityInUsd": number   // Token B liquidity in USD
}

使用例

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接サブスクライブするだけで、SDKが接続状態を自動検出し必要に応じて接続
client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('ローソク足データ:', data);
  }
});

// ウォレット残高のサブスクライブ
client.stream.subscribeWalletBalance({
  chain: 'sol',
  walletAddress: 'YOUR_WALLET_ADDRESS',
  callback: (data) => {
    console.log('ウォレット残高:', data);
  }
});

再接続戦略

指数バックオフによる再接続を推奨します：

function reconnect(attempt) {
  const delay = Math.min(1000 * Math.pow(2, attempt), 10000);
  setTimeout(() => {
    connect();
  }, delay);
}

使用制限

制限項目	制限値	説明
最大サブスクリプション数	100/接続	超過分は拒否されます
メッセージサイズ	100KB	超過分は切り捨てられます
ハートビート間隔	30秒	定期的なハートビートが必要です

ベストプラクティス

接続管理
- 単一のWebSocket接続を維持
- 自動再接続を実装
- 定期的なハートビートの送信
エラーハンドリング
- 完全なエラー処理を実装
- 詳細なエラー情報をログに記録
- 指数バックオフによる再接続を使用
パフォーマンス最適化
- サブスクリプション数を制御
- メッセージキューメカニズムを実装
- 使用していないサブスクリプションをクリーンアップ

完全な例

SDK使用（推奨）
ネイティブWebSocket

import { ChainStreamClient } from '@chainstream-io/sdk';
import { Resolution } from '@chainstream-io/sdk/openapi';

const client = new ChainStreamClient('YOUR_ACCESS_TOKEN');

// 直接サブスクライブするだけで、SDKが接続状態を自動検出し必要に応じて接続
const subscription = client.stream.subscribeTokenCandles({
  chain: 'sol',
  tokenAddress: '6p6xgHyF7AeE6TZkSmFsko444wqoP15icUSqi2jfGiPN',
  resolution: Resolution._1m,
  callback: (data) => {
    console.log('ローソク足データ:', data);
  }
});

// サブスクリプション解除
subscription.unsubscribe();

SDKを使用する場合、認証、再接続、ハートビートなどはすべて自動的に処理されます。本番環境での使用を推奨します。

TypeScript/JavaScript SDK: @chainstream-io/sdk
Python SDK: chainstream-sdk
Go SDK: chainstream-go-sdk
Rust SDK: chainstream-sdk

class DexWebSocket {
  private ws: WebSocket;
  private reconnectAttempts = 0;
  private maxReconnectAttempts = 5;
  private subscriptions = new Set<string>();

  constructor(
    private baseUrl: string,
    private accessToken: string
  ) {
    this.connect();
  }

  private connect() {
    // Append token parameter to URL for authentication
    const url = `${this.baseUrl}?token=${this.accessToken}`;
    this.ws = new WebSocket(url);
    
    this.ws.onopen = () => {
      console.log('WebSocket connection established');
      this.reconnectAttempts = 0;
      // Resubscribe to previous channels
      this.resubscribe();
    };

    this.ws.onmessage = (event) => {
      this.handleMessage(JSON.parse(event.data));
    };

    this.ws.onclose = () => {
      console.log('WebSocket connection closed');
      this.reconnect();
    };

    this.ws.onerror = (error) => {
      console.error('WebSocket error:', error);
    };
  }

  private reconnect() {
    if (this.reconnectAttempts < this.maxReconnectAttempts) {
      const delay = Math.min(1000 * Math.pow(2, this.reconnectAttempts), 10000);
      this.reconnectAttempts++;
      console.log(`Attempting reconnection in ${delay}ms...`);
      setTimeout(() => this.connect(), delay);
    }
  }

  private resubscribe() {
    this.subscriptions.forEach(channel => {
      this.send({ type: "subscribe", channel });
    });
  }

  private handleMessage(data: any) {
    // Handle message
  }

  private send(data: any) {
    if (this.ws.readyState === WebSocket.OPEN) {
      this.ws.send(JSON.stringify(data));
    }
  }

  public subscribe(channel: string) {
    this.subscriptions.add(channel);
    this.send({ type: "subscribe", channel });
  }

  public unsubscribe(channel: string) {
    this.subscriptions.delete(channel);
    this.send({ type: "unsubscribe", channel });
  }
}

// Usage example
const client = new DexWebSocket(
  "wss://realtime-dex.chainstream.io/connection/websocket",
  "YOUR_ACCESS_TOKEN"
);

認証

DATA API

DEFI API

​概要

​クイックスタート

​1. 接続の確立

​2. データのサブスクライブ

​3. データの処理

​データサブスクリプション

​ローソク足

​ローソク足データ

​トークン関連

​トークン統計

​トークン保有者統計

​新規トークンメタデータ

​新規トークン

​トークン供給量

​トークン流動性

​トークン最大流動性

​トークン合計流動性

​ランキング関連

​ランキングトークン統計

​ランキングトークン保有者統計

​ランキングトークン供給量データ

​ランキングトークン流動性データ

​ランキングトークンリスト

​ランキングトークンボンディングカーブ

​ウォレット関連

​ウォレット残高

​ウォレットPnLデータ（トークンレベル）

​ウォレットPnLデータ（ウォレットレベル）

​取引関連

​トークン取引

​ウォレット取引

​DEXプール関連

​DEXプール残高

​使用例

​再接続戦略

​使用制限

​ベストプラクティス

​完全な例

概要

クイックスタート

1. 接続の確立

2. データのサブスクライブ

3. データの処理

データサブスクリプション

ローソク足

ローソク足データ

トークン関連

トークン統計

トークン保有者統計

新規トークンメタデータ

新規トークン

トークン供給量

トークン流動性

トークン最大流動性

トークン合計流動性

ランキング関連

ランキングトークン統計

ランキングトークン保有者統計

ランキングトークン供給量データ

ランキングトークン流動性データ

ランキングトークンリスト

ランキングトークンボンディングカーブ

ウォレット関連

ウォレット残高

ウォレットPnLデータ（トークンレベル）

ウォレットPnLデータ（ウォレットレベル）

取引関連

トークン取引

ウォレット取引

DEXプール関連

DEXプール残高

使用例

再接続戦略

使用制限

ベストプラクティス

完全な例