feat: add string renderer

producer/proto/messages.go

@@ -2,7 +2,6 @@ package protoproducer
 
 import (
 	"bytes"
-	"encoding/hex"
 	"fmt"
 	"hash"
 	"hash/fnv"
@@ -121,7 +120,8 @@ func (m *ProtoProducerMessage) mapUnknown() map[string]interface{} {
 				value = v
 			} else if dataType == protowire.BytesType {
 				v, _ := protowire.ConsumeString(data)
-				value = hex.EncodeToString([]byte(v))
+				//value = hex.EncodeToString([]byte(v)) // removed, this conversion is left to the renderer
+				value = []byte(v)
 			} else {
 				continue
 			}

producer/proto/messages_test.go

@@ -4,6 +4,8 @@ import (
 	"testing"
 
 	"google.golang.org/protobuf/encoding/protowire"
+
+	"github.com/stretchr/testify/assert"
 )
 
 func TestMarshalJSON(t *testing.T) {
@@ -30,15 +32,15 @@ func TestMarshalJSON(t *testing.T) {
 			102: ProtobufFormatterConfig{
 				Name:  "test3",
 				Index: 102,
-				Type:  "string",
+				Type:  "bytes",
 				Array: false,
 			},
 		},
 		render: map[string]RenderFunc{
 			"Etype": EtypeRenderer,
 			"test1": EtypeRenderer,
 			"test2": NilRenderer,
-			//"test3": nil,
+			"test3": StringRenderer,
 		},
 	}
 
@@ -54,10 +56,12 @@ func TestMarshalJSON(t *testing.T) {
 	unk = protowire.AppendString(unk, string("testing"))
 
 	unk = protowire.AppendTag(unk, protowire.Number(102), protowire.BytesType)
-	unk = protowire.AppendString(unk, string("testing"))
+	unk = protowire.AppendString(unk, string([]byte{0x74, 0x65, 0x73, 0x74, 0x69, 0x6e, 0x67}))
 
 	fmr.SetUnknown(unk)
 
 	out, err := m.MarshalJSON()
-	t.Log(string(out), err)
+	assert.Nil(t, err)
+	t.Log(string(out))
+	assert.Equal(t, "{\"etype\":\"IPv6\",\"test1\":\"IPv6\",\"test2\":\"74657374696e67\",\"test3\":\"testing\"}", string(out))
 }

producer/proto/render.go

@@ -22,6 +22,7 @@ const (
 	RendererNetwork      RendererID = "network"
 	RendererDateTime     RendererID = "datetime"
 	RendererDateTimeNano RendererID = "datetimenano"
+	RendererString       RendererID = "string"
 )
 
 var (
@@ -33,6 +34,7 @@ var (
 		RendererProto:        ProtoRenderer,
 		RendererDateTime:     DateTimeRenderer,
 		RendererDateTimeNano: DateTimeNanoRenderer,
+		RendererString:       StringRenderer,
 	}
 
 	defaultRenderers = map[string]RenderFunc{
@@ -95,6 +97,15 @@ func NilRenderer(msg *ProtoProducerMessage, fieldName string, data interface{})
 	return data
 }
 
+func StringRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface{} {
+	if dataC, ok := data.([]byte); ok {
+		return string(dataC)
+	} else if dataC, ok := data.(string); ok {
+		return string(dataC)
+	} // maybe should support uint64?
+	return NilRenderer(msg, fieldName, data)
+}
+
 func DateTimeRenderer(msg *ProtoProducerMessage, fieldName string, data interface{}) interface{} {
 	if dataC, ok := data.(uint64); ok {
 		ts := time.Unix(int64(dataC), 0).UTC()