Fix decode plugin with protobuf decoder (#721)

ozontech · Dec 12, 2024 · 1da9776 · 1da9776
1 parent cfe8d68
commit 1da9776
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/plugin/action/decode/decode.go b/plugin/action/decode/decode.go
@@ -543,10 +543,11 @@ func (p *Plugin) decodeNginxError(root *insaneJSON.Root, node *insaneJSON.Node)
 }
 
 func (p *Plugin) decodeProtobuf(root *insaneJSON.Root, node *insaneJSON.Node, buf []byte) {
-	t := insaneJSON.Spawn()
-	defer insaneJSON.Release(t)
-
-	err := p.decoder.DecodeToJson(t, node.AsBytes())
+	jsonRaw, err := p.decoder.Decode(node.AsBytes())
+	if p.checkError(err, node) {
+		return
+	}
+	t, err := root.DecodeBytesAdditional(jsonRaw.([]byte))
 	if p.checkError(err, node) {
 		return
 	}
@@ -565,7 +566,7 @@ func (p *Plugin) decodeProtobuf(root *insaneJSON.Root, node *insaneJSON.Node, bu
 		node.Suicide()
 	}
 
-	root.MergeWith(t.Node)
+	root.MergeWith(t)
 }
 
 func (p *Plugin) addFieldPrefix(root *insaneJSON.Root, key string, val []byte) {