Skip to content

Commit 7f823f0

Browse files
author
Flowersea
committed
Fix grpc any.proto marshal error
1 parent 973a12d commit 7f823f0

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

js/modules/k6/grpc/client.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -262,9 +262,12 @@ func (c *Client) convertToMethodInfo(fdset *descriptorpb.FileDescriptorSet) ([]M
262262
messages := fd.Messages()
263263
for i := 0; i < messages.Len(); i++ {
264264
message := messages.Get(i)
265-
err = protoregistry.GlobalTypes.RegisterMessage(dynamicpb.NewMessageType(message))
266-
if err != nil {
267-
return false
265+
_, errFind := protoregistry.GlobalTypes.FindMessageByName(message.FullName())
266+
if errFind == protoregistry.NotFound {
267+
err = protoregistry.GlobalTypes.RegisterMessage(dynamicpb.NewMessageType(message))
268+
if err != nil {
269+
return false
270+
}
268271
}
269272
}
270273
return true

0 commit comments

Comments
 (0)