diff --git a/strafesnet/bots_pb2.py b/strafesnet/bots_pb2.py index 319a147..2fe75af 100644 --- a/strafesnet/bots_pb2.py +++ b/strafesnet/bots_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: bots.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nbots.proto\x12\x _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'bots_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z%git.itzana.me/strafesnet/go-grpc/bots' _globals['_IDLIST']._serialized_start=20 _globals['_IDLIST']._serialized_end=40 diff --git a/strafesnet/bots_pb2_grpc.py b/strafesnet/bots_pb2_grpc.py index cbb5b24..e4be266 100644 --- a/strafesnet/bots_pb2_grpc.py +++ b/strafesnet/bots_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import bots_pb2 as bots__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in bots_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class BotsServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +43,32 @@ class BotsServiceStub(object): '/bots.BotsService/Get', request_serializer=bots__pb2.IdMessage.SerializeToString, response_deserializer=bots__pb2.BotResponse.FromString, - ) + _registered_method=True) self.GetList = channel.unary_unary( '/bots.BotsService/GetList', request_serializer=bots__pb2.IdList.SerializeToString, response_deserializer=bots__pb2.BotList.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/bots.BotsService/Update', request_serializer=bots__pb2.BotRequest.SerializeToString, response_deserializer=bots__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Create = channel.unary_unary( '/bots.BotsService/Create', request_serializer=bots__pb2.BotRequest.SerializeToString, response_deserializer=bots__pb2.IdMessage.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/bots.BotsService/Delete', request_serializer=bots__pb2.IdMessage.SerializeToString, response_deserializer=bots__pb2.NullResponse.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/bots.BotsService/List', request_serializer=bots__pb2.ListRequest.SerializeToString, response_deserializer=bots__pb2.BotList.FromString, - ) + _registered_method=True) class BotsServiceServicer(object): @@ -122,6 +147,7 @@ def add_BotsServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'bots.BotsService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('bots.BotsService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +165,21 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/Get', bots__pb2.IdMessage.SerializeToString, bots__pb2.BotResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetList(request, @@ -156,11 +192,21 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/GetList', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/GetList', bots__pb2.IdList.SerializeToString, bots__pb2.BotList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -173,11 +219,21 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/Update', bots__pb2.BotRequest.SerializeToString, bots__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Create(request, @@ -190,11 +246,21 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/Create', bots__pb2.BotRequest.SerializeToString, bots__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -207,11 +273,21 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/Delete', bots__pb2.IdMessage.SerializeToString, bots__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -224,8 +300,18 @@ class BotsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/bots.BotsService/List', + return grpc.experimental.unary_unary( + request, + target, + '/bots.BotsService/List', bots__pb2.ListRequest.SerializeToString, bots__pb2.BotList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/datastore_pb2.py b/strafesnet/datastore_pb2.py index 8e0a1a9..0281bed 100644 --- a/strafesnet/datastore_pb2.py +++ b/strafesnet/datastore_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: datastore.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0f\x64\x61tastor _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'datastore_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z*git.itzana.me/strafesnet/go-grpc/datastore' _globals['_KEYMESSAGE']._serialized_start=60 _globals['_KEYMESSAGE']._serialized_end=85 diff --git a/strafesnet/datastore_pb2_grpc.py b/strafesnet/datastore_pb2_grpc.py index 1a4baac..db0bf49 100644 --- a/strafesnet/datastore_pb2_grpc.py +++ b/strafesnet/datastore_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import datastore_pb2 as datastore__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in datastore_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class DatastoreServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,17 +43,17 @@ class DatastoreServiceStub(object): '/datastore.DatastoreService/Get', request_serializer=datastore__pb2.KeyMessage.SerializeToString, response_deserializer=datastore__pb2.ObjectResponse.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/datastore.DatastoreService/Update', request_serializer=datastore__pb2.UpdateMessage.SerializeToString, response_deserializer=datastore__pb2.ObjectResponse.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/datastore.DatastoreService/Delete', request_serializer=datastore__pb2.KeyMessage.SerializeToString, response_deserializer=datastore__pb2.NullResponse.FromString, - ) + _registered_method=True) class DatastoreServiceServicer(object): @@ -74,6 +99,7 @@ def add_DatastoreServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'datastore.DatastoreService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('datastore.DatastoreService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -91,11 +117,21 @@ class DatastoreService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/datastore.DatastoreService/Get', datastore__pb2.KeyMessage.SerializeToString, datastore__pb2.ObjectResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -108,11 +144,21 @@ class DatastoreService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/datastore.DatastoreService/Update', datastore__pb2.UpdateMessage.SerializeToString, datastore__pb2.ObjectResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -125,8 +171,18 @@ class DatastoreService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/datastore.DatastoreService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/datastore.DatastoreService/Delete', datastore__pb2.KeyMessage.SerializeToString, datastore__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/events_pb2.py b/strafesnet/events_pb2.py index e046326..968bdb1 100644 --- a/strafesnet/events_pb2.py +++ b/strafesnet/events_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: events.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0c\x65vents.prot _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'events_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z\'git.itzana.me/strafesnet/go-grpc/events' _globals['_EVENTCREATE']._serialized_start=54 _globals['_EVENTCREATE']._serialized_end=167 diff --git a/strafesnet/events_pb2_grpc.py b/strafesnet/events_pb2_grpc.py index 2a279a5..d867464 100644 --- a/strafesnet/events_pb2_grpc.py +++ b/strafesnet/events_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import events_pb2 as events__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in events_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class EventsServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,17 +43,17 @@ class EventsServiceStub(object): '/events.EventsService/Latest', request_serializer=events__pb2.LatestRequest.SerializeToString, response_deserializer=events__pb2.LatestResponse.FromString, - ) + _registered_method=True) self.Create = channel.unary_unary( '/events.EventsService/Create', request_serializer=events__pb2.EventCreate.SerializeToString, response_deserializer=events__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Clean = channel.unary_unary( '/events.EventsService/Clean', request_serializer=events__pb2.NullResponse.SerializeToString, response_deserializer=events__pb2.NullResponse.FromString, - ) + _registered_method=True) class EventsServiceServicer(object): @@ -74,6 +99,7 @@ def add_EventsServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'events.EventsService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('events.EventsService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -91,11 +117,21 @@ class EventsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/events.EventsService/Latest', + return grpc.experimental.unary_unary( + request, + target, + '/events.EventsService/Latest', events__pb2.LatestRequest.SerializeToString, events__pb2.LatestResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Create(request, @@ -108,11 +144,21 @@ class EventsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/events.EventsService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/events.EventsService/Create', events__pb2.EventCreate.SerializeToString, events__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Clean(request, @@ -125,8 +171,18 @@ class EventsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/events.EventsService/Clean', + return grpc.experimental.unary_unary( + request, + target, + '/events.EventsService/Clean', events__pb2.NullResponse.SerializeToString, events__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/maps_pb2.py b/strafesnet/maps_pb2.py index c9f091a..09f684d 100644 --- a/strafesnet/maps_pb2.py +++ b/strafesnet/maps_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: maps.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\nmaps.proto\x12\x _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'maps_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z%git.itzana.me/strafesnet/go-grpc/maps' _globals['_IDLIST']._serialized_start=20 _globals['_IDLIST']._serialized_end=40 diff --git a/strafesnet/maps_pb2_grpc.py b/strafesnet/maps_pb2_grpc.py index bdd769d..6df05ee 100644 --- a/strafesnet/maps_pb2_grpc.py +++ b/strafesnet/maps_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import maps_pb2 as maps__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in maps_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class MapsServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +43,32 @@ class MapsServiceStub(object): '/maps.MapsService/Get', request_serializer=maps__pb2.IdMessage.SerializeToString, response_deserializer=maps__pb2.MapResponse.FromString, - ) + _registered_method=True) self.GetList = channel.unary_unary( '/maps.MapsService/GetList', request_serializer=maps__pb2.IdList.SerializeToString, response_deserializer=maps__pb2.MapList.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/maps.MapsService/Update', request_serializer=maps__pb2.MapRequest.SerializeToString, response_deserializer=maps__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Create = channel.unary_unary( '/maps.MapsService/Create', request_serializer=maps__pb2.MapRequest.SerializeToString, response_deserializer=maps__pb2.IdMessage.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/maps.MapsService/Delete', request_serializer=maps__pb2.IdMessage.SerializeToString, response_deserializer=maps__pb2.NullResponse.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/maps.MapsService/List', request_serializer=maps__pb2.ListRequest.SerializeToString, response_deserializer=maps__pb2.MapList.FromString, - ) + _registered_method=True) class MapsServiceServicer(object): @@ -122,6 +147,7 @@ def add_MapsServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'maps.MapsService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('maps.MapsService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +165,21 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/Get', maps__pb2.IdMessage.SerializeToString, maps__pb2.MapResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetList(request, @@ -156,11 +192,21 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/GetList', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/GetList', maps__pb2.IdList.SerializeToString, maps__pb2.MapList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -173,11 +219,21 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/Update', maps__pb2.MapRequest.SerializeToString, maps__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Create(request, @@ -190,11 +246,21 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/Create', maps__pb2.MapRequest.SerializeToString, maps__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -207,11 +273,21 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/Delete', maps__pb2.IdMessage.SerializeToString, maps__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -224,8 +300,18 @@ class MapsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/maps.MapsService/List', + return grpc.experimental.unary_unary( + request, + target, + '/maps.MapsService/List', maps__pb2.ListRequest.SerializeToString, maps__pb2.MapList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/ranks_pb2.py b/strafesnet/ranks_pb2.py index 20c0586..3a63fa2 100644 --- a/strafesnet/ranks_pb2.py +++ b/strafesnet/ranks_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: ranks.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -20,8 +20,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0branks.proto\x1 _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ranks_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/ranks' _globals['_IDMESSAGE']._serialized_start=35 _globals['_IDMESSAGE']._serialized_end=58 diff --git a/strafesnet/ranks_pb2_grpc.py b/strafesnet/ranks_pb2_grpc.py index 48e8ec9..5ba4daa 100644 --- a/strafesnet/ranks_pb2_grpc.py +++ b/strafesnet/ranks_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import ranks_pb2 as ranks__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in ranks_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class RanksServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,17 +43,17 @@ class RanksServiceStub(object): '/ranks.RanksService/Get', request_serializer=ranks__pb2.GetRequest.SerializeToString, response_deserializer=ranks__pb2.RankMessage.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/ranks.RanksService/List', request_serializer=ranks__pb2.ListRequest.SerializeToString, response_deserializer=ranks__pb2.RankList.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/ranks.RanksService/Delete', request_serializer=ranks__pb2.IdMessage.SerializeToString, response_deserializer=ranks__pb2.IdMessage.FromString, - ) + _registered_method=True) class RanksServiceServicer(object): @@ -74,6 +99,7 @@ def add_RanksServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'ranks.RanksService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('ranks.RanksService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -91,11 +117,21 @@ class RanksService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/ranks.RanksService/Get', ranks__pb2.GetRequest.SerializeToString, ranks__pb2.RankMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -108,11 +144,21 @@ class RanksService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/List', + return grpc.experimental.unary_unary( + request, + target, + '/ranks.RanksService/List', ranks__pb2.ListRequest.SerializeToString, ranks__pb2.RankList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -125,8 +171,18 @@ class RanksService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/ranks.RanksService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/ranks.RanksService/Delete', ranks__pb2.IdMessage.SerializeToString, ranks__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/servers_pb2.py b/strafesnet/servers_pb2.py index 42c5efa..2ad45e2 100644 --- a/strafesnet/servers_pb2.py +++ b/strafesnet/servers_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: servers.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -21,8 +21,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\rservers.proto\x1 _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'servers_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z(git.itzana.me/strafesnet/go-grpc/servers' _globals['_SERVERLIST']._serialized_start=51 _globals['_SERVERLIST']._serialized_end=101 diff --git a/strafesnet/servers_pb2_grpc.py b/strafesnet/servers_pb2_grpc.py index 960eca3..d61efae 100644 --- a/strafesnet/servers_pb2_grpc.py +++ b/strafesnet/servers_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import servers_pb2 as servers__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in servers_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class ServerServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,27 +43,27 @@ class ServerServiceStub(object): '/servers.ServerService/Create', request_serializer=servers__pb2.ServerCreate.SerializeToString, response_deserializer=servers__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/servers.ServerService/Update', request_serializer=servers__pb2.ServerUpdate.SerializeToString, response_deserializer=servers__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/servers.ServerService/Delete', request_serializer=servers__pb2.IdMessage.SerializeToString, response_deserializer=servers__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Get = channel.unary_unary( '/servers.ServerService/Get', request_serializer=servers__pb2.IdMessage.SerializeToString, response_deserializer=servers__pb2.ServerItem.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/servers.ServerService/List', request_serializer=servers__pb2.ServerListRequest.SerializeToString, response_deserializer=servers__pb2.ServerList.FromString, - ) + _registered_method=True) class ServerServiceServicer(object): @@ -106,6 +131,7 @@ def add_ServerServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'servers.ServerService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('servers.ServerService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -123,11 +149,21 @@ class ServerService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/servers.ServerService/Create', servers__pb2.ServerCreate.SerializeToString, servers__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -140,11 +176,21 @@ class ServerService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/servers.ServerService/Update', servers__pb2.ServerUpdate.SerializeToString, servers__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -157,11 +203,21 @@ class ServerService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/servers.ServerService/Delete', servers__pb2.IdMessage.SerializeToString, servers__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Get(request, @@ -174,11 +230,21 @@ class ServerService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/servers.ServerService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/servers.ServerService/Get', servers__pb2.IdMessage.SerializeToString, servers__pb2.ServerItem.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -191,8 +257,18 @@ class ServerService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/servers.ServerService/List', + return grpc.experimental.unary_unary( + request, + target, + '/servers.ServerService/List', servers__pb2.ServerListRequest.SerializeToString, servers__pb2.ServerList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/times_pb2.py b/strafesnet/times_pb2.py index e6bed1a..a860bdd 100644 --- a/strafesnet/times_pb2.py +++ b/strafesnet/times_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: times.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -22,8 +22,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0btimes.proto\x1 _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'times_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/times' _globals['_TIMEREQUEST']._serialized_start=60 _globals['_TIMEREQUEST']._serialized_end=301 diff --git a/strafesnet/times_pb2_grpc.py b/strafesnet/times_pb2_grpc.py index b3012c0..b4f646f 100644 --- a/strafesnet/times_pb2_grpc.py +++ b/strafesnet/times_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import times_pb2 as times__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in times_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class TimesServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +43,32 @@ class TimesServiceStub(object): '/times.TimesService/Create', request_serializer=times__pb2.TimeRequest.SerializeToString, response_deserializer=times__pb2.IdMessage.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/times.TimesService/Update', request_serializer=times__pb2.TimeRequest.SerializeToString, response_deserializer=times__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/times.TimesService/Delete', request_serializer=times__pb2.IdMessage.SerializeToString, response_deserializer=times__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Get = channel.unary_unary( '/times.TimesService/Get', request_serializer=times__pb2.IdMessage.SerializeToString, response_deserializer=times__pb2.TimeResponse.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/times.TimesService/List', request_serializer=times__pb2.ListRequest.SerializeToString, response_deserializer=times__pb2.TimeList.FromString, - ) + _registered_method=True) self.Rank = channel.unary_unary( '/times.TimesService/Rank', request_serializer=times__pb2.IdMessage.SerializeToString, response_deserializer=times__pb2.RankResponse.FromString, - ) + _registered_method=True) class TimesServiceServicer(object): @@ -122,6 +147,7 @@ def add_TimesServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'times.TimesService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('times.TimesService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +165,21 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/Create', times__pb2.TimeRequest.SerializeToString, times__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -156,11 +192,21 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/Update', times__pb2.TimeRequest.SerializeToString, times__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -173,11 +219,21 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/Delete', times__pb2.IdMessage.SerializeToString, times__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Get(request, @@ -190,11 +246,21 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/Get', times__pb2.IdMessage.SerializeToString, times__pb2.TimeResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -207,11 +273,21 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/List', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/List', times__pb2.ListRequest.SerializeToString, times__pb2.TimeList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Rank(request, @@ -224,8 +300,18 @@ class TimesService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/times.TimesService/Rank', + return grpc.experimental.unary_unary( + request, + target, + '/times.TimesService/Rank', times__pb2.IdMessage.SerializeToString, times__pb2.RankResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/transactions_pb2.py b/strafesnet/transactions_pb2.py index c9a66a5..5506eae 100644 --- a/strafesnet/transactions_pb2.py +++ b/strafesnet/transactions_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: transactions.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -21,8 +21,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12transactions.p _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'transactions_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z-git.itzana.me/strafesnet/go-grpc/transactions' _globals['_TRANSACTIONCREATE']._serialized_start=79 _globals['_TRANSACTIONCREATE']._serialized_end=197 diff --git a/strafesnet/transactions_pb2_grpc.py b/strafesnet/transactions_pb2_grpc.py index f56e3f7..014a243 100644 --- a/strafesnet/transactions_pb2_grpc.py +++ b/strafesnet/transactions_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import transactions_pb2 as transactions__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in transactions_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class TransactionsServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +43,32 @@ class TransactionsServiceStub(object): '/transactions.TransactionsService/Create', request_serializer=transactions__pb2.TransactionCreate.SerializeToString, response_deserializer=transactions__pb2.IdMessage.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/transactions.TransactionsService/Update', request_serializer=transactions__pb2.TransactionUpdate.SerializeToString, response_deserializer=transactions__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/transactions.TransactionsService/Delete', request_serializer=transactions__pb2.IdMessage.SerializeToString, response_deserializer=transactions__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Balance = channel.unary_unary( '/transactions.TransactionsService/Balance', request_serializer=transactions__pb2.UserIdMessage.SerializeToString, response_deserializer=transactions__pb2.BalanceResponse.FromString, - ) + _registered_method=True) self.Get = channel.unary_unary( '/transactions.TransactionsService/Get', request_serializer=transactions__pb2.IdMessage.SerializeToString, response_deserializer=transactions__pb2.TransactionItem.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/transactions.TransactionsService/List', request_serializer=transactions__pb2.ListRequest.SerializeToString, response_deserializer=transactions__pb2.TransactionList.FromString, - ) + _registered_method=True) class TransactionsServiceServicer(object): @@ -122,6 +147,7 @@ def add_TransactionsServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'transactions.TransactionsService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('transactions.TransactionsService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +165,21 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/Create', transactions__pb2.TransactionCreate.SerializeToString, transactions__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -156,11 +192,21 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/Update', transactions__pb2.TransactionUpdate.SerializeToString, transactions__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -173,11 +219,21 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/Delete', transactions__pb2.IdMessage.SerializeToString, transactions__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Balance(request, @@ -190,11 +246,21 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Balance', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/Balance', transactions__pb2.UserIdMessage.SerializeToString, transactions__pb2.BalanceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Get(request, @@ -207,11 +273,21 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/Get', transactions__pb2.IdMessage.SerializeToString, transactions__pb2.TransactionItem.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -224,8 +300,18 @@ class TransactionsService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/transactions.TransactionsService/List', + return grpc.experimental.unary_unary( + request, + target, + '/transactions.TransactionsService/List', transactions__pb2.ListRequest.SerializeToString, transactions__pb2.TransactionList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) diff --git a/strafesnet/users_pb2.py b/strafesnet/users_pb2.py index 229e862..4c57b93 100644 --- a/strafesnet/users_pb2.py +++ b/strafesnet/users_pb2.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: users.proto -# Protobuf Python Version: 4.25.0 +# Protobuf Python Version: 5.26.1 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool @@ -19,8 +19,8 @@ DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0busers.proto\x1 _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'users_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - _globals['DESCRIPTOR']._options = None +if not _descriptor._USE_C_DESCRIPTORS: + _globals['DESCRIPTOR']._loaded_options = None _globals['DESCRIPTOR']._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/users' _globals['_IDLIST']._serialized_start=22 _globals['_IDLIST']._serialized_end=42 diff --git a/strafesnet/users_pb2_grpc.py b/strafesnet/users_pb2_grpc.py index ce18ede..5b58538 100644 --- a/strafesnet/users_pb2_grpc.py +++ b/strafesnet/users_pb2_grpc.py @@ -1,9 +1,34 @@ # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! """Client and server classes corresponding to protobuf-defined services.""" import grpc +import warnings from . import users_pb2 as users__pb2 +GRPC_GENERATED_VERSION = '1.64.1' +GRPC_VERSION = grpc.__version__ +EXPECTED_ERROR_RELEASE = '1.65.0' +SCHEDULED_RELEASE_DATE = 'June 25, 2024' +_version_not_supported = False + +try: + from grpc._utilities import first_version_is_lower + _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) +except ImportError: + _version_not_supported = True + +if _version_not_supported: + warnings.warn( + f'The grpc package installed is at version {GRPC_VERSION},' + + f' but the generated code in users_pb2_grpc.py depends on' + + f' grpcio>={GRPC_GENERATED_VERSION}.' + + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}' + + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.' + + f' This warning will become an error in {EXPECTED_ERROR_RELEASE},' + + f' scheduled for release on {SCHEDULED_RELEASE_DATE}.', + RuntimeWarning + ) + class UsersServiceStub(object): """Missing associated documentation comment in .proto file.""" @@ -18,32 +43,32 @@ class UsersServiceStub(object): '/users.UsersService/Get', request_serializer=users__pb2.IdMessage.SerializeToString, response_deserializer=users__pb2.UserResponse.FromString, - ) + _registered_method=True) self.GetList = channel.unary_unary( '/users.UsersService/GetList', request_serializer=users__pb2.IdList.SerializeToString, response_deserializer=users__pb2.UserList.FromString, - ) + _registered_method=True) self.Update = channel.unary_unary( '/users.UsersService/Update', request_serializer=users__pb2.UserRequest.SerializeToString, response_deserializer=users__pb2.NullResponse.FromString, - ) + _registered_method=True) self.Create = channel.unary_unary( '/users.UsersService/Create', request_serializer=users__pb2.UserRequest.SerializeToString, response_deserializer=users__pb2.IdMessage.FromString, - ) + _registered_method=True) self.Delete = channel.unary_unary( '/users.UsersService/Delete', request_serializer=users__pb2.IdMessage.SerializeToString, response_deserializer=users__pb2.NullResponse.FromString, - ) + _registered_method=True) self.List = channel.unary_unary( '/users.UsersService/List', request_serializer=users__pb2.ListRequest.SerializeToString, response_deserializer=users__pb2.UserList.FromString, - ) + _registered_method=True) class UsersServiceServicer(object): @@ -122,6 +147,7 @@ def add_UsersServiceServicer_to_server(servicer, server): generic_handler = grpc.method_handlers_generic_handler( 'users.UsersService', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,)) + server.add_registered_method_handlers('users.UsersService', rpc_method_handlers) # This class is part of an EXPERIMENTAL API. @@ -139,11 +165,21 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/Get', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/Get', users__pb2.IdMessage.SerializeToString, users__pb2.UserResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def GetList(request, @@ -156,11 +192,21 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/GetList', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/GetList', users__pb2.IdList.SerializeToString, users__pb2.UserList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Update(request, @@ -173,11 +219,21 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/Update', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/Update', users__pb2.UserRequest.SerializeToString, users__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Create(request, @@ -190,11 +246,21 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/Create', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/Create', users__pb2.UserRequest.SerializeToString, users__pb2.IdMessage.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def Delete(request, @@ -207,11 +273,21 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/Delete', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/Delete', users__pb2.IdMessage.SerializeToString, users__pb2.NullResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True) @staticmethod def List(request, @@ -224,8 +300,18 @@ class UsersService(object): wait_for_ready=None, timeout=None, metadata=None): - return grpc.experimental.unary_unary(request, target, '/users.UsersService/List', + return grpc.experimental.unary_unary( + request, + target, + '/users.UsersService/List', users__pb2.ListRequest.SerializeToString, users__pb2.UserList.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + _registered_method=True)