Signal Bots

import { RestClient } from 'okx-api';

const client = new RestClient({
  apiKey: process.env.API_KEY!,
  apiSecret: process.env.API_SECRET!,
  apiPass: process.env.API_PASS!,
});

const [signal] = await client.createSignal({
  signalChanName: 'My RSI Signal',
  signalChanDesc: 'Fires when 4H RSI crosses 30 or 70',
});

console.log('Signal channel token:', signal.signalChanToken);
console.log('Signal channel ID:', signal.signalChanId);

const [bot] = await client.createSignalBot({
  signalChanId: 'your-signal-channel-id',
  lever: '3',
  instIds: ['BTC-USDT-SWAP', 'ETH-USDT-SWAP'],
  investAmt: '500',
  subOrdType: '1',    // '1' = market orders
  includeAll: false,
});

console.log('Bot algo ID:', bot.algoId);

// Get active bot details
const bots = await client.getActiveSignalBot({
  algoOrdType: 'signal',
  algoId: 'your-algo-id',
});
console.log('Bot state:', bots[0]?.state);

// Get open positions
const positions = await client.getSignalBotPositions({
  algoOrdType: 'signal',
  algoId: 'your-algo-id',
});
for (const pos of positions) {
  console.log(`${pos.instId}: pos=${pos.pos}, uPnL=${pos.upl}`);
}

await client.updateSignalTPSL({
  algoId: 'your-algo-id',
  tpRatio: '0.2',   // 20% take profit
  slRatio: '0.1',   // 10% stop loss
});

const [stopped] = await client.cancelSignalBots({
  algoId: 'your-algo-id',
});
console.log('Stopped bot:', stopped.algoId);

const events = await client.getSignalBotEventHistory({
  algoId: 'your-algo-id',
  limit: '20',
});
for (const event of events) {
  console.log(`[${event.cTime}] ${event.eventType}: ${event.msg}`);
}