Crate exchange_apiws 

exchange-apiws — Exchange REST and WebSocket clients.

Currently supports KuCoin (Spot, Futures, Unified). The crate is designed to be exchange-agnostic: new exchanges implement the actors::ExchangeConnector trait and the shared runner drives their feeds.

Quick start

use std::sync::Arc;
use tokio::sync::{mpsc, watch};
use exchange_apiws::client::Credentials;
use exchange_apiws::connectors::KuCoin;
use exchange_apiws::actors::{DataMessage, ExchangeConnector};
use exchange_apiws::ws::{KucoinConnector, WsRunnerConfig, run_feed};

#[tokio::main]
async fn main() -> exchange_apiws::Result<()> {
    // ── Connect ───────────────────────────────────────────────────────────
    let kucoin = KuCoin::futures(Credentials::from_env()?);
    let client = kucoin.rest_client()?;

    // ── REST ──────────────────────────────────────────────────────────────
    let bal  = client.get_balance("USDT").await?;
    let pos  = client.get_position("XBTUSDTM").await?;
    let bars = client.fetch_klines("XBTUSDTM", 200, "1").await?;

    // ── WebSocket (public) ────────────────────────────────────────────────
    let token = client.get_ws_token_public().await?;
    let conn  = Arc::new(KucoinConnector::new(&token, kucoin.env())?);

    let mut subs = vec![];
    if let Some(s) = conn.trade_subscription("XBTUSDTM")  { subs.push(s); }
    if let Some(s) = conn.ticker_subscription("XBTUSDTM") { subs.push(s); }

    let (tx, mut rx)    = mpsc::channel::<DataMessage>(1024);
    let (sd_tx, sd_rx)  = watch::channel(false);
    let config = WsRunnerConfig::from_ping_interval(conn.ping_interval_secs);

    tokio::spawn(run_feed(conn.ws_url().to_string(), subs, conn, tx, config, sd_rx));

    while let Some(msg) = rx.recv().await {
        println!("{msg:?}");
    }
    Ok(())
}

Module layout

exchange_apiws
├── connectors  — exchange-specific config: KucoinEnv, KuCoin builder, ExchangeConfig trait
│                 (extension point — add new exchanges here)
├── rest/
│   ├── account  — balance, positions, auto-deposit, risk limit, funding history
│   ├── market   — klines, ticker, order book, funding rate, mark price, contracts
│   └── orders   — place, close, cancel, stop orders; fill history; KuCoinClient::calc_contracts
├── ws/
│   ├── connect  — bullet-private / bullet-public token negotiation
│   ├── feed     — KucoinConnector: subscription builders + frame parser
│   ├── runner   — run_feed: async connect/ping/reconnect loop
│   └── types    — WsToken, WsMessage
├── actors   — ExchangeConnector trait, DataMessage and all data types
├── auth     — HMAC-SHA256 signing (key version 2, KuCoin-specific)
├── client   — KuCoinClient (generic HTTP plumbing), Credentials
├── error    — ExchangeError, Result
└── types    — Candle, Side, OrderType, TimeInForce, STP

Re-exports

pub use client::Credentials;

pub use client::KuCoinClient;

pub use connectors::ExchangeConfig;

pub use connectors::KuCoin;

pub use connectors::KucoinEnv;

pub use error::ExchangeError;

pub use error::Result;

pub use types::Candle;

pub use types::OrderType;

pub use types::STP;

pub use types::Side;

pub use types::TimeInForce;

pub use ws::KucoinConnector;

pub use ws::WsRunnerConfig;

pub use ws::run_feed;

Modules

actors

Exchange-agnostic connector traits and normalized data types.

auth

KuCoin API authentication — HMAC-SHA256 signing, key version 2.

client

Generic HTTP client — authenticated reqwest wrapper with exponential-backoff retry.

connectors

Exchange connector definitions.

error

Error types — ExchangeError and the Result alias used throughout the crate.

rest

REST API modules — market data, order management, account.

types

Shared domain types — candles, order sides, contract sizing.

ws

WebSocket modules — types, token negotiation, connector, and runner.