IBKR: Interactive Brokers

import ibkr from '@stoqey/ibkr';

await ibkr();

// your code

import ibkr from '@stoqey/ibkr';

await ibkr({
  host: "127.0.0.1",
  port: 7497,
  reconnectInterval: 5000,
  connectionWatchdogInterval: 1,
});

import { IBKREvents, IBKREVENTS } from '@stoqey/ibkr';
import type { MarketData, Trade } from '@stoqey/ibkr';

const events = IBKREvents.Instance;

events.on(IBKREVENTS.IBKR_BAR, (bar: MarketData) => {
  console.log(bar.instrument?.symbol, bar.close);
});

events.on(IBKREVENTS.IBKR_SAVE_TRADE, (trade: Trade) => {
  console.log(trade.instrument?.symbol, trade.action, trade.quantity);
});

import { AccountSummary, IBKREvents, IBKREVENTS } from "@stoqey/ibkr";

const accountInstance = AccountSummary.Instance;

// account summaries is automatically updated for you
const accountSummaries = accountInstance.accountSummary;

const accountId = accountSummaries.accountId;

const totalCashValue = accountSummaries.TotalCashValue.value;

IBKREvents.Instance.on(IBKREVENTS.IBKR_ACCOUNT_UPDATED, () => {
  console.log(accountInstance.accountSummary.NetLiquidation.value);
});

import { Portfolios, IBKREvents, IBKREVENTS } from "@stoqey/ibkr";

// Get current portfolios
const portfolios = Portfolios.Instance;

// positions returns the latest cached snapshot
const accountPortfolios = portfolios.positions;
console.log(accountPortfolios);

IBKREvents.Instance.on(IBKREVENTS.IBKR_POSITIONS_UPDATED, () => {
  const updatedPortfolios = portfolios.positions;
  console.log(updatedPortfolios);
});

import { MarketDataManager } from '@stoqey/ibkr';
import { BarSizeSetting, WhatToShow } from '@stoqey/ib';

// 1. Get market data manager
const mkdManager = MarketDataManager.Instance;

// 2. Resolve an IBKR contract
const contract = await mkdManager.getContract({
  symbol: "AAPL",
  secType: "STK",
  exchange: "SMART",
  currency: "USD",
});

// 3. Get historical bars
const data = await mkdManager.getHistoricalData(
  contract,
  undefined,
  "1 D",
  BarSizeSetting.MINUTES_FIVE,
  WhatToShow.TRADES,
  true
);

import { MarketDataManager, IBKREvents, IBKREVENTS } from '@stoqey/ibkr';
import type { MarketData } from '@stoqey/ibkr';
import { BarSizeSetting, WhatToShow } from '@stoqey/ib';

// 1. Get IBKR events
const ibkrEvents = IBKREvents.Instance;

// 2. Get market data manager
const mkdManager = MarketDataManager.Instance;

// 3. Request historical data updates
await mkdManager.getHistoricalDataUpdates(
  contract,
  BarSizeSetting.SECONDS_FIVE,
  WhatToShow.TRADES
);

// 4. Subscribe for realtime bars
ibkrEvents.on(IBKREVENTS.IBKR_BAR, (bar: MarketData) => {
  // use the realtime bar here
});

// 5. Get cached market data for a date range
const cachedData = await mkdManager.historicalData(contract, start, end);

// 6. Get the latest cached quote, or the quote at or before a timestamp
const latestQuote = await mkdManager.getQuote(contract);
const pointInTimeQuote = await mkdManager.getQuote(contract, new Date("2026-01-15T15:30:00Z"));

// Unsubscribe from historical data updates
mkdManager.removeHistoricalDataUpdates(contract);

import { MarketDataManager, IBKREvents, IBKREVENTS } from '@stoqey/ibkr';
import type { MarketData } from '@stoqey/ibkr';

const ibkrEvents = IBKREvents.Instance;
const mkdManager = MarketDataManager.Instance;

ibkrEvents.on(IBKREVENTS.IBKR_BAR, (bar: MarketData) => {
  console.log(bar.date, bar.close, bar.volume);
});

await mkdManager.getTickByTickDataUpdates(contract);

// Later, unsubscribe
mkdManager.removeTickByTickDataUpdates(contract);

const ticks = await mkdManager.getHistoricalTicksLast(
  contract,
  new Date("2026-01-15T14:30:00Z"),
  new Date("2026-01-15T15:30:00Z"),
  1000,
  false
);

import { MarketDataManager } from '@stoqey/ibkr';

// 1. Get market data manager
const mkdManager = MarketDataManager.Instance;

const contract = {
  symbol: "PLTR",
  secType: "STK"
};

const contractDetails = await mkdManager.getContract(contract);

//  or e.g options
const contractDetails = await mkdManager.getContract({
    currency: 'USD',
    exchange: 'SMART',
    multiplier: 100,
    right: 'C',
    secType: 'OPT',
    strike: 300,
    symbol: 'AAPL'
});

// e.g forex
const contractDetails = await mkdManager.getContract({
    "symbol":"GBP",
    "secType":"CASH",
    "currency":"USD",
});

const contracts = await mkdManager.searchContracts({
  symbol: "ES",
  secType: "FUT",
});

import { MarketDataManager, Orders, IBKREvents, IBKREVENTS } from '@stoqey/ibkr';
import type { Trade } from '@stoqey/ibkr';
import { OrderAction, OrderType } from '@stoqey/ib';

// 1. Get IBKR events
const ibkrEvents = IBKREvents.Instance;

// 2. Get orders manager
const ordersManager = Orders.Instance;

// 3. Place order
const mkdManager = MarketDataManager.Instance;
const contract = await mkdManager.getContract({
  symbol: "AAPL",
  secType: "STK" /* STK, OPT, FUT, etc. */,
  exchange: "SMART" /* SMART, NYSE, NASDAQ, etc. */,
  currency: "USD"  /* USD, EUR, GBP, etc. */
});

const price = 200;
const quantity = 1;
const myOrder = {
  action: OrderAction.BUY,
  totalQuantity: quantity,
  orderType: price ? OrderType.LMT : OrderType.MKT,
  ...(price && { lmtPrice: price }),
  transmit: true, // true to submit order immediately, false to save as draft
  outsideRth: false, // true to allow execution outside regular trading hours, false otherwise
  tif: "DAY", // DAY (day order), GTC (good till canceled), IOC (immediate or cancel), etc.
};

const placed = await ordersManager.placeOrder(contract, myOrder);

// 4. Modify order
const modifyOrder = await ordersManager.modifyOrder(id, contract, myOrder);

// get orders, this is automatically updated
const orders = ordersManager.orders;

// get filled orders(trades), this is automatically updated
const trades = ordersManager.trades;

// subscribe for trades, when orders are filled in real time
ibkrEvents.on(IBKREVENTS.IBKR_SAVE_TRADE, (trade: Trade) => {
  // use trade here
});

ibkrEvents.on(IBKREVENTS.IBKR_OPEN_ORDERS_UPDATED, () => {
  console.log(ordersManager.orders);
});

ibkrEvents.on(IBKREVENTS.IBKR_COMPLETED_TRADES_UPDATED, () => {
  console.log(ordersManager.trades);
});

// other methods e.t.c....
await ordersManager.cancelOrder(orderId);

await ordersManager.cancelAllOrders({});