// ================= 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()); // ================= CONFIG ================= const CONFIG = { USER: "YOUR_USER", PASSWORD: "YOUR_PASSWORD", API_SECRET: "YOUR_API_SECRET", VENDOR: "YOUR_VENDOR", IMEI: "1234567890", TOTP_SECRET: "YOUR_TOTP_SECRET", SYMBOLS: { NIFTY: { lot: 65, lots: 1 }, BANKNIFTY: { lot: 30, lots: 1 }, SENSEX: { lot: 20, lots: 1 } } }; // ================= BROKER ================= const api = new ShoonyaApi(); let loggedIn = false; // ================= STATE ================= let state = {}; for (let s of Object.keys(CONFIG.SYMBOLS)) { state[s] = { running: false, prices: [], orbHigh: 0, orbLow: Infinity, 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 }); loggedIn = true; console.log("✅ LOGIN SUCCESS"); } // ================= ORDER ================= async function placeOrder(symbol, side) { const qty = CONFIG.SYMBOLS[symbol].lot * CONFIG.SYMBOLS[symbol].lots; console.log(`🚀 ORDER ${symbol} ${side} QTY:${qty}`); const res = await api.place_order({ buy_or_sell: side === "BUY" ? "B" : "S", product_type: "MIS", exchange: "NSE", tradingsymbol: symbol, quantity: qty, price_type: "MKT" }); state[symbol].position = { side, entry: res.avgprc || 0 }; } // ================= EXIT ================= async function exit(symbol, reason) { const pos = state[symbol].position; if (!pos) return; const qty = CONFIG.SYMBOLS[symbol].lot * CONFIG.SYMBOLS[symbol].lots; console.log(`❌ EXIT ${symbol} ${reason}`); await api.place_order({ buy_or_sell: pos.side === "BUY" ? "S" : "B", product_type: "MIS", exchange: "NSE", tradingsymbol: symbol, quantity: qty, price_type: "MKT" }); state[symbol].position = null; } // ================= ORB STRATEGY ================= function onTick(tick) { const symbol = tick.ts; // may need mapping fix depending on broker feed 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 BUILD (9:15 - 9:45) ===== 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 RULES ===== 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 exit(symbol, "TARGET"); if ( (s.position.side === "BUY" && ltp <= stop) || (s.position.side === "SELL" && ltp >= stop) ) return exit(symbol, "STOP"); } } // ================= CONTROLS ================= 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; res.send(`STARTED ${sym}`); console.log("▶️ START", sym); }); app.post("/stop/:symbol", (req, res) => { const sym = req.params.symbol; state[sym].running = false; res.send(`STOPPED ${sym}`); console.log("⏹ STOP", sym); }); // ================= SIMPLE UI ================= app.get("/", (req, res) => { res.send(`

LIVE ORB TRADING BOT

NIFTY

BANKNIFTY

SENSEX

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

Orb Pulse