diff --git a/core/adapter.go b/core/adapter.go index c75dde5..5f47dc3 100644 --- a/core/adapter.go +++ b/core/adapter.go @@ -259,6 +259,14 @@ func (f *Factory) Fail() int { return f.errorTimes } +func (f *Factory) GetBotID() string { + return f.botid +} + +func (f *Factory) GetPlatform() string { + return f.botplt +} + func (f *Factory) Success() { f.errorTimes = 0 } diff --git a/core/plugin_impl.go b/core/plugin_impl.go index 0654cf4..4078e80 100644 --- a/core/plugin_impl.go +++ b/core/plugin_impl.go @@ -172,6 +172,7 @@ func (sender *SenderJsIplm) GetImType() string { func (sender *SenderJsIplm) GetPlatform() string { return sender.Message.GetImType() } + func (sender *SenderJsIplm) RecallMessage(p ...interface{}) { sender.Message.RecallMessage(p...) } @@ -308,6 +309,10 @@ func (sender *SenderJsIplm) Action(options map[string]interface{}) interface{} { } } +func (sender *SenderJsIplm) DoAction(options map[string]interface{}) interface{} { + return sender.Action(options) +} + func (sender *SenderJsIplm) Reply(texts ...interface{}) interface{} { i, err := sender.Message.Reply(texts...) var errstr interface{} diff --git a/proto3/note.sh b/proto3/note.sh index b7135f9..e53fd59 100644 --- a/proto3/note.sh +++ b/proto3/note.sh @@ -12,7 +12,11 @@ protoc --js_out=import_style=commonjs,binary:. --grpc_out=. srpc.proto protoc --go_out=. -I. --go-grpc_out=. srpc.proto protoc-gen-grpc --ts_out=service=grpc-node:. srpc.proto -#--grpc_out=. +#protoc-gen-grpc --python_out=. srpc.proto +#protoc --python_out=. srpc.proto +# pip install "grpcio-tools==1.43.0" +python3 -m grpc_tools.protoc -I. --python_out=. --grpc_python_out=. srpc.proto + #打包 npx webpack --config webpack.config.js diff --git a/proto3/sillygirl.py b/proto3/sillygirl.py new file mode 100644 index 0000000..cdd1d6b --- /dev/null +++ b/proto3/sillygirl.py @@ -0,0 +1,192 @@ +import asyncio +import json, pickle, base64, os, grpc +import time +import random +import threading +from queue import Queue + +import srpc_pb2, srpc_pb2_grpc + +plugin_id = os.environ.get("PLUGIN_ID", "") +runtime_id = os.environ.get("RUNTIME_ID", "") + +metadata = (("RUNTIME_ID", runtime_id),) +metadata = grpc.metadata_call_credentials(metadata) + +channel = grpc.insecure_channel("localhost:50051") +stub = srpc_pb2_grpc.SillyGirlServiceStub(channel) + + +def transform(value): + # 将从远程存储桶中获取的值进行转换，将其转换为相应的 Python 类型 + if value.startswith("f:"): + return float(value[2:]) + elif value.startswith("i:"): + return int(value[2:]) + elif value.startswith("b:"): + return value[2:] == "true" + elif value.startswith("o:"): + return json.loads(value[2:]) + elif value.startswith("p:"): + return pickle.loads(base64.b64decode(value[2:])) + elif value == "": + return None + return value + + +def reverseTransform(value): + # 将 Python 值转换为存储桶中的字符串表示形式 + try: + if isinstance(value, float): + return f"f:{value}" + elif isinstance(value, bool): + res = "true" if value else "false" + return f"b:{res}" + elif isinstance(value, int): + return f"i:{value}" + elif isinstance(value, str): + return value + elif value == None: + return "" + else: + return f"o:{json.dumps(value)}" + except: + return "p:%s" % base64.b64encode(pickle.dumps(value)).decode("utf-8") + + +class Bucket: + def __init__(self, name): + self.__name = name + print("name=", name, "self.__name=", self.__name) + + def __getitem__(self, key): + return self.get(key) + + def __getattr__(self, name): + return self.get(name) + + def __setitem__(self, key, value): + self.set(key, value) + + def __setattr__(self, name, value): + if name in ["data", "_Bucket__name"]: + # 使用object类的方法设置属性，避免无限递归 + object.__setattr__(self, name, value) + else: + self.set(name, value) + + def get(self, key, defaultValue=None): + request = srpc_pb2.BucketKeyRequest(name=self.__name, key=key) + response = stub.BucketGet(request) + if response.value != "": + return transform(response.value) + else: + return defaultValue + + def set(self, key, value): + request = srpc_pb2.BucketSetRequest( + name=self.__name, key=key, value=reverseTransform(value) + ) + response = stub.BucketSet(request) + return {"message": response.message, "changed": response.changed} + + def delete(self, key): + return self.set(key, None) + + def deleteAll(self): + request = srpc_pb2.BucketRequest(name=self.__name) + stub.BucketDelete(request) + + def keys(self): + print("name", self.__name) + request = srpc_pb2.BucketKeyRequest(name=self.__name) + response = stub.BucketKeys(request) + return list(response.keys) + + def len(self): + request = srpc_pb2.BucketRequest(name=self.__name) + response = stub.BucketLen(request) + return response.length + + def buckets(self): + request = srpc_pb2.Empty() + response = stub.BucketBuckets(request) + return list(response.buckets) + + def watch(self, key, handle): + queue = Queue() + + def entry_request_iterator(): + yield srpc_pb2.BucketWatchRequest( + name=self.__name, key=key, plugin_id=plugin_id + ) + while True: + yield queue.get() + print("queue.get()") + # 阻塞A区 等待B区发送数据 + + generator = entry_request_iterator() + for response in stub.BucketWatch(generator): + print("Server response:", response) + old = transform(response.old) + now = transform(response.now) + result = handle(old, now, response.key) + try: + fin = result + except Exception as e: + print(e) + continue + storage_modifier = { + "echo": response.echo, + } + if not fin: + storage_modifier["error"] = "VOID" + else: + if "now" in fin: + storage_modifier["now"] = reverseTransform(fin["now"]) + if "message" in fin: + storage_modifier["message"] = fin["message"] + if "error" in fin: + storage_modifier["error"] = fin["error"] + queue.put(srpc_pb2.BucketWatchRequest(**storage_modifier)) + + +app = Bucket("test") + + +def handle(old_value, new_value, key): + print("Bucket value changed!") + print("Key:", key) + print("Old value:", old_value) + print("New value:", new_value) + return { + "now": "shit", + } + + +app.watch(key="*", handle=handle) +# app.name = 1 +# print(app.name) +# app["name"] = (1,3, {3,4,5}) +# print(app["name"]) +# app.set("name", 1.23) +# print(app.get("name")) +# print("keys", app.keys()) +# print("len", app.len()) +# print("buckets", app.buckets()) +# # app.delete("name") +# app.name = 0 +# print(app.name) +# print("==") +# app.name = random.randrange(1,100,1) +# print("==") +# app.deleteAll() +print(app.name) + + +class Sender: + pass + + +class Adapter: + pass diff --git a/proto3/srpc_pb2.py b/proto3/srpc_pb2.py new file mode 100644 index 0000000..42dfbbb --- /dev/null +++ b/proto3/srpc_pb2.py @@ -0,0 +1,1442 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: srpc.proto +"""Generated protocol buffer code.""" +from google.protobuf import descriptor as _descriptor +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() + + + + +DESCRIPTOR = _descriptor.FileDescriptor( + name='srpc.proto', + package='srpc', + syntax='proto3', + serialized_options=b'Z\005srpc/', + create_key=_descriptor._internal_create_key, + serialized_pb=b'\n\nsrpc.proto\x12\x04srpc\"\x07\n\x05\x45mpty\"\x18\n\x07\x44\x65\x66\x61ult\x12\r\n\x05value\x18\x01 \x01(\t\"<\n\x10\x42ucketSetRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0b\n\x03key\x18\x02 \x01(\t\x12\r\n\x05value\x18\x03 \x01(\t\"}\n\x12\x42ucketWatchRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0b\n\x03key\x18\x02 \x01(\t\x12\x0f\n\x07message\x18\x03 \x01(\t\x12\r\n\x05\x65rror\x18\x04 \x01(\t\x12\x0b\n\x03now\x18\x05 \x01(\t\x12\x0c\n\x04\x65\x63ho\x18\x06 \x01(\t\x12\x11\n\tplugin_id\x18\x07 \x01(\t\"J\n\x13\x42ucketWatchResponse\x12\x0c\n\x04\x65\x63ho\x18\x01 \x01(\t\x12\x0b\n\x03old\x18\x02 \x01(\t\x12\x0b\n\x03now\x18\x03 \x01(\t\x12\x0b\n\x03key\x18\x04 \x01(\t\"5\n\x11\x42ucketSetResponse\x12\x0f\n\x07\x63hanged\x18\x01 \x01(\x08\x12\x0f\n\x07message\x18\x02 \x01(\t\"-\n\x10\x42ucketKeyRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\x0b\n\x03key\x18\x02 \x01(\t\"\x1d\n\rBucketRequest\x12\x0c\n\x04name\x18\x01 \x01(\t\"\"\n\x12\x42ucketKeysResponse\x12\x0c\n\x04keys\x18\x01 \x03(\t\"\x1d\n\x0bLenResponse\x12\x0e\n\x06length\x18\x01 \x01(\x05\"\x1d\n\x0c\x42oolResponse\x12\r\n\x05value\x18\x01 \x01(\x08\"\"\n\x0f\x42ucketsResponse\x12\x0f\n\x07\x62uckets\x18\x01 \x03(\t\"\x1d\n\rSenderRequest\x12\x0c\n\x04uuid\x18\x01 \x01(\t\"-\n\x0cReplyRequest\x12\x0c\n\x04uuid\x18\x01 \x01(\t\x12\x0f\n\x07\x63ontent\x18\x02 \x01(\t\"5\n\x14SenderContentRequest\x12\x0c\n\x04uuid\x18\x01 \x01(\t\x12\x0f\n\x07\x63ontent\x18\x02 \x01(\t\"2\n\x14SenderListenResponse\x12\x0c\n\x04\x65\x63ho\x18\x01 \x01(\t\x12\x0c\n\x04uuid\x18\x02 \x01(\t\"\xcf\x02\n\x13SenderListenRequest\x12\x0c\n\x04uuid\x18\x01 \x01(\t\x12\r\n\x05rules\x18\x02 \x03(\t\x12\x0f\n\x07timeout\x18\x03 \x01(\x05\x12\x14\n\x0clisten_group\x18\x04 \x01(\x08\x12\x16\n\x0elisten_private\x18\x05 \x01(\x08\x12\x15\n\rrequire_admin\x18\x06 \x01(\x08\x12\x17\n\x0f\x61llow_platforms\x18\x07 \x03(\t\x12\x1a\n\x12prohibit_platforms\x18\x08 \x03(\t\x12\x13\n\x0b\x61llow_users\x18\t \x03(\t\x12\x16\n\x0eprohibit_users\x18\n \x03(\t\x12\x14\n\x0c\x61llow_groups\x18\x0b \x03(\t\x12\x17\n\x0fprohibit_groups\x18\x0c \x03(\t\x12\x12\n\npersistent\x18\r \x01(\x08\x12\r\n\x05value\x18\x0e \x01(\t\x12\x11\n\tplugin_id\x18\x0f \x01(\t\"8\n\x14\x41\x64\x61pterRegistRequest\x12\x10\n\x08platform\x18\x01 \x01(\t\x12\x0e\n\x06\x62ot_id\x18\x02 \x01(\t\"A\n\x0e\x41\x64\x61pterRequest\x12\x10\n\x08platform\x18\x01 \x01(\t\x12\x0e\n\x06\x62ot_id\x18\x02 \x01(\t\x12\r\n\x05value\x18\x03 \x01(\t\"&\n\x03\x41ny\x12\x10\n\x08type_url\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c\"B\n\x0e\x43onsoleRequest\x12\x0c\n\x04type\x18\x01 \x01(\t\x12\x0f\n\x07\x63ontent\x18\x02 \x01(\t\x12\x11\n\tplugin_id\x18\x03 \x01(\t2\xce\r\n\x10SillyGirlService\x12\x32\n\tBucketGet\x12\x16.srpc.BucketKeyRequest\x1a\r.srpc.Default\x12<\n\tBucketSet\x12\x16.srpc.BucketSetRequest\x1a\x17.srpc.BucketSetResponse\x12\x30\n\x0c\x42ucketDelete\x12\x13.srpc.BucketRequest\x1a\x0b.srpc.Empty\x12;\n\nBucketKeys\x12\x13.srpc.BucketRequest\x1a\x18.srpc.BucketKeysResponse\x12\x33\n\tBucketLen\x12\x13.srpc.BucketRequest\x1a\x11.srpc.LenResponse\x12\x32\n\x0c\x42ucketGetAll\x12\x13.srpc.BucketRequest\x1a\r.srpc.Default\x12\x33\n\rBucketBuckets\x12\x0b.srpc.Empty\x1a\x15.srpc.BucketsResponse\x12\x46\n\x0b\x42ucketWatch\x12\x18.srpc.BucketWatchRequest\x1a\x19.srpc.BucketWatchResponse(\x01\x30\x01\x12\x35\n\x0fSenderGetUserId\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x37\n\x11SenderGetUserName\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x35\n\x0fSenderGetChatId\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x37\n\x11SenderGetChatName\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x38\n\x12SenderGetMessageId\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x38\n\rSenderIsAdmin\x12\x13.srpc.SenderRequest\x1a\x12.srpc.BoolResponse\x12\x37\n\x11SenderGetPlatform\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x34\n\x0eSenderGetBotId\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x36\n\x10SenderGetContent\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12;\n\x10SenderSetContent\x12\x1a.srpc.SenderContentRequest\x1a\x0b.srpc.Empty\x12\x32\n\x0eSenderContinue\x12\x13.srpc.SenderRequest\x1a\x0b.srpc.Empty\x12I\n\x0cSenderListen\x12\x19.srpc.SenderListenRequest\x1a\x1a.srpc.SenderListenResponse(\x01\x30\x01\x12\x31\n\x0bSenderEvent\x12\x13.srpc.SenderRequest\x1a\r.srpc.Default\x12\x30\n\x0bSenderReply\x12\x12.srpc.ReplyRequest\x1a\r.srpc.Default\x12\x30\n\x0bSenderParam\x12\x12.srpc.ReplyRequest\x1a\r.srpc.Default\x12\x31\n\x0cSenderAction\x12\x12.srpc.ReplyRequest\x1a\r.srpc.Default\x12\x30\n\rSenderDestroy\x12\x12.srpc.ReplyRequest\x1a\x0b.srpc.Empty\x12>\n\rAdapterRegist\x12\x1a.srpc.AdapterRegistRequest\x1a\r.srpc.Default(\x01\x30\x01\x12\x33\n\x0e\x41\x64\x61pterReceive\x12\x14.srpc.AdapterRequest\x1a\x0b.srpc.Empty\x12\x32\n\x0b\x41\x64\x61pterPush\x12\x14.srpc.AdapterRequest\x1a\r.srpc.Default\x12\x33\n\x0e\x41\x64\x61pterDestroy\x12\x14.srpc.AdapterRequest\x1a\x0b.srpc.Empty\x12\x34\n\rAdapterSender\x12\x14.srpc.AdapterRequest\x1a\r.srpc.Default\x12,\n\x07\x43onsole\x12\x14.srpc.ConsoleRequest\x1a\x0b.srpc.EmptyB\x07Z\x05srpc/b\x06proto3' +) + + + + +_EMPTY = _descriptor.Descriptor( + name='Empty', + full_name='srpc.Empty', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=20, + serialized_end=27, +) + + +_DEFAULT = _descriptor.Descriptor( + name='Default', + full_name='srpc.Default', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='value', full_name='srpc.Default.value', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=29, + serialized_end=53, +) + + +_BUCKETSETREQUEST = _descriptor.Descriptor( + name='BucketSetRequest', + full_name='srpc.BucketSetRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='name', full_name='srpc.BucketSetRequest.name', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='key', full_name='srpc.BucketSetRequest.key', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='value', full_name='srpc.BucketSetRequest.value', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=55, + serialized_end=115, +) + + +_BUCKETWATCHREQUEST = _descriptor.Descriptor( + name='BucketWatchRequest', + full_name='srpc.BucketWatchRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='name', full_name='srpc.BucketWatchRequest.name', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='key', full_name='srpc.BucketWatchRequest.key', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='message', full_name='srpc.BucketWatchRequest.message', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='error', full_name='srpc.BucketWatchRequest.error', index=3, + number=4, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='now', full_name='srpc.BucketWatchRequest.now', index=4, + number=5, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='echo', full_name='srpc.BucketWatchRequest.echo', index=5, + number=6, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='plugin_id', full_name='srpc.BucketWatchRequest.plugin_id', index=6, + number=7, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=117, + serialized_end=242, +) + + +_BUCKETWATCHRESPONSE = _descriptor.Descriptor( + name='BucketWatchResponse', + full_name='srpc.BucketWatchResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='echo', full_name='srpc.BucketWatchResponse.echo', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='old', full_name='srpc.BucketWatchResponse.old', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='now', full_name='srpc.BucketWatchResponse.now', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='key', full_name='srpc.BucketWatchResponse.key', index=3, + number=4, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=244, + serialized_end=318, +) + + +_BUCKETSETRESPONSE = _descriptor.Descriptor( + name='BucketSetResponse', + full_name='srpc.BucketSetResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='changed', full_name='srpc.BucketSetResponse.changed', index=0, + number=1, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='message', full_name='srpc.BucketSetResponse.message', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=320, + serialized_end=373, +) + + +_BUCKETKEYREQUEST = _descriptor.Descriptor( + name='BucketKeyRequest', + full_name='srpc.BucketKeyRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='name', full_name='srpc.BucketKeyRequest.name', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='key', full_name='srpc.BucketKeyRequest.key', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=375, + serialized_end=420, +) + + +_BUCKETREQUEST = _descriptor.Descriptor( + name='BucketRequest', + full_name='srpc.BucketRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='name', full_name='srpc.BucketRequest.name', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=422, + serialized_end=451, +) + + +_BUCKETKEYSRESPONSE = _descriptor.Descriptor( + name='BucketKeysResponse', + full_name='srpc.BucketKeysResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='keys', full_name='srpc.BucketKeysResponse.keys', index=0, + number=1, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=453, + serialized_end=487, +) + + +_LENRESPONSE = _descriptor.Descriptor( + name='LenResponse', + full_name='srpc.LenResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='length', full_name='srpc.LenResponse.length', index=0, + number=1, type=5, cpp_type=1, label=1, + has_default_value=False, default_value=0, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=489, + serialized_end=518, +) + + +_BOOLRESPONSE = _descriptor.Descriptor( + name='BoolResponse', + full_name='srpc.BoolResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='value', full_name='srpc.BoolResponse.value', index=0, + number=1, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=520, + serialized_end=549, +) + + +_BUCKETSRESPONSE = _descriptor.Descriptor( + name='BucketsResponse', + full_name='srpc.BucketsResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='buckets', full_name='srpc.BucketsResponse.buckets', index=0, + number=1, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=551, + serialized_end=585, +) + + +_SENDERREQUEST = _descriptor.Descriptor( + name='SenderRequest', + full_name='srpc.SenderRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='uuid', full_name='srpc.SenderRequest.uuid', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=587, + serialized_end=616, +) + + +_REPLYREQUEST = _descriptor.Descriptor( + name='ReplyRequest', + full_name='srpc.ReplyRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='uuid', full_name='srpc.ReplyRequest.uuid', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='content', full_name='srpc.ReplyRequest.content', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=618, + serialized_end=663, +) + + +_SENDERCONTENTREQUEST = _descriptor.Descriptor( + name='SenderContentRequest', + full_name='srpc.SenderContentRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='uuid', full_name='srpc.SenderContentRequest.uuid', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='content', full_name='srpc.SenderContentRequest.content', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=665, + serialized_end=718, +) + + +_SENDERLISTENRESPONSE = _descriptor.Descriptor( + name='SenderListenResponse', + full_name='srpc.SenderListenResponse', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='echo', full_name='srpc.SenderListenResponse.echo', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='uuid', full_name='srpc.SenderListenResponse.uuid', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=720, + serialized_end=770, +) + + +_SENDERLISTENREQUEST = _descriptor.Descriptor( + name='SenderListenRequest', + full_name='srpc.SenderListenRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='uuid', full_name='srpc.SenderListenRequest.uuid', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='rules', full_name='srpc.SenderListenRequest.rules', index=1, + number=2, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='timeout', full_name='srpc.SenderListenRequest.timeout', index=2, + number=3, type=5, cpp_type=1, label=1, + has_default_value=False, default_value=0, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='listen_group', full_name='srpc.SenderListenRequest.listen_group', index=3, + number=4, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='listen_private', full_name='srpc.SenderListenRequest.listen_private', index=4, + number=5, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='require_admin', full_name='srpc.SenderListenRequest.require_admin', index=5, + number=6, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='allow_platforms', full_name='srpc.SenderListenRequest.allow_platforms', index=6, + number=7, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='prohibit_platforms', full_name='srpc.SenderListenRequest.prohibit_platforms', index=7, + number=8, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='allow_users', full_name='srpc.SenderListenRequest.allow_users', index=8, + number=9, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='prohibit_users', full_name='srpc.SenderListenRequest.prohibit_users', index=9, + number=10, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='allow_groups', full_name='srpc.SenderListenRequest.allow_groups', index=10, + number=11, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='prohibit_groups', full_name='srpc.SenderListenRequest.prohibit_groups', index=11, + number=12, type=9, cpp_type=9, label=3, + has_default_value=False, default_value=[], + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='persistent', full_name='srpc.SenderListenRequest.persistent', index=12, + number=13, type=8, cpp_type=7, label=1, + has_default_value=False, default_value=False, + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='value', full_name='srpc.SenderListenRequest.value', index=13, + number=14, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='plugin_id', full_name='srpc.SenderListenRequest.plugin_id', index=14, + number=15, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=773, + serialized_end=1108, +) + + +_ADAPTERREGISTREQUEST = _descriptor.Descriptor( + name='AdapterRegistRequest', + full_name='srpc.AdapterRegistRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='platform', full_name='srpc.AdapterRegistRequest.platform', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='bot_id', full_name='srpc.AdapterRegistRequest.bot_id', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=1110, + serialized_end=1166, +) + + +_ADAPTERREQUEST = _descriptor.Descriptor( + name='AdapterRequest', + full_name='srpc.AdapterRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='platform', full_name='srpc.AdapterRequest.platform', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='bot_id', full_name='srpc.AdapterRequest.bot_id', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='value', full_name='srpc.AdapterRequest.value', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=1168, + serialized_end=1233, +) + + +_ANY = _descriptor.Descriptor( + name='Any', + full_name='srpc.Any', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='type_url', full_name='srpc.Any.type_url', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='value', full_name='srpc.Any.value', index=1, + number=2, type=12, cpp_type=9, label=1, + has_default_value=False, default_value=b"", + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=1235, + serialized_end=1273, +) + + +_CONSOLEREQUEST = _descriptor.Descriptor( + name='ConsoleRequest', + full_name='srpc.ConsoleRequest', + filename=None, + file=DESCRIPTOR, + containing_type=None, + create_key=_descriptor._internal_create_key, + fields=[ + _descriptor.FieldDescriptor( + name='type', full_name='srpc.ConsoleRequest.type', index=0, + number=1, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='content', full_name='srpc.ConsoleRequest.content', index=1, + number=2, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + _descriptor.FieldDescriptor( + name='plugin_id', full_name='srpc.ConsoleRequest.plugin_id', index=2, + number=3, type=9, cpp_type=9, label=1, + has_default_value=False, default_value=b"".decode('utf-8'), + message_type=None, enum_type=None, containing_type=None, + is_extension=False, extension_scope=None, + serialized_options=None, file=DESCRIPTOR, create_key=_descriptor._internal_create_key), + ], + extensions=[ + ], + nested_types=[], + enum_types=[ + ], + serialized_options=None, + is_extendable=False, + syntax='proto3', + extension_ranges=[], + oneofs=[ + ], + serialized_start=1275, + serialized_end=1341, +) + +DESCRIPTOR.message_types_by_name['Empty'] = _EMPTY +DESCRIPTOR.message_types_by_name['Default'] = _DEFAULT +DESCRIPTOR.message_types_by_name['BucketSetRequest'] = _BUCKETSETREQUEST +DESCRIPTOR.message_types_by_name['BucketWatchRequest'] = _BUCKETWATCHREQUEST +DESCRIPTOR.message_types_by_name['BucketWatchResponse'] = _BUCKETWATCHRESPONSE +DESCRIPTOR.message_types_by_name['BucketSetResponse'] = _BUCKETSETRESPONSE +DESCRIPTOR.message_types_by_name['BucketKeyRequest'] = _BUCKETKEYREQUEST +DESCRIPTOR.message_types_by_name['BucketRequest'] = _BUCKETREQUEST +DESCRIPTOR.message_types_by_name['BucketKeysResponse'] = _BUCKETKEYSRESPONSE +DESCRIPTOR.message_types_by_name['LenResponse'] = _LENRESPONSE +DESCRIPTOR.message_types_by_name['BoolResponse'] = _BOOLRESPONSE +DESCRIPTOR.message_types_by_name['BucketsResponse'] = _BUCKETSRESPONSE +DESCRIPTOR.message_types_by_name['SenderRequest'] = _SENDERREQUEST +DESCRIPTOR.message_types_by_name['ReplyRequest'] = _REPLYREQUEST +DESCRIPTOR.message_types_by_name['SenderContentRequest'] = _SENDERCONTENTREQUEST +DESCRIPTOR.message_types_by_name['SenderListenResponse'] = _SENDERLISTENRESPONSE +DESCRIPTOR.message_types_by_name['SenderListenRequest'] = _SENDERLISTENREQUEST +DESCRIPTOR.message_types_by_name['AdapterRegistRequest'] = _ADAPTERREGISTREQUEST +DESCRIPTOR.message_types_by_name['AdapterRequest'] = _ADAPTERREQUEST +DESCRIPTOR.message_types_by_name['Any'] = _ANY +DESCRIPTOR.message_types_by_name['ConsoleRequest'] = _CONSOLEREQUEST +_sym_db.RegisterFileDescriptor(DESCRIPTOR) + +Empty = _reflection.GeneratedProtocolMessageType('Empty', (_message.Message,), { + 'DESCRIPTOR' : _EMPTY, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.Empty) + }) +_sym_db.RegisterMessage(Empty) + +Default = _reflection.GeneratedProtocolMessageType('Default', (_message.Message,), { + 'DESCRIPTOR' : _DEFAULT, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.Default) + }) +_sym_db.RegisterMessage(Default) + +BucketSetRequest = _reflection.GeneratedProtocolMessageType('BucketSetRequest', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETSETREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketSetRequest) + }) +_sym_db.RegisterMessage(BucketSetRequest) + +BucketWatchRequest = _reflection.GeneratedProtocolMessageType('BucketWatchRequest', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETWATCHREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketWatchRequest) + }) +_sym_db.RegisterMessage(BucketWatchRequest) + +BucketWatchResponse = _reflection.GeneratedProtocolMessageType('BucketWatchResponse', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETWATCHRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketWatchResponse) + }) +_sym_db.RegisterMessage(BucketWatchResponse) + +BucketSetResponse = _reflection.GeneratedProtocolMessageType('BucketSetResponse', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETSETRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketSetResponse) + }) +_sym_db.RegisterMessage(BucketSetResponse) + +BucketKeyRequest = _reflection.GeneratedProtocolMessageType('BucketKeyRequest', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETKEYREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketKeyRequest) + }) +_sym_db.RegisterMessage(BucketKeyRequest) + +BucketRequest = _reflection.GeneratedProtocolMessageType('BucketRequest', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketRequest) + }) +_sym_db.RegisterMessage(BucketRequest) + +BucketKeysResponse = _reflection.GeneratedProtocolMessageType('BucketKeysResponse', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETKEYSRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketKeysResponse) + }) +_sym_db.RegisterMessage(BucketKeysResponse) + +LenResponse = _reflection.GeneratedProtocolMessageType('LenResponse', (_message.Message,), { + 'DESCRIPTOR' : _LENRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.LenResponse) + }) +_sym_db.RegisterMessage(LenResponse) + +BoolResponse = _reflection.GeneratedProtocolMessageType('BoolResponse', (_message.Message,), { + 'DESCRIPTOR' : _BOOLRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BoolResponse) + }) +_sym_db.RegisterMessage(BoolResponse) + +BucketsResponse = _reflection.GeneratedProtocolMessageType('BucketsResponse', (_message.Message,), { + 'DESCRIPTOR' : _BUCKETSRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.BucketsResponse) + }) +_sym_db.RegisterMessage(BucketsResponse) + +SenderRequest = _reflection.GeneratedProtocolMessageType('SenderRequest', (_message.Message,), { + 'DESCRIPTOR' : _SENDERREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.SenderRequest) + }) +_sym_db.RegisterMessage(SenderRequest) + +ReplyRequest = _reflection.GeneratedProtocolMessageType('ReplyRequest', (_message.Message,), { + 'DESCRIPTOR' : _REPLYREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.ReplyRequest) + }) +_sym_db.RegisterMessage(ReplyRequest) + +SenderContentRequest = _reflection.GeneratedProtocolMessageType('SenderContentRequest', (_message.Message,), { + 'DESCRIPTOR' : _SENDERCONTENTREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.SenderContentRequest) + }) +_sym_db.RegisterMessage(SenderContentRequest) + +SenderListenResponse = _reflection.GeneratedProtocolMessageType('SenderListenResponse', (_message.Message,), { + 'DESCRIPTOR' : _SENDERLISTENRESPONSE, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.SenderListenResponse) + }) +_sym_db.RegisterMessage(SenderListenResponse) + +SenderListenRequest = _reflection.GeneratedProtocolMessageType('SenderListenRequest', (_message.Message,), { + 'DESCRIPTOR' : _SENDERLISTENREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.SenderListenRequest) + }) +_sym_db.RegisterMessage(SenderListenRequest) + +AdapterRegistRequest = _reflection.GeneratedProtocolMessageType('AdapterRegistRequest', (_message.Message,), { + 'DESCRIPTOR' : _ADAPTERREGISTREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.AdapterRegistRequest) + }) +_sym_db.RegisterMessage(AdapterRegistRequest) + +AdapterRequest = _reflection.GeneratedProtocolMessageType('AdapterRequest', (_message.Message,), { + 'DESCRIPTOR' : _ADAPTERREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.AdapterRequest) + }) +_sym_db.RegisterMessage(AdapterRequest) + +Any = _reflection.GeneratedProtocolMessageType('Any', (_message.Message,), { + 'DESCRIPTOR' : _ANY, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.Any) + }) +_sym_db.RegisterMessage(Any) + +ConsoleRequest = _reflection.GeneratedProtocolMessageType('ConsoleRequest', (_message.Message,), { + 'DESCRIPTOR' : _CONSOLEREQUEST, + '__module__' : 'srpc_pb2' + # @@protoc_insertion_point(class_scope:srpc.ConsoleRequest) + }) +_sym_db.RegisterMessage(ConsoleRequest) + + +DESCRIPTOR._options = None + +_SILLYGIRLSERVICE = _descriptor.ServiceDescriptor( + name='SillyGirlService', + full_name='srpc.SillyGirlService', + file=DESCRIPTOR, + index=0, + serialized_options=None, + create_key=_descriptor._internal_create_key, + serialized_start=1344, + serialized_end=3086, + methods=[ + _descriptor.MethodDescriptor( + name='BucketGet', + full_name='srpc.SillyGirlService.BucketGet', + index=0, + containing_service=None, + input_type=_BUCKETKEYREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketSet', + full_name='srpc.SillyGirlService.BucketSet', + index=1, + containing_service=None, + input_type=_BUCKETSETREQUEST, + output_type=_BUCKETSETRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketDelete', + full_name='srpc.SillyGirlService.BucketDelete', + index=2, + containing_service=None, + input_type=_BUCKETREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketKeys', + full_name='srpc.SillyGirlService.BucketKeys', + index=3, + containing_service=None, + input_type=_BUCKETREQUEST, + output_type=_BUCKETKEYSRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketLen', + full_name='srpc.SillyGirlService.BucketLen', + index=4, + containing_service=None, + input_type=_BUCKETREQUEST, + output_type=_LENRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketGetAll', + full_name='srpc.SillyGirlService.BucketGetAll', + index=5, + containing_service=None, + input_type=_BUCKETREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketBuckets', + full_name='srpc.SillyGirlService.BucketBuckets', + index=6, + containing_service=None, + input_type=_EMPTY, + output_type=_BUCKETSRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='BucketWatch', + full_name='srpc.SillyGirlService.BucketWatch', + index=7, + containing_service=None, + input_type=_BUCKETWATCHREQUEST, + output_type=_BUCKETWATCHRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetUserId', + full_name='srpc.SillyGirlService.SenderGetUserId', + index=8, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetUserName', + full_name='srpc.SillyGirlService.SenderGetUserName', + index=9, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetChatId', + full_name='srpc.SillyGirlService.SenderGetChatId', + index=10, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetChatName', + full_name='srpc.SillyGirlService.SenderGetChatName', + index=11, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetMessageId', + full_name='srpc.SillyGirlService.SenderGetMessageId', + index=12, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderIsAdmin', + full_name='srpc.SillyGirlService.SenderIsAdmin', + index=13, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_BOOLRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetPlatform', + full_name='srpc.SillyGirlService.SenderGetPlatform', + index=14, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetBotId', + full_name='srpc.SillyGirlService.SenderGetBotId', + index=15, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderGetContent', + full_name='srpc.SillyGirlService.SenderGetContent', + index=16, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderSetContent', + full_name='srpc.SillyGirlService.SenderSetContent', + index=17, + containing_service=None, + input_type=_SENDERCONTENTREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderContinue', + full_name='srpc.SillyGirlService.SenderContinue', + index=18, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderListen', + full_name='srpc.SillyGirlService.SenderListen', + index=19, + containing_service=None, + input_type=_SENDERLISTENREQUEST, + output_type=_SENDERLISTENRESPONSE, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderEvent', + full_name='srpc.SillyGirlService.SenderEvent', + index=20, + containing_service=None, + input_type=_SENDERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderReply', + full_name='srpc.SillyGirlService.SenderReply', + index=21, + containing_service=None, + input_type=_REPLYREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderParam', + full_name='srpc.SillyGirlService.SenderParam', + index=22, + containing_service=None, + input_type=_REPLYREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderAction', + full_name='srpc.SillyGirlService.SenderAction', + index=23, + containing_service=None, + input_type=_REPLYREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='SenderDestroy', + full_name='srpc.SillyGirlService.SenderDestroy', + index=24, + containing_service=None, + input_type=_REPLYREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='AdapterRegist', + full_name='srpc.SillyGirlService.AdapterRegist', + index=25, + containing_service=None, + input_type=_ADAPTERREGISTREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='AdapterReceive', + full_name='srpc.SillyGirlService.AdapterReceive', + index=26, + containing_service=None, + input_type=_ADAPTERREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='AdapterPush', + full_name='srpc.SillyGirlService.AdapterPush', + index=27, + containing_service=None, + input_type=_ADAPTERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='AdapterDestroy', + full_name='srpc.SillyGirlService.AdapterDestroy', + index=28, + containing_service=None, + input_type=_ADAPTERREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='AdapterSender', + full_name='srpc.SillyGirlService.AdapterSender', + index=29, + containing_service=None, + input_type=_ADAPTERREQUEST, + output_type=_DEFAULT, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), + _descriptor.MethodDescriptor( + name='Console', + full_name='srpc.SillyGirlService.Console', + index=30, + containing_service=None, + input_type=_CONSOLEREQUEST, + output_type=_EMPTY, + serialized_options=None, + create_key=_descriptor._internal_create_key, + ), +]) +_sym_db.RegisterServiceDescriptor(_SILLYGIRLSERVICE) + +DESCRIPTOR.services_by_name['SillyGirlService'] = _SILLYGIRLSERVICE + +# @@protoc_insertion_point(module_scope) diff --git a/proto3/srpc_pb2_grpc.py b/proto3/srpc_pb2_grpc.py new file mode 100644 index 0000000..41e5567 --- /dev/null +++ b/proto3/srpc_pb2_grpc.py @@ -0,0 +1,1056 @@ +# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! +"""Client and server classes corresponding to protobuf-defined services.""" +import grpc + +import srpc_pb2 as srpc__pb2 + + +class SillyGirlServiceStub(object): + """Missing associated documentation comment in .proto file.""" + + def __init__(self, channel): + """Constructor. + + Args: + channel: A grpc.Channel. + """ + self.BucketGet = channel.unary_unary( + '/srpc.SillyGirlService/BucketGet', + request_serializer=srpc__pb2.BucketKeyRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.BucketSet = channel.unary_unary( + '/srpc.SillyGirlService/BucketSet', + request_serializer=srpc__pb2.BucketSetRequest.SerializeToString, + response_deserializer=srpc__pb2.BucketSetResponse.FromString, + ) + self.BucketDelete = channel.unary_unary( + '/srpc.SillyGirlService/BucketDelete', + request_serializer=srpc__pb2.BucketRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.BucketKeys = channel.unary_unary( + '/srpc.SillyGirlService/BucketKeys', + request_serializer=srpc__pb2.BucketRequest.SerializeToString, + response_deserializer=srpc__pb2.BucketKeysResponse.FromString, + ) + self.BucketLen = channel.unary_unary( + '/srpc.SillyGirlService/BucketLen', + request_serializer=srpc__pb2.BucketRequest.SerializeToString, + response_deserializer=srpc__pb2.LenResponse.FromString, + ) + self.BucketGetAll = channel.unary_unary( + '/srpc.SillyGirlService/BucketGetAll', + request_serializer=srpc__pb2.BucketRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.BucketBuckets = channel.unary_unary( + '/srpc.SillyGirlService/BucketBuckets', + request_serializer=srpc__pb2.Empty.SerializeToString, + response_deserializer=srpc__pb2.BucketsResponse.FromString, + ) + self.BucketWatch = channel.stream_stream( + '/srpc.SillyGirlService/BucketWatch', + request_serializer=srpc__pb2.BucketWatchRequest.SerializeToString, + response_deserializer=srpc__pb2.BucketWatchResponse.FromString, + ) + self.SenderGetUserId = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetUserId', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetUserName = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetUserName', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetChatId = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetChatId', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetChatName = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetChatName', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetMessageId = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetMessageId', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderIsAdmin = channel.unary_unary( + '/srpc.SillyGirlService/SenderIsAdmin', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.BoolResponse.FromString, + ) + self.SenderGetPlatform = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetPlatform', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetBotId = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetBotId', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderGetContent = channel.unary_unary( + '/srpc.SillyGirlService/SenderGetContent', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderSetContent = channel.unary_unary( + '/srpc.SillyGirlService/SenderSetContent', + request_serializer=srpc__pb2.SenderContentRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.SenderContinue = channel.unary_unary( + '/srpc.SillyGirlService/SenderContinue', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.SenderListen = channel.stream_stream( + '/srpc.SillyGirlService/SenderListen', + request_serializer=srpc__pb2.SenderListenRequest.SerializeToString, + response_deserializer=srpc__pb2.SenderListenResponse.FromString, + ) + self.SenderEvent = channel.unary_unary( + '/srpc.SillyGirlService/SenderEvent', + request_serializer=srpc__pb2.SenderRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderReply = channel.unary_unary( + '/srpc.SillyGirlService/SenderReply', + request_serializer=srpc__pb2.ReplyRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderParam = channel.unary_unary( + '/srpc.SillyGirlService/SenderParam', + request_serializer=srpc__pb2.ReplyRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderAction = channel.unary_unary( + '/srpc.SillyGirlService/SenderAction', + request_serializer=srpc__pb2.ReplyRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.SenderDestroy = channel.unary_unary( + '/srpc.SillyGirlService/SenderDestroy', + request_serializer=srpc__pb2.ReplyRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.AdapterRegist = channel.stream_stream( + '/srpc.SillyGirlService/AdapterRegist', + request_serializer=srpc__pb2.AdapterRegistRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.AdapterReceive = channel.unary_unary( + '/srpc.SillyGirlService/AdapterReceive', + request_serializer=srpc__pb2.AdapterRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.AdapterPush = channel.unary_unary( + '/srpc.SillyGirlService/AdapterPush', + request_serializer=srpc__pb2.AdapterRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.AdapterDestroy = channel.unary_unary( + '/srpc.SillyGirlService/AdapterDestroy', + request_serializer=srpc__pb2.AdapterRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + self.AdapterSender = channel.unary_unary( + '/srpc.SillyGirlService/AdapterSender', + request_serializer=srpc__pb2.AdapterRequest.SerializeToString, + response_deserializer=srpc__pb2.Default.FromString, + ) + self.Console = channel.unary_unary( + '/srpc.SillyGirlService/Console', + request_serializer=srpc__pb2.ConsoleRequest.SerializeToString, + response_deserializer=srpc__pb2.Empty.FromString, + ) + + +class SillyGirlServiceServicer(object): + """Missing associated documentation comment in .proto file.""" + + def BucketGet(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 BucketSet(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 BucketDelete(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 BucketKeys(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 BucketLen(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 BucketGetAll(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 BucketBuckets(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 BucketWatch(self, request_iterator, 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 SenderGetUserId(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 SenderGetUserName(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 SenderGetChatId(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 SenderGetChatName(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 SenderGetMessageId(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 SenderIsAdmin(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 SenderGetPlatform(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 SenderGetBotId(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 SenderGetContent(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 SenderSetContent(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 SenderContinue(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 SenderListen(self, request_iterator, 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 SenderEvent(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 SenderReply(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 SenderParam(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 SenderAction(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 SenderDestroy(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 AdapterRegist(self, request_iterator, 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 AdapterReceive(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 AdapterPush(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 AdapterDestroy(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 AdapterSender(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 Console(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_SillyGirlServiceServicer_to_server(servicer, server): + rpc_method_handlers = { + 'BucketGet': grpc.unary_unary_rpc_method_handler( + servicer.BucketGet, + request_deserializer=srpc__pb2.BucketKeyRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'BucketSet': grpc.unary_unary_rpc_method_handler( + servicer.BucketSet, + request_deserializer=srpc__pb2.BucketSetRequest.FromString, + response_serializer=srpc__pb2.BucketSetResponse.SerializeToString, + ), + 'BucketDelete': grpc.unary_unary_rpc_method_handler( + servicer.BucketDelete, + request_deserializer=srpc__pb2.BucketRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'BucketKeys': grpc.unary_unary_rpc_method_handler( + servicer.BucketKeys, + request_deserializer=srpc__pb2.BucketRequest.FromString, + response_serializer=srpc__pb2.BucketKeysResponse.SerializeToString, + ), + 'BucketLen': grpc.unary_unary_rpc_method_handler( + servicer.BucketLen, + request_deserializer=srpc__pb2.BucketRequest.FromString, + response_serializer=srpc__pb2.LenResponse.SerializeToString, + ), + 'BucketGetAll': grpc.unary_unary_rpc_method_handler( + servicer.BucketGetAll, + request_deserializer=srpc__pb2.BucketRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'BucketBuckets': grpc.unary_unary_rpc_method_handler( + servicer.BucketBuckets, + request_deserializer=srpc__pb2.Empty.FromString, + response_serializer=srpc__pb2.BucketsResponse.SerializeToString, + ), + 'BucketWatch': grpc.stream_stream_rpc_method_handler( + servicer.BucketWatch, + request_deserializer=srpc__pb2.BucketWatchRequest.FromString, + response_serializer=srpc__pb2.BucketWatchResponse.SerializeToString, + ), + 'SenderGetUserId': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetUserId, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetUserName': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetUserName, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetChatId': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetChatId, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetChatName': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetChatName, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetMessageId': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetMessageId, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderIsAdmin': grpc.unary_unary_rpc_method_handler( + servicer.SenderIsAdmin, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.BoolResponse.SerializeToString, + ), + 'SenderGetPlatform': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetPlatform, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetBotId': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetBotId, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderGetContent': grpc.unary_unary_rpc_method_handler( + servicer.SenderGetContent, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderSetContent': grpc.unary_unary_rpc_method_handler( + servicer.SenderSetContent, + request_deserializer=srpc__pb2.SenderContentRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'SenderContinue': grpc.unary_unary_rpc_method_handler( + servicer.SenderContinue, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'SenderListen': grpc.stream_stream_rpc_method_handler( + servicer.SenderListen, + request_deserializer=srpc__pb2.SenderListenRequest.FromString, + response_serializer=srpc__pb2.SenderListenResponse.SerializeToString, + ), + 'SenderEvent': grpc.unary_unary_rpc_method_handler( + servicer.SenderEvent, + request_deserializer=srpc__pb2.SenderRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderReply': grpc.unary_unary_rpc_method_handler( + servicer.SenderReply, + request_deserializer=srpc__pb2.ReplyRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderParam': grpc.unary_unary_rpc_method_handler( + servicer.SenderParam, + request_deserializer=srpc__pb2.ReplyRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderAction': grpc.unary_unary_rpc_method_handler( + servicer.SenderAction, + request_deserializer=srpc__pb2.ReplyRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'SenderDestroy': grpc.unary_unary_rpc_method_handler( + servicer.SenderDestroy, + request_deserializer=srpc__pb2.ReplyRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'AdapterRegist': grpc.stream_stream_rpc_method_handler( + servicer.AdapterRegist, + request_deserializer=srpc__pb2.AdapterRegistRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'AdapterReceive': grpc.unary_unary_rpc_method_handler( + servicer.AdapterReceive, + request_deserializer=srpc__pb2.AdapterRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'AdapterPush': grpc.unary_unary_rpc_method_handler( + servicer.AdapterPush, + request_deserializer=srpc__pb2.AdapterRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'AdapterDestroy': grpc.unary_unary_rpc_method_handler( + servicer.AdapterDestroy, + request_deserializer=srpc__pb2.AdapterRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + 'AdapterSender': grpc.unary_unary_rpc_method_handler( + servicer.AdapterSender, + request_deserializer=srpc__pb2.AdapterRequest.FromString, + response_serializer=srpc__pb2.Default.SerializeToString, + ), + 'Console': grpc.unary_unary_rpc_method_handler( + servicer.Console, + request_deserializer=srpc__pb2.ConsoleRequest.FromString, + response_serializer=srpc__pb2.Empty.SerializeToString, + ), + } + generic_handler = grpc.method_handlers_generic_handler( + 'srpc.SillyGirlService', rpc_method_handlers) + server.add_generic_rpc_handlers((generic_handler,)) + + + # This class is part of an EXPERIMENTAL API. +class SillyGirlService(object): + """Missing associated documentation comment in .proto file.""" + + @staticmethod + def BucketGet(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, '/srpc.SillyGirlService/BucketGet', + srpc__pb2.BucketKeyRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketSet(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, '/srpc.SillyGirlService/BucketSet', + srpc__pb2.BucketSetRequest.SerializeToString, + srpc__pb2.BucketSetResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketDelete(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, '/srpc.SillyGirlService/BucketDelete', + srpc__pb2.BucketRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketKeys(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, '/srpc.SillyGirlService/BucketKeys', + srpc__pb2.BucketRequest.SerializeToString, + srpc__pb2.BucketKeysResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketLen(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, '/srpc.SillyGirlService/BucketLen', + srpc__pb2.BucketRequest.SerializeToString, + srpc__pb2.LenResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketGetAll(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, '/srpc.SillyGirlService/BucketGetAll', + srpc__pb2.BucketRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketBuckets(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, '/srpc.SillyGirlService/BucketBuckets', + srpc__pb2.Empty.SerializeToString, + srpc__pb2.BucketsResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def BucketWatch(request_iterator, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.stream_stream(request_iterator, target, '/srpc.SillyGirlService/BucketWatch', + srpc__pb2.BucketWatchRequest.SerializeToString, + srpc__pb2.BucketWatchResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetUserId(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, '/srpc.SillyGirlService/SenderGetUserId', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetUserName(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, '/srpc.SillyGirlService/SenderGetUserName', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetChatId(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, '/srpc.SillyGirlService/SenderGetChatId', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetChatName(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, '/srpc.SillyGirlService/SenderGetChatName', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetMessageId(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, '/srpc.SillyGirlService/SenderGetMessageId', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderIsAdmin(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, '/srpc.SillyGirlService/SenderIsAdmin', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.BoolResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetPlatform(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, '/srpc.SillyGirlService/SenderGetPlatform', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetBotId(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, '/srpc.SillyGirlService/SenderGetBotId', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderGetContent(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, '/srpc.SillyGirlService/SenderGetContent', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderSetContent(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, '/srpc.SillyGirlService/SenderSetContent', + srpc__pb2.SenderContentRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderContinue(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, '/srpc.SillyGirlService/SenderContinue', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderListen(request_iterator, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.stream_stream(request_iterator, target, '/srpc.SillyGirlService/SenderListen', + srpc__pb2.SenderListenRequest.SerializeToString, + srpc__pb2.SenderListenResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderEvent(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, '/srpc.SillyGirlService/SenderEvent', + srpc__pb2.SenderRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderReply(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, '/srpc.SillyGirlService/SenderReply', + srpc__pb2.ReplyRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderParam(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, '/srpc.SillyGirlService/SenderParam', + srpc__pb2.ReplyRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderAction(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, '/srpc.SillyGirlService/SenderAction', + srpc__pb2.ReplyRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def SenderDestroy(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, '/srpc.SillyGirlService/SenderDestroy', + srpc__pb2.ReplyRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def AdapterRegist(request_iterator, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None): + return grpc.experimental.stream_stream(request_iterator, target, '/srpc.SillyGirlService/AdapterRegist', + srpc__pb2.AdapterRegistRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def AdapterReceive(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, '/srpc.SillyGirlService/AdapterReceive', + srpc__pb2.AdapterRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def AdapterPush(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, '/srpc.SillyGirlService/AdapterPush', + srpc__pb2.AdapterRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def AdapterDestroy(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, '/srpc.SillyGirlService/AdapterDestroy', + srpc__pb2.AdapterRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def AdapterSender(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, '/srpc.SillyGirlService/AdapterSender', + srpc__pb2.AdapterRequest.SerializeToString, + srpc__pb2.Default.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def Console(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, '/srpc.SillyGirlService/Console', + srpc__pb2.ConsoleRequest.SerializeToString, + srpc__pb2.Empty.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata)