From f53aac64eb0959d47c0dba2cf56511a8dfd649c2 Mon Sep 17 00:00:00 2001 From: itzaname Date: Sun, 23 Oct 2022 15:39:34 -0400 Subject: [PATCH] Update proto --- strafesnet/datastore_pb2.py | 69 ++++++++++++++++ strafesnet/datastore_pb2_grpc.py | 132 +++++++++++++++++++++++++++++++ strafesnet/ranks_pb2.py | 99 +++++++++++++++++++++++ strafesnet/ranks_pb2_grpc.py | 132 +++++++++++++++++++++++++++++++ 4 files changed, 432 insertions(+) create mode 100644 strafesnet/datastore_pb2.py create mode 100644 strafesnet/datastore_pb2_grpc.py create mode 100644 strafesnet/ranks_pb2.py create mode 100644 strafesnet/ranks_pb2_grpc.py diff --git a/strafesnet/datastore_pb2.py b/strafesnet/datastore_pb2.py new file mode 100644 index 0000000..0202431 --- /dev/null +++ b/strafesnet/datastore_pb2.py @@ -0,0 +1,69 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: datastore.proto +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection +from google.protobuf import symbol_database as _symbol_database +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + +from google.protobuf import struct_pb2 as google_dot_protobuf_dot_struct__pb2 + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0f\x64\x61tastore.proto\x12\tdatastore\x1a\x1cgoogle/protobuf/struct.proto\"\x19\n\nKeyMessage\x12\x0b\n\x03Key\x18\x01 \x01(\t\"p\n\rUpdateMessage\x12\x0b\n\x03Key\x18\x01 \x01(\t\x12(\n\x07Updates\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\x12(\n\x07\x44\x65letes\x18\x03 \x01(\x0b\x32\x17.google.protobuf.Struct\"D\n\x0eObjectResponse\x12\x0b\n\x03Key\x18\x01 \x01(\t\x12%\n\x04\x44\x61ta\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\"\x0e\n\x0cNullResponse2\xc4\x01\n\x10\x44\x61tastoreService\x12\x37\n\x03Get\x12\x15.datastore.KeyMessage\x1a\x19.datastore.ObjectResponse\x12=\n\x06Update\x12\x18.datastore.UpdateMessage\x1a\x19.datastore.ObjectResponse\x12\x38\n\x06\x44\x65lete\x12\x15.datastore.KeyMessage\x1a\x17.datastore.NullResponseB,Z*git.itzana.me/strafesnet/go-grpc/datastoreb\x06proto3') + + + +_KEYMESSAGE = DESCRIPTOR.message_types_by_name['KeyMessage'] +_UPDATEMESSAGE = DESCRIPTOR.message_types_by_name['UpdateMessage'] +_OBJECTRESPONSE = DESCRIPTOR.message_types_by_name['ObjectResponse'] +_NULLRESPONSE = DESCRIPTOR.message_types_by_name['NullResponse'] +KeyMessage = _reflection.GeneratedProtocolMessageType('KeyMessage', (_message.Message,), { + 'DESCRIPTOR' : _KEYMESSAGE, + '__module__' : 'datastore_pb2' + # @@protoc_insertion_point(class_scope:datastore.KeyMessage) + }) +_sym_db.RegisterMessage(KeyMessage) + +UpdateMessage = _reflection.GeneratedProtocolMessageType('UpdateMessage', (_message.Message,), { + 'DESCRIPTOR' : _UPDATEMESSAGE, + '__module__' : 'datastore_pb2' + # @@protoc_insertion_point(class_scope:datastore.UpdateMessage) + }) +_sym_db.RegisterMessage(UpdateMessage) + +ObjectResponse = _reflection.GeneratedProtocolMessageType('ObjectResponse', (_message.Message,), { + 'DESCRIPTOR' : _OBJECTRESPONSE, + '__module__' : 'datastore_pb2' + # @@protoc_insertion_point(class_scope:datastore.ObjectResponse) + }) +_sym_db.RegisterMessage(ObjectResponse) + +NullResponse = _reflection.GeneratedProtocolMessageType('NullResponse', (_message.Message,), { + 'DESCRIPTOR' : _NULLRESPONSE, + '__module__' : 'datastore_pb2' + # @@protoc_insertion_point(class_scope:datastore.NullResponse) + }) +_sym_db.RegisterMessage(NullResponse) + +_DATASTORESERVICE = DESCRIPTOR.services_by_name['DatastoreService'] +if _descriptor._USE_C_DESCRIPTORS == False: + + DESCRIPTOR._options = None + DESCRIPTOR._serialized_options = b'Z*git.itzana.me/strafesnet/go-grpc/datastore' + _KEYMESSAGE._serialized_start=60 + _KEYMESSAGE._serialized_end=85 + _UPDATEMESSAGE._serialized_start=87 + _UPDATEMESSAGE._serialized_end=199 + _OBJECTRESPONSE._serialized_start=201 + _OBJECTRESPONSE._serialized_end=269 + _NULLRESPONSE._serialized_start=271 + _NULLRESPONSE._serialized_end=285 + _DATASTORESERVICE._serialized_start=288 + _DATASTORESERVICE._serialized_end=484 +# @@protoc_insertion_point(module_scope) diff --git a/strafesnet/datastore_pb2_grpc.py b/strafesnet/datastore_pb2_grpc.py new file mode 100644 index 0000000..55d3a7f --- /dev/null +++ b/strafesnet/datastore_pb2_grpc.py @@ -0,0 +1,132 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc + +import datastore_pb2 as datastore__pb2 + + +class DatastoreServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Get = channel.unary_unary( + '/datastore.DatastoreService/Get', + request_serializer=datastore__pb2.KeyMessage.SerializeToString, + response_deserializer=datastore__pb2.ObjectResponse.FromString, + ) + self.Update = channel.unary_unary( + '/datastore.DatastoreService/Update', + request_serializer=datastore__pb2.UpdateMessage.SerializeToString, + response_deserializer=datastore__pb2.ObjectResponse.FromString, + ) + self.Delete = channel.unary_unary( + '/datastore.DatastoreService/Delete', + request_serializer=datastore__pb2.KeyMessage.SerializeToString, + response_deserializer=datastore__pb2.NullResponse.FromString, + ) + + +class DatastoreServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def Get(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def Update(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def Delete(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_DatastoreServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Get': grpc.unary_unary_rpc_method_handler( + servicer.Get, + request_deserializer=datastore__pb2.KeyMessage.FromString, + response_serializer=datastore__pb2.ObjectResponse.SerializeToString, + ), + 'Update': grpc.unary_unary_rpc_method_handler( + servicer.Update, + request_deserializer=datastore__pb2.UpdateMessage.FromString, + response_serializer=datastore__pb2.ObjectResponse.SerializeToString, + ), + 'Delete': grpc.unary_unary_rpc_method_handler( + servicer.Delete, + request_deserializer=datastore__pb2.KeyMessage.FromString, + response_serializer=datastore__pb2.NullResponse.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'datastore.DatastoreService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + + + # This class is part of an EXPERIMENTAL API. +class DatastoreService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def Get(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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) + + @staticmethod + def Update(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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) + + @staticmethod + def Delete(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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) diff --git a/strafesnet/ranks_pb2.py b/strafesnet/ranks_pb2.py new file mode 100644 index 0000000..037ba5b --- /dev/null +++ b/strafesnet/ranks_pb2.py @@ -0,0 +1,99 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: ranks.proto +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import message as _message +from google.protobuf import reflection as _reflection +from google.protobuf import symbol_database as _symbol_database +# @@protoc_insertion_point(imports) + +_sym_db = _symbol_database.Default() + + +import users_pb2 as users__pb2 + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0branks.proto\x12\x05ranks\x1a\x0busers.proto\"\x17\n\tIdMessage\x12\n\n\x02ID\x18\x01 \x01(\x03\"M\n\nGetRequest\x12\x0e\n\x06UserID\x18\x01 \x01(\x03\x12\x0f\n\x07StyleID\x18\x02 \x01(\x05\x12\x0e\n\x06GameID\x18\x03 \x01(\x05\x12\x0e\n\x06ModeID\x18\x04 \x01(\x05\"m\n\x0bListRequest\x12\x0f\n\x07StyleID\x18\x01 \x01(\x05\x12\x0e\n\x06GameID\x18\x02 \x01(\x05\x12\x0e\n\x06ModeID\x18\x03 \x01(\x05\x12\x0c\n\x04Sort\x18\x04 \x01(\x03\x12\x1f\n\x04Page\x18\x05 \x01(\x0b\x32\x11.ranks.Pagination\"-\n\x08RankList\x12!\n\x05ranks\x18\x01 \x03(\x0b\x32\x12.ranks.RankMessage\"\x9d\x01\n\x0bRankMessage\x12\n\n\x02ID\x18\x01 \x01(\x03\x12!\n\x04User\x18\x02 \x01(\x0b\x32\x13.users.UserResponse\x12\x0f\n\x07StyleID\x18\x03 \x01(\x05\x12\x0e\n\x06ModeID\x18\x04 \x01(\x05\x12\x0e\n\x06GameID\x18\x05 \x01(\x05\x12\x0c\n\x04Rank\x18\x06 \x01(\x01\x12\r\n\x05Skill\x18\x07 \x01(\x01\x12\x11\n\tUpdatedAt\x18\x08 \x01(\x03\"*\n\nPagination\x12\x0c\n\x04Size\x18\x01 \x01(\x05\x12\x0e\n\x06Number\x18\x02 \x01(\x05\"\x0e\n\x0cNullResponse2\x97\x01\n\x0cRanksService\x12,\n\x03Get\x12\x11.ranks.GetRequest\x1a\x12.ranks.RankMessage\x12+\n\x04List\x12\x12.ranks.ListRequest\x1a\x0f.ranks.RankList\x12,\n\x06\x44\x65lete\x12\x10.ranks.IdMessage\x1a\x10.ranks.IdMessageB(Z&git.itzana.me/strafesnet/go-grpc/ranksb\x06proto3') + + + +_IDMESSAGE = DESCRIPTOR.message_types_by_name['IdMessage'] +_GETREQUEST = DESCRIPTOR.message_types_by_name['GetRequest'] +_LISTREQUEST = DESCRIPTOR.message_types_by_name['ListRequest'] +_RANKLIST = DESCRIPTOR.message_types_by_name['RankList'] +_RANKMESSAGE = DESCRIPTOR.message_types_by_name['RankMessage'] +_PAGINATION = DESCRIPTOR.message_types_by_name['Pagination'] +_NULLRESPONSE = DESCRIPTOR.message_types_by_name['NullResponse'] +IdMessage = _reflection.GeneratedProtocolMessageType('IdMessage', (_message.Message,), { + 'DESCRIPTOR' : _IDMESSAGE, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.IdMessage) + }) +_sym_db.RegisterMessage(IdMessage) + +GetRequest = _reflection.GeneratedProtocolMessageType('GetRequest', (_message.Message,), { + 'DESCRIPTOR' : _GETREQUEST, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.GetRequest) + }) +_sym_db.RegisterMessage(GetRequest) + +ListRequest = _reflection.GeneratedProtocolMessageType('ListRequest', (_message.Message,), { + 'DESCRIPTOR' : _LISTREQUEST, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.ListRequest) + }) +_sym_db.RegisterMessage(ListRequest) + +RankList = _reflection.GeneratedProtocolMessageType('RankList', (_message.Message,), { + 'DESCRIPTOR' : _RANKLIST, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.RankList) + }) +_sym_db.RegisterMessage(RankList) + +RankMessage = _reflection.GeneratedProtocolMessageType('RankMessage', (_message.Message,), { + 'DESCRIPTOR' : _RANKMESSAGE, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.RankMessage) + }) +_sym_db.RegisterMessage(RankMessage) + +Pagination = _reflection.GeneratedProtocolMessageType('Pagination', (_message.Message,), { + 'DESCRIPTOR' : _PAGINATION, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.Pagination) + }) +_sym_db.RegisterMessage(Pagination) + +NullResponse = _reflection.GeneratedProtocolMessageType('NullResponse', (_message.Message,), { + 'DESCRIPTOR' : _NULLRESPONSE, + '__module__' : 'ranks_pb2' + # @@protoc_insertion_point(class_scope:ranks.NullResponse) + }) +_sym_db.RegisterMessage(NullResponse) + +_RANKSSERVICE = DESCRIPTOR.services_by_name['RanksService'] +if _descriptor._USE_C_DESCRIPTORS == False: + + DESCRIPTOR._options = None + DESCRIPTOR._serialized_options = b'Z&git.itzana.me/strafesnet/go-grpc/ranks' + _IDMESSAGE._serialized_start=35 + _IDMESSAGE._serialized_end=58 + _GETREQUEST._serialized_start=60 + _GETREQUEST._serialized_end=137 + _LISTREQUEST._serialized_start=139 + _LISTREQUEST._serialized_end=248 + _RANKLIST._serialized_start=250 + _RANKLIST._serialized_end=295 + _RANKMESSAGE._serialized_start=298 + _RANKMESSAGE._serialized_end=455 + _PAGINATION._serialized_start=457 + _PAGINATION._serialized_end=499 + _NULLRESPONSE._serialized_start=501 + _NULLRESPONSE._serialized_end=515 + _RANKSSERVICE._serialized_start=518 + _RANKSSERVICE._serialized_end=669 +# @@protoc_insertion_point(module_scope) diff --git a/strafesnet/ranks_pb2_grpc.py b/strafesnet/ranks_pb2_grpc.py new file mode 100644 index 0000000..3f2b449 --- /dev/null +++ b/strafesnet/ranks_pb2_grpc.py @@ -0,0 +1,132 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc + +import ranks_pb2 as ranks__pb2 + + +class RanksServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.Get = channel.unary_unary( + '/ranks.RanksService/Get', + request_serializer=ranks__pb2.GetRequest.SerializeToString, + response_deserializer=ranks__pb2.RankMessage.FromString, + ) + self.List = channel.unary_unary( + '/ranks.RanksService/List', + request_serializer=ranks__pb2.ListRequest.SerializeToString, + response_deserializer=ranks__pb2.RankList.FromString, + ) + self.Delete = channel.unary_unary( + '/ranks.RanksService/Delete', + request_serializer=ranks__pb2.IdMessage.SerializeToString, + response_deserializer=ranks__pb2.IdMessage.FromString, + ) + + +class RanksServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def Get(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def List(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def Delete(self, request, context): + """Missing associated documentation comment in .proto file.""" + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + +def add_RanksServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'Get': grpc.unary_unary_rpc_method_handler( + servicer.Get, + request_deserializer=ranks__pb2.GetRequest.FromString, + response_serializer=ranks__pb2.RankMessage.SerializeToString, + ), + 'List': grpc.unary_unary_rpc_method_handler( + servicer.List, + request_deserializer=ranks__pb2.ListRequest.FromString, + response_serializer=ranks__pb2.RankList.SerializeToString, + ), + 'Delete': grpc.unary_unary_rpc_method_handler( + servicer.Delete, + request_deserializer=ranks__pb2.IdMessage.FromString, + response_serializer=ranks__pb2.IdMessage.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'ranks.RanksService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + + + # This class is part of an EXPERIMENTAL API. +class RanksService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def Get(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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) + + @staticmethod + def List(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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) + + @staticmethod + def Delete(request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + 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)