Rename the JSON Transformer field from valueFields to valuesFilter

pkg/messaging/pubsub.go

@@ -114,7 +114,7 @@ func CreateMessage(conn *protomfx.ConnByKeyRes, protocol, subject string, payloa
 
 	if conn.Profile.Transformer != nil {
 		msg.Profile.Transformer = &protomfx.Transformer{
-			ValueFields:  conn.Profile.Transformer.ValueFields,
+			ValuesFilter: conn.Profile.Transformer.ValuesFilter,
 			TimeField:    conn.Profile.Transformer.TimeField,
 			TimeFormat:   conn.Profile.Transformer.TimeFormat,
 			TimeLocation: conn.Profile.Transformer.TimeLocation,

pkg/proto/mfx.proto

@@ -59,7 +59,7 @@ message Profile {
 }
 
 message Transformer {
-    repeated string valueFields = 1;
+    repeated string valuesFilter = 1;
     string timeField            = 2;
     string timeFormat           = 3;
     string timeLocation         = 4;

pkg/transformers/json/transformer.go

@@ -66,7 +66,7 @@ func (ts *transformerService) Transform(msg protomfx.Message) (interface{}, erro
 
 	switch p := payload.(type) {
 	case map[string]interface{}:
-		formattedPayload := transformPayload(p, msg.Profile.Transformer.ValueFields)
+		formattedPayload := transformPayload(p, msg.Profile.Transformer.ValuesFilter)
 		ret.Payload = formattedPayload
 
 		// Apply timestamp transformation rules depending on key/unit pairs
@@ -89,7 +89,7 @@ func (ts *transformerService) Transform(msg protomfx.Message) (interface{}, erro
 			}
 			newMsg := ret
 
-			formattedPayload := transformPayload(v, msg.Profile.Transformer.ValueFields)
+			formattedPayload := transformPayload(v, msg.Profile.Transformer.ValuesFilter)
 			newMsg.Payload = formattedPayload
 
 			// Apply timestamp transformation rules depending on key/unit pairs

pkg/transformers/json/transformer_test.go

@@ -29,10 +29,10 @@ const (
 )
 
 var (
-	valueFields = []string{"key1", "key2", "key3"}
+	valuesFilter = []string{"key1", "key2", "key3"}
 )
 
-var profile = &protomfx.Profile{Transformer: &protomfx.Transformer{ValueFields: valueFields, TimeField: "nanos_key", TimeFormat: timeFieldFormat, TimeLocation: timeFieldLocation}}
+var profile = &protomfx.Profile{Transformer: &protomfx.Transformer{ValuesFilter: valuesFilter, TimeField: "nanos_key", TimeFormat: timeFieldFormat, TimeLocation: timeFieldLocation}}
 
 func TestTransformJSON(t *testing.T) {
 	now := time.Now().Unix()
@@ -59,7 +59,7 @@ func TestTransformJSON(t *testing.T) {
 
 	microsMsg := msg
 	microsMsg.Payload = []byte(microsPayload)
-	microsMsg.Profile = &protomfx.Profile{Transformer: &protomfx.Transformer{ValueFields: valueFields, TimeField: "custom_ts_micro_key", TimeFormat: "unix_us", TimeLocation: timeFieldLocation}}
+	microsMsg.Profile = &protomfx.Profile{Transformer: &protomfx.Transformer{ValuesFilter: valuesFilter, TimeField: "custom_ts_micro_key", TimeFormat: "unix_us", TimeLocation: timeFieldLocation}}
 
 	invalidTimeField := msg
 	invalidTimeField.Payload = []byte(invalidTsPayload)

things/api/grpc/endpoint.go

@@ -29,7 +29,7 @@ func getConnByKeyEndpoint(svc things.Service) endpoint.Endpoint {
 		}
 
 		transformer := &protomfx.Transformer{
-			ValueFields:  p.Transformer.ValueFields,
+			ValuesFilter: p.Transformer.ValuesFilter,
 			TimeField:    p.Transformer.TimeField,
 			TimeFormat:   p.Transformer.TimeFormat,
 			TimeLocation: p.Transformer.TimeLocation,
@@ -127,7 +127,7 @@ func getProfileByThingIDEndpoint(svc things.Service) endpoint.Endpoint {
 		}
 
 		transformer := &protomfx.Transformer{
-			ValueFields:  p.Transformer.ValueFields,
+			ValuesFilter: p.Transformer.ValuesFilter,
 			TimeField:    p.Transformer.TimeField,
 			TimeFormat:   p.Transformer.TimeFormat,
 			TimeLocation: p.Transformer.TimeLocation,

things/channels.go

@@ -28,7 +28,7 @@ type Profile struct {
 }
 
 type Transformer struct {
-	ValueFields  []string `json:"value_fields"`
+	ValuesFilter []string `json:"values_filter"`
 	TimeField    string   `json:"time_field"`
 	TimeFormat   string   `json:"time_format"`
 	TimeLocation string   `json:"time_location"`