grpc: convert kline prices to string

SynapticDreams · Apr 13, 2022 · d9617b5 · d9617b5
1 parent 4df3a63
commit d9617b5
Show file tree

Hide file tree

Showing 3 changed files with 127 additions and 113 deletions.
diff --git a/pkg/grpc/server.go b/pkg/grpc/server.go
@@ -155,13 +155,15 @@ func (s *Server) QueryKLines(ctx context.Context, request *pb.QueryKLinesRequest
 				response.Klines = append(response.Klines, &pb.KLine{
 					Exchange:    kline.Exchange.String(),
 					Symbol:      kline.Symbol,
+					Open:        kline.Open.String(),
+					High:        kline.High.String(),
+					Low:         kline.Low.String(),
+					Close:       kline.Close.String(),
+					Volume:      kline.Volume.String(),
+					QuoteVolume: kline.QuoteVolume.String(),
+					Closed:      kline.Closed,
 					StartTime:   kline.StartTime.UnixMilli(),
-					Open:        kline.Open.Float64(),
-					High:        kline.High.Float64(),
-					Low:         kline.Low.Float64(),
-					Close:       kline.Close.Float64(),
-					Volume:      kline.Volume.Float64(),
-					QuoteVolume: kline.QuoteVolume.Float64(),
+					EndTime:     kline.EndTime.UnixMilli(),
 				})
 			}
 
@@ -262,14 +264,15 @@ func transKLine(session *bbgo.ExchangeSession, kline types.KLine) *pb.SubscribeR
 			Session:     session.Name,
 			Exchange:    kline.Exchange.String(),
 			Symbol:      kline.Symbol,
-			Open:        kline.Open.Float64(),
-			High:        kline.High.Float64(),
-			Low:         kline.Low.Float64(),
-			Close:       kline.Close.Float64(),
-			Volume:      kline.Volume.Float64(),
-			QuoteVolume: kline.QuoteVolume.Float64(),
+			Open:        kline.Open.String(),
+			High:        kline.High.String(),
+			Low:         kline.Low.String(),
+			Close:       kline.Close.String(),
+			Volume:      kline.Volume.String(),
+			QuoteVolume: kline.QuoteVolume.String(),
 			StartTime:   kline.StartTime.UnixMilli(),
 			EndTime:     kline.StartTime.UnixMilli(),
+			Closed:      kline.Closed,
 		},
 		SubscribedAt: 0,
 	}