package features

import (
	"git.qtrade.icu/coin-quant/exchange"
	. "git.qtrade.icu/coin-quant/trademodel"
	bfutures "github.com/adshao/go-binance/v2/futures"
)

func processWsCandle(doneC chan struct{}, cb exchange.WatchFn) func(event *bfutures.WsKlineEvent) {
	return func(event *bfutures.WsKlineEvent) {
		select {
		case <-doneC:
			return
		default:
		}
		if event.Kline.IsFinal {
			candle := Candle{
				ID:       0,
				Start:    event.Kline.StartTime / 1000,
				Open:     parseFloat(event.Kline.Open),
				High:     parseFloat(event.Kline.High),
				Low:      parseFloat(event.Kline.Low),
				Close:    parseFloat(event.Kline.Close),
				Turnover: parseFloat(event.Kline.QuoteVolume),
				Volume:   parseFloat(event.Kline.Volume),
				Trades:   event.Kline.TradeNum,
			}
			cb(&candle)
		}
	}
}