instruments

type Config struct {
	UpdateConfig   *UpdateConfig          // defaults to DefaultUpdateConfig() if nil
	Logger         *slog.Logger           // required
	TestData       map[uint32]*Instrument // if set, skips HTTP loading and uses test data
	InstrumentsURL string                 // URL to fetch instruments from; defaults to Kite API URL
}

type Instrument struct {
	ID                string  `json:"id"`
	InstrumentToken   uint32  `json:"instrument_token"`
	ExchangeToken     uint32  `json:"exchange_token"`
	Tradingsymbol     string  `json:"tradingsymbol"`
	Exchange          string  `json:"exchange"`
	ISIN              string  `json:"isin"`
	Name              string  `json:"name"`
	Series            string  `json:"series"`
	LastPrice         float64 `json:"last_price"`
	Strike            float64 `json:"strike"`
	TickSize          float64 `json:"tick_size"`
	LotSize           int     `json:"lot_size"`
	Multiplier        int     `json:"multiplier"`
	InstrumentType    string  `json:"instrument_type"`
	Segment           string  `json:"segment"`
	DeliveryUnits     string  `json:"delivery_units"`
	PriceUnits        string  `json:"price_units"`
	FreezeQuantity    uint32  `json:"freeze_quantity"`
	MaxOrderQuantity  int     `json:"max_order_quantity"`
	ExpiryType        string  `json:"expiry_type"`
	ExpiryDate        string  `json:"expiry_date"`
	ExerciseStartDate string  `json:"exercise_start_date"`
	ExerciseEndDate   string  `json:"exercise_end_date"`
	IssueDate         string  `json:"issue_date"`
	ListingDate       string  `json:"listing_date"`
	MaturityDate      string  `json:"maturity_date"`
	LowerCircuitLimit float64 `json:"lower_circuit_limit"`
	UpperCircuitLimit float64 `json:"upper_circuit_limit"`

	// In FO, a large number of strikes are marked "inactive".
	Active bool `json:"active"`
}

type InstrumentManagerInterface interface {
	// GetByID returns an instrument using the symbol (exchange:tradingsymbol).
	GetByID(id string) (Instrument, error)

	// GetByTradingsymbol returns an instrument using exchange and trading symbol.
	GetByTradingsymbol(exchange, tradingsymbol string) (Instrument, error)

	// GetByISIN returns instruments matching the given ISIN.
	GetByISIN(isin string) ([]Instrument, error)

	// GetByInstToken returns an instrument using its instrument token.
	GetByInstToken(token uint32) (Instrument, error)

	// GetByExchToken returns an instrument using exchange and exchange token.
	GetByExchToken(exch string, exchToken uint32) (Instrument, error)

	// Filter returns instruments matching the given filter function.
	Filter(filter func(Instrument) bool) []Instrument

	// GetAllByUnderlying returns F&O instruments for the given underlying.
	GetAllByUnderlying(exchange, underlying string) ([]Instrument, error)

	// Count returns the number of instruments loaded.
	Count() int

	// GetUpdateStats returns current update statistics.
	GetUpdateStats() UpdateStats

	// UpdateInstruments fetches and updates instrument data.
	UpdateInstruments() error

	// ForceUpdateInstruments forces an instrument update regardless of timing.
	ForceUpdateInstruments() error

	// Shutdown gracefully shuts down the instruments manager.
	Shutdown()
}

type Manager struct {
	// contains filtered or unexported fields
}

type UpdateConfig struct {
	// UpdateHour is the hour in IST when instruments should be updated (0-23)
	UpdateHour int
	// UpdateMinute is the minute when instruments should be updated (0-59)
	UpdateMinute int
	// RetryAttempts is the number of retry attempts for failed updates
	RetryAttempts int
	// RetryDelay is the delay between retry attempts
	RetryDelay time.Duration
	// EnableScheduler enables automatic scheduled updates
	EnableScheduler bool
}

type UpdateStats struct {
	LastUpdateTime      time.Time
	LastUpdateCount     int
	TotalUpdates        int
	FailedUpdates       int
	MemoryUsageBytes    int64
	ScheduledNextUpdate time.Time
}