Market sessions

Source: src/utils/marketSessionManager.ts Orchestrates when recurring buy, trailing sell, and market data services start and stop based on exchange trading hours.

Core functions

Function	Purpose
`initializeMarketServices()`	Startup: ensure Zerodha streaming, start order services for open exchanges
`initializeMarketDataIfNeeded()`	Auto-login Zerodha if streaming is down
`startOrderServicesForSymbol(setting)`	Start recurring buy + schedule order for one index
`startOrderServicesForExchanges(exchanges)`	Start services for all active settings on given exchanges
`stopOrderServicesForExchanges(exchanges)`	Stop intervals and disable recurring status
`resetSymbolsForExchanges(exchanges?)`	Full reset for active symbols (optional exchange filter)
`resetAll()`	Reset all active index settings
`handleEquitySessionClose()`	Stop NSE, BSE, NFO, BFO + sync instruments
`handleCurrencySessionClose()`	Stop CDS, BCD + sync instruments
`handleMcxSessionClose()`	Stop MCX + sync instruments

Starting order services for a symbol

startOrderServicesForSymbol checks isExchangeMarketOpen(exchange) first. If closed, it skips. For each active index setting:

Schedule orders — ScheduleOrderController.startScheduleOrder(userId, indexName)
Recurring buy — based on activeSegment:

Segment	Condition	Interval source
`options`	`lastActiveRight` is `CALL` or `PUT`	`callBuyDuration` or `putBuyDuration`
`cash`	`cash.isRecurringBuy`	`cash.buyDuration`
`futures`	`futures.isRecurringBuy`	`futures.buyDuration`

Calls RecurringOrderController.handleRecurringOrder with recurringStatus: true

Stopping order services

stopOrderServicesForExchanges:

Calls resetSymbolsForExchanges which for each active setting:
- Stops intervals: scheduleOrder_{index}, recurringOrder_{index}_CALL, recurringOrder_{index}_PUT
- Sets recurringStatus: false on the latest RecurringOrder record
Calls syncTrailingSellInterval

Trailing sell interval sync

syncTrailingSellInterval:

If any active index setting’s exchange is open → ScheduleOrderController.startInterval()
Otherwise → ScheduleOrderController.stopInterval()

Session close handlers

Handler	Exchanges stopped	Post-close action
`handleEquitySessionClose`	NSE, BSE, NFO, BFO	`syncIndexSettings()`
`handleCurrencySessionClose`	CDS, BCD	`syncIndexSettings()`
`handleMcxSessionClose`	MCX	`syncIndexSettings()`

syncIndexSettings refreshes instrument chains and expiry maps from Kite. initializeMarketDataIfNeeded:

Calls ensureMarketDataRunning() — returns if streaming is active
Skips if 6 AM Zerodha refresh is in progress
Attempts autoZerodhaLogin() as fallback

Exchange hours

Market open/close times are defined in src/utils/marketHours.ts:

isExchangeMarketOpen(exchange: Exchange, now?: Moment): boolean
getMarketHoursForGroup(group: 'equity' | 'currency' | 'mcx')
getTimezone(): string  // 'Asia/Kolkata'

Integration with app.ts

Trigger	Function called
Server startup	`initializeMarketServices()`
Equity open cron	`initializeMarketServices()`
MCX open cron	`initializeMarketDataIfNeeded()`, `startOrderServicesForExchanges(['MCX'])`
Session close crons	`handleEquitySessionClose`, etc.
Graceful shutdown	`resetAll()`
`POST /api/order/resetIndex`	Per-index reset via `OrderController`
`GET /api/order/resetAll`	`resetAll()`

Architecture

Authentication

Database Models

API Reference

Trading Engine

Zerodha Integration

Real-time

Reference

Core functions

Starting order services for a symbol

Stopping order services

Trailing sell interval sync

Session close handlers

Exchange hours

Integration with app.ts

​Core functions

​Starting order services for a symbol

​Stopping order services

​Trailing sell interval sync

​Session close handlers

​Market data auto-login

​Exchange hours

​Integration with app.ts

Core functions

Starting order services for a symbol

Stopping order services

Trailing sell interval sync

Session close handlers

Market data auto-login

Exchange hours

Integration with app.ts