Support protovalidate

Author: Ronen Hilewicz

.gitignore

@@ -7,3 +7,4 @@ __pycache__
 .pytest_cache
 .vscode
 .coverage
+.python-version

magefiles/magefile.go

@@ -99,6 +99,7 @@ func gen(bufImage, fileSources string) error {
 	for bufImage, clientFiles := range files {
 		err = buf.Run(
 			buf.AddArg("generate"),
+			buf.AddArg("--include-imports"),
 			buf.AddArg("--template"),
 			buf.AddArg(filepath.Join("buf", "buf.gen.yaml")),
 			buf.AddArg(bufImage),

pyproject.toml

@@ -30,12 +30,15 @@ packages = [
 
 [tool.poetry.dependencies]
 python = ">=3.8"
-grpcio = ">=1.58.0"
+grpcio = "^1.49.0"
 typing-extensions = ">=3.10.0"
+protobuf = "^4.21.0"
+protovalidate = { version = "^0.3.0", python = ">=3.11"}
 
 [tool.poetry.dev-dependencies]
-black = "^23.10.1"
-isort = "^5.10.1"
+black = "^23.11.0"
+isort = "^5.10.0"
+pyright = "^1.1.0"
 
 [tool.mypy]
 explicit_package_bases = true

src/buf/validate/expression_pb2.py

@@ -0,0 +1,34 @@
+from google.protobuf.internal import containers as _containers
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import message as _message
+from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union
+
+DESCRIPTOR: _descriptor.FileDescriptor
+
+class Constraint(_message.Message):
+    __slots__ = ("id", "message", "expression")
+    ID_FIELD_NUMBER: _ClassVar[int]
+    MESSAGE_FIELD_NUMBER: _ClassVar[int]
+    EXPRESSION_FIELD_NUMBER: _ClassVar[int]
+    id: str
+    message: str
+    expression: str
+    def __init__(self, id: _Optional[str] = ..., message: _Optional[str] = ..., expression: _Optional[str] = ...) -> None: ...
+
+class Violations(_message.Message):
+    __slots__ = ("violations",)
+    VIOLATIONS_FIELD_NUMBER: _ClassVar[int]
+    violations: _containers.RepeatedCompositeFieldContainer[Violation]
+    def __init__(self, violations: _Optional[_Iterable[_Union[Violation, _Mapping]]] = ...) -> None: ...
+
+class Violation(_message.Message):
+    __slots__ = ("field_path", "constraint_id", "message", "for_key")
+    FIELD_PATH_FIELD_NUMBER: _ClassVar[int]
+    CONSTRAINT_ID_FIELD_NUMBER: _ClassVar[int]
+    MESSAGE_FIELD_NUMBER: _ClassVar[int]
+    FOR_KEY_FIELD_NUMBER: _ClassVar[int]
+    field_path: str
+    constraint_id: str
+    message: str
+    for_key: bool
+    def __init__(self, field_path: _Optional[str] = ..., constraint_id: _Optional[str] = ..., message: _Optional[str] = ..., for_key: bool = ...) -> None: ...

src/buf/validate/expression_pb2.pyi

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+

src/buf/validate/expression_pb2_grpc.py

@@ -0,0 +1,30 @@
+"""
+@generated by mypy-protobuf.  Do not edit manually!
+isort:skip_file
+Copyright 2023 Buf Technologies, Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+"""
+import abc
+import collections.abc
+import grpc
+import grpc.aio
+import typing
+
+_T = typing.TypeVar('_T')
+
+class _MaybeAsyncIterator(collections.abc.AsyncIterator[_T], collections.abc.Iterator[_T], metaclass=abc.ABCMeta):
+    ...
+
+class _ServicerContext(grpc.ServicerContext, grpc.aio.ServicerContext):  # type: ignore
+    ...

src/buf/validate/expression_pb2_grpc.pyi

@@ -0,0 +1,25 @@
+from google.protobuf import descriptor_pb2 as _descriptor_pb2
+from google.protobuf.internal import containers as _containers
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import message as _message
+from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union
+
+DESCRIPTOR: _descriptor.FileDescriptor
+FIELD_FIELD_NUMBER: _ClassVar[int]
+field: _descriptor.FieldDescriptor
+
+class FieldConstraints(_message.Message):
+    __slots__ = ("cel",)
+    CEL_FIELD_NUMBER: _ClassVar[int]
+    cel: _containers.RepeatedCompositeFieldContainer[Constraint]
+    def __init__(self, cel: _Optional[_Iterable[_Union[Constraint, _Mapping]]] = ...) -> None: ...
+
+class Constraint(_message.Message):
+    __slots__ = ("id", "message", "expression")
+    ID_FIELD_NUMBER: _ClassVar[int]
+    MESSAGE_FIELD_NUMBER: _ClassVar[int]
+    EXPRESSION_FIELD_NUMBER: _ClassVar[int]
+    id: str
+    message: str
+    expression: str
+    def __init__(self, id: _Optional[str] = ..., message: _Optional[str] = ..., expression: _Optional[str] = ...) -> None: ...

src/buf/validate/priv/private_pb2.py

@@ -0,0 +1,4 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+