Read SDK

import { DecibelReadDex, TESTNET_CONFIG } from "@decibeltrade/sdk";

const read = new DecibelReadDex(TESTNET_CONFIG, {
  // Required: SDK will send Authorization: Bearer <YOUR_NODE_API_KEY> on fullnode requests
  nodeApiKey: process.env.APTOS_NODE_API_KEY!,
  onWsError: (e) => console.warn("WS error", e), // optional
  onChainFallback: ({ method }) => console.warn(`${method} fell back to chain views`), // optional
});

const markets = await read.markets.getAll();
const btc = await read.markets.getByName("BTC/USD");

// getAll() returns perp markets only. Pass includeSpot for both products
// (narrow rows with isSpotMarket / isPerpMarket), or use getAllSpot() for
// spot markets alone. On spot rows, sz_decimals is the base-asset decimals
// and px_decimals the quote-asset decimals; perp-only fields are zeroed.
import { isSpotMarket } from "@decibeltrade/sdk";
const allMarkets = await read.markets.getAll({ includeSpot: true });
const spotMarkets = await read.markets.getAllSpot();

const perpOnly = await read.userOpenOrders.getByAddr({ subAddr });
const spotOnly = await read.userOrderHistory.getByAddr({ subAddr, assetType: "spot" });
const merged = await read.userOpenOrders.getByAddr({ subAddr, assetType: "all" });
const spotFills = await read.userTradeHistory.getByAddr({ subAddr, assetType: "spot" });

// Single order by orderId (perp + spot) or clientOrderId (perp only).
// assetType defaults to unset here: the API checks perp, then spot.
const order = await read.userOrders.getOrder({ subAddr, market, orderId: "42" });

// Bulk orders: placement status by sequence number, and fills
const status = await read.userBulkOrders.getStatus({ subAddr, market, sequenceNumber: 7 });
const fills = await read.userBulkOrders.getFills({ subAddr, assetType: "all" });

const controller = new AbortController();
const request = { subAddr, limit: 1000, fetchOptions: { signal: controller.signal } };
const positions = await read.userPositions.getByAddr(request);
const orders = await read.userOpenOrders.getByAddr({ ...request, assetType: "all" });
const twaps = await read.userActiveTwaps.getByAddr(request);
const activatedTwaps = twaps.filter((twap) => twap.status === "Activated");

const price = await read.marketPrices.getByName({ marketName: "BTC/USD" });

// Subscribe (unsubscribe by calling the returned function)
const unsubscribe = read.marketPrices.subscribeByName("BTC/USD", (msg) => {
  console.log("Price update", msg);
});

// Spot mids: one row per spot market, mid is null unless both book sides
// have liquidity, last_trade_price is null until the first fill
const unsubscribeSpot = read.marketPrices.subscribeAllSpotMids((msg) => {
  console.log("Spot mids", msg.mids);
});

// Candlesticks
import { CandlestickInterval } from "@decibeltrade/sdk";
const candles = await read.candlesticks.getByName({
  marketName: "BTC/USD",
  interval: CandlestickInterval.OneMinute,
  startTime: Date.now() - 60 * 60 * 1000,
  endTime: Date.now(),
});

const spotCandles = await read.candlesticks.getByName({
  marketName: "APT/USDC",
  assetType: "spot",
  interval: CandlestickInterval.OneMinute,
  startTime: Date.now() - 60 * 60 * 1000,
  endTime: Date.now(),
});
const unsubTrades = read.marketTrades.subscribeByName("APT/USDC", onTrades, "spot");
const unsubDepth = read.marketDepth.subscribeByName("APT/USDC", 1, onDepth, "spot");

// If you already hold the market address, skip derivation entirely — the
// address encodes the product, so no assetType is needed
const tradesByAddr = await read.marketTrades.getByAddr({ marketAddr: market.market_addr });
const unsubTradesByAddr = read.marketTrades.subscribeByAddr(market.market_addr, onTrades);
const unsubDepthByAddr = read.marketDepth.subscribeByAddr(market.market_addr, 1, onDepth);
const byAddr = await read.candlesticks.getByAddr({
  marketAddr: market.market_addr,
  interval: CandlestickInterval.OneMinute,
  startTime: Date.now() - 60 * 60 * 1000,
  endTime: Date.now(),
});
const unsubCandles = read.candlesticks.subscribeByAddr(
  market.market_addr,
  CandlestickInterval.OneMinute,
  onCandle,
);

const ownerAddr = "0x...owner";
const subs = await read.userSubaccounts.getByAddr({ ownerAddr });
const overview = await read.accountOverview.getByAddr({ subAddr: subs[0].subaccount_addr });

// Spot inventory: PFS holdings with cost-basis PnL, open-order escrow
// reservations, and lifetime spot metrics. Null for wallet-only owners;
// absent on API versions that predate spot support.
overview.spot?.positions; // [{ asset_addr, asset_symbol, amount, usd_value, entry_notional_usd, unrealized_pnl_usd }]
overview.spot?.in_flight_orders; // escrow reserved by open spot orders
overview.spot?.metrics; // cumulative volume / fees / realized PnL (USD)

const campaigns = await read.campaigns.getActive();
const summary = await read.campaigns.getSummary({
  accountAddress: "0x...owner",
  limit: 20,
  offset: 0,
});

const subAddr = "0x....subaccount";
const fees = await read.userFees.getByAddr({ subAddr });
// fees.user_taker_rate, fees.user_maker_rate, fees.fee_tier (decimals; 0.00045 = 0.045%)
// fees.fee_schedule.tiers.vip[], fees.daily_user_volume[]

const subAddr = "0x....subaccount";

const stopPositions = read.userPositions.subscribeByAddr(subAddr, (data) => {
  data.positions.forEach((position) => {
    console.log("Position delta", position.market_name, position.open_size);
  });
});

// Stop streaming for this subaccount
stopPositions();