Fix TS.INFO error for simple string values. (#159)

* Fix redis time-series error, add integration test.

* Format

Co-authored-by: Mikhail <[email protected]>

Author: santriseus

pkg/datasource_test.go

@@ -176,7 +176,7 @@ func TestQueryData(t *testing.T) {
 		PluginContext: backend.PluginContext{},
 		Headers:       nil,
 		Queries: []backend.DataQuery{
-			backend.DataQuery{
+			{
 				RefID:         "",
 				QueryType:     "",
 				MaxDataPoints: 100,
@@ -212,7 +212,7 @@ func TestQueryDataWithError(t *testing.T) {
 		PluginContext: backend.PluginContext{},
 		Headers:       nil,
 		Queries: []backend.DataQuery{
-			backend.DataQuery{
+			{
 				RefID:         "",
 				QueryType:     "",
 				MaxDataPoints: 100,

pkg/redis-time-series.go

@@ -288,6 +288,8 @@ func queryTsInfo(qm queryModel, client redisClient) backend.DataResponse {
 			frame.Fields = append(frame.Fields, field)
 		case []byte:
 			frame.Fields = append(frame.Fields, data.NewField(key, nil, []string{string(value)}))
+		case string:
+			frame.Fields = append(frame.Fields, data.NewField(key, nil, []string{value}))
 		case []interface{}:
 			frame = addFrameFieldsFromArray(value, frame)
 		default:

pkg/redis-time-series_integration_test.go

@@ -0,0 +1,25 @@
+// +build integration
+
+package main
+
+import (
+	"fmt"
+	"testing"
+
+	"github.com/mediocregopher/radix/v3"
+	"github.com/stretchr/testify/require"
+)
+
+/**
+ * TS.INFO
+ */
+func TestTSInfoIntegration(t *testing.T) {
+	// Client
+	radixClient, _ := radix.NewPool("tcp", fmt.Sprintf("127.0.0.1:%d", integrationTestPort), 10)
+	client := radixV3Impl{radixClient: radixClient}
+
+	// Response
+	resp := queryTsInfo(queryModel{Command: "ts.info", Key: "test:timeseries2"}, &client)
+	require.Len(t, resp.Frames, 1)
+	require.Len(t, resp.Frames[0].Fields, 12)
+}

pkg/redis-time-series_test.go

@@ -494,15 +494,16 @@ func TestQueryTsInfo(t *testing.T) {
 				"lastTimestamp":   int64(1548149279),
 				"retentionTime":   int64(0),
 				"chunkCount":      int64(1),
+				"byteField":       []byte("byteField"),
 				"chunkSize":       int64(256),
-				"chunkType":       []byte("compressed"),
+				"chunkType":       "compressed",
 				"duplicatePolicy": interface{}(nil),
 				"labels":          []interface{}{[]interface{}{[]byte("sensor_id"), []byte("2")}, []interface{}{[]byte("area_id"), []byte("32")}},
 				"sourceKey":       interface{}(nil),
 				"unsupportedType": nil,
 				"rules":           []interface{}{},
 			},
-			10,
+			11,
 			1,
 			[]valueToCheckByLabelInResponse{
 				{frameIndex: 0, fieldName: "totalSamples", rowIndex: 0, value: int64(100)},