adapter

type AggTradeConfig struct{}

type DataClient interface {
	HasSub() bool
	Connect(ctx context.Context) error
	Disconnect()
	SubscribeDepthUpdate(symbolID int, depthLevel int, pushRateMs int)
	SubscribeTrade(symbolID int)
	SubscribeAggTrade(symbolID int)
	SubscribeKline(symbolID int, interval string)
	ReqDepthSnapshot(symbolID int, limit int) error
	// ReqHistoricalKline fetches historical candles. Times are nanoseconds; 0 omits the bound.
	ReqHistoricalKline(symbolID int, interval string, startTimeNs, endTimeNs uint64, limit int) error
}

type DataClientFactory func(cat *catalog.Catalog, bus *msgbus.MsgBus) DataClient

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

type DataRouterEntry struct {
	Symbol   string          `yaml:"symbol"`             // Universal ticker (required)
	Endpoint string          `yaml:"endpoint,omitempty"` // Regional endpoint: bybit, bybit_tr, bybit_eu
	Depth    *DepthConfig    `yaml:"depth,omitempty"`    // Depth subscription options
	Trade    *TradeConfig    `yaml:"trade,omitempty"`    // Trade tick subscription
	AggTrade *AggTradeConfig `yaml:"aggTrade,omitempty"` // Aggregate trade subscription
	Kline    *KlineConfig    `yaml:"kline,omitempty"`    // Kline subscription options
}

type DepthConfig struct {
	// Type selects the depth stream kind for Binance:
	//   delta (default) → diff depth (@depth@100ms)
	//   depth5|depth10|depth20 → partial book WS (@depthN@100ms → DepthSnapshot)
	Type     string `yaml:"type,omitempty"`
	PushRate string `yaml:"push_rate,omitempty"` // 100ms, 1000ms (binance)
	Levels   int    `yaml:"levels,omitempty"`    // 1, 50, 200, 1000 (bybit)
}

type DepthOptions struct {
	Type     string // delta, depth5, depth10, depth20 (binance)
	PushRate string // 100ms, 1000ms (binance)
	Levels   int    // 1, 50, 200, 1000 (bybit)
}

type ExecRouterEntry struct {
	Account string `yaml:"account"`
	Wallet  string `yaml:"wallet"`
	API     string `yaml:"api"`
}

type ExecutionClient interface {
	// Connect establishes the connection for trading
	Connect(ctx context.Context) error

	// Disconnect closes the connection
	Disconnect()

	// SubscribeOrderUpdate subscribes to order status update events
	// Events: OrderAccepted, OrderPartiallyFilled, OrderFilled, OrderCanceled, OrderRejected
	SubscribeOrderUpdate() error

	// SubscribeFill subscribes to execution/fill events
	// Events: Fill (trade execution details including price, quantity, fees)
	SubscribeFill() error

	// SubscribeBalance subscribes to wallet/balance update events
	// Events: BalanceUpdate (available, locked, total for each asset)
	SubscribeBalance() error

	// SubmitOrder submits a new order with the given client order ID
	SubmitOrder(clientOrderID int, symbolID int, side common.Side, orderType common.OrderType, timeInForce common.TimeInForce, price float64, quantity float64) error

	// CancelOrder cancels an order by orderID, with clientOrderID for response correlation
	CancelOrder(symbolID int, orderID int, clientOrderID int) error

	// CancelAllOrders cancels all open orders for a symbol
	CancelAllOrders(symbolID int) error

	// ReqBalanceSnapshot requests the current balance snapshot for the given wallet type.
	// The response will be published as a RespBalanceSnapshot event.
	ReqBalanceSnapshot(walletType common.WalletType) error
}

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

type KlineConfig struct {
	Interval string `yaml:"interval,omitempty"` // 1m, 5m, 1h, 1d, ... (Binance form; Bybit mapped)
}

type KlineOptions struct {
	Interval string // 1m, 5m, 1h, 1d, ...
}

type RouterError struct {
	AccountID int
	Err       error
}

type TradeConfig struct{}