npm install dhan-ts

import { DhanHqClient, DhanFeed, DhanEnv } from 'dhan-ts';

const config = {
  accessToken: process.env.DHAN_ACCESS_TOKEN!,
  clientId: process.env.DHAN_CLIENT_ID!,
  env: DhanEnv.PROD,
};

// REST API Client
const client = new DhanHqClient(config);

// WebSocket Feed Client
const feed = new DhanFeed(config);

// Get your fund limits
const funds = await client.funds.getFundLimit();
console.log('Available Balance:', funds.availabelBalance);

// Get your holdings
const holdings = await client.portfolio.getHoldings();
console.log('Holdings:', holdings);

// Place an order
const order = await client.orders.placeOrder({
  dhanClientId: config.clientId,
  transactionType: 'BUY',
  exchangeSegment: 'NSE_EQ',
  productType: 'CNC',
  orderType: 'LIMIT',
  validity: 'DAY',
  securityId: '1333',
  quantity: 1,
  price: 1850.00,
  afterMarketOrder: false,
});

import { FeedRequestCode, ExchangeSegment } from 'dhan-ts';

const liveFeed = feed.liveFeed;

// Connect
await liveFeed.connect();

// Subscribe to instruments
const instruments = [
  [ExchangeSegment.NSE_EQ, "1333"], // Reliance
  [ExchangeSegment.NSE_EQ, "13"],   // Nifty 50
];

liveFeed.subscribe(instruments, FeedRequestCode.SUBSCRIBE_TICKER);

// Listen for updates
liveFeed.on('data', (data) => {
  if (data.type === 'ticker') {
    console.log(`${data.securityId}: ₹${data.lastTradedPrice}`);
  }
});

// Monitor market data and place orders based on strategy
liveFeed.on('data', async (data) => {
  if (data.type === 'ticker') {
    const price = data.lastTradedPrice;

    // Your trading logic here
    if (shouldBuy(price)) {
      await client.orders.placeOrder({
        // ... order details
      });
    }
  }
});

// View and manage your portfolio
const holdings = await client.portfolio.getHoldings();
const positions = await client.portfolio.getPositions();
const funds = await client.funds.getFundLimit();

// Calculate total portfolio value
const totalValue = holdings.reduce((sum, h) =>
  sum + (h.totalQty * h.avgCostPrice), 0
);

// Get option chain with Greeks
const optionChain = await client.optionChain.getOptionChain({
  UnderlyingScrip: 13,
  UnderlyingSeg: "IDX_I",
  Expiry: "2024-01-25",
});

// Analyze strikes
Object.entries(optionChain.data.oc).forEach(([strike, data]) => {
  console.log(`${strike} CE IV: ${data.ce?.implied_volatility}`);
  console.log(`${strike} PE Delta: ${data.pe?.greeks.delta}`);
});

// Get historical data for backtesting
const historicalData = await client.marketData.getProcessedCandleData({
  securityId: '1333',
  exchangeSegment: ExchangeSegmentText.NSE_EQ,
  instrument: 'EQUITY',
  expiryCode: 0,
  interval: TimeInterval.DAY_1,
  daysAgo: 100,
});

// Analyze candlestick patterns
historicalData.timestamp.forEach((ts, i) => {
  const candle = {
    open: historicalData.open[i],
    high: historicalData.high[i],
    low: historicalData.low[i],
    close: historicalData.close[i],
    volume: historicalData.volume[i],
  };
  // Your analysis logic
});

// IntelliSense shows all available fields
const order: OrderResponse = await client.orders.placeOrder({
  dhanClientId: string,
  transactionType: TransactionType.BUY,
  // ... TypeScript guides you through all fields
});

try {
  await client.orders.placeOrder(orderRequest);
} catch (error: any) {
  if (error.code === 'DH-906') {
    console.error('Order error:', error.message);
  } else if (error.code === 'DH-904') {
    console.error('Rate limit exceeded');
  }
}

liveFeed.on('disconnected', (data) => {
  console.log('Disconnected, will auto-reconnect');
});

liveFeed.on('error', (error) => {
  console.log('Error, reconnecting...');
});

// Production
const config = {
  accessToken: process.env.DHAN_ACCESS_TOKEN!,
  clientId: process.env.DHAN_CLIENT_ID!,
  env: DhanEnv.PROD, // Production
};

// Sandbox for testing
const sandboxConfig = {
  accessToken: 'sandbox-token',
  clientId: 'sandbox-client',
  env: DhanEnv.SANDBOX, // Sandbox
};