handling of dynamicpb.Map

streamingfast · Feb 26, 2024 · f3b1567 · f3b1567
1 parent d474951
commit f3b1567
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/json/marshallers.go b/json/marshallers.go
@@ -132,6 +132,20 @@ func (m *Marshaller) dynamicpbMessage(encoder *jsontext.Encoder, msg *dynamicpb.
 	}
 
 	msg.Range(func(fd protoreflect.FieldDescriptor, v protoreflect.Value) bool {
+		if fd.IsMap() {
+			out := map[string]interface{}{}
+			v.Map().Range(func(k protoreflect.MapKey, v2 protoreflect.Value) bool {
+				key := k.String()
+				out[key] = v2.Interface()
+				return true
+			})
+			kvl = append(kvl, &kv{
+				key:   string(fd.Name()),
+				value: out,
+			})
+			return true
+		}
+
 		if fd.IsList() {
 			out := make([]any, v.List().Len())
 			for i := 0; i < v.List().Len(); i++ {