json

Author: VladKochetov007

common/data/candlestick.go

@@ -1,8 +1,10 @@
 package data
 
 import (
+	"encoding/json"
 	"sort"
 	"time"
+	goErrors "errors"
 
 	"github.com/quick-trade/xoney/errors"
 	"github.com/quick-trade/xoney/internal"
@@ -92,12 +94,12 @@ func (t TimeStamp) Len() int { return len(t.Timestamp) }
 // encapsulating the open, high, low, close values and the volume of trading
 // over a particular time period, with TimeClose marking the end of that period.
 type Candle struct {
-	Open      float64
-	High      float64
-	Low       float64
-	Close     float64
-	Volume    float64
-	TimeClose time.Time
+	Open      float64   `json:"open"`
+	High      float64   `json:"high"`
+	Low       float64   `json:"low"`
+	Close     float64   `json:"close"`
+	Volume    float64   `json:"volume"`
+	TimeClose time.Time `json:"time_close"`
 }
 
 func NewCandle(open, high, low, c, volume float64, timeClose time.Time) *Candle {
@@ -127,6 +129,40 @@ func NewInstrumentCandle(candle Candle, instrument Instrument) *InstrumentCandle
 	}
 }
 
+
+// creates an InstrumentCandle from a JSON-encoded string.
+func NewInstrumentCandleFromJSON(data []byte) (*InstrumentCandle, error) {
+	var icj InstrumentCandle
+	if err := json.Unmarshal(data, &icj); err != nil {
+		return nil, goErrors.New("failed to unmarshal instrument candle JSON: " + err.Error())
+	}
+
+	// Create a Candle from the unmarshaled CandleJSON
+	candle := Candle{
+		Open:      icj.Candle.Open,
+		High:      icj.Candle.High,
+		Low:       icj.Candle.Low,
+		Close:     icj.Candle.Close,
+		Volume:    icj.Candle.Volume,
+		TimeClose: icj.Candle.TimeClose,
+	}
+
+	// Create and return the InstrumentCandle
+	return &InstrumentCandle{
+		Candle:     candle,
+		Instrument: icj.Instrument,
+	}, nil
+}
+
+func CandlesFromJSON(data []byte) ([]InstrumentCandle, error) {
+	var icj []InstrumentCandle
+	if err := json.Unmarshal(data, &icj); err != nil {
+		return nil, goErrors.New("failed to unmarshal instrument candle JSON: " + err.Error())
+	}
+
+	return icj, nil
+}
+
 // Chart represents a sequence of candlestick data points for a specific instrument.
 // It contains slices of open, high, low, close values and the trading volume,
 // along with the corresponding timestamps for each data point.

common/data/instrument.go

@@ -14,8 +14,8 @@ type Exchange string
 // It contains the asset identifier (e.g., "BTC" for Bitcoin) and
 // the exchange where it is traded.
 type Currency struct {
-	Asset    string   // Identifier of the financial asset.
-	Exchange Exchange // Exchange on which the asset is traded.
+	Asset    string   `json:"asset"`    // Identifier of the financial asset.
+	Exchange Exchange `json:"exchange"` // Exchange on which the asset is traded.
 }
 
 // String returns the string representation of the Currency in the format

realtime/executor.go

@@ -100,3 +100,36 @@ func (e *Executor) stop() error {
 
 	return firstErr
 }
+
+type DummySupplier struct {
+	candles []data.InstrumentCandle
+}
+
+func (s *DummySupplier) GetCharts(durations st.Durations) (data.ChartContainer, error) {
+	return data.ChartContainer{}, nil
+}
+
+func (s *DummySupplier) SetCandles(candles []data.InstrumentCandle) {
+	s.candles = candles
+}
+
+func (s *DummySupplier) SetCandlesFromJSON(json []byte) error {
+	candles, err := data.CandlesFromJSON(json)
+	if err != nil {
+		return err
+	}
+
+	s.candles = candles
+	return nil
+}
+
+func (s *DummySupplier) StreamCandles(ctx context.Context, instruments []data.Instrument) <-chan data.InstrumentCandle {
+	ch := make(chan data.InstrumentCandle)
+	go func() {
+		defer close(ch)
+		for _, candle := range s.candles {
+			ch <- candle
+		}
+	}()
+	return ch
+}