// ====== CONFIG ====== const CONFIG = { USER: "YOUR_USER", PASSWORD: "YOUR_PASSWORD", API_SECRET: "YOUR_API_SECRET", VENDOR: "YOUR_VENDOR_CODE", IMEI: "1234567890", TOTP_SECRET: "YOUR_TOTP_SECRET", SYMBOLS: { NIFTY: { qty: 50 }, BANKNIFTY: { qty: 15 }, SENSEX: { qty: 10 } } }; // ====== IMPORTS ====== const express = require("express"); const cors = require("cors"); const speakeasy = require("speakeasy"); const ShoonyaApi = require("shoonya-api-js"); const app = express(); app.use(express.json()); app.use(cors()); const api = new ShoonyaApi(); // ====== STATE PER SYMBOL ====== let state = {}; Object.keys(CONFIG.SYMBOLS).forEach(sym => { state[sym] = { running: false, orbHigh: 0, orbLow: Infinity, prices: [], position: null }; }); // ====== LOGIN ====== async function login() { const totp = speakeasy.totp({ secret: CONFIG.TOTP_SECRET, encoding: "base32", }); await api.login({ userid: CONFIG.USER, password: CONFIG.PASSWORD, twoFA: totp, vendor_code: CONFIG.VENDOR, api_secret: CONFIG.API_SECRET, imei: CONFIG.IMEI, }); console.log("✅ Logged in"); } // ====== ORDER ====== async function placeOrder(symbol, side) { console.log(`🚀 ${symbol} ORDER:`, side); const res = await api.place_order({ buy_or_sell: side === "BUY" ? "B" : "S", product_type: "MIS", exchange: "NSE", tradingsymbol: symbol, quantity: CONFIG.SYMBOLS[symbol].qty, price_type: "MKT", }); state[symbol].position = { side, entry: res.avgprc || 0, }; } // ====== EXIT ====== async function exitPosition(symbol, reason) { const pos = state[symbol].position; if (!pos) return; console.log(`❌ ${symbol} EXIT:`, reason); await api.place_order({ buy_or_sell: pos.side === "BUY" ? "S" : "B", product_type: "MIS", exchange: "NSE", tradingsymbol: symbol, quantity: CONFIG.SYMBOLS[symbol].qty, price_type: "MKT", }); state[symbol].position = null; } // ====== ORB LOGIC ====== function onTick(tick) { const symbol = tick.ts; // depends on Shoonya mapping if (!state[symbol]) return; const s = state[symbol]; if (!s.running) return; const ltp = parseFloat(tick.lp); const now = new Date(); const min = now.getMinutes(); // ORB if (min < 45) { s.prices.push(ltp); s.orbHigh = Math.max(...s.prices); s.orbLow = Math.min(...s.prices); return; } const range = s.orbHigh - s.orbLow; const exp = range * 0.09; // ENTRY if (!s.position) { if (ltp > s.orbHigh + exp) return placeOrder(symbol, "BUY"); if (ltp < s.orbLow - exp) return placeOrder(symbol, "SELL"); } // EXIT if (s.position) { const entry = s.position.entry; let target = entry * 1.015; let stop = entry * 0.98; if (s.position.side === "SELL") { target = entry * 0.985; stop = entry * 1.02; } if ( (s.position.side === "BUY" && ltp >= target) || (s.position.side === "SELL" && ltp <= target) ) return exitPosition(symbol, "TARGET"); if ( (s.position.side === "BUY" && ltp <= stop) || (s.position.side === "SELL" && ltp >= stop) ) return exitPosition(symbol, "STOP"); } } // ====== ROUTES ====== app.post("/start/:symbol", (req, res) => { const sym = req.params.symbol; state[sym].running = true; state[sym].prices = []; state[sym].orbHigh = 0; state[sym].orbLow = Infinity; console.log(`▶️ START ${sym}`); res.send("STARTED " + sym); }); app.post("/stop/:symbol", (req, res) => { const sym = req.params.symbol; state[sym].running = false; console.log(`⏹ STOP ${sym}`); res.send("STOPPED " + sym); }); // ====== UI ====== app.get("/", (req, res) => { res.send(`

ORB BOT - SYMBOL CONTROL

NIFTY

BANKNIFTY

SENSEX

`); }); // ====== START ====== app.listen(8787, async () => { await login(); api.start_websocket({ subscribe: Object.keys(CONFIG.SYMBOLS), on_tick: onTick, }); console.log("🚀 http://localhost:8787"); });

ORB Pulse Deck