protovalidate: return gRPC status-compatible error

Author: ash2k

interceptors/protovalidate/protovalidate.go

@@ -68,7 +68,7 @@ func (w *wrappedServerStream) RecvMsg(m interface{}) error {
 func validateMsg(m interface{}, validator *protovalidate.Validator, opts *options) error {
 	msg, ok := m.(proto.Message)
 	if !ok {
-		return errors.New("unsupported message type")
+		return status.Errorf(codes.Internal, "unsupported message type: %T", m)
 	}
 	if opts.shouldIgnoreMessage(msg.ProtoReflect().Descriptor().FullName()) {
 		return nil

interceptors/protovalidate/protovalidate_test.go

@@ -53,8 +53,8 @@ func TestUnaryServerInterceptor(t *testing.T) {
 
 	t.Run("not_protobuf", func(t *testing.T) {
 		_, err = interceptor(context.Background(), "not protobuf", info, handler)
-		assert.Error(t, err)
-		assert.Equal(t, codes.Unknown, status.Code(err))
+		assert.EqualError(t, err, "rpc error: code = Internal desc = unsupported message type: string")
+		assert.Equal(t, codes.Internal, status.Code(err))
 	})
 
 	interceptor = protovalidate_middleware.UnaryServerInterceptor(validator,