From 9ea88a080a7233b8663dc9a83ee3bd0de489d765 Mon Sep 17 00:00:00 2001 From: 1-6 Date: Mon, 31 Jul 2023 13:31:58 +0800 Subject: [PATCH] x --- core/adapter.go | 34 ++- core/grpc_asset.go | 2 +- core/grpc_plugins.go | 10 +- core/grpc_sender.go | 8 + core/plugin_core.go | 1 + core/plugin_parse.go | 2 +- main.go | 17 +- proto3/note.sh | 4 +- proto3/sillygirl.d.ts | 3 + proto3/sillygirl.js | 24 +- proto3/sillygirl.ts | 27 +- proto3/srpc.d.ts | 30 +++ proto3/srpc.js | 72 ++++++ proto3/srpc.proto | 5 + proto3/srpc.ts | 80 ++++++ proto3/srpc/srpc.pb.go | 502 ++++++++++++++++++++---------------- proto3/srpc/srpc_grpc.pb.go | 37 +++ 17 files changed, 613 insertions(+), 245 deletions(-) diff --git a/core/adapter.go b/core/adapter.go index 6c7f24b..c75dde5 100644 --- a/core/adapter.go +++ b/core/adapter.go @@ -104,23 +104,32 @@ func GetMessageByUUID(uuid string) string { } func GetAdapter(botplt string, bots_id ...string) (*Factory, error) { - BotsLocker.RLock() - defer BotsLocker.RUnlock() + var bots = []*Factory{} var select_bots = []*Factory{} - for i := range Bots { - plt, id := i[0], i[1] - // fmt.Println("plt", plt, "id", id, botplt, bots_id) - for j := range bots_id { - if plt == botplt && bots_id[j] == id { - select_bots = append(select_bots, Bots[i]) - } - if plt == botplt { - bots = append(bots, Bots[i]) + var tries = 0 +Try: + func() { + BotsLocker.RLock() + defer BotsLocker.RUnlock() + for i := range Bots { + plt, id := i[0], i[1] + for j := range bots_id { + if plt == botplt && bots_id[j] == id { + select_bots = append(select_bots, Bots[i]) + } + if plt == botplt { + bots = append(bots, Bots[i]) + } } } - } + }() if len(bots) == 0 { + if tries < 8 { + tries++ + time.Sleep(10 * time.Millisecond) + goto Try + } return nil, ErrNotFind } if len(select_bots) != 0 { @@ -672,6 +681,7 @@ type PUSH string func (sender *CustomSender) Action(options map[string]interface{}) (interface{}, error) { if sender.F.action != nil { + return sender.F.action(options), nil } var platform = sender.F.botplt diff --git a/core/grpc_asset.go b/core/grpc_asset.go index be58c72..ae9d478 100644 --- a/core/grpc_asset.go +++ b/core/grpc_asset.go @@ -24,7 +24,7 @@ type Language struct { } var plugin_dir = utils.ExecPath + "/plugins" -var release = "20230730" +var release = "20230731" var languages = []Language{ { diff --git a/core/grpc_plugins.go b/core/grpc_plugins.go index a42fece..8027f1b 100644 --- a/core/grpc_plugins.go +++ b/core/grpc_plugins.go @@ -342,6 +342,7 @@ var typeat = `declare class Sender { getPlatform(): Promise; getBotId(): Promise; getContent(): Promise; + isAdmin(): Promise; param(key: number | string): Promise; setContent(content: string): Promise; continue(): Promise; @@ -427,6 +428,8 @@ interface CQParams { declare let utils: { buildCQTag: (type: string, params: CQParams, prefix?: string) => string; parseCQText: (text: string, prefix?: string) => (string | CQItem)[]; + image: (url: string) => string; + video: (url: string) => string; }; declare let console: { log(...args: any[]): void; @@ -447,5 +450,10 @@ func defaultScript(title string) string { * @version v1.0.0 */ -const { sender: s, Bucket, Adapter, sleep, utils, console } = require("sillygirl");` +const { + sender: s, + Bucket, + utils: { buildCQTag, image, video }, +} = require("sillygirl"); +` } diff --git a/core/grpc_sender.go b/core/grpc_sender.go index ce53055..b27348c 100644 --- a/core/grpc_sender.go +++ b/core/grpc_sender.go @@ -30,6 +30,14 @@ func (sg *SillyGirlService) SenderGetUserName(ctx context.Context, req *srpc.Sen return &srpc.Default{Value: s.GetUserName()}, nil } +func (sg *SillyGirlService) SenderIsAdmin(ctx context.Context, req *srpc.SenderRequest) (*srpc.BoolResponse, error) { + s, err := getRegisterSenderByCtx(ctx, req.Uuid) + if err != nil { + return nil, err + } + return &srpc.BoolResponse{Value: s.IsAdmin()}, nil +} + func (sg *SillyGirlService) SenderGetChatId(ctx context.Context, req *srpc.SenderRequest) (*srpc.Default, error) { s, err := getRegisterSenderByCtx(ctx, req.Uuid) if err != nil { diff --git a/core/plugin_core.go b/core/plugin_core.go index e87d195..4d035ef 100644 --- a/core/plugin_core.go +++ b/core/plugin_core.go @@ -121,6 +121,7 @@ func initPlugins() { fin = &storage.Final{ Now: storage.EMPTY, } + } if isNameUuid(key) { if new == "install" { diff --git a/core/plugin_parse.go b/core/plugin_parse.go index 68fef22..ab404de 100644 --- a/core/plugin_parse.go +++ b/core/plugin_parse.go @@ -215,7 +215,7 @@ func pluginParse(script string, uuid string) (*common.Function, []func()) { carry = strings.TrimSpace(res[2]) == "true" case "encrypt": encrypt = strings.TrimSpace(res[2]) == "true" - case "on_start": + case "on_start", "service": onStart = strings.TrimSpace(res[2]) == "true" case "form": hasForm = true diff --git a/main.go b/main.go index 6b0b0af..961c574 100644 --- a/main.go +++ b/main.go @@ -11,6 +11,7 @@ import ( // _ "github.com/cdle/sillyplus/adapters/qq" "github.com/cdle/sillyplus/adapters/web" "github.com/cdle/sillyplus/core" + "github.com/cdle/sillyplus/core/common" "github.com/cdle/sillyplus/utils" ) @@ -67,14 +68,17 @@ func main() { scanner := bufio.NewScanner(os.Stdin) a := &core.Factory{} a.Init("terminal", "default", nil) + i := 0 a.SetReplyHandler(func(m map[string]interface{}) string { + i++ fmt.Printf("\x1b[%dm%s \x1b[0m\n", 31, m[core.CONETNT]) + return fmt.Sprint(i) + }) + a.SetActionHandler(func(m map[string]interface{}) string { + fmt.Println(`do action: ` + string(utils.JsonMarshal(m))) return "" }) - // a.SetActionHandler(func(m map[string]interface{}) string { - // fmt.Println("action", m) - // return `{"a":"a"}` - // }) + for scanner.Scan() { data := scanner.Text() s := &core.CustomSender{ @@ -83,6 +87,11 @@ func main() { // Admin: true, F: a, } + i++ + s.SetFsps(&common.FakerSenderParams{ + Content: data, + MessageID: fmt.Sprint(i), + }) s.SetContent(data) core.Messages <- s } diff --git a/proto3/note.sh b/proto3/note.sh index 3691011..b7135f9 100644 --- a/proto3/note.sh +++ b/proto3/note.sh @@ -10,7 +10,9 @@ protoc --js_out=import_style=commonjs,binary:. --grpc_out=. srpc.proto #ok protoc --go_out=. -I. --go-grpc_out=. srpc.proto -protoc-gen-grpc --ts_out=service=grpc-node:. --grpc_out=. srpc.proto +protoc-gen-grpc --ts_out=service=grpc-node:. srpc.proto + +#--grpc_out=. #打包 npx webpack --config webpack.config.js diff --git a/proto3/sillygirl.d.ts b/proto3/sillygirl.d.ts index 829e163..3aad38e 100644 --- a/proto3/sillygirl.d.ts +++ b/proto3/sillygirl.d.ts @@ -11,6 +11,7 @@ declare class Sender { getPlatform(): Promise; getBotId(): Promise; getContent(): Promise; + isAdmin(): Promise; param(key: number | string): Promise; setContent(content: string): Promise; continue(): Promise; @@ -96,6 +97,8 @@ interface CQParams { declare let utils: { buildCQTag: (type: string, params: CQParams, prefix?: string) => string; parseCQText: (text: string, prefix?: string) => (string | CQItem)[]; + image: (url: string) => string; + video: (url: string) => string; }; declare let console: { log(...args: any[]): void; diff --git a/proto3/sillygirl.js b/proto3/sillygirl.js index d0c804f..4f77e69 100644 --- a/proto3/sillygirl.js +++ b/proto3/sillygirl.js @@ -158,6 +158,20 @@ class Sender { }); }); } + async isAdmin() { + return new Promise((resolve, reject) => { + client.SenderIsAdmin(new srpc_1.srpc.SenderRequest({ + uuid: this.uuid, + }), metadata, (err, resp) => { + if (err) { + reject(err); + } + else { + resolve(resp?.value ?? false); + } + }); + }); + } async param(key) { return new Promise((resolve, reject) => { client.SenderParam(new srpc_1.srpc.ReplyRequest({ @@ -304,10 +318,6 @@ class Sender { } async doAction(options) { return new Promise((resolve, reject) => { - console.log({ - uuid: this.uuid, - content: JSON.stringify(options), - }); client.SenderAction(new srpc_1.srpc.ReplyRequest({ uuid: this.uuid, content: JSON.stringify(options), @@ -685,6 +695,12 @@ let utils = { } return result; }, + image: (url) => { + return utils.buildCQTag("image", { url }); + }, + video: (url) => { + return utils.buildCQTag("video", { url }); + }, }; exports.utils = utils; let console = { diff --git a/proto3/sillygirl.ts b/proto3/sillygirl.ts index 0c23641..b883439 100644 --- a/proto3/sillygirl.ts +++ b/proto3/sillygirl.ts @@ -166,6 +166,23 @@ class Sender { ); }); } + async isAdmin(): Promise { + return new Promise((resolve, reject) => { + client.SenderIsAdmin( + new srpc.SenderRequest({ + uuid: this.uuid, + }), + metadata, + (err, resp) => { + if (err) { + reject(err); + } else { + resolve(resp?.value ?? false); + } + } + ); + }); + } async param(key: number | string): Promise { return new Promise((resolve, reject) => { client.SenderParam( @@ -343,10 +360,6 @@ class Sender { } async doAction(options: Record): Promise { return new Promise((resolve, reject) => { - console.log({ - uuid: this.uuid, - content: JSON.stringify(options), - }); client.SenderAction( new srpc.ReplyRequest({ uuid: this.uuid, @@ -814,6 +827,12 @@ let utils = { } return result; }, + image: (url: string) => { + return utils.buildCQTag("image", { url }); + }, + video: (url: string) => { + return utils.buildCQTag("video", { url }); + }, }; let console = { diff --git a/proto3/srpc.d.ts b/proto3/srpc.d.ts index ab79a12..181d887 100644 --- a/proto3/srpc.d.ts +++ b/proto3/srpc.d.ts @@ -254,6 +254,25 @@ export declare namespace srpc { serializeBinary(): Uint8Array; static deserializeBinary(bytes: Uint8Array): LenResponse; } + export class BoolResponse extends pb_1.Message { + #private; + constructor(data?: any[] | { + value?: boolean; + }); + get value(): boolean; + set value(value: boolean); + static fromObject(data: { + value?: boolean; + }): BoolResponse; + toObject(): { + value?: boolean | undefined; + }; + serialize(): Uint8Array; + serialize(w: pb_1.BinaryWriter): void; + static deserialize(bytes: Uint8Array | pb_1.BinaryReader): BoolResponse; + serializeBinary(): Uint8Array; + static deserializeBinary(bytes: Uint8Array): BoolResponse; + } export class BucketsResponse extends pb_1.Message { #private; constructor(data?: any[] | { @@ -688,6 +707,15 @@ export declare namespace srpc { responseSerialize: (message: Default) => Buffer; responseDeserialize: (bytes: Buffer) => Default; }; + SenderIsAdmin: { + path: string; + requestStream: boolean; + responseStream: boolean; + requestSerialize: (message: SenderRequest) => Buffer; + requestDeserialize: (bytes: Buffer) => SenderRequest; + responseSerialize: (message: BoolResponse) => Buffer; + responseDeserialize: (bytes: Buffer) => BoolResponse; + }; SenderGetPlatform: { path: string; requestStream: boolean; @@ -856,6 +884,7 @@ export declare namespace srpc { abstract SenderGetChatId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetChatName(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetMessageId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract SenderIsAdmin(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetPlatform(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetBotId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetContent(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; @@ -890,6 +919,7 @@ export declare namespace srpc { SenderGetChatId: GrpcUnaryServiceInterface; SenderGetChatName: GrpcUnaryServiceInterface; SenderGetMessageId: GrpcUnaryServiceInterface; + SenderIsAdmin: GrpcUnaryServiceInterface; SenderGetPlatform: GrpcUnaryServiceInterface; SenderGetBotId: GrpcUnaryServiceInterface; SenderGetContent: GrpcUnaryServiceInterface; diff --git a/proto3/srpc.js b/proto3/srpc.js index ce8ae81..f57269a 100644 --- a/proto3/srpc.js +++ b/proto3/srpc.js @@ -872,6 +872,66 @@ var srpc; } } srpc.LenResponse = LenResponse; + class BoolResponse extends pb_1.Message { + #one_of_decls = []; + constructor(data) { + super(); + pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); + if (!Array.isArray(data) && typeof data == "object") { + if ("value" in data && data.value != undefined) { + this.value = data.value; + } + } + } + get value() { + return pb_1.Message.getFieldWithDefault(this, 1, false); + } + set value(value) { + pb_1.Message.setField(this, 1, value); + } + static fromObject(data) { + const message = new BoolResponse({}); + if (data.value != null) { + message.value = data.value; + } + return message; + } + toObject() { + const data = {}; + if (this.value != null) { + data.value = this.value; + } + return data; + } + serialize(w) { + const writer = w || new pb_1.BinaryWriter(); + if (this.value != false) + writer.writeBool(1, this.value); + if (!w) + return writer.getResultBuffer(); + } + static deserialize(bytes) { + const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new BoolResponse(); + while (reader.nextField()) { + if (reader.isEndGroup()) + break; + switch (reader.getFieldNumber()) { + case 1: + message.value = reader.readBool(); + break; + default: reader.skipField(); + } + } + return message; + } + serializeBinary() { + return this.serialize(); + } + static deserializeBinary(bytes) { + return BoolResponse.deserialize(bytes); + } + } + srpc.BoolResponse = BoolResponse; class BucketsResponse extends pb_1.Message { #one_of_decls = []; constructor(data) { @@ -2051,6 +2111,15 @@ var srpc; responseSerialize: (message) => Buffer.from(message.serialize()), responseDeserialize: (bytes) => Default.deserialize(new Uint8Array(bytes)) }, + SenderIsAdmin: { + path: "/srpc.SillyGirlService/SenderIsAdmin", + requestStream: false, + responseStream: false, + requestSerialize: (message) => Buffer.from(message.serialize()), + requestDeserialize: (bytes) => SenderRequest.deserialize(new Uint8Array(bytes)), + responseSerialize: (message) => Buffer.from(message.serialize()), + responseDeserialize: (bytes) => BoolResponse.deserialize(new Uint8Array(bytes)) + }, SenderGetPlatform: { path: "/srpc.SillyGirlService/SenderGetPlatform", requestStream: false, @@ -2250,6 +2319,9 @@ var srpc; SenderGetMessageId = (message, metadata, options, callback) => { return super.SenderGetMessageId(message, metadata, options, callback); }; + SenderIsAdmin = (message, metadata, options, callback) => { + return super.SenderIsAdmin(message, metadata, options, callback); + }; SenderGetPlatform = (message, metadata, options, callback) => { return super.SenderGetPlatform(message, metadata, options, callback); }; diff --git a/proto3/srpc.proto b/proto3/srpc.proto index 20b1d48..48dc770 100644 --- a/proto3/srpc.proto +++ b/proto3/srpc.proto @@ -55,6 +55,10 @@ message LenResponse { int32 length = 1; } +message BoolResponse { + bool value = 1; +} + message BucketsResponse { repeated string buckets = 1; } @@ -133,6 +137,7 @@ service SillyGirlService { rpc SenderGetChatId (SenderRequest) returns (Default); rpc SenderGetChatName (SenderRequest) returns (Default); rpc SenderGetMessageId (SenderRequest) returns (Default); + rpc SenderIsAdmin (SenderRequest) returns (BoolResponse); rpc SenderGetPlatform (SenderRequest) returns (Default); rpc SenderGetBotId (SenderRequest) returns (Default); rpc SenderGetContent (SenderRequest) returns (Default); diff --git a/proto3/srpc.ts b/proto3/srpc.ts index e608f5e..aba4036 100644 --- a/proto3/srpc.ts +++ b/proto3/srpc.ts @@ -948,6 +948,73 @@ export namespace srpc { return LenResponse.deserialize(bytes); } } + export class BoolResponse extends pb_1.Message { + #one_of_decls: number[][] = []; + constructor(data?: any[] | { + value?: boolean; + }) { + super(); + pb_1.Message.initialize(this, Array.isArray(data) ? data : [], 0, -1, [], this.#one_of_decls); + if (!Array.isArray(data) && typeof data == "object") { + if ("value" in data && data.value != undefined) { + this.value = data.value; + } + } + } + get value() { + return pb_1.Message.getFieldWithDefault(this, 1, false) as boolean; + } + set value(value: boolean) { + pb_1.Message.setField(this, 1, value); + } + static fromObject(data: { + value?: boolean; + }): BoolResponse { + const message = new BoolResponse({}); + if (data.value != null) { + message.value = data.value; + } + return message; + } + toObject() { + const data: { + value?: boolean; + } = {}; + if (this.value != null) { + data.value = this.value; + } + return data; + } + serialize(): Uint8Array; + serialize(w: pb_1.BinaryWriter): void; + serialize(w?: pb_1.BinaryWriter): Uint8Array | void { + const writer = w || new pb_1.BinaryWriter(); + if (this.value != false) + writer.writeBool(1, this.value); + if (!w) + return writer.getResultBuffer(); + } + static deserialize(bytes: Uint8Array | pb_1.BinaryReader): BoolResponse { + const reader = bytes instanceof pb_1.BinaryReader ? bytes : new pb_1.BinaryReader(bytes), message = new BoolResponse(); + while (reader.nextField()) { + if (reader.isEndGroup()) + break; + switch (reader.getFieldNumber()) { + case 1: + message.value = reader.readBool(); + break; + default: reader.skipField(); + } + } + return message; + } + serializeBinary(): Uint8Array { + return this.serialize(); + } + static deserializeBinary(bytes: Uint8Array): BoolResponse { + return BoolResponse.deserialize(bytes); + } + } export class BucketsResponse extends pb_1.Message { #one_of_decls: number[][] = []; constructor(data?: any[] | { @@ -2290,6 +2357,15 @@ export namespace srpc { responseSerialize: (message: Default) => Buffer.from(message.serialize()), responseDeserialize: (bytes: Buffer) => Default.deserialize(new Uint8Array(bytes)) }, + SenderIsAdmin: { + path: "/srpc.SillyGirlService/SenderIsAdmin", + requestStream: false, + responseStream: false, + requestSerialize: (message: SenderRequest) => Buffer.from(message.serialize()), + requestDeserialize: (bytes: Buffer) => SenderRequest.deserialize(new Uint8Array(bytes)), + responseSerialize: (message: BoolResponse) => Buffer.from(message.serialize()), + responseDeserialize: (bytes: Buffer) => BoolResponse.deserialize(new Uint8Array(bytes)) + }, SenderGetPlatform: { path: "/srpc.SillyGirlService/SenderGetPlatform", requestStream: false, @@ -2458,6 +2534,7 @@ export namespace srpc { abstract SenderGetChatId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetChatName(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetMessageId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; + abstract SenderIsAdmin(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetPlatform(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetBotId(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; abstract SenderGetContent(call: grpc_1.ServerUnaryCall, callback: grpc_1.sendUnaryData): void; @@ -2519,6 +2596,9 @@ export namespace srpc { SenderGetMessageId: GrpcUnaryServiceInterface = (message: SenderRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.SenderGetMessageId(message, metadata, options, callback); }; + SenderIsAdmin: GrpcUnaryServiceInterface = (message: SenderRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { + return super.SenderIsAdmin(message, metadata, options, callback); + }; SenderGetPlatform: GrpcUnaryServiceInterface = (message: SenderRequest, metadata: grpc_1.Metadata | grpc_1.CallOptions | grpc_1.requestCallback, options?: grpc_1.CallOptions | grpc_1.requestCallback, callback?: grpc_1.requestCallback): grpc_1.ClientUnaryCall => { return super.SenderGetPlatform(message, metadata, options, callback); }; diff --git a/proto3/srpc/srpc.pb.go b/proto3/srpc/srpc.pb.go index 5908d9a..5133efb 100644 --- a/proto3/srpc/srpc.pb.go +++ b/proto3/srpc/srpc.pb.go @@ -585,6 +585,53 @@ func (x *LenResponse) GetLength() int32 { return 0 } +type BoolResponse struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` +} + +func (x *BoolResponse) Reset() { + *x = BoolResponse{} + if protoimpl.UnsafeEnabled { + mi := &file_srpc_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *BoolResponse) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*BoolResponse) ProtoMessage() {} + +func (x *BoolResponse) ProtoReflect() protoreflect.Message { + mi := &file_srpc_proto_msgTypes[10] + if protoimpl.UnsafeEnabled && x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use BoolResponse.ProtoReflect.Descriptor instead. +func (*BoolResponse) Descriptor() ([]byte, []int) { + return file_srpc_proto_rawDescGZIP(), []int{10} +} + +func (x *BoolResponse) GetValue() bool { + if x != nil { + return x.Value + } + return false +} + type BucketsResponse struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -596,7 +643,7 @@ type BucketsResponse struct { func (x *BucketsResponse) Reset() { *x = BucketsResponse{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[10] + mi := &file_srpc_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -609,7 +656,7 @@ func (x *BucketsResponse) String() string { func (*BucketsResponse) ProtoMessage() {} func (x *BucketsResponse) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[10] + mi := &file_srpc_proto_msgTypes[11] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -622,7 +669,7 @@ func (x *BucketsResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use BucketsResponse.ProtoReflect.Descriptor instead. func (*BucketsResponse) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{10} + return file_srpc_proto_rawDescGZIP(), []int{11} } func (x *BucketsResponse) GetBuckets() []string { @@ -643,7 +690,7 @@ type SenderRequest struct { func (x *SenderRequest) Reset() { *x = SenderRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[11] + mi := &file_srpc_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -656,7 +703,7 @@ func (x *SenderRequest) String() string { func (*SenderRequest) ProtoMessage() {} func (x *SenderRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[11] + mi := &file_srpc_proto_msgTypes[12] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -669,7 +716,7 @@ func (x *SenderRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SenderRequest.ProtoReflect.Descriptor instead. func (*SenderRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{11} + return file_srpc_proto_rawDescGZIP(), []int{12} } func (x *SenderRequest) GetUuid() string { @@ -691,7 +738,7 @@ type ReplyRequest struct { func (x *ReplyRequest) Reset() { *x = ReplyRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[12] + mi := &file_srpc_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -704,7 +751,7 @@ func (x *ReplyRequest) String() string { func (*ReplyRequest) ProtoMessage() {} func (x *ReplyRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[12] + mi := &file_srpc_proto_msgTypes[13] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -717,7 +764,7 @@ func (x *ReplyRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ReplyRequest.ProtoReflect.Descriptor instead. func (*ReplyRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{12} + return file_srpc_proto_rawDescGZIP(), []int{13} } func (x *ReplyRequest) GetUuid() string { @@ -746,7 +793,7 @@ type SenderContentRequest struct { func (x *SenderContentRequest) Reset() { *x = SenderContentRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[13] + mi := &file_srpc_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -759,7 +806,7 @@ func (x *SenderContentRequest) String() string { func (*SenderContentRequest) ProtoMessage() {} func (x *SenderContentRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[13] + mi := &file_srpc_proto_msgTypes[14] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -772,7 +819,7 @@ func (x *SenderContentRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SenderContentRequest.ProtoReflect.Descriptor instead. func (*SenderContentRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{13} + return file_srpc_proto_rawDescGZIP(), []int{14} } func (x *SenderContentRequest) GetUuid() string { @@ -801,7 +848,7 @@ type SenderListenResponse struct { func (x *SenderListenResponse) Reset() { *x = SenderListenResponse{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[14] + mi := &file_srpc_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -814,7 +861,7 @@ func (x *SenderListenResponse) String() string { func (*SenderListenResponse) ProtoMessage() {} func (x *SenderListenResponse) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[14] + mi := &file_srpc_proto_msgTypes[15] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -827,7 +874,7 @@ func (x *SenderListenResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use SenderListenResponse.ProtoReflect.Descriptor instead. func (*SenderListenResponse) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{14} + return file_srpc_proto_rawDescGZIP(), []int{15} } func (x *SenderListenResponse) GetEcho() string { @@ -869,7 +916,7 @@ type SenderListenRequest struct { func (x *SenderListenRequest) Reset() { *x = SenderListenRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[15] + mi := &file_srpc_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -882,7 +929,7 @@ func (x *SenderListenRequest) String() string { func (*SenderListenRequest) ProtoMessage() {} func (x *SenderListenRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[15] + mi := &file_srpc_proto_msgTypes[16] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -895,7 +942,7 @@ func (x *SenderListenRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use SenderListenRequest.ProtoReflect.Descriptor instead. func (*SenderListenRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{15} + return file_srpc_proto_rawDescGZIP(), []int{16} } func (x *SenderListenRequest) GetUuid() string { @@ -1015,7 +1062,7 @@ type AdapterRegistRequest struct { func (x *AdapterRegistRequest) Reset() { *x = AdapterRegistRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[16] + mi := &file_srpc_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1028,7 +1075,7 @@ func (x *AdapterRegistRequest) String() string { func (*AdapterRegistRequest) ProtoMessage() {} func (x *AdapterRegistRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[16] + mi := &file_srpc_proto_msgTypes[17] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1041,7 +1088,7 @@ func (x *AdapterRegistRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use AdapterRegistRequest.ProtoReflect.Descriptor instead. func (*AdapterRegistRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{16} + return file_srpc_proto_rawDescGZIP(), []int{17} } func (x *AdapterRegistRequest) GetPlatform() string { @@ -1071,7 +1118,7 @@ type AdapterRequest struct { func (x *AdapterRequest) Reset() { *x = AdapterRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[17] + mi := &file_srpc_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1084,7 +1131,7 @@ func (x *AdapterRequest) String() string { func (*AdapterRequest) ProtoMessage() {} func (x *AdapterRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[17] + mi := &file_srpc_proto_msgTypes[18] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1097,7 +1144,7 @@ func (x *AdapterRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use AdapterRequest.ProtoReflect.Descriptor instead. func (*AdapterRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{17} + return file_srpc_proto_rawDescGZIP(), []int{18} } func (x *AdapterRequest) GetPlatform() string { @@ -1133,7 +1180,7 @@ type Any struct { func (x *Any) Reset() { *x = Any{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[18] + mi := &file_srpc_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1146,7 +1193,7 @@ func (x *Any) String() string { func (*Any) ProtoMessage() {} func (x *Any) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[18] + mi := &file_srpc_proto_msgTypes[19] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1159,7 +1206,7 @@ func (x *Any) ProtoReflect() protoreflect.Message { // Deprecated: Use Any.ProtoReflect.Descriptor instead. func (*Any) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{18} + return file_srpc_proto_rawDescGZIP(), []int{19} } func (x *Any) GetTypeUrl() string { @@ -1189,7 +1236,7 @@ type ConsoleRequest struct { func (x *ConsoleRequest) Reset() { *x = ConsoleRequest{} if protoimpl.UnsafeEnabled { - mi := &file_srpc_proto_msgTypes[19] + mi := &file_srpc_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1202,7 +1249,7 @@ func (x *ConsoleRequest) String() string { func (*ConsoleRequest) ProtoMessage() {} func (x *ConsoleRequest) ProtoReflect() protoreflect.Message { - mi := &file_srpc_proto_msgTypes[19] + mi := &file_srpc_proto_msgTypes[20] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1215,7 +1262,7 @@ func (x *ConsoleRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ConsoleRequest.ProtoReflect.Descriptor instead. func (*ConsoleRequest) Descriptor() ([]byte, []int) { - return file_srpc_proto_rawDescGZIP(), []int{19} + return file_srpc_proto_rawDescGZIP(), []int{20} } func (x *ConsoleRequest) GetType() string { @@ -1283,124 +1330,130 @@ var file_srpc_proto_rawDesc = []byte{ 0x65, 0x79, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x04, 0x6b, 0x65, 0x79, 0x73, 0x22, 0x25, 0x0a, 0x0b, 0x4c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, - 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x22, 0x2b, 0x0a, 0x0f, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, - 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x62, 0x75, 0x63, - 0x6b, 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x62, 0x75, 0x63, 0x6b, - 0x65, 0x74, 0x73, 0x22, 0x23, 0x0a, 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x22, 0x3c, 0x0a, 0x0c, 0x52, 0x65, 0x70, 0x6c, - 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, - 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, - 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x22, 0x44, 0x0a, 0x14, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, - 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, + 0x6c, 0x65, 0x6e, 0x67, 0x74, 0x68, 0x22, 0x24, 0x0a, 0x0c, 0x42, 0x6f, 0x6f, 0x6c, 0x52, 0x65, + 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x2b, 0x0a, 0x0f, + 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, + 0x18, 0x0a, 0x07, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, + 0x52, 0x07, 0x62, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x22, 0x23, 0x0a, 0x0d, 0x53, 0x65, 0x6e, + 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, + 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x22, 0x3c, + 0x0a, 0x0c, 0x52, 0x65, 0x70, 0x6c, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x22, 0x3e, 0x0a, 0x14, - 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, - 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x65, 0x63, 0x68, 0x6f, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x65, 0x63, 0x68, 0x6f, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x22, 0x87, 0x04, 0x0a, - 0x13, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x52, 0x65, 0x71, + 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x22, 0x44, 0x0a, 0x14, + 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x72, 0x75, 0x6c, 0x65, - 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x72, 0x75, 0x6c, 0x65, 0x73, 0x12, 0x18, - 0x0a, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, - 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x12, 0x21, 0x0a, 0x0c, 0x6c, 0x69, 0x73, 0x74, - 0x65, 0x6e, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, - 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x12, 0x25, 0x0a, 0x0e, 0x6c, - 0x69, 0x73, 0x74, 0x65, 0x6e, 0x5f, 0x70, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, - 0x01, 0x28, 0x08, 0x52, 0x0d, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x50, 0x72, 0x69, 0x76, 0x61, - 0x74, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x5f, 0x61, 0x64, - 0x6d, 0x69, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0c, 0x72, 0x65, 0x71, 0x75, 0x69, - 0x72, 0x65, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x12, 0x27, 0x0a, 0x0f, 0x61, 0x6c, 0x6c, 0x6f, 0x77, - 0x5f, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x18, 0x07, 0x20, 0x03, 0x28, 0x09, - 0x52, 0x0e, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, - 0x12, 0x2d, 0x0a, 0x12, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x5f, 0x70, 0x6c, 0x61, - 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x18, 0x08, 0x20, 0x03, 0x28, 0x09, 0x52, 0x11, 0x70, 0x72, - 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x12, - 0x1f, 0x0a, 0x0b, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x73, 0x18, 0x09, - 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x55, 0x73, 0x65, 0x72, 0x73, - 0x12, 0x25, 0x0a, 0x0e, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x5f, 0x75, 0x73, 0x65, - 0x72, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0d, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, - 0x69, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x12, 0x21, 0x0a, 0x0c, 0x61, 0x6c, 0x6c, 0x6f, 0x77, - 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x18, 0x0b, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0b, 0x61, - 0x6c, 0x6c, 0x6f, 0x77, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x72, - 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x18, 0x0c, 0x20, - 0x03, 0x28, 0x09, 0x52, 0x0e, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x47, 0x72, 0x6f, - 0x75, 0x70, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, - 0x74, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x70, 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, - 0x65, 0x6e, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x0e, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x6c, 0x75, - 0x67, 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, - 0x75, 0x67, 0x69, 0x6e, 0x49, 0x64, 0x22, 0x49, 0x0a, 0x14, 0x41, 0x64, 0x61, 0x70, 0x74, 0x65, - 0x72, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, - 0x0a, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, 0x15, 0x0a, 0x06, 0x62, 0x6f, - 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x62, 0x6f, 0x74, 0x49, - 0x64, 0x22, 0x59, 0x0a, 0x0e, 0x41, 0x64, 0x61, 0x70, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, - 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, - 0x15, 0x0a, 0x06, 0x62, 0x6f, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x05, 0x62, 0x6f, 0x74, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, - 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x36, 0x0a, 0x03, - 0x41, 0x6e, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x75, 0x72, 0x6c, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x79, 0x70, 0x65, 0x55, 0x72, 0x6c, 0x12, 0x14, - 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, - 0x61, 0x6c, 0x75, 0x65, 0x22, 0x5b, 0x0a, 0x0e, 0x43, 0x6f, 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x52, - 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, - 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, - 0x74, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x5f, 0x69, - 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x49, - 0x64, 0x32, 0x94, 0x0d, 0x0a, 0x10, 0x53, 0x69, 0x6c, 0x6c, 0x79, 0x47, 0x69, 0x72, 0x6c, 0x53, - 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x32, 0x0a, 0x09, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, - 0x47, 0x65, 0x74, 0x12, 0x16, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, - 0x74, 0x4b, 0x65, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, - 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x3c, 0x0a, 0x09, 0x42, 0x75, - 0x63, 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, 0x12, 0x16, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, - 0x75, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, - 0x17, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, - 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30, 0x0a, 0x0c, 0x42, 0x75, 0x63, 0x6b, - 0x65, 0x74, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, - 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0b, 0x2e, - 0x73, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x12, 0x3b, 0x0a, 0x0a, 0x42, 0x75, - 0x63, 0x6b, 0x65, 0x74, 0x4b, 0x65, 0x79, 0x73, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, - 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, - 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x4b, 0x65, 0x79, 0x73, 0x52, - 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, 0x09, 0x42, 0x75, 0x63, 0x6b, 0x65, - 0x74, 0x4c, 0x65, 0x6e, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, - 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x11, 0x2e, 0x73, 0x72, 0x70, 0x63, - 0x2e, 0x4c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x32, 0x0a, 0x0c, - 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x47, 0x65, 0x74, 0x41, 0x6c, 0x6c, 0x12, 0x13, 0x2e, 0x73, - 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, + 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, + 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, + 0x6e, 0x74, 0x22, 0x3e, 0x0a, 0x14, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4c, 0x69, 0x73, 0x74, + 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x65, 0x63, + 0x68, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x65, 0x63, 0x68, 0x6f, 0x12, 0x12, + 0x0a, 0x04, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, + 0x69, 0x64, 0x22, 0x87, 0x04, 0x0a, 0x13, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4c, 0x69, 0x73, + 0x74, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x75, 0x75, + 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x75, 0x75, 0x69, 0x64, 0x12, 0x14, + 0x0a, 0x05, 0x72, 0x75, 0x6c, 0x65, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28, 0x09, 0x52, 0x05, 0x72, + 0x75, 0x6c, 0x65, 0x73, 0x12, 0x18, 0x0a, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x18, + 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x74, 0x69, 0x6d, 0x65, 0x6f, 0x75, 0x74, 0x12, 0x21, + 0x0a, 0x0c, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x18, 0x04, + 0x20, 0x01, 0x28, 0x08, 0x52, 0x0b, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x47, 0x72, 0x6f, 0x75, + 0x70, 0x12, 0x25, 0x0a, 0x0e, 0x6c, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x5f, 0x70, 0x72, 0x69, 0x76, + 0x61, 0x74, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0d, 0x6c, 0x69, 0x73, 0x74, 0x65, + 0x6e, 0x50, 0x72, 0x69, 0x76, 0x61, 0x74, 0x65, 0x12, 0x23, 0x0a, 0x0d, 0x72, 0x65, 0x71, 0x75, + 0x69, 0x72, 0x65, 0x5f, 0x61, 0x64, 0x6d, 0x69, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x08, 0x52, + 0x0c, 0x72, 0x65, 0x71, 0x75, 0x69, 0x72, 0x65, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x12, 0x27, 0x0a, + 0x0f, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x5f, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, + 0x18, 0x07, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x50, 0x6c, 0x61, + 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x12, 0x2d, 0x0a, 0x12, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, + 0x69, 0x74, 0x5f, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x18, 0x08, 0x20, 0x03, + 0x28, 0x09, 0x52, 0x11, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x50, 0x6c, 0x61, 0x74, + 0x66, 0x6f, 0x72, 0x6d, 0x73, 0x12, 0x1f, 0x0a, 0x0b, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x5f, 0x75, + 0x73, 0x65, 0x72, 0x73, 0x18, 0x09, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0a, 0x61, 0x6c, 0x6c, 0x6f, + 0x77, 0x55, 0x73, 0x65, 0x72, 0x73, 0x12, 0x25, 0x0a, 0x0e, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, + 0x69, 0x74, 0x5f, 0x75, 0x73, 0x65, 0x72, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0d, + 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x55, 0x73, 0x65, 0x72, 0x73, 0x12, 0x21, 0x0a, + 0x0c, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x5f, 0x67, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x18, 0x0b, 0x20, + 0x03, 0x28, 0x09, 0x52, 0x0b, 0x61, 0x6c, 0x6c, 0x6f, 0x77, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x73, + 0x12, 0x27, 0x0a, 0x0f, 0x70, 0x72, 0x6f, 0x68, 0x69, 0x62, 0x69, 0x74, 0x5f, 0x67, 0x72, 0x6f, + 0x75, 0x70, 0x73, 0x18, 0x0c, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x70, 0x72, 0x6f, 0x68, 0x69, + 0x62, 0x69, 0x74, 0x47, 0x72, 0x6f, 0x75, 0x70, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x70, 0x65, 0x72, + 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x70, + 0x65, 0x72, 0x73, 0x69, 0x73, 0x74, 0x65, 0x6e, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, + 0x1b, 0x0a, 0x09, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x0f, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x49, 0x64, 0x22, 0x49, 0x0a, 0x14, + 0x41, 0x64, 0x61, 0x70, 0x74, 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, + 0x12, 0x15, 0x0a, 0x06, 0x62, 0x6f, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x05, 0x62, 0x6f, 0x74, 0x49, 0x64, 0x22, 0x59, 0x0a, 0x0e, 0x41, 0x64, 0x61, 0x70, 0x74, + 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x1a, 0x0a, 0x08, 0x70, 0x6c, 0x61, + 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, 0x6c, 0x61, + 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, 0x15, 0x0a, 0x06, 0x62, 0x6f, 0x74, 0x5f, 0x69, 0x64, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x62, 0x6f, 0x74, 0x49, 0x64, 0x12, 0x14, 0x0a, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x22, 0x36, 0x0a, 0x03, 0x41, 0x6e, 0x79, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x79, 0x70, + 0x65, 0x5f, 0x75, 0x72, 0x6c, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x79, 0x70, + 0x65, 0x55, 0x72, 0x6c, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x0c, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x5b, 0x0a, 0x0e, 0x43, 0x6f, + 0x6e, 0x73, 0x6f, 0x6c, 0x65, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, + 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, + 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x70, 0x6c, + 0x75, 0x67, 0x69, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x70, + 0x6c, 0x75, 0x67, 0x69, 0x6e, 0x49, 0x64, 0x32, 0xce, 0x0d, 0x0a, 0x10, 0x53, 0x69, 0x6c, 0x6c, + 0x79, 0x47, 0x69, 0x72, 0x6c, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x32, 0x0a, 0x09, + 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x47, 0x65, 0x74, 0x12, 0x16, 0x2e, 0x73, 0x72, 0x70, 0x63, + 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x4b, 0x65, 0x79, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, - 0x12, 0x33, 0x0a, 0x0d, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, - 0x73, 0x12, 0x0b, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x15, - 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, - 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x46, 0x0a, 0x0b, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x57, - 0x61, 0x74, 0x63, 0x68, 0x12, 0x18, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, - 0x65, 0x74, 0x57, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, - 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x57, 0x61, 0x74, 0x63, - 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x28, 0x01, 0x30, 0x01, 0x12, 0x35, 0x0a, - 0x0f, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, - 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, - 0x61, 0x75, 0x6c, 0x74, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, - 0x74, 0x55, 0x73, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, - 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, - 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x35, 0x0a, - 0x0f, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x43, 0x68, 0x61, 0x74, 0x49, 0x64, - 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, - 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, - 0x61, 0x75, 0x6c, 0x74, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, - 0x74, 0x43, 0x68, 0x61, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, + 0x12, 0x3c, 0x0a, 0x09, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, 0x12, 0x16, 0x2e, + 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, 0x52, 0x65, + 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x17, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, + 0x6b, 0x65, 0x74, 0x53, 0x65, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x30, + 0x0a, 0x0c, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x44, 0x65, 0x6c, 0x65, 0x74, 0x65, 0x12, 0x13, + 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x0b, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x45, 0x6d, 0x70, 0x74, 0x79, + 0x12, 0x3b, 0x0a, 0x0a, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x4b, 0x65, 0x79, 0x73, 0x12, 0x13, + 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x18, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, + 0x74, 0x4b, 0x65, 0x79, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x33, 0x0a, + 0x09, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x4c, 0x65, 0x6e, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, + 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, + 0x11, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, + 0x73, 0x65, 0x12, 0x32, 0x0a, 0x0c, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x47, 0x65, 0x74, 0x41, + 0x6c, 0x6c, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, + 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x33, 0x0a, 0x0d, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, + 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x73, 0x12, 0x0b, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x45, + 0x6d, 0x70, 0x74, 0x79, 0x1a, 0x15, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, + 0x65, 0x74, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x46, 0x0a, 0x0b, 0x42, + 0x75, 0x63, 0x6b, 0x65, 0x74, 0x57, 0x61, 0x74, 0x63, 0x68, 0x12, 0x18, 0x2e, 0x73, 0x72, 0x70, + 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x57, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x1a, 0x19, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x75, 0x63, 0x6b, + 0x65, 0x74, 0x57, 0x61, 0x74, 0x63, 0x68, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x28, + 0x01, 0x30, 0x01, 0x12, 0x35, 0x0a, 0x0f, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, + 0x55, 0x73, 0x65, 0x72, 0x49, 0x64, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, + 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, + 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, + 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x55, 0x73, 0x65, 0x72, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, + 0x75, 0x6c, 0x74, 0x12, 0x35, 0x0a, 0x0f, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, + 0x43, 0x68, 0x61, 0x74, 0x49, 0x64, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, + 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, + 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, + 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x43, 0x68, 0x61, 0x74, 0x4e, 0x61, 0x6d, 0x65, 0x12, + 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, + 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, + 0x75, 0x6c, 0x74, 0x12, 0x38, 0x0a, 0x12, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, + 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, 0x64, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x38, 0x0a, - 0x12, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, - 0x65, 0x49, 0x64, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, - 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, - 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, 0x6e, 0x64, 0x65, + 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x49, 0x73, 0x41, 0x64, 0x6d, 0x69, 0x6e, 0x12, 0x13, + 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x1a, 0x12, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x42, 0x6f, 0x6f, 0x6c, 0x52, + 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x37, 0x0a, 0x11, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x47, 0x65, 0x74, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, 0x13, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x0d, 0x2e, 0x73, 0x72, 0x70, 0x63, 0x2e, 0x44, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, @@ -1474,7 +1527,7 @@ func file_srpc_proto_rawDescGZIP() []byte { return file_srpc_proto_rawDescData } -var file_srpc_proto_msgTypes = make([]protoimpl.MessageInfo, 20) +var file_srpc_proto_msgTypes = make([]protoimpl.MessageInfo, 21) var file_srpc_proto_goTypes = []interface{}{ (*Empty)(nil), // 0: srpc.Empty (*Default)(nil), // 1: srpc.Default @@ -1486,16 +1539,17 @@ var file_srpc_proto_goTypes = []interface{}{ (*BucketRequest)(nil), // 7: srpc.BucketRequest (*BucketKeysResponse)(nil), // 8: srpc.BucketKeysResponse (*LenResponse)(nil), // 9: srpc.LenResponse - (*BucketsResponse)(nil), // 10: srpc.BucketsResponse - (*SenderRequest)(nil), // 11: srpc.SenderRequest - (*ReplyRequest)(nil), // 12: srpc.ReplyRequest - (*SenderContentRequest)(nil), // 13: srpc.SenderContentRequest - (*SenderListenResponse)(nil), // 14: srpc.SenderListenResponse - (*SenderListenRequest)(nil), // 15: srpc.SenderListenRequest - (*AdapterRegistRequest)(nil), // 16: srpc.AdapterRegistRequest - (*AdapterRequest)(nil), // 17: srpc.AdapterRequest - (*Any)(nil), // 18: srpc.Any - (*ConsoleRequest)(nil), // 19: srpc.ConsoleRequest + (*BoolResponse)(nil), // 10: srpc.BoolResponse + (*BucketsResponse)(nil), // 11: srpc.BucketsResponse + (*SenderRequest)(nil), // 12: srpc.SenderRequest + (*ReplyRequest)(nil), // 13: srpc.ReplyRequest + (*SenderContentRequest)(nil), // 14: srpc.SenderContentRequest + (*SenderListenResponse)(nil), // 15: srpc.SenderListenResponse + (*SenderListenRequest)(nil), // 16: srpc.SenderListenRequest + (*AdapterRegistRequest)(nil), // 17: srpc.AdapterRegistRequest + (*AdapterRequest)(nil), // 18: srpc.AdapterRequest + (*Any)(nil), // 19: srpc.Any + (*ConsoleRequest)(nil), // 20: srpc.ConsoleRequest } var file_srpc_proto_depIdxs = []int32{ 6, // 0: srpc.SillyGirlService.BucketGet:input_type -> srpc.BucketKeyRequest @@ -1506,60 +1560,62 @@ var file_srpc_proto_depIdxs = []int32{ 7, // 5: srpc.SillyGirlService.BucketGetAll:input_type -> srpc.BucketRequest 0, // 6: srpc.SillyGirlService.BucketBuckets:input_type -> srpc.Empty 3, // 7: srpc.SillyGirlService.BucketWatch:input_type -> srpc.BucketWatchRequest - 11, // 8: srpc.SillyGirlService.SenderGetUserId:input_type -> srpc.SenderRequest - 11, // 9: srpc.SillyGirlService.SenderGetUserName:input_type -> srpc.SenderRequest - 11, // 10: srpc.SillyGirlService.SenderGetChatId:input_type -> srpc.SenderRequest - 11, // 11: srpc.SillyGirlService.SenderGetChatName:input_type -> srpc.SenderRequest - 11, // 12: srpc.SillyGirlService.SenderGetMessageId:input_type -> srpc.SenderRequest - 11, // 13: srpc.SillyGirlService.SenderGetPlatform:input_type -> srpc.SenderRequest - 11, // 14: srpc.SillyGirlService.SenderGetBotId:input_type -> srpc.SenderRequest - 11, // 15: srpc.SillyGirlService.SenderGetContent:input_type -> srpc.SenderRequest - 13, // 16: srpc.SillyGirlService.SenderSetContent:input_type -> srpc.SenderContentRequest - 11, // 17: srpc.SillyGirlService.SenderContinue:input_type -> srpc.SenderRequest - 15, // 18: srpc.SillyGirlService.SenderListen:input_type -> srpc.SenderListenRequest - 11, // 19: srpc.SillyGirlService.SenderEvent:input_type -> srpc.SenderRequest - 12, // 20: srpc.SillyGirlService.SenderReply:input_type -> srpc.ReplyRequest - 12, // 21: srpc.SillyGirlService.SenderParam:input_type -> srpc.ReplyRequest - 12, // 22: srpc.SillyGirlService.SenderAction:input_type -> srpc.ReplyRequest - 12, // 23: srpc.SillyGirlService.SenderDestroy:input_type -> srpc.ReplyRequest - 16, // 24: srpc.SillyGirlService.AdapterRegist:input_type -> srpc.AdapterRegistRequest - 17, // 25: srpc.SillyGirlService.AdapterReceive:input_type -> srpc.AdapterRequest - 17, // 26: srpc.SillyGirlService.AdapterPush:input_type -> srpc.AdapterRequest - 17, // 27: srpc.SillyGirlService.AdapterDestroy:input_type -> srpc.AdapterRequest - 17, // 28: srpc.SillyGirlService.AdapterSender:input_type -> srpc.AdapterRequest - 19, // 29: srpc.SillyGirlService.Console:input_type -> srpc.ConsoleRequest - 1, // 30: srpc.SillyGirlService.BucketGet:output_type -> srpc.Default - 5, // 31: srpc.SillyGirlService.BucketSet:output_type -> srpc.BucketSetResponse - 0, // 32: srpc.SillyGirlService.BucketDelete:output_type -> srpc.Empty - 8, // 33: srpc.SillyGirlService.BucketKeys:output_type -> srpc.BucketKeysResponse - 9, // 34: srpc.SillyGirlService.BucketLen:output_type -> srpc.LenResponse - 1, // 35: srpc.SillyGirlService.BucketGetAll:output_type -> srpc.Default - 10, // 36: srpc.SillyGirlService.BucketBuckets:output_type -> srpc.BucketsResponse - 4, // 37: srpc.SillyGirlService.BucketWatch:output_type -> srpc.BucketWatchResponse - 1, // 38: srpc.SillyGirlService.SenderGetUserId:output_type -> srpc.Default - 1, // 39: srpc.SillyGirlService.SenderGetUserName:output_type -> srpc.Default - 1, // 40: srpc.SillyGirlService.SenderGetChatId:output_type -> srpc.Default - 1, // 41: srpc.SillyGirlService.SenderGetChatName:output_type -> srpc.Default - 1, // 42: srpc.SillyGirlService.SenderGetMessageId:output_type -> srpc.Default - 1, // 43: srpc.SillyGirlService.SenderGetPlatform:output_type -> srpc.Default - 1, // 44: srpc.SillyGirlService.SenderGetBotId:output_type -> srpc.Default - 1, // 45: srpc.SillyGirlService.SenderGetContent:output_type -> srpc.Default - 0, // 46: srpc.SillyGirlService.SenderSetContent:output_type -> srpc.Empty - 0, // 47: srpc.SillyGirlService.SenderContinue:output_type -> srpc.Empty - 14, // 48: srpc.SillyGirlService.SenderListen:output_type -> srpc.SenderListenResponse - 1, // 49: srpc.SillyGirlService.SenderEvent:output_type -> srpc.Default - 1, // 50: srpc.SillyGirlService.SenderReply:output_type -> srpc.Default - 1, // 51: srpc.SillyGirlService.SenderParam:output_type -> srpc.Default - 1, // 52: srpc.SillyGirlService.SenderAction:output_type -> srpc.Default - 0, // 53: srpc.SillyGirlService.SenderDestroy:output_type -> srpc.Empty - 1, // 54: srpc.SillyGirlService.AdapterRegist:output_type -> srpc.Default - 0, // 55: srpc.SillyGirlService.AdapterReceive:output_type -> srpc.Empty - 1, // 56: srpc.SillyGirlService.AdapterPush:output_type -> srpc.Default - 0, // 57: srpc.SillyGirlService.AdapterDestroy:output_type -> srpc.Empty - 1, // 58: srpc.SillyGirlService.AdapterSender:output_type -> srpc.Default - 0, // 59: srpc.SillyGirlService.Console:output_type -> srpc.Empty - 30, // [30:60] is the sub-list for method output_type - 0, // [0:30] is the sub-list for method input_type + 12, // 8: srpc.SillyGirlService.SenderGetUserId:input_type -> srpc.SenderRequest + 12, // 9: srpc.SillyGirlService.SenderGetUserName:input_type -> srpc.SenderRequest + 12, // 10: srpc.SillyGirlService.SenderGetChatId:input_type -> srpc.SenderRequest + 12, // 11: srpc.SillyGirlService.SenderGetChatName:input_type -> srpc.SenderRequest + 12, // 12: srpc.SillyGirlService.SenderGetMessageId:input_type -> srpc.SenderRequest + 12, // 13: srpc.SillyGirlService.SenderIsAdmin:input_type -> srpc.SenderRequest + 12, // 14: srpc.SillyGirlService.SenderGetPlatform:input_type -> srpc.SenderRequest + 12, // 15: srpc.SillyGirlService.SenderGetBotId:input_type -> srpc.SenderRequest + 12, // 16: srpc.SillyGirlService.SenderGetContent:input_type -> srpc.SenderRequest + 14, // 17: srpc.SillyGirlService.SenderSetContent:input_type -> srpc.SenderContentRequest + 12, // 18: srpc.SillyGirlService.SenderContinue:input_type -> srpc.SenderRequest + 16, // 19: srpc.SillyGirlService.SenderListen:input_type -> srpc.SenderListenRequest + 12, // 20: srpc.SillyGirlService.SenderEvent:input_type -> srpc.SenderRequest + 13, // 21: srpc.SillyGirlService.SenderReply:input_type -> srpc.ReplyRequest + 13, // 22: srpc.SillyGirlService.SenderParam:input_type -> srpc.ReplyRequest + 13, // 23: srpc.SillyGirlService.SenderAction:input_type -> srpc.ReplyRequest + 13, // 24: srpc.SillyGirlService.SenderDestroy:input_type -> srpc.ReplyRequest + 17, // 25: srpc.SillyGirlService.AdapterRegist:input_type -> srpc.AdapterRegistRequest + 18, // 26: srpc.SillyGirlService.AdapterReceive:input_type -> srpc.AdapterRequest + 18, // 27: srpc.SillyGirlService.AdapterPush:input_type -> srpc.AdapterRequest + 18, // 28: srpc.SillyGirlService.AdapterDestroy:input_type -> srpc.AdapterRequest + 18, // 29: srpc.SillyGirlService.AdapterSender:input_type -> srpc.AdapterRequest + 20, // 30: srpc.SillyGirlService.Console:input_type -> srpc.ConsoleRequest + 1, // 31: srpc.SillyGirlService.BucketGet:output_type -> srpc.Default + 5, // 32: srpc.SillyGirlService.BucketSet:output_type -> srpc.BucketSetResponse + 0, // 33: srpc.SillyGirlService.BucketDelete:output_type -> srpc.Empty + 8, // 34: srpc.SillyGirlService.BucketKeys:output_type -> srpc.BucketKeysResponse + 9, // 35: srpc.SillyGirlService.BucketLen:output_type -> srpc.LenResponse + 1, // 36: srpc.SillyGirlService.BucketGetAll:output_type -> srpc.Default + 11, // 37: srpc.SillyGirlService.BucketBuckets:output_type -> srpc.BucketsResponse + 4, // 38: srpc.SillyGirlService.BucketWatch:output_type -> srpc.BucketWatchResponse + 1, // 39: srpc.SillyGirlService.SenderGetUserId:output_type -> srpc.Default + 1, // 40: srpc.SillyGirlService.SenderGetUserName:output_type -> srpc.Default + 1, // 41: srpc.SillyGirlService.SenderGetChatId:output_type -> srpc.Default + 1, // 42: srpc.SillyGirlService.SenderGetChatName:output_type -> srpc.Default + 1, // 43: srpc.SillyGirlService.SenderGetMessageId:output_type -> srpc.Default + 10, // 44: srpc.SillyGirlService.SenderIsAdmin:output_type -> srpc.BoolResponse + 1, // 45: srpc.SillyGirlService.SenderGetPlatform:output_type -> srpc.Default + 1, // 46: srpc.SillyGirlService.SenderGetBotId:output_type -> srpc.Default + 1, // 47: srpc.SillyGirlService.SenderGetContent:output_type -> srpc.Default + 0, // 48: srpc.SillyGirlService.SenderSetContent:output_type -> srpc.Empty + 0, // 49: srpc.SillyGirlService.SenderContinue:output_type -> srpc.Empty + 15, // 50: srpc.SillyGirlService.SenderListen:output_type -> srpc.SenderListenResponse + 1, // 51: srpc.SillyGirlService.SenderEvent:output_type -> srpc.Default + 1, // 52: srpc.SillyGirlService.SenderReply:output_type -> srpc.Default + 1, // 53: srpc.SillyGirlService.SenderParam:output_type -> srpc.Default + 1, // 54: srpc.SillyGirlService.SenderAction:output_type -> srpc.Default + 0, // 55: srpc.SillyGirlService.SenderDestroy:output_type -> srpc.Empty + 1, // 56: srpc.SillyGirlService.AdapterRegist:output_type -> srpc.Default + 0, // 57: srpc.SillyGirlService.AdapterReceive:output_type -> srpc.Empty + 1, // 58: srpc.SillyGirlService.AdapterPush:output_type -> srpc.Default + 0, // 59: srpc.SillyGirlService.AdapterDestroy:output_type -> srpc.Empty + 1, // 60: srpc.SillyGirlService.AdapterSender:output_type -> srpc.Default + 0, // 61: srpc.SillyGirlService.Console:output_type -> srpc.Empty + 31, // [31:62] is the sub-list for method output_type + 0, // [0:31] is the sub-list for method input_type 0, // [0:0] is the sub-list for extension type_name 0, // [0:0] is the sub-list for extension extendee 0, // [0:0] is the sub-list for field type_name @@ -1692,7 +1748,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*BucketsResponse); i { + switch v := v.(*BoolResponse); i { case 0: return &v.state case 1: @@ -1704,7 +1760,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SenderRequest); i { + switch v := v.(*BucketsResponse); i { case 0: return &v.state case 1: @@ -1716,7 +1772,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*ReplyRequest); i { + switch v := v.(*SenderRequest); i { case 0: return &v.state case 1: @@ -1728,7 +1784,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SenderContentRequest); i { + switch v := v.(*ReplyRequest); i { case 0: return &v.state case 1: @@ -1740,7 +1796,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SenderListenResponse); i { + switch v := v.(*SenderContentRequest); i { case 0: return &v.state case 1: @@ -1752,7 +1808,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*SenderListenRequest); i { + switch v := v.(*SenderListenResponse); i { case 0: return &v.state case 1: @@ -1764,7 +1820,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AdapterRegistRequest); i { + switch v := v.(*SenderListenRequest); i { case 0: return &v.state case 1: @@ -1776,7 +1832,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*AdapterRequest); i { + switch v := v.(*AdapterRegistRequest); i { case 0: return &v.state case 1: @@ -1788,7 +1844,7 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { - switch v := v.(*Any); i { + switch v := v.(*AdapterRequest); i { case 0: return &v.state case 1: @@ -1800,6 +1856,18 @@ func file_srpc_proto_init() { } } file_srpc_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*Any); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_srpc_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*ConsoleRequest); i { case 0: return &v.state @@ -1818,7 +1886,7 @@ func file_srpc_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_srpc_proto_rawDesc, NumEnums: 0, - NumMessages: 20, + NumMessages: 21, NumExtensions: 0, NumServices: 1, }, diff --git a/proto3/srpc/srpc_grpc.pb.go b/proto3/srpc/srpc_grpc.pb.go index 3221af2..3c099ca 100644 --- a/proto3/srpc/srpc_grpc.pb.go +++ b/proto3/srpc/srpc_grpc.pb.go @@ -32,6 +32,7 @@ const ( SillyGirlService_SenderGetChatId_FullMethodName = "/srpc.SillyGirlService/SenderGetChatId" SillyGirlService_SenderGetChatName_FullMethodName = "/srpc.SillyGirlService/SenderGetChatName" SillyGirlService_SenderGetMessageId_FullMethodName = "/srpc.SillyGirlService/SenderGetMessageId" + SillyGirlService_SenderIsAdmin_FullMethodName = "/srpc.SillyGirlService/SenderIsAdmin" SillyGirlService_SenderGetPlatform_FullMethodName = "/srpc.SillyGirlService/SenderGetPlatform" SillyGirlService_SenderGetBotId_FullMethodName = "/srpc.SillyGirlService/SenderGetBotId" SillyGirlService_SenderGetContent_FullMethodName = "/srpc.SillyGirlService/SenderGetContent" @@ -68,6 +69,7 @@ type SillyGirlServiceClient interface { SenderGetChatId(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) SenderGetChatName(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) SenderGetMessageId(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) + SenderIsAdmin(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*BoolResponse, error) SenderGetPlatform(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) SenderGetBotId(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) SenderGetContent(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) @@ -234,6 +236,15 @@ func (c *sillyGirlServiceClient) SenderGetMessageId(ctx context.Context, in *Sen return out, nil } +func (c *sillyGirlServiceClient) SenderIsAdmin(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*BoolResponse, error) { + out := new(BoolResponse) + err := c.cc.Invoke(ctx, SillyGirlService_SenderIsAdmin_FullMethodName, in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + func (c *sillyGirlServiceClient) SenderGetPlatform(ctx context.Context, in *SenderRequest, opts ...grpc.CallOption) (*Default, error) { out := new(Default) err := c.cc.Invoke(ctx, SillyGirlService_SenderGetPlatform_FullMethodName, in, out, opts...) @@ -448,6 +459,7 @@ type SillyGirlServiceServer interface { SenderGetChatId(context.Context, *SenderRequest) (*Default, error) SenderGetChatName(context.Context, *SenderRequest) (*Default, error) SenderGetMessageId(context.Context, *SenderRequest) (*Default, error) + SenderIsAdmin(context.Context, *SenderRequest) (*BoolResponse, error) SenderGetPlatform(context.Context, *SenderRequest) (*Default, error) SenderGetBotId(context.Context, *SenderRequest) (*Default, error) SenderGetContent(context.Context, *SenderRequest) (*Default, error) @@ -511,6 +523,9 @@ func (UnimplementedSillyGirlServiceServer) SenderGetChatName(context.Context, *S func (UnimplementedSillyGirlServiceServer) SenderGetMessageId(context.Context, *SenderRequest) (*Default, error) { return nil, status.Errorf(codes.Unimplemented, "method SenderGetMessageId not implemented") } +func (UnimplementedSillyGirlServiceServer) SenderIsAdmin(context.Context, *SenderRequest) (*BoolResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method SenderIsAdmin not implemented") +} func (UnimplementedSillyGirlServiceServer) SenderGetPlatform(context.Context, *SenderRequest) (*Default, error) { return nil, status.Errorf(codes.Unimplemented, "method SenderGetPlatform not implemented") } @@ -817,6 +832,24 @@ func _SillyGirlService_SenderGetMessageId_Handler(srv interface{}, ctx context.C return interceptor(ctx, in, info, handler) } +func _SillyGirlService_SenderIsAdmin_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(SenderRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(SillyGirlServiceServer).SenderIsAdmin(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: SillyGirlService_SenderIsAdmin_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(SillyGirlServiceServer).SenderIsAdmin(ctx, req.(*SenderRequest)) + } + return interceptor(ctx, in, info, handler) +} + func _SillyGirlService_SenderGetPlatform_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SenderRequest) if err := dec(in); err != nil { @@ -1194,6 +1227,10 @@ var SillyGirlService_ServiceDesc = grpc.ServiceDesc{ MethodName: "SenderGetMessageId", Handler: _SillyGirlService_SenderGetMessageId_Handler, }, + { + MethodName: "SenderIsAdmin", + Handler: _SillyGirlService_SenderIsAdmin_Handler, + }, { MethodName: "SenderGetPlatform", Handler: _SillyGirlService_SenderGetPlatform_Handler,