diff --git a/Makefile b/Makefile index 4158f1cd..72990320 100644 --- a/Makefile +++ b/Makefile @@ -154,7 +154,7 @@ $(gen_sum): $(gen_src) --workdir="/go/src/berty.tech/weshnet" \ --entrypoint="sh" \ --rm \ - bertytech/buf:4 \ + bertytech/buf:5 \ -xec 'make generate_local'; \ $(MAKE) tidy \ ) diff --git a/docs/Makefile b/docs/Makefile index db0956df..b9ea011b 100644 --- a/docs/Makefile +++ b/docs/Makefile @@ -22,7 +22,7 @@ $(gen_sum): $(gen_src) --workdir="/go/src/berty.tech/berty/docs" \ --entrypoint="sh" \ --rm \ - bertytech/buf:2 \ + bertytech/buf:5 \ -xec 'make generate_local' \ ) .PHONY: generate diff --git a/docs/apis/protocoltypes.swagger.json b/docs/apis/protocoltypes.swagger.json index f1f5a586..e851dfd7 100644 --- a/docs/apis/protocoltypes.swagger.json +++ b/docs/apis/protocoltypes.swagger.json @@ -12,6 +12,16 @@ ], "paths": {}, "definitions": { + "GroupDeviceStatusType": { + "type": "string", + "enum": [ + "TypeUnknown", + "TypePeerDisconnected", + "TypePeerConnected", + "TypePeerReconnecting" + ], + "default": "TypeUnknown" + }, "OrbitDBReplicationStatus": { "type": "object", "properties": { @@ -569,7 +579,7 @@ "type": "object", "properties": { "type": { - "$ref": "#/definitions/v1GroupDeviceStatusType" + "$ref": "#/definitions/GroupDeviceStatusType" }, "event": { "type": "string", @@ -577,16 +587,6 @@ } } }, - "v1GroupDeviceStatusType": { - "type": "string", - "enum": [ - "TypeUnknown", - "TypePeerDisconnected", - "TypePeerConnected", - "TypePeerReconnecting" - ], - "default": "TypeUnknown" - }, "v1GroupInfoReply": { "type": "object", "properties": { diff --git a/docs/gen.sum b/docs/gen.sum index 4d99fddf..b9e6632c 100644 --- a/docs/gen.sum +++ b/docs/gen.sum @@ -1 +1 @@ -1874a7a933c38866216b36435e426d3f7c74561e Makefile +10db4498e1b002bb5bbfeb67ec3ce4d259b35c3d Makefile diff --git a/gen.sum b/gen.sum index 36f9c72d..6992d6ec 100644 --- a/gen.sum +++ b/gen.sum @@ -1 +1 @@ -5c2cb692d768a8f1afb037311ad55074aa61bf93 Makefile +78cfa180bfe8caf1572068cd6ea6bee4b89b3348 Makefile diff --git a/internal/handshake/handshake.pb.go b/internal/handshake/handshake.pb.go index bd0ae9a6..4cf99846 100644 --- a/internal/handshake/handshake.pb.go +++ b/internal/handshake/handshake.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: handshake/handshake.proto @@ -310,7 +310,7 @@ func file_handshake_handshake_proto_rawDescGZIP() []byte { } var file_handshake_handshake_proto_msgTypes = make([]protoimpl.MessageInfo, 5) -var file_handshake_handshake_proto_goTypes = []interface{}{ +var file_handshake_handshake_proto_goTypes = []any{ (*BoxEnvelope)(nil), // 0: handshake.BoxEnvelope (*HelloPayload)(nil), // 1: handshake.HelloPayload (*RequesterAuthenticatePayload)(nil), // 2: handshake.RequesterAuthenticatePayload @@ -331,7 +331,7 @@ func file_handshake_handshake_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_handshake_handshake_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_handshake_handshake_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*BoxEnvelope); i { case 0: return &v.state @@ -343,7 +343,7 @@ func file_handshake_handshake_proto_init() { return nil } } - file_handshake_handshake_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_handshake_handshake_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*HelloPayload); i { case 0: return &v.state @@ -355,7 +355,7 @@ func file_handshake_handshake_proto_init() { return nil } } - file_handshake_handshake_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_handshake_handshake_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*RequesterAuthenticatePayload); i { case 0: return &v.state @@ -367,7 +367,7 @@ func file_handshake_handshake_proto_init() { return nil } } - file_handshake_handshake_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_handshake_handshake_proto_msgTypes[3].Exporter = func(v any, i int) any { switch v := v.(*ResponderAcceptPayload); i { case 0: return &v.state @@ -379,7 +379,7 @@ func file_handshake_handshake_proto_init() { return nil } } - file_handshake_handshake_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_handshake_handshake_proto_msgTypes[4].Exporter = func(v any, i int) any { switch v := v.(*RequesterAcknowledgePayload); i { case 0: return &v.state diff --git a/internal/tools/tools.go b/internal/tools/tools.go index 8f1e6295..0de4e3e1 100644 --- a/internal/tools/tools.go +++ b/internal/tools/tools.go @@ -12,8 +12,6 @@ import ( // required by Makefile _ "github.com/daixiang0/gci" // required by protoc - _ "google.golang.org/protobuf/proto" - // required by protoc _ "github.com/grpc-ecosystem/grpc-gateway/protoc-gen-grpc-gateway" // required by protoc _ "github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger" @@ -31,6 +29,8 @@ import ( _ "google.golang.org/grpc/cmd/protoc-gen-go-grpc" // required by protoc _ "google.golang.org/protobuf/cmd/protoc-gen-go" + // required by protoc + _ "google.golang.org/protobuf/proto" // required by Makefile _ "moul.io/testman" // required by Makefile diff --git a/pkg/errcode/errcode.pb.go b/pkg/errcode/errcode.pb.go index 7e847571..65b19f1c 100644 --- a/pkg/errcode/errcode.pb.go +++ b/pkg/errcode/errcode.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: errcode/errcode.proto @@ -551,7 +551,7 @@ func file_errcode_errcode_proto_rawDescGZIP() []byte { var file_errcode_errcode_proto_enumTypes = make([]protoimpl.EnumInfo, 1) var file_errcode_errcode_proto_msgTypes = make([]protoimpl.MessageInfo, 1) -var file_errcode_errcode_proto_goTypes = []interface{}{ +var file_errcode_errcode_proto_goTypes = []any{ (ErrCode)(0), // 0: weshnet.errcode.ErrCode (*ErrDetails)(nil), // 1: weshnet.errcode.ErrDetails } @@ -570,7 +570,7 @@ func file_errcode_errcode_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_errcode_errcode_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_errcode_errcode_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*ErrDetails); i { case 0: return &v.state diff --git a/pkg/outofstoremessagetypes/outofstoremessage.pb.go b/pkg/outofstoremessagetypes/outofstoremessage.pb.go index c018a44e..1f2b0ab2 100644 --- a/pkg/outofstoremessagetypes/outofstoremessage.pb.go +++ b/pkg/outofstoremessagetypes/outofstoremessage.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: outofstoremessagetypes/outofstoremessage.proto @@ -44,7 +44,7 @@ var file_outofstoremessagetypes_outofstoremessage_proto_rawDesc = []byte{ 0x79, 0x70, 0x65, 0x73, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } -var file_outofstoremessagetypes_outofstoremessage_proto_goTypes = []interface{}{ +var file_outofstoremessagetypes_outofstoremessage_proto_goTypes = []any{ (*protocoltypes.OutOfStoreReceive_Request)(nil), // 0: weshnet.protocol.v1.OutOfStoreReceive.Request (*protocoltypes.OutOfStoreReceive_Reply)(nil), // 1: weshnet.protocol.v1.OutOfStoreReceive.Reply } diff --git a/pkg/outofstoremessagetypes/outofstoremessage_grpc.pb.go b/pkg/outofstoremessagetypes/outofstoremessage_grpc.pb.go index 8bf6f75e..cfeb1049 100644 --- a/pkg/outofstoremessagetypes/outofstoremessage_grpc.pb.go +++ b/pkg/outofstoremessagetypes/outofstoremessage_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 +// - protoc-gen-go-grpc v1.5.1 // - protoc (unknown) // source: outofstoremessagetypes/outofstoremessage.proto @@ -16,8 +16,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.64.0 or later. +const _ = grpc.SupportPackageIsVersion9 const ( OutOfStoreMessageService_OutOfStoreReceive_FullMethodName = "/weshnet.outofstoremessage.v1.OutOfStoreMessageService/OutOfStoreReceive" @@ -26,6 +26,9 @@ const ( // OutOfStoreMessageServiceClient is the client API for OutOfStoreMessageService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +// +// OutOfStoreMessageService is the service used to open out-of-store messages (e.g. push notifications) +// It is used to open messages with a lightweight protocol service for mobile backgroup processes. type OutOfStoreMessageServiceClient interface { // OutOfStoreReceive parses a payload received outside a synchronized store OutOfStoreReceive(ctx context.Context, in *protocoltypes.OutOfStoreReceive_Request, opts ...grpc.CallOption) (*protocoltypes.OutOfStoreReceive_Reply, error) @@ -40,8 +43,9 @@ func NewOutOfStoreMessageServiceClient(cc grpc.ClientConnInterface) OutOfStoreMe } func (c *outOfStoreMessageServiceClient) OutOfStoreReceive(ctx context.Context, in *protocoltypes.OutOfStoreReceive_Request, opts ...grpc.CallOption) (*protocoltypes.OutOfStoreReceive_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(protocoltypes.OutOfStoreReceive_Reply) - err := c.cc.Invoke(ctx, OutOfStoreMessageService_OutOfStoreReceive_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, OutOfStoreMessageService_OutOfStoreReceive_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -50,22 +54,29 @@ func (c *outOfStoreMessageServiceClient) OutOfStoreReceive(ctx context.Context, // OutOfStoreMessageServiceServer is the server API for OutOfStoreMessageService service. // All implementations must embed UnimplementedOutOfStoreMessageServiceServer -// for forward compatibility +// for forward compatibility. +// +// OutOfStoreMessageService is the service used to open out-of-store messages (e.g. push notifications) +// It is used to open messages with a lightweight protocol service for mobile backgroup processes. type OutOfStoreMessageServiceServer interface { // OutOfStoreReceive parses a payload received outside a synchronized store OutOfStoreReceive(context.Context, *protocoltypes.OutOfStoreReceive_Request) (*protocoltypes.OutOfStoreReceive_Reply, error) mustEmbedUnimplementedOutOfStoreMessageServiceServer() } -// UnimplementedOutOfStoreMessageServiceServer must be embedded to have forward compatible implementations. -type UnimplementedOutOfStoreMessageServiceServer struct { -} +// UnimplementedOutOfStoreMessageServiceServer must be embedded to have +// forward compatible implementations. +// +// NOTE: this should be embedded by value instead of pointer to avoid a nil +// pointer dereference when methods are called. +type UnimplementedOutOfStoreMessageServiceServer struct{} func (UnimplementedOutOfStoreMessageServiceServer) OutOfStoreReceive(context.Context, *protocoltypes.OutOfStoreReceive_Request) (*protocoltypes.OutOfStoreReceive_Reply, error) { return nil, status.Errorf(codes.Unimplemented, "method OutOfStoreReceive not implemented") } func (UnimplementedOutOfStoreMessageServiceServer) mustEmbedUnimplementedOutOfStoreMessageServiceServer() { } +func (UnimplementedOutOfStoreMessageServiceServer) testEmbeddedByValue() {} // UnsafeOutOfStoreMessageServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to OutOfStoreMessageServiceServer will @@ -75,6 +86,13 @@ type UnsafeOutOfStoreMessageServiceServer interface { } func RegisterOutOfStoreMessageServiceServer(s grpc.ServiceRegistrar, srv OutOfStoreMessageServiceServer) { + // If the following call pancis, it indicates UnimplementedOutOfStoreMessageServiceServer was + // embedded by pointer and is nil. This will cause panics if an + // unimplemented method is ever invoked, so we test this at initialization + // time to prevent it from happening at runtime later due to I/O. + if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { + t.testEmbeddedByValue() + } s.RegisterService(&OutOfStoreMessageService_ServiceDesc, srv) } diff --git a/pkg/protocoltypes/protocoltypes.pb.go b/pkg/protocoltypes/protocoltypes.pb.go index 44ca12a6..3fdc10ba 100644 --- a/pkg/protocoltypes/protocoltypes.pb.go +++ b/pkg/protocoltypes/protocoltypes.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: protocoltypes.proto @@ -11239,7 +11239,7 @@ func file_protocoltypes_proto_rawDescGZIP() []byte { var file_protocoltypes_proto_enumTypes = make([]protoimpl.EnumInfo, 9) var file_protocoltypes_proto_msgTypes = make([]protoimpl.MessageInfo, 178) -var file_protocoltypes_proto_goTypes = []interface{}{ +var file_protocoltypes_proto_goTypes = []any{ (GroupType)(0), // 0: weshnet.protocol.v1.GroupType (EventType)(0), // 1: weshnet.protocol.v1.EventType (DebugInspectGroupLogType)(0), // 2: weshnet.protocol.v1.DebugInspectGroupLogType @@ -11563,7 +11563,7 @@ func file_protocoltypes_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_protocoltypes_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*Account); i { case 0: return &v.state @@ -11575,7 +11575,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*Group); i { case 0: return &v.state @@ -11587,7 +11587,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*GroupHeadsExport); i { case 0: return &v.state @@ -11599,7 +11599,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[3].Exporter = func(v any, i int) any { switch v := v.(*GroupMetadata); i { case 0: return &v.state @@ -11611,7 +11611,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[4].Exporter = func(v any, i int) any { switch v := v.(*GroupEnvelope); i { case 0: return &v.state @@ -11623,7 +11623,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[5].Exporter = func(v any, i int) any { switch v := v.(*MessageHeaders); i { case 0: return &v.state @@ -11635,7 +11635,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[6].Exporter = func(v any, i int) any { switch v := v.(*ProtocolMetadata); i { case 0: return &v.state @@ -11647,7 +11647,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[7].Exporter = func(v any, i int) any { switch v := v.(*EncryptedMessage); i { case 0: return &v.state @@ -11659,7 +11659,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[8].Exporter = func(v any, i int) any { switch v := v.(*MessageEnvelope); i { case 0: return &v.state @@ -11671,7 +11671,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[9].Exporter = func(v any, i int) any { switch v := v.(*EventContext); i { case 0: return &v.state @@ -11683,7 +11683,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[10].Exporter = func(v any, i int) any { switch v := v.(*GroupMetadataPayloadSent); i { case 0: return &v.state @@ -11695,7 +11695,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[11].Exporter = func(v any, i int) any { switch v := v.(*ContactAliasKeyAdded); i { case 0: return &v.state @@ -11707,7 +11707,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[12].Exporter = func(v any, i int) any { switch v := v.(*GroupMemberDeviceAdded); i { case 0: return &v.state @@ -11719,7 +11719,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[13].Exporter = func(v any, i int) any { switch v := v.(*DeviceChainKey); i { case 0: return &v.state @@ -11731,7 +11731,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[14].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceChainKeyAdded); i { case 0: return &v.state @@ -11743,7 +11743,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[15].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAliasResolverAdded); i { case 0: return &v.state @@ -11755,7 +11755,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[16].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAdminRoleGranted); i { case 0: return &v.state @@ -11767,7 +11767,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[17].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupInitialMemberAnnounced); i { case 0: return &v.state @@ -11779,7 +11779,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[18].Exporter = func(v any, i int) any { switch v := v.(*GroupAddAdditionalRendezvousSeed); i { case 0: return &v.state @@ -11791,7 +11791,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[19].Exporter = func(v any, i int) any { switch v := v.(*GroupRemoveAdditionalRendezvousSeed); i { case 0: return &v.state @@ -11803,7 +11803,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[20].Exporter = func(v any, i int) any { switch v := v.(*AccountGroupJoined); i { case 0: return &v.state @@ -11815,7 +11815,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[21].Exporter = func(v any, i int) any { switch v := v.(*AccountGroupLeft); i { case 0: return &v.state @@ -11827,7 +11827,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[22].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestDisabled); i { case 0: return &v.state @@ -11839,7 +11839,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[23].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestEnabled); i { case 0: return &v.state @@ -11851,7 +11851,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[24].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestReferenceReset); i { case 0: return &v.state @@ -11863,7 +11863,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[25].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestOutgoingEnqueued); i { case 0: return &v.state @@ -11875,7 +11875,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[26].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestOutgoingSent); i { case 0: return &v.state @@ -11887,7 +11887,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[27].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestIncomingReceived); i { case 0: return &v.state @@ -11899,7 +11899,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[28].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestIncomingDiscarded); i { case 0: return &v.state @@ -11911,7 +11911,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[29].Exporter = func(v any, i int) any { switch v := v.(*AccountContactRequestIncomingAccepted); i { case 0: return &v.state @@ -11923,7 +11923,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[30].Exporter = func(v any, i int) any { switch v := v.(*AccountContactBlocked); i { case 0: return &v.state @@ -11935,7 +11935,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[31].Exporter = func(v any, i int) any { switch v := v.(*AccountContactUnblocked); i { case 0: return &v.state @@ -11947,7 +11947,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[32].Exporter = func(v any, i int) any { switch v := v.(*GroupReplicating); i { case 0: return &v.state @@ -11959,7 +11959,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[33].Exporter = func(v any, i int) any { switch v := v.(*ServiceExportData); i { case 0: return &v.state @@ -11971,7 +11971,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[34].Exporter = func(v any, i int) any { switch v := v.(*ServiceGetConfiguration); i { case 0: return &v.state @@ -11983,7 +11983,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[35].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestReference); i { case 0: return &v.state @@ -11995,7 +11995,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[36].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDisable); i { case 0: return &v.state @@ -12007,7 +12007,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[37].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestEnable); i { case 0: return &v.state @@ -12019,7 +12019,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[38].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestResetReference); i { case 0: return &v.state @@ -12031,7 +12031,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[39].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[39].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestSend); i { case 0: return &v.state @@ -12043,7 +12043,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[40].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[40].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestAccept); i { case 0: return &v.state @@ -12055,7 +12055,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[41].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[41].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDiscard); i { case 0: return &v.state @@ -12067,7 +12067,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[42].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[42].Exporter = func(v any, i int) any { switch v := v.(*ShareContact); i { case 0: return &v.state @@ -12079,7 +12079,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[43].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[43].Exporter = func(v any, i int) any { switch v := v.(*DecodeContact); i { case 0: return &v.state @@ -12091,7 +12091,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[44].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[44].Exporter = func(v any, i int) any { switch v := v.(*ContactBlock); i { case 0: return &v.state @@ -12103,7 +12103,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[45].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[45].Exporter = func(v any, i int) any { switch v := v.(*ContactUnblock); i { case 0: return &v.state @@ -12115,7 +12115,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[46].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[46].Exporter = func(v any, i int) any { switch v := v.(*ContactAliasKeySend); i { case 0: return &v.state @@ -12127,7 +12127,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[47].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[47].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupCreate); i { case 0: return &v.state @@ -12139,7 +12139,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[48].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupJoin); i { case 0: return &v.state @@ -12151,7 +12151,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[49].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[49].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupLeave); i { case 0: return &v.state @@ -12163,7 +12163,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[50].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[50].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAliasResolverDisclose); i { case 0: return &v.state @@ -12175,7 +12175,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[51].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[51].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAdminRoleGrant); i { case 0: return &v.state @@ -12187,7 +12187,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[52].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[52].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupInvitationCreate); i { case 0: return &v.state @@ -12199,7 +12199,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[53].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[53].Exporter = func(v any, i int) any { switch v := v.(*AppMetadataSend); i { case 0: return &v.state @@ -12211,7 +12211,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[54].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[54].Exporter = func(v any, i int) any { switch v := v.(*AppMessageSend); i { case 0: return &v.state @@ -12223,7 +12223,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[55].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[55].Exporter = func(v any, i int) any { switch v := v.(*GroupMetadataEvent); i { case 0: return &v.state @@ -12235,7 +12235,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[56].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[56].Exporter = func(v any, i int) any { switch v := v.(*GroupMessageEvent); i { case 0: return &v.state @@ -12247,7 +12247,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[57].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[57].Exporter = func(v any, i int) any { switch v := v.(*GroupMetadataList); i { case 0: return &v.state @@ -12259,7 +12259,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[58].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[58].Exporter = func(v any, i int) any { switch v := v.(*GroupMessageList); i { case 0: return &v.state @@ -12271,7 +12271,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[59].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[59].Exporter = func(v any, i int) any { switch v := v.(*GroupInfo); i { case 0: return &v.state @@ -12283,7 +12283,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[60].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[60].Exporter = func(v any, i int) any { switch v := v.(*ActivateGroup); i { case 0: return &v.state @@ -12295,7 +12295,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[61].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[61].Exporter = func(v any, i int) any { switch v := v.(*DeactivateGroup); i { case 0: return &v.state @@ -12307,7 +12307,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[62].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[62].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus); i { case 0: return &v.state @@ -12319,7 +12319,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[63].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[63].Exporter = func(v any, i int) any { switch v := v.(*DebugListGroups); i { case 0: return &v.state @@ -12331,7 +12331,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[64].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[64].Exporter = func(v any, i int) any { switch v := v.(*DebugInspectGroupStore); i { case 0: return &v.state @@ -12343,7 +12343,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[65].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[65].Exporter = func(v any, i int) any { switch v := v.(*DebugGroup); i { case 0: return &v.state @@ -12355,7 +12355,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[66].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[66].Exporter = func(v any, i int) any { switch v := v.(*ShareableContact); i { case 0: return &v.state @@ -12367,7 +12367,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[67].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[67].Exporter = func(v any, i int) any { switch v := v.(*ServiceTokenSupportedService); i { case 0: return &v.state @@ -12379,7 +12379,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[68].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[68].Exporter = func(v any, i int) any { switch v := v.(*ServiceToken); i { case 0: return &v.state @@ -12391,7 +12391,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[69].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[69].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceInitFlow); i { case 0: return &v.state @@ -12403,7 +12403,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[70].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[70].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceCompleteFlow); i { case 0: return &v.state @@ -12415,7 +12415,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[71].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[71].Exporter = func(v any, i int) any { switch v := v.(*VerifiedCredentialsList); i { case 0: return &v.state @@ -12427,7 +12427,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[72].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[72].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceRegisterGroup); i { case 0: return &v.state @@ -12439,7 +12439,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[73].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[73].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup); i { case 0: return &v.state @@ -12451,7 +12451,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[74].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[74].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo); i { case 0: return &v.state @@ -12463,7 +12463,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[75].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[75].Exporter = func(v any, i int) any { switch v := v.(*PeerList); i { case 0: return &v.state @@ -12475,7 +12475,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[76].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[76].Exporter = func(v any, i int) any { switch v := v.(*Progress); i { case 0: return &v.state @@ -12487,7 +12487,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[77].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[77].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreMessage); i { case 0: return &v.state @@ -12499,7 +12499,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[78].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[78].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreMessageEnvelope); i { case 0: return &v.state @@ -12511,7 +12511,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[79].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[79].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreReceive); i { case 0: return &v.state @@ -12523,7 +12523,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[80].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[80].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreSeal); i { case 0: return &v.state @@ -12535,7 +12535,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[81].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[81].Exporter = func(v any, i int) any { switch v := v.(*AccountVerifiedCredentialRegistered); i { case 0: return &v.state @@ -12547,7 +12547,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[82].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[82].Exporter = func(v any, i int) any { switch v := v.(*FirstLastCounters); i { case 0: return &v.state @@ -12559,7 +12559,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[83].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[83].Exporter = func(v any, i int) any { switch v := v.(*OrbitDBMessageHeads); i { case 0: return &v.state @@ -12571,7 +12571,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[84].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[84].Exporter = func(v any, i int) any { switch v := v.(*RefreshContactRequest); i { case 0: return &v.state @@ -12583,7 +12583,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[86].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[86].Exporter = func(v any, i int) any { switch v := v.(*ServiceExportData_Request); i { case 0: return &v.state @@ -12595,7 +12595,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[87].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[87].Exporter = func(v any, i int) any { switch v := v.(*ServiceExportData_Reply); i { case 0: return &v.state @@ -12607,7 +12607,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[88].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[88].Exporter = func(v any, i int) any { switch v := v.(*ServiceGetConfiguration_Request); i { case 0: return &v.state @@ -12619,7 +12619,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[89].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[89].Exporter = func(v any, i int) any { switch v := v.(*ServiceGetConfiguration_Reply); i { case 0: return &v.state @@ -12631,7 +12631,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[90].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[90].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestReference_Request); i { case 0: return &v.state @@ -12643,7 +12643,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[91].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[91].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestReference_Reply); i { case 0: return &v.state @@ -12655,7 +12655,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[92].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[92].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDisable_Request); i { case 0: return &v.state @@ -12667,7 +12667,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[93].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[93].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDisable_Reply); i { case 0: return &v.state @@ -12679,7 +12679,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[94].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[94].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestEnable_Request); i { case 0: return &v.state @@ -12691,7 +12691,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[95].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[95].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestEnable_Reply); i { case 0: return &v.state @@ -12703,7 +12703,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[96].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[96].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestResetReference_Request); i { case 0: return &v.state @@ -12715,7 +12715,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[97].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[97].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestResetReference_Reply); i { case 0: return &v.state @@ -12727,7 +12727,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[98].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[98].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestSend_Request); i { case 0: return &v.state @@ -12739,7 +12739,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[99].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[99].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestSend_Reply); i { case 0: return &v.state @@ -12751,7 +12751,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[100].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[100].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestAccept_Request); i { case 0: return &v.state @@ -12763,7 +12763,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[101].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[101].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestAccept_Reply); i { case 0: return &v.state @@ -12775,7 +12775,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[102].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[102].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDiscard_Request); i { case 0: return &v.state @@ -12787,7 +12787,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[103].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[103].Exporter = func(v any, i int) any { switch v := v.(*ContactRequestDiscard_Reply); i { case 0: return &v.state @@ -12799,7 +12799,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[104].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[104].Exporter = func(v any, i int) any { switch v := v.(*ShareContact_Request); i { case 0: return &v.state @@ -12811,7 +12811,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[105].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[105].Exporter = func(v any, i int) any { switch v := v.(*ShareContact_Reply); i { case 0: return &v.state @@ -12823,7 +12823,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[106].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[106].Exporter = func(v any, i int) any { switch v := v.(*DecodeContact_Request); i { case 0: return &v.state @@ -12835,7 +12835,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[107].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[107].Exporter = func(v any, i int) any { switch v := v.(*DecodeContact_Reply); i { case 0: return &v.state @@ -12847,7 +12847,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[108].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[108].Exporter = func(v any, i int) any { switch v := v.(*ContactBlock_Request); i { case 0: return &v.state @@ -12859,7 +12859,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[109].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[109].Exporter = func(v any, i int) any { switch v := v.(*ContactBlock_Reply); i { case 0: return &v.state @@ -12871,7 +12871,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[110].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[110].Exporter = func(v any, i int) any { switch v := v.(*ContactUnblock_Request); i { case 0: return &v.state @@ -12883,7 +12883,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[111].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[111].Exporter = func(v any, i int) any { switch v := v.(*ContactUnblock_Reply); i { case 0: return &v.state @@ -12895,7 +12895,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[112].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[112].Exporter = func(v any, i int) any { switch v := v.(*ContactAliasKeySend_Request); i { case 0: return &v.state @@ -12907,7 +12907,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[113].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[113].Exporter = func(v any, i int) any { switch v := v.(*ContactAliasKeySend_Reply); i { case 0: return &v.state @@ -12919,7 +12919,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[114].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[114].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupCreate_Request); i { case 0: return &v.state @@ -12931,7 +12931,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[115].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[115].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupCreate_Reply); i { case 0: return &v.state @@ -12943,7 +12943,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[116].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[116].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupJoin_Request); i { case 0: return &v.state @@ -12955,7 +12955,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[117].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[117].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupJoin_Reply); i { case 0: return &v.state @@ -12967,7 +12967,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[118].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[118].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupLeave_Request); i { case 0: return &v.state @@ -12979,7 +12979,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[119].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[119].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupLeave_Reply); i { case 0: return &v.state @@ -12991,7 +12991,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[120].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[120].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAliasResolverDisclose_Request); i { case 0: return &v.state @@ -13003,7 +13003,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[121].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[121].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAliasResolverDisclose_Reply); i { case 0: return &v.state @@ -13015,7 +13015,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[122].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[122].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAdminRoleGrant_Request); i { case 0: return &v.state @@ -13027,7 +13027,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[123].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[123].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupAdminRoleGrant_Reply); i { case 0: return &v.state @@ -13039,7 +13039,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[124].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[124].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupInvitationCreate_Request); i { case 0: return &v.state @@ -13051,7 +13051,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[125].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[125].Exporter = func(v any, i int) any { switch v := v.(*MultiMemberGroupInvitationCreate_Reply); i { case 0: return &v.state @@ -13063,7 +13063,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[126].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[126].Exporter = func(v any, i int) any { switch v := v.(*AppMetadataSend_Request); i { case 0: return &v.state @@ -13075,7 +13075,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[127].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[127].Exporter = func(v any, i int) any { switch v := v.(*AppMetadataSend_Reply); i { case 0: return &v.state @@ -13087,7 +13087,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[128].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[128].Exporter = func(v any, i int) any { switch v := v.(*AppMessageSend_Request); i { case 0: return &v.state @@ -13099,7 +13099,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[129].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[129].Exporter = func(v any, i int) any { switch v := v.(*AppMessageSend_Reply); i { case 0: return &v.state @@ -13111,7 +13111,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[130].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[130].Exporter = func(v any, i int) any { switch v := v.(*GroupMetadataList_Request); i { case 0: return &v.state @@ -13123,7 +13123,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[131].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[131].Exporter = func(v any, i int) any { switch v := v.(*GroupMessageList_Request); i { case 0: return &v.state @@ -13135,7 +13135,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[132].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[132].Exporter = func(v any, i int) any { switch v := v.(*GroupInfo_Request); i { case 0: return &v.state @@ -13147,7 +13147,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[133].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[133].Exporter = func(v any, i int) any { switch v := v.(*GroupInfo_Reply); i { case 0: return &v.state @@ -13159,7 +13159,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[134].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[134].Exporter = func(v any, i int) any { switch v := v.(*ActivateGroup_Request); i { case 0: return &v.state @@ -13171,7 +13171,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[135].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[135].Exporter = func(v any, i int) any { switch v := v.(*ActivateGroup_Reply); i { case 0: return &v.state @@ -13183,7 +13183,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[136].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[136].Exporter = func(v any, i int) any { switch v := v.(*DeactivateGroup_Request); i { case 0: return &v.state @@ -13195,7 +13195,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[137].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[137].Exporter = func(v any, i int) any { switch v := v.(*DeactivateGroup_Reply); i { case 0: return &v.state @@ -13207,7 +13207,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[138].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[138].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus_Request); i { case 0: return &v.state @@ -13219,7 +13219,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[139].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[139].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus_Reply); i { case 0: return &v.state @@ -13231,7 +13231,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[140].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[140].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus_Reply_PeerConnected); i { case 0: return &v.state @@ -13243,7 +13243,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[141].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[141].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus_Reply_PeerReconnecting); i { case 0: return &v.state @@ -13255,7 +13255,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[142].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[142].Exporter = func(v any, i int) any { switch v := v.(*GroupDeviceStatus_Reply_PeerDisconnected); i { case 0: return &v.state @@ -13267,7 +13267,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[143].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[143].Exporter = func(v any, i int) any { switch v := v.(*DebugListGroups_Request); i { case 0: return &v.state @@ -13279,7 +13279,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[144].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[144].Exporter = func(v any, i int) any { switch v := v.(*DebugListGroups_Reply); i { case 0: return &v.state @@ -13291,7 +13291,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[145].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[145].Exporter = func(v any, i int) any { switch v := v.(*DebugInspectGroupStore_Request); i { case 0: return &v.state @@ -13303,7 +13303,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[146].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[146].Exporter = func(v any, i int) any { switch v := v.(*DebugInspectGroupStore_Reply); i { case 0: return &v.state @@ -13315,7 +13315,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[147].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[147].Exporter = func(v any, i int) any { switch v := v.(*DebugGroup_Request); i { case 0: return &v.state @@ -13327,7 +13327,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[148].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[148].Exporter = func(v any, i int) any { switch v := v.(*DebugGroup_Reply); i { case 0: return &v.state @@ -13339,7 +13339,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[149].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[149].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceInitFlow_Request); i { case 0: return &v.state @@ -13351,7 +13351,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[150].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[150].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceInitFlow_Reply); i { case 0: return &v.state @@ -13363,7 +13363,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[151].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[151].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceCompleteFlow_Request); i { case 0: return &v.state @@ -13375,7 +13375,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[152].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[152].Exporter = func(v any, i int) any { switch v := v.(*CredentialVerificationServiceCompleteFlow_Reply); i { case 0: return &v.state @@ -13387,7 +13387,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[153].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[153].Exporter = func(v any, i int) any { switch v := v.(*VerifiedCredentialsList_Request); i { case 0: return &v.state @@ -13399,7 +13399,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[154].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[154].Exporter = func(v any, i int) any { switch v := v.(*VerifiedCredentialsList_Reply); i { case 0: return &v.state @@ -13411,7 +13411,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[155].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[155].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceRegisterGroup_Request); i { case 0: return &v.state @@ -13423,7 +13423,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[156].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[156].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceRegisterGroup_Reply); i { case 0: return &v.state @@ -13435,7 +13435,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[157].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[157].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup_Request); i { case 0: return &v.state @@ -13447,7 +13447,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[158].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[158].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup_Reply); i { case 0: return &v.state @@ -13459,7 +13459,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[159].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[159].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_Request); i { case 0: return &v.state @@ -13471,7 +13471,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[160].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[160].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_Reply); i { case 0: return &v.state @@ -13483,7 +13483,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[161].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[161].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_OrbitDB); i { case 0: return &v.state @@ -13495,7 +13495,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[162].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[162].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_P2P); i { case 0: return &v.state @@ -13507,7 +13507,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[163].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[163].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_Process); i { case 0: return &v.state @@ -13519,7 +13519,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[164].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[164].Exporter = func(v any, i int) any { switch v := v.(*SystemInfo_OrbitDB_ReplicationStatus); i { case 0: return &v.state @@ -13531,7 +13531,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[165].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[165].Exporter = func(v any, i int) any { switch v := v.(*PeerList_Request); i { case 0: return &v.state @@ -13543,7 +13543,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[166].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[166].Exporter = func(v any, i int) any { switch v := v.(*PeerList_Reply); i { case 0: return &v.state @@ -13555,7 +13555,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[167].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[167].Exporter = func(v any, i int) any { switch v := v.(*PeerList_Peer); i { case 0: return &v.state @@ -13567,7 +13567,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[168].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[168].Exporter = func(v any, i int) any { switch v := v.(*PeerList_Route); i { case 0: return &v.state @@ -13579,7 +13579,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[169].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[169].Exporter = func(v any, i int) any { switch v := v.(*PeerList_Stream); i { case 0: return &v.state @@ -13591,7 +13591,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[170].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[170].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreReceive_Request); i { case 0: return &v.state @@ -13603,7 +13603,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[171].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[171].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreReceive_Reply); i { case 0: return &v.state @@ -13615,7 +13615,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[172].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[172].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreSeal_Request); i { case 0: return &v.state @@ -13627,7 +13627,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[173].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[173].Exporter = func(v any, i int) any { switch v := v.(*OutOfStoreSeal_Reply); i { case 0: return &v.state @@ -13639,7 +13639,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[174].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[174].Exporter = func(v any, i int) any { switch v := v.(*OrbitDBMessageHeads_Box); i { case 0: return &v.state @@ -13651,7 +13651,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[175].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[175].Exporter = func(v any, i int) any { switch v := v.(*RefreshContactRequest_Peer); i { case 0: return &v.state @@ -13663,7 +13663,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[176].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[176].Exporter = func(v any, i int) any { switch v := v.(*RefreshContactRequest_Request); i { case 0: return &v.state @@ -13675,7 +13675,7 @@ func file_protocoltypes_proto_init() { return nil } } - file_protocoltypes_proto_msgTypes[177].Exporter = func(v interface{}, i int) interface{} { + file_protocoltypes_proto_msgTypes[177].Exporter = func(v any, i int) any { switch v := v.(*RefreshContactRequest_Reply); i { case 0: return &v.state diff --git a/pkg/protocoltypes/protocoltypes_grpc.pb.go b/pkg/protocoltypes/protocoltypes_grpc.pb.go index dcf2ec4b..51d0a398 100644 --- a/pkg/protocoltypes/protocoltypes_grpc.pb.go +++ b/pkg/protocoltypes/protocoltypes_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 +// - protoc-gen-go-grpc v1.5.1 // - protoc (unknown) // source: protocoltypes.proto @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.64.0 or later. +const _ = grpc.SupportPackageIsVersion9 const ( ProtocolService_ServiceExportData_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ServiceExportData" @@ -64,9 +64,12 @@ const ( // ProtocolServiceClient is the client API for ProtocolService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +// +// ProtocolService is the top-level API to manage the Wesh protocol service. +// Each active Wesh protocol service is considered as a Wesh device and is associated with a Wesh user. type ProtocolServiceClient interface { // ServiceExportData exports the current data of the protocol service - ServiceExportData(ctx context.Context, in *ServiceExportData_Request, opts ...grpc.CallOption) (ProtocolService_ServiceExportDataClient, error) + ServiceExportData(ctx context.Context, in *ServiceExportData_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ServiceExportData_Reply], error) // ServiceGetConfiguration gets the current configuration of the protocol service ServiceGetConfiguration(ctx context.Context, in *ServiceGetConfiguration_Request, opts ...grpc.CallOption) (*ServiceGetConfiguration_Reply, error) // ContactRequestReference retrieves the information required to create a reference (ie. included in a shareable link) to the current account @@ -112,9 +115,9 @@ type ProtocolServiceClient interface { // AppMessageSend adds an app event to the message store, the message is encrypted using a derived key and readable by current group members AppMessageSend(ctx context.Context, in *AppMessageSend_Request, opts ...grpc.CallOption) (*AppMessageSend_Reply, error) // GroupMetadataList replays previous and subscribes to new metadata events from the group - GroupMetadataList(ctx context.Context, in *GroupMetadataList_Request, opts ...grpc.CallOption) (ProtocolService_GroupMetadataListClient, error) + GroupMetadataList(ctx context.Context, in *GroupMetadataList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupMetadataEvent], error) // GroupMessageList replays previous and subscribes to new message events from the group - GroupMessageList(ctx context.Context, in *GroupMessageList_Request, opts ...grpc.CallOption) (ProtocolService_GroupMessageListClient, error) + GroupMessageList(ctx context.Context, in *GroupMessageList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupMessageEvent], error) // GroupInfo retrieves information about a group GroupInfo(ctx context.Context, in *GroupInfo_Request, opts ...grpc.CallOption) (*GroupInfo_Reply, error) // ActivateGroup explicitly opens a group @@ -122,9 +125,9 @@ type ProtocolServiceClient interface { // DeactivateGroup closes a group DeactivateGroup(ctx context.Context, in *DeactivateGroup_Request, opts ...grpc.CallOption) (*DeactivateGroup_Reply, error) // GroupDeviceStatus monitor device status - GroupDeviceStatus(ctx context.Context, in *GroupDeviceStatus_Request, opts ...grpc.CallOption) (ProtocolService_GroupDeviceStatusClient, error) - DebugListGroups(ctx context.Context, in *DebugListGroups_Request, opts ...grpc.CallOption) (ProtocolService_DebugListGroupsClient, error) - DebugInspectGroupStore(ctx context.Context, in *DebugInspectGroupStore_Request, opts ...grpc.CallOption) (ProtocolService_DebugInspectGroupStoreClient, error) + GroupDeviceStatus(ctx context.Context, in *GroupDeviceStatus_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupDeviceStatus_Reply], error) + DebugListGroups(ctx context.Context, in *DebugListGroups_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DebugListGroups_Reply], error) + DebugInspectGroupStore(ctx context.Context, in *DebugInspectGroupStore_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DebugInspectGroupStore_Reply], error) DebugGroup(ctx context.Context, in *DebugGroup_Request, opts ...grpc.CallOption) (*DebugGroup_Reply, error) SystemInfo(ctx context.Context, in *SystemInfo_Request, opts ...grpc.CallOption) (*SystemInfo_Reply, error) // CredentialVerificationServiceInitFlow Initialize a credential verification flow @@ -132,7 +135,7 @@ type ProtocolServiceClient interface { // CredentialVerificationServiceCompleteFlow Completes a credential verification flow CredentialVerificationServiceCompleteFlow(ctx context.Context, in *CredentialVerificationServiceCompleteFlow_Request, opts ...grpc.CallOption) (*CredentialVerificationServiceCompleteFlow_Reply, error) // VerifiedCredentialsList Retrieves the list of verified credentials - VerifiedCredentialsList(ctx context.Context, in *VerifiedCredentialsList_Request, opts ...grpc.CallOption) (ProtocolService_VerifiedCredentialsListClient, error) + VerifiedCredentialsList(ctx context.Context, in *VerifiedCredentialsList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[VerifiedCredentialsList_Reply], error) // ReplicationServiceRegisterGroup Asks a replication service to distribute a group contents ReplicationServiceRegisterGroup(ctx context.Context, in *ReplicationServiceRegisterGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceRegisterGroup_Reply, error) // PeerList returns a list of P2P peers @@ -153,12 +156,13 @@ func NewProtocolServiceClient(cc grpc.ClientConnInterface) ProtocolServiceClient return &protocolServiceClient{cc} } -func (c *protocolServiceClient) ServiceExportData(ctx context.Context, in *ServiceExportData_Request, opts ...grpc.CallOption) (ProtocolService_ServiceExportDataClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[0], ProtocolService_ServiceExportData_FullMethodName, opts...) +func (c *protocolServiceClient) ServiceExportData(ctx context.Context, in *ServiceExportData_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ServiceExportData_Reply], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[0], ProtocolService_ServiceExportData_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceServiceExportDataClient{stream} + x := &grpc.GenericClientStream[ServiceExportData_Request, ServiceExportData_Reply]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -168,26 +172,13 @@ func (c *protocolServiceClient) ServiceExportData(ctx context.Context, in *Servi return x, nil } -type ProtocolService_ServiceExportDataClient interface { - Recv() (*ServiceExportData_Reply, error) - grpc.ClientStream -} - -type protocolServiceServiceExportDataClient struct { - grpc.ClientStream -} - -func (x *protocolServiceServiceExportDataClient) Recv() (*ServiceExportData_Reply, error) { - m := new(ServiceExportData_Reply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_ServiceExportDataClient = grpc.ServerStreamingClient[ServiceExportData_Reply] func (c *protocolServiceClient) ServiceGetConfiguration(ctx context.Context, in *ServiceGetConfiguration_Request, opts ...grpc.CallOption) (*ServiceGetConfiguration_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ServiceGetConfiguration_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ServiceGetConfiguration_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ServiceGetConfiguration_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -195,8 +186,9 @@ func (c *protocolServiceClient) ServiceGetConfiguration(ctx context.Context, in } func (c *protocolServiceClient) ContactRequestReference(ctx context.Context, in *ContactRequestReference_Request, opts ...grpc.CallOption) (*ContactRequestReference_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestReference_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestReference_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestReference_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -204,8 +196,9 @@ func (c *protocolServiceClient) ContactRequestReference(ctx context.Context, in } func (c *protocolServiceClient) ContactRequestDisable(ctx context.Context, in *ContactRequestDisable_Request, opts ...grpc.CallOption) (*ContactRequestDisable_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestDisable_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDisable_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDisable_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -213,8 +206,9 @@ func (c *protocolServiceClient) ContactRequestDisable(ctx context.Context, in *C } func (c *protocolServiceClient) ContactRequestEnable(ctx context.Context, in *ContactRequestEnable_Request, opts ...grpc.CallOption) (*ContactRequestEnable_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestEnable_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestEnable_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestEnable_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -222,8 +216,9 @@ func (c *protocolServiceClient) ContactRequestEnable(ctx context.Context, in *Co } func (c *protocolServiceClient) ContactRequestResetReference(ctx context.Context, in *ContactRequestResetReference_Request, opts ...grpc.CallOption) (*ContactRequestResetReference_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestResetReference_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestResetReference_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestResetReference_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -231,8 +226,9 @@ func (c *protocolServiceClient) ContactRequestResetReference(ctx context.Context } func (c *protocolServiceClient) ContactRequestSend(ctx context.Context, in *ContactRequestSend_Request, opts ...grpc.CallOption) (*ContactRequestSend_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestSend_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestSend_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestSend_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -240,8 +236,9 @@ func (c *protocolServiceClient) ContactRequestSend(ctx context.Context, in *Cont } func (c *protocolServiceClient) ContactRequestAccept(ctx context.Context, in *ContactRequestAccept_Request, opts ...grpc.CallOption) (*ContactRequestAccept_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestAccept_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestAccept_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestAccept_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -249,8 +246,9 @@ func (c *protocolServiceClient) ContactRequestAccept(ctx context.Context, in *Co } func (c *protocolServiceClient) ContactRequestDiscard(ctx context.Context, in *ContactRequestDiscard_Request, opts ...grpc.CallOption) (*ContactRequestDiscard_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactRequestDiscard_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDiscard_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDiscard_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -258,8 +256,9 @@ func (c *protocolServiceClient) ContactRequestDiscard(ctx context.Context, in *C } func (c *protocolServiceClient) ShareContact(ctx context.Context, in *ShareContact_Request, opts ...grpc.CallOption) (*ShareContact_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ShareContact_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ShareContact_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ShareContact_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -267,8 +266,9 @@ func (c *protocolServiceClient) ShareContact(ctx context.Context, in *ShareConta } func (c *protocolServiceClient) DecodeContact(ctx context.Context, in *DecodeContact_Request, opts ...grpc.CallOption) (*DecodeContact_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(DecodeContact_Reply) - err := c.cc.Invoke(ctx, ProtocolService_DecodeContact_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DecodeContact_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -276,8 +276,9 @@ func (c *protocolServiceClient) DecodeContact(ctx context.Context, in *DecodeCon } func (c *protocolServiceClient) ContactBlock(ctx context.Context, in *ContactBlock_Request, opts ...grpc.CallOption) (*ContactBlock_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactBlock_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactBlock_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactBlock_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -285,8 +286,9 @@ func (c *protocolServiceClient) ContactBlock(ctx context.Context, in *ContactBlo } func (c *protocolServiceClient) ContactUnblock(ctx context.Context, in *ContactUnblock_Request, opts ...grpc.CallOption) (*ContactUnblock_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactUnblock_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactUnblock_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactUnblock_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -294,8 +296,9 @@ func (c *protocolServiceClient) ContactUnblock(ctx context.Context, in *ContactU } func (c *protocolServiceClient) ContactAliasKeySend(ctx context.Context, in *ContactAliasKeySend_Request, opts ...grpc.CallOption) (*ContactAliasKeySend_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ContactAliasKeySend_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ContactAliasKeySend_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactAliasKeySend_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -303,8 +306,9 @@ func (c *protocolServiceClient) ContactAliasKeySend(ctx context.Context, in *Con } func (c *protocolServiceClient) MultiMemberGroupCreate(ctx context.Context, in *MultiMemberGroupCreate_Request, opts ...grpc.CallOption) (*MultiMemberGroupCreate_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupCreate_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupCreate_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupCreate_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -312,8 +316,9 @@ func (c *protocolServiceClient) MultiMemberGroupCreate(ctx context.Context, in * } func (c *protocolServiceClient) MultiMemberGroupJoin(ctx context.Context, in *MultiMemberGroupJoin_Request, opts ...grpc.CallOption) (*MultiMemberGroupJoin_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupJoin_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupJoin_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupJoin_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -321,8 +326,9 @@ func (c *protocolServiceClient) MultiMemberGroupJoin(ctx context.Context, in *Mu } func (c *protocolServiceClient) MultiMemberGroupLeave(ctx context.Context, in *MultiMemberGroupLeave_Request, opts ...grpc.CallOption) (*MultiMemberGroupLeave_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupLeave_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupLeave_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupLeave_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -330,8 +336,9 @@ func (c *protocolServiceClient) MultiMemberGroupLeave(ctx context.Context, in *M } func (c *protocolServiceClient) MultiMemberGroupAliasResolverDisclose(ctx context.Context, in *MultiMemberGroupAliasResolverDisclose_Request, opts ...grpc.CallOption) (*MultiMemberGroupAliasResolverDisclose_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupAliasResolverDisclose_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAliasResolverDisclose_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAliasResolverDisclose_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -339,8 +346,9 @@ func (c *protocolServiceClient) MultiMemberGroupAliasResolverDisclose(ctx contex } func (c *protocolServiceClient) MultiMemberGroupAdminRoleGrant(ctx context.Context, in *MultiMemberGroupAdminRoleGrant_Request, opts ...grpc.CallOption) (*MultiMemberGroupAdminRoleGrant_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupAdminRoleGrant_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAdminRoleGrant_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAdminRoleGrant_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -348,8 +356,9 @@ func (c *protocolServiceClient) MultiMemberGroupAdminRoleGrant(ctx context.Conte } func (c *protocolServiceClient) MultiMemberGroupInvitationCreate(ctx context.Context, in *MultiMemberGroupInvitationCreate_Request, opts ...grpc.CallOption) (*MultiMemberGroupInvitationCreate_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(MultiMemberGroupInvitationCreate_Reply) - err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupInvitationCreate_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupInvitationCreate_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -357,8 +366,9 @@ func (c *protocolServiceClient) MultiMemberGroupInvitationCreate(ctx context.Con } func (c *protocolServiceClient) AppMetadataSend(ctx context.Context, in *AppMetadataSend_Request, opts ...grpc.CallOption) (*AppMetadataSend_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(AppMetadataSend_Reply) - err := c.cc.Invoke(ctx, ProtocolService_AppMetadataSend_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AppMetadataSend_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -366,20 +376,22 @@ func (c *protocolServiceClient) AppMetadataSend(ctx context.Context, in *AppMeta } func (c *protocolServiceClient) AppMessageSend(ctx context.Context, in *AppMessageSend_Request, opts ...grpc.CallOption) (*AppMessageSend_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(AppMessageSend_Reply) - err := c.cc.Invoke(ctx, ProtocolService_AppMessageSend_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AppMessageSend_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *protocolServiceClient) GroupMetadataList(ctx context.Context, in *GroupMetadataList_Request, opts ...grpc.CallOption) (ProtocolService_GroupMetadataListClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[1], ProtocolService_GroupMetadataList_FullMethodName, opts...) +func (c *protocolServiceClient) GroupMetadataList(ctx context.Context, in *GroupMetadataList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupMetadataEvent], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[1], ProtocolService_GroupMetadataList_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceGroupMetadataListClient{stream} + x := &grpc.GenericClientStream[GroupMetadataList_Request, GroupMetadataEvent]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -389,29 +401,16 @@ func (c *protocolServiceClient) GroupMetadataList(ctx context.Context, in *Group return x, nil } -type ProtocolService_GroupMetadataListClient interface { - Recv() (*GroupMetadataEvent, error) - grpc.ClientStream -} - -type protocolServiceGroupMetadataListClient struct { - grpc.ClientStream -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupMetadataListClient = grpc.ServerStreamingClient[GroupMetadataEvent] -func (x *protocolServiceGroupMetadataListClient) Recv() (*GroupMetadataEvent, error) { - m := new(GroupMetadataEvent) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -func (c *protocolServiceClient) GroupMessageList(ctx context.Context, in *GroupMessageList_Request, opts ...grpc.CallOption) (ProtocolService_GroupMessageListClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[2], ProtocolService_GroupMessageList_FullMethodName, opts...) +func (c *protocolServiceClient) GroupMessageList(ctx context.Context, in *GroupMessageList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupMessageEvent], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[2], ProtocolService_GroupMessageList_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceGroupMessageListClient{stream} + x := &grpc.GenericClientStream[GroupMessageList_Request, GroupMessageEvent]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -421,26 +420,13 @@ func (c *protocolServiceClient) GroupMessageList(ctx context.Context, in *GroupM return x, nil } -type ProtocolService_GroupMessageListClient interface { - Recv() (*GroupMessageEvent, error) - grpc.ClientStream -} - -type protocolServiceGroupMessageListClient struct { - grpc.ClientStream -} - -func (x *protocolServiceGroupMessageListClient) Recv() (*GroupMessageEvent, error) { - m := new(GroupMessageEvent) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupMessageListClient = grpc.ServerStreamingClient[GroupMessageEvent] func (c *protocolServiceClient) GroupInfo(ctx context.Context, in *GroupInfo_Request, opts ...grpc.CallOption) (*GroupInfo_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(GroupInfo_Reply) - err := c.cc.Invoke(ctx, ProtocolService_GroupInfo_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_GroupInfo_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -448,8 +434,9 @@ func (c *protocolServiceClient) GroupInfo(ctx context.Context, in *GroupInfo_Req } func (c *protocolServiceClient) ActivateGroup(ctx context.Context, in *ActivateGroup_Request, opts ...grpc.CallOption) (*ActivateGroup_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ActivateGroup_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ActivateGroup_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ActivateGroup_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -457,20 +444,22 @@ func (c *protocolServiceClient) ActivateGroup(ctx context.Context, in *ActivateG } func (c *protocolServiceClient) DeactivateGroup(ctx context.Context, in *DeactivateGroup_Request, opts ...grpc.CallOption) (*DeactivateGroup_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(DeactivateGroup_Reply) - err := c.cc.Invoke(ctx, ProtocolService_DeactivateGroup_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DeactivateGroup_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *protocolServiceClient) GroupDeviceStatus(ctx context.Context, in *GroupDeviceStatus_Request, opts ...grpc.CallOption) (ProtocolService_GroupDeviceStatusClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[3], ProtocolService_GroupDeviceStatus_FullMethodName, opts...) +func (c *protocolServiceClient) GroupDeviceStatus(ctx context.Context, in *GroupDeviceStatus_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[GroupDeviceStatus_Reply], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[3], ProtocolService_GroupDeviceStatus_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceGroupDeviceStatusClient{stream} + x := &grpc.GenericClientStream[GroupDeviceStatus_Request, GroupDeviceStatus_Reply]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -480,29 +469,16 @@ func (c *protocolServiceClient) GroupDeviceStatus(ctx context.Context, in *Group return x, nil } -type ProtocolService_GroupDeviceStatusClient interface { - Recv() (*GroupDeviceStatus_Reply, error) - grpc.ClientStream -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupDeviceStatusClient = grpc.ServerStreamingClient[GroupDeviceStatus_Reply] -type protocolServiceGroupDeviceStatusClient struct { - grpc.ClientStream -} - -func (x *protocolServiceGroupDeviceStatusClient) Recv() (*GroupDeviceStatus_Reply, error) { - m := new(GroupDeviceStatus_Reply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} - -func (c *protocolServiceClient) DebugListGroups(ctx context.Context, in *DebugListGroups_Request, opts ...grpc.CallOption) (ProtocolService_DebugListGroupsClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[4], ProtocolService_DebugListGroups_FullMethodName, opts...) +func (c *protocolServiceClient) DebugListGroups(ctx context.Context, in *DebugListGroups_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DebugListGroups_Reply], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[4], ProtocolService_DebugListGroups_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceDebugListGroupsClient{stream} + x := &grpc.GenericClientStream[DebugListGroups_Request, DebugListGroups_Reply]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -512,29 +488,16 @@ func (c *protocolServiceClient) DebugListGroups(ctx context.Context, in *DebugLi return x, nil } -type ProtocolService_DebugListGroupsClient interface { - Recv() (*DebugListGroups_Reply, error) - grpc.ClientStream -} - -type protocolServiceDebugListGroupsClient struct { - grpc.ClientStream -} - -func (x *protocolServiceDebugListGroupsClient) Recv() (*DebugListGroups_Reply, error) { - m := new(DebugListGroups_Reply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_DebugListGroupsClient = grpc.ServerStreamingClient[DebugListGroups_Reply] -func (c *protocolServiceClient) DebugInspectGroupStore(ctx context.Context, in *DebugInspectGroupStore_Request, opts ...grpc.CallOption) (ProtocolService_DebugInspectGroupStoreClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[5], ProtocolService_DebugInspectGroupStore_FullMethodName, opts...) +func (c *protocolServiceClient) DebugInspectGroupStore(ctx context.Context, in *DebugInspectGroupStore_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[DebugInspectGroupStore_Reply], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[5], ProtocolService_DebugInspectGroupStore_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceDebugInspectGroupStoreClient{stream} + x := &grpc.GenericClientStream[DebugInspectGroupStore_Request, DebugInspectGroupStore_Reply]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -544,26 +507,13 @@ func (c *protocolServiceClient) DebugInspectGroupStore(ctx context.Context, in * return x, nil } -type ProtocolService_DebugInspectGroupStoreClient interface { - Recv() (*DebugInspectGroupStore_Reply, error) - grpc.ClientStream -} - -type protocolServiceDebugInspectGroupStoreClient struct { - grpc.ClientStream -} - -func (x *protocolServiceDebugInspectGroupStoreClient) Recv() (*DebugInspectGroupStore_Reply, error) { - m := new(DebugInspectGroupStore_Reply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_DebugInspectGroupStoreClient = grpc.ServerStreamingClient[DebugInspectGroupStore_Reply] func (c *protocolServiceClient) DebugGroup(ctx context.Context, in *DebugGroup_Request, opts ...grpc.CallOption) (*DebugGroup_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(DebugGroup_Reply) - err := c.cc.Invoke(ctx, ProtocolService_DebugGroup_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DebugGroup_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -571,8 +521,9 @@ func (c *protocolServiceClient) DebugGroup(ctx context.Context, in *DebugGroup_R } func (c *protocolServiceClient) SystemInfo(ctx context.Context, in *SystemInfo_Request, opts ...grpc.CallOption) (*SystemInfo_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(SystemInfo_Reply) - err := c.cc.Invoke(ctx, ProtocolService_SystemInfo_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_SystemInfo_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -580,8 +531,9 @@ func (c *protocolServiceClient) SystemInfo(ctx context.Context, in *SystemInfo_R } func (c *protocolServiceClient) CredentialVerificationServiceInitFlow(ctx context.Context, in *CredentialVerificationServiceInitFlow_Request, opts ...grpc.CallOption) (*CredentialVerificationServiceInitFlow_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(CredentialVerificationServiceInitFlow_Reply) - err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceInitFlow_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceInitFlow_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -589,20 +541,22 @@ func (c *protocolServiceClient) CredentialVerificationServiceInitFlow(ctx contex } func (c *protocolServiceClient) CredentialVerificationServiceCompleteFlow(ctx context.Context, in *CredentialVerificationServiceCompleteFlow_Request, opts ...grpc.CallOption) (*CredentialVerificationServiceCompleteFlow_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(CredentialVerificationServiceCompleteFlow_Reply) - err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceCompleteFlow_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceCompleteFlow_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } return out, nil } -func (c *protocolServiceClient) VerifiedCredentialsList(ctx context.Context, in *VerifiedCredentialsList_Request, opts ...grpc.CallOption) (ProtocolService_VerifiedCredentialsListClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[6], ProtocolService_VerifiedCredentialsList_FullMethodName, opts...) +func (c *protocolServiceClient) VerifiedCredentialsList(ctx context.Context, in *VerifiedCredentialsList_Request, opts ...grpc.CallOption) (grpc.ServerStreamingClient[VerifiedCredentialsList_Reply], error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[6], ProtocolService_VerifiedCredentialsList_FullMethodName, cOpts...) if err != nil { return nil, err } - x := &protocolServiceVerifiedCredentialsListClient{stream} + x := &grpc.GenericClientStream[VerifiedCredentialsList_Request, VerifiedCredentialsList_Reply]{ClientStream: stream} if err := x.ClientStream.SendMsg(in); err != nil { return nil, err } @@ -612,26 +566,13 @@ func (c *protocolServiceClient) VerifiedCredentialsList(ctx context.Context, in return x, nil } -type ProtocolService_VerifiedCredentialsListClient interface { - Recv() (*VerifiedCredentialsList_Reply, error) - grpc.ClientStream -} - -type protocolServiceVerifiedCredentialsListClient struct { - grpc.ClientStream -} - -func (x *protocolServiceVerifiedCredentialsListClient) Recv() (*VerifiedCredentialsList_Reply, error) { - m := new(VerifiedCredentialsList_Reply) - if err := x.ClientStream.RecvMsg(m); err != nil { - return nil, err - } - return m, nil -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_VerifiedCredentialsListClient = grpc.ServerStreamingClient[VerifiedCredentialsList_Reply] func (c *protocolServiceClient) ReplicationServiceRegisterGroup(ctx context.Context, in *ReplicationServiceRegisterGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceRegisterGroup_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ReplicationServiceRegisterGroup_Reply) - err := c.cc.Invoke(ctx, ProtocolService_ReplicationServiceRegisterGroup_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ReplicationServiceRegisterGroup_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -639,8 +580,9 @@ func (c *protocolServiceClient) ReplicationServiceRegisterGroup(ctx context.Cont } func (c *protocolServiceClient) PeerList(ctx context.Context, in *PeerList_Request, opts ...grpc.CallOption) (*PeerList_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(PeerList_Reply) - err := c.cc.Invoke(ctx, ProtocolService_PeerList_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_PeerList_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -648,8 +590,9 @@ func (c *protocolServiceClient) PeerList(ctx context.Context, in *PeerList_Reque } func (c *protocolServiceClient) OutOfStoreReceive(ctx context.Context, in *OutOfStoreReceive_Request, opts ...grpc.CallOption) (*OutOfStoreReceive_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(OutOfStoreReceive_Reply) - err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreReceive_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreReceive_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -657,8 +600,9 @@ func (c *protocolServiceClient) OutOfStoreReceive(ctx context.Context, in *OutOf } func (c *protocolServiceClient) OutOfStoreSeal(ctx context.Context, in *OutOfStoreSeal_Request, opts ...grpc.CallOption) (*OutOfStoreSeal_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(OutOfStoreSeal_Reply) - err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreSeal_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreSeal_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -666,8 +610,9 @@ func (c *protocolServiceClient) OutOfStoreSeal(ctx context.Context, in *OutOfSto } func (c *protocolServiceClient) RefreshContactRequest(ctx context.Context, in *RefreshContactRequest_Request, opts ...grpc.CallOption) (*RefreshContactRequest_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(RefreshContactRequest_Reply) - err := c.cc.Invoke(ctx, ProtocolService_RefreshContactRequest_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_RefreshContactRequest_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -676,10 +621,13 @@ func (c *protocolServiceClient) RefreshContactRequest(ctx context.Context, in *R // ProtocolServiceServer is the server API for ProtocolService service. // All implementations must embed UnimplementedProtocolServiceServer -// for forward compatibility +// for forward compatibility. +// +// ProtocolService is the top-level API to manage the Wesh protocol service. +// Each active Wesh protocol service is considered as a Wesh device and is associated with a Wesh user. type ProtocolServiceServer interface { // ServiceExportData exports the current data of the protocol service - ServiceExportData(*ServiceExportData_Request, ProtocolService_ServiceExportDataServer) error + ServiceExportData(*ServiceExportData_Request, grpc.ServerStreamingServer[ServiceExportData_Reply]) error // ServiceGetConfiguration gets the current configuration of the protocol service ServiceGetConfiguration(context.Context, *ServiceGetConfiguration_Request) (*ServiceGetConfiguration_Reply, error) // ContactRequestReference retrieves the information required to create a reference (ie. included in a shareable link) to the current account @@ -725,9 +673,9 @@ type ProtocolServiceServer interface { // AppMessageSend adds an app event to the message store, the message is encrypted using a derived key and readable by current group members AppMessageSend(context.Context, *AppMessageSend_Request) (*AppMessageSend_Reply, error) // GroupMetadataList replays previous and subscribes to new metadata events from the group - GroupMetadataList(*GroupMetadataList_Request, ProtocolService_GroupMetadataListServer) error + GroupMetadataList(*GroupMetadataList_Request, grpc.ServerStreamingServer[GroupMetadataEvent]) error // GroupMessageList replays previous and subscribes to new message events from the group - GroupMessageList(*GroupMessageList_Request, ProtocolService_GroupMessageListServer) error + GroupMessageList(*GroupMessageList_Request, grpc.ServerStreamingServer[GroupMessageEvent]) error // GroupInfo retrieves information about a group GroupInfo(context.Context, *GroupInfo_Request) (*GroupInfo_Reply, error) // ActivateGroup explicitly opens a group @@ -735,9 +683,9 @@ type ProtocolServiceServer interface { // DeactivateGroup closes a group DeactivateGroup(context.Context, *DeactivateGroup_Request) (*DeactivateGroup_Reply, error) // GroupDeviceStatus monitor device status - GroupDeviceStatus(*GroupDeviceStatus_Request, ProtocolService_GroupDeviceStatusServer) error - DebugListGroups(*DebugListGroups_Request, ProtocolService_DebugListGroupsServer) error - DebugInspectGroupStore(*DebugInspectGroupStore_Request, ProtocolService_DebugInspectGroupStoreServer) error + GroupDeviceStatus(*GroupDeviceStatus_Request, grpc.ServerStreamingServer[GroupDeviceStatus_Reply]) error + DebugListGroups(*DebugListGroups_Request, grpc.ServerStreamingServer[DebugListGroups_Reply]) error + DebugInspectGroupStore(*DebugInspectGroupStore_Request, grpc.ServerStreamingServer[DebugInspectGroupStore_Reply]) error DebugGroup(context.Context, *DebugGroup_Request) (*DebugGroup_Reply, error) SystemInfo(context.Context, *SystemInfo_Request) (*SystemInfo_Reply, error) // CredentialVerificationServiceInitFlow Initialize a credential verification flow @@ -745,7 +693,7 @@ type ProtocolServiceServer interface { // CredentialVerificationServiceCompleteFlow Completes a credential verification flow CredentialVerificationServiceCompleteFlow(context.Context, *CredentialVerificationServiceCompleteFlow_Request) (*CredentialVerificationServiceCompleteFlow_Reply, error) // VerifiedCredentialsList Retrieves the list of verified credentials - VerifiedCredentialsList(*VerifiedCredentialsList_Request, ProtocolService_VerifiedCredentialsListServer) error + VerifiedCredentialsList(*VerifiedCredentialsList_Request, grpc.ServerStreamingServer[VerifiedCredentialsList_Reply]) error // ReplicationServiceRegisterGroup Asks a replication service to distribute a group contents ReplicationServiceRegisterGroup(context.Context, *ReplicationServiceRegisterGroup_Request) (*ReplicationServiceRegisterGroup_Reply, error) // PeerList returns a list of P2P peers @@ -759,11 +707,14 @@ type ProtocolServiceServer interface { mustEmbedUnimplementedProtocolServiceServer() } -// UnimplementedProtocolServiceServer must be embedded to have forward compatible implementations. -type UnimplementedProtocolServiceServer struct { -} +// UnimplementedProtocolServiceServer must be embedded to have +// forward compatible implementations. +// +// NOTE: this should be embedded by value instead of pointer to avoid a nil +// pointer dereference when methods are called. +type UnimplementedProtocolServiceServer struct{} -func (UnimplementedProtocolServiceServer) ServiceExportData(*ServiceExportData_Request, ProtocolService_ServiceExportDataServer) error { +func (UnimplementedProtocolServiceServer) ServiceExportData(*ServiceExportData_Request, grpc.ServerStreamingServer[ServiceExportData_Reply]) error { return status.Errorf(codes.Unimplemented, "method ServiceExportData not implemented") } func (UnimplementedProtocolServiceServer) ServiceGetConfiguration(context.Context, *ServiceGetConfiguration_Request) (*ServiceGetConfiguration_Reply, error) { @@ -829,10 +780,10 @@ func (UnimplementedProtocolServiceServer) AppMetadataSend(context.Context, *AppM func (UnimplementedProtocolServiceServer) AppMessageSend(context.Context, *AppMessageSend_Request) (*AppMessageSend_Reply, error) { return nil, status.Errorf(codes.Unimplemented, "method AppMessageSend not implemented") } -func (UnimplementedProtocolServiceServer) GroupMetadataList(*GroupMetadataList_Request, ProtocolService_GroupMetadataListServer) error { +func (UnimplementedProtocolServiceServer) GroupMetadataList(*GroupMetadataList_Request, grpc.ServerStreamingServer[GroupMetadataEvent]) error { return status.Errorf(codes.Unimplemented, "method GroupMetadataList not implemented") } -func (UnimplementedProtocolServiceServer) GroupMessageList(*GroupMessageList_Request, ProtocolService_GroupMessageListServer) error { +func (UnimplementedProtocolServiceServer) GroupMessageList(*GroupMessageList_Request, grpc.ServerStreamingServer[GroupMessageEvent]) error { return status.Errorf(codes.Unimplemented, "method GroupMessageList not implemented") } func (UnimplementedProtocolServiceServer) GroupInfo(context.Context, *GroupInfo_Request) (*GroupInfo_Reply, error) { @@ -844,13 +795,13 @@ func (UnimplementedProtocolServiceServer) ActivateGroup(context.Context, *Activa func (UnimplementedProtocolServiceServer) DeactivateGroup(context.Context, *DeactivateGroup_Request) (*DeactivateGroup_Reply, error) { return nil, status.Errorf(codes.Unimplemented, "method DeactivateGroup not implemented") } -func (UnimplementedProtocolServiceServer) GroupDeviceStatus(*GroupDeviceStatus_Request, ProtocolService_GroupDeviceStatusServer) error { +func (UnimplementedProtocolServiceServer) GroupDeviceStatus(*GroupDeviceStatus_Request, grpc.ServerStreamingServer[GroupDeviceStatus_Reply]) error { return status.Errorf(codes.Unimplemented, "method GroupDeviceStatus not implemented") } -func (UnimplementedProtocolServiceServer) DebugListGroups(*DebugListGroups_Request, ProtocolService_DebugListGroupsServer) error { +func (UnimplementedProtocolServiceServer) DebugListGroups(*DebugListGroups_Request, grpc.ServerStreamingServer[DebugListGroups_Reply]) error { return status.Errorf(codes.Unimplemented, "method DebugListGroups not implemented") } -func (UnimplementedProtocolServiceServer) DebugInspectGroupStore(*DebugInspectGroupStore_Request, ProtocolService_DebugInspectGroupStoreServer) error { +func (UnimplementedProtocolServiceServer) DebugInspectGroupStore(*DebugInspectGroupStore_Request, grpc.ServerStreamingServer[DebugInspectGroupStore_Reply]) error { return status.Errorf(codes.Unimplemented, "method DebugInspectGroupStore not implemented") } func (UnimplementedProtocolServiceServer) DebugGroup(context.Context, *DebugGroup_Request) (*DebugGroup_Reply, error) { @@ -865,7 +816,7 @@ func (UnimplementedProtocolServiceServer) CredentialVerificationServiceInitFlow( func (UnimplementedProtocolServiceServer) CredentialVerificationServiceCompleteFlow(context.Context, *CredentialVerificationServiceCompleteFlow_Request) (*CredentialVerificationServiceCompleteFlow_Reply, error) { return nil, status.Errorf(codes.Unimplemented, "method CredentialVerificationServiceCompleteFlow not implemented") } -func (UnimplementedProtocolServiceServer) VerifiedCredentialsList(*VerifiedCredentialsList_Request, ProtocolService_VerifiedCredentialsListServer) error { +func (UnimplementedProtocolServiceServer) VerifiedCredentialsList(*VerifiedCredentialsList_Request, grpc.ServerStreamingServer[VerifiedCredentialsList_Reply]) error { return status.Errorf(codes.Unimplemented, "method VerifiedCredentialsList not implemented") } func (UnimplementedProtocolServiceServer) ReplicationServiceRegisterGroup(context.Context, *ReplicationServiceRegisterGroup_Request) (*ReplicationServiceRegisterGroup_Reply, error) { @@ -884,6 +835,7 @@ func (UnimplementedProtocolServiceServer) RefreshContactRequest(context.Context, return nil, status.Errorf(codes.Unimplemented, "method RefreshContactRequest not implemented") } func (UnimplementedProtocolServiceServer) mustEmbedUnimplementedProtocolServiceServer() {} +func (UnimplementedProtocolServiceServer) testEmbeddedByValue() {} // UnsafeProtocolServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ProtocolServiceServer will @@ -893,6 +845,13 @@ type UnsafeProtocolServiceServer interface { } func RegisterProtocolServiceServer(s grpc.ServiceRegistrar, srv ProtocolServiceServer) { + // If the following call pancis, it indicates UnimplementedProtocolServiceServer was + // embedded by pointer and is nil. This will cause panics if an + // unimplemented method is ever invoked, so we test this at initialization + // time to prevent it from happening at runtime later due to I/O. + if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { + t.testEmbeddedByValue() + } s.RegisterService(&ProtocolService_ServiceDesc, srv) } @@ -901,21 +860,11 @@ func _ProtocolService_ServiceExportData_Handler(srv interface{}, stream grpc.Ser if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).ServiceExportData(m, &protocolServiceServiceExportDataServer{stream}) -} - -type ProtocolService_ServiceExportDataServer interface { - Send(*ServiceExportData_Reply) error - grpc.ServerStream + return srv.(ProtocolServiceServer).ServiceExportData(m, &grpc.GenericServerStream[ServiceExportData_Request, ServiceExportData_Reply]{ServerStream: stream}) } -type protocolServiceServiceExportDataServer struct { - grpc.ServerStream -} - -func (x *protocolServiceServiceExportDataServer) Send(m *ServiceExportData_Reply) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_ServiceExportDataServer = grpc.ServerStreamingServer[ServiceExportData_Reply] func _ProtocolService_ServiceGetConfiguration_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ServiceGetConfiguration_Request) @@ -1300,42 +1249,22 @@ func _ProtocolService_GroupMetadataList_Handler(srv interface{}, stream grpc.Ser if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).GroupMetadataList(m, &protocolServiceGroupMetadataListServer{stream}) + return srv.(ProtocolServiceServer).GroupMetadataList(m, &grpc.GenericServerStream[GroupMetadataList_Request, GroupMetadataEvent]{ServerStream: stream}) } -type ProtocolService_GroupMetadataListServer interface { - Send(*GroupMetadataEvent) error - grpc.ServerStream -} - -type protocolServiceGroupMetadataListServer struct { - grpc.ServerStream -} - -func (x *protocolServiceGroupMetadataListServer) Send(m *GroupMetadataEvent) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupMetadataListServer = grpc.ServerStreamingServer[GroupMetadataEvent] func _ProtocolService_GroupMessageList_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(GroupMessageList_Request) if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).GroupMessageList(m, &protocolServiceGroupMessageListServer{stream}) -} - -type ProtocolService_GroupMessageListServer interface { - Send(*GroupMessageEvent) error - grpc.ServerStream -} - -type protocolServiceGroupMessageListServer struct { - grpc.ServerStream + return srv.(ProtocolServiceServer).GroupMessageList(m, &grpc.GenericServerStream[GroupMessageList_Request, GroupMessageEvent]{ServerStream: stream}) } -func (x *protocolServiceGroupMessageListServer) Send(m *GroupMessageEvent) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupMessageListServer = grpc.ServerStreamingServer[GroupMessageEvent] func _ProtocolService_GroupInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GroupInfo_Request) @@ -1396,63 +1325,33 @@ func _ProtocolService_GroupDeviceStatus_Handler(srv interface{}, stream grpc.Ser if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).GroupDeviceStatus(m, &protocolServiceGroupDeviceStatusServer{stream}) -} - -type ProtocolService_GroupDeviceStatusServer interface { - Send(*GroupDeviceStatus_Reply) error - grpc.ServerStream + return srv.(ProtocolServiceServer).GroupDeviceStatus(m, &grpc.GenericServerStream[GroupDeviceStatus_Request, GroupDeviceStatus_Reply]{ServerStream: stream}) } -type protocolServiceGroupDeviceStatusServer struct { - grpc.ServerStream -} - -func (x *protocolServiceGroupDeviceStatusServer) Send(m *GroupDeviceStatus_Reply) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_GroupDeviceStatusServer = grpc.ServerStreamingServer[GroupDeviceStatus_Reply] func _ProtocolService_DebugListGroups_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(DebugListGroups_Request) if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).DebugListGroups(m, &protocolServiceDebugListGroupsServer{stream}) -} - -type ProtocolService_DebugListGroupsServer interface { - Send(*DebugListGroups_Reply) error - grpc.ServerStream -} - -type protocolServiceDebugListGroupsServer struct { - grpc.ServerStream + return srv.(ProtocolServiceServer).DebugListGroups(m, &grpc.GenericServerStream[DebugListGroups_Request, DebugListGroups_Reply]{ServerStream: stream}) } -func (x *protocolServiceDebugListGroupsServer) Send(m *DebugListGroups_Reply) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_DebugListGroupsServer = grpc.ServerStreamingServer[DebugListGroups_Reply] func _ProtocolService_DebugInspectGroupStore_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(DebugInspectGroupStore_Request) if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).DebugInspectGroupStore(m, &protocolServiceDebugInspectGroupStoreServer{stream}) -} - -type ProtocolService_DebugInspectGroupStoreServer interface { - Send(*DebugInspectGroupStore_Reply) error - grpc.ServerStream + return srv.(ProtocolServiceServer).DebugInspectGroupStore(m, &grpc.GenericServerStream[DebugInspectGroupStore_Request, DebugInspectGroupStore_Reply]{ServerStream: stream}) } -type protocolServiceDebugInspectGroupStoreServer struct { - grpc.ServerStream -} - -func (x *protocolServiceDebugInspectGroupStoreServer) Send(m *DebugInspectGroupStore_Reply) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_DebugInspectGroupStoreServer = grpc.ServerStreamingServer[DebugInspectGroupStore_Reply] func _ProtocolService_DebugGroup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DebugGroup_Request) @@ -1531,21 +1430,11 @@ func _ProtocolService_VerifiedCredentialsList_Handler(srv interface{}, stream gr if err := stream.RecvMsg(m); err != nil { return err } - return srv.(ProtocolServiceServer).VerifiedCredentialsList(m, &protocolServiceVerifiedCredentialsListServer{stream}) + return srv.(ProtocolServiceServer).VerifiedCredentialsList(m, &grpc.GenericServerStream[VerifiedCredentialsList_Request, VerifiedCredentialsList_Reply]{ServerStream: stream}) } -type ProtocolService_VerifiedCredentialsListServer interface { - Send(*VerifiedCredentialsList_Reply) error - grpc.ServerStream -} - -type protocolServiceVerifiedCredentialsListServer struct { - grpc.ServerStream -} - -func (x *protocolServiceVerifiedCredentialsListServer) Send(m *VerifiedCredentialsList_Reply) error { - return x.ServerStream.SendMsg(m) -} +// This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name. +type ProtocolService_VerifiedCredentialsListServer = grpc.ServerStreamingServer[VerifiedCredentialsList_Reply] func _ProtocolService_ReplicationServiceRegisterGroup_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ReplicationServiceRegisterGroup_Request) diff --git a/pkg/replicationtypes/bertyreplication.pb.go b/pkg/replicationtypes/bertyreplication.pb.go index c6fc8b98..09e4622a 100644 --- a/pkg/replicationtypes/bertyreplication.pb.go +++ b/pkg/replicationtypes/bertyreplication.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: replicationtypes/bertyreplication.proto @@ -759,7 +759,7 @@ func file_replicationtypes_bertyreplication_proto_rawDescGZIP() []byte { } var file_replicationtypes_bertyreplication_proto_msgTypes = make([]protoimpl.MessageInfo, 11) -var file_replicationtypes_bertyreplication_proto_goTypes = []interface{}{ +var file_replicationtypes_bertyreplication_proto_goTypes = []any{ (*ReplicatedGroup)(nil), // 0: weshnet.replication.v1.ReplicatedGroup (*ReplicatedGroupToken)(nil), // 1: weshnet.replication.v1.ReplicatedGroupToken (*ReplicationServiceReplicateGroup)(nil), // 2: weshnet.replication.v1.ReplicationServiceReplicateGroup @@ -796,7 +796,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_replicationtypes_bertyreplication_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*ReplicatedGroup); i { case 0: return &v.state @@ -808,7 +808,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*ReplicatedGroupToken); i { case 0: return &v.state @@ -820,7 +820,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup); i { case 0: return &v.state @@ -832,7 +832,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[3].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGlobalStats); i { case 0: return &v.state @@ -844,7 +844,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[4].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGroupStats); i { case 0: return &v.state @@ -856,7 +856,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[5].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup_Request); i { case 0: return &v.state @@ -868,7 +868,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[6].Exporter = func(v any, i int) any { switch v := v.(*ReplicationServiceReplicateGroup_Reply); i { case 0: return &v.state @@ -880,7 +880,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[7].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGlobalStats_Request); i { case 0: return &v.state @@ -892,7 +892,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[8].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGlobalStats_Reply); i { case 0: return &v.state @@ -904,7 +904,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[9].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGroupStats_Request); i { case 0: return &v.state @@ -916,7 +916,7 @@ func file_replicationtypes_bertyreplication_proto_init() { return nil } } - file_replicationtypes_bertyreplication_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + file_replicationtypes_bertyreplication_proto_msgTypes[10].Exporter = func(v any, i int) any { switch v := v.(*ReplicateGroupStats_Reply); i { case 0: return &v.state diff --git a/pkg/replicationtypes/bertyreplication_grpc.pb.go b/pkg/replicationtypes/bertyreplication_grpc.pb.go index 33ff7c9a..39042a0b 100644 --- a/pkg/replicationtypes/bertyreplication_grpc.pb.go +++ b/pkg/replicationtypes/bertyreplication_grpc.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: -// - protoc-gen-go-grpc v1.3.0 +// - protoc-gen-go-grpc v1.5.1 // - protoc (unknown) // source: replicationtypes/bertyreplication.proto @@ -15,8 +15,8 @@ import ( // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. -// Requires gRPC-Go v1.32.0 or later. -const _ = grpc.SupportPackageIsVersion7 +// Requires gRPC-Go v1.64.0 or later. +const _ = grpc.SupportPackageIsVersion9 const ( ReplicationService_ReplicateGroup_FullMethodName = "/weshnet.replication.v1.ReplicationService/ReplicateGroup" @@ -27,6 +27,8 @@ const ( // ReplicationServiceClient is the client API for ReplicationService service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. +// +// ReplicationService type ReplicationServiceClient interface { // ReplicateGroup ReplicateGroup(ctx context.Context, in *ReplicationServiceReplicateGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceReplicateGroup_Reply, error) @@ -43,8 +45,9 @@ func NewReplicationServiceClient(cc grpc.ClientConnInterface) ReplicationService } func (c *replicationServiceClient) ReplicateGroup(ctx context.Context, in *ReplicationServiceReplicateGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceReplicateGroup_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ReplicationServiceReplicateGroup_Reply) - err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroup_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroup_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -52,8 +55,9 @@ func (c *replicationServiceClient) ReplicateGroup(ctx context.Context, in *Repli } func (c *replicationServiceClient) ReplicateGlobalStats(ctx context.Context, in *ReplicateGlobalStats_Request, opts ...grpc.CallOption) (*ReplicateGlobalStats_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ReplicateGlobalStats_Reply) - err := c.cc.Invoke(ctx, ReplicationService_ReplicateGlobalStats_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGlobalStats_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -61,8 +65,9 @@ func (c *replicationServiceClient) ReplicateGlobalStats(ctx context.Context, in } func (c *replicationServiceClient) ReplicateGroupStats(ctx context.Context, in *ReplicateGroupStats_Request, opts ...grpc.CallOption) (*ReplicateGroupStats_Reply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) out := new(ReplicateGroupStats_Reply) - err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroupStats_FullMethodName, in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroupStats_FullMethodName, in, out, cOpts...) if err != nil { return nil, err } @@ -71,7 +76,9 @@ func (c *replicationServiceClient) ReplicateGroupStats(ctx context.Context, in * // ReplicationServiceServer is the server API for ReplicationService service. // All implementations must embed UnimplementedReplicationServiceServer -// for forward compatibility +// for forward compatibility. +// +// ReplicationService type ReplicationServiceServer interface { // ReplicateGroup ReplicateGroup(context.Context, *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error) @@ -80,9 +87,12 @@ type ReplicationServiceServer interface { mustEmbedUnimplementedReplicationServiceServer() } -// UnimplementedReplicationServiceServer must be embedded to have forward compatible implementations. -type UnimplementedReplicationServiceServer struct { -} +// UnimplementedReplicationServiceServer must be embedded to have +// forward compatible implementations. +// +// NOTE: this should be embedded by value instead of pointer to avoid a nil +// pointer dereference when methods are called. +type UnimplementedReplicationServiceServer struct{} func (UnimplementedReplicationServiceServer) ReplicateGroup(context.Context, *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error) { return nil, status.Errorf(codes.Unimplemented, "method ReplicateGroup not implemented") @@ -94,6 +104,7 @@ func (UnimplementedReplicationServiceServer) ReplicateGroupStats(context.Context return nil, status.Errorf(codes.Unimplemented, "method ReplicateGroupStats not implemented") } func (UnimplementedReplicationServiceServer) mustEmbedUnimplementedReplicationServiceServer() {} +func (UnimplementedReplicationServiceServer) testEmbeddedByValue() {} // UnsafeReplicationServiceServer may be embedded to opt out of forward compatibility for this service. // Use of this interface is not recommended, as added methods to ReplicationServiceServer will @@ -103,6 +114,13 @@ type UnsafeReplicationServiceServer interface { } func RegisterReplicationServiceServer(s grpc.ServiceRegistrar, srv ReplicationServiceServer) { + // If the following call pancis, it indicates UnimplementedReplicationServiceServer was + // embedded by pointer and is nil. This will cause panics if an + // unimplemented method is ever invoked, so we test this at initialization + // time to prevent it from happening at runtime later due to I/O. + if t, ok := srv.(interface{ testEmbeddedByValue() }); ok { + t.testEmbeddedByValue() + } s.RegisterService(&ReplicationService_ServiceDesc, srv) } diff --git a/pkg/tinder/records.pb.go b/pkg/tinder/records.pb.go index 4efc17ad..48f193ed 100644 --- a/pkg/tinder/records.pb.go +++ b/pkg/tinder/records.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: tinder/records.proto @@ -151,7 +151,7 @@ func file_tinder_records_proto_rawDescGZIP() []byte { } var file_tinder_records_proto_msgTypes = make([]protoimpl.MessageInfo, 2) -var file_tinder_records_proto_goTypes = []interface{}{ +var file_tinder_records_proto_goTypes = []any{ (*Records)(nil), // 0: tinder.Records (*Record)(nil), // 1: tinder.Record } @@ -170,7 +170,7 @@ func file_tinder_records_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_tinder_records_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_tinder_records_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*Records); i { case 0: return &v.state @@ -182,7 +182,7 @@ func file_tinder_records_proto_init() { return nil } } - file_tinder_records_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_tinder_records_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*Record); i { case 0: return &v.state diff --git a/pkg/verifiablecredstypes/bertyverifiablecreds.pb.go b/pkg/verifiablecredstypes/bertyverifiablecreds.pb.go index db423796..9fad4dbe 100644 --- a/pkg/verifiablecredstypes/bertyverifiablecreds.pb.go +++ b/pkg/verifiablecredstypes/bertyverifiablecreds.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.34.1 +// protoc-gen-go v1.34.2 // protoc (unknown) // source: verifiablecredstypes/bertyverifiablecreds.proto @@ -423,7 +423,7 @@ func file_verifiablecredstypes_bertyverifiablecreds_proto_rawDescGZIP() []byte { var file_verifiablecredstypes_bertyverifiablecreds_proto_enumTypes = make([]protoimpl.EnumInfo, 2) var file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes = make([]protoimpl.MessageInfo, 3) -var file_verifiablecredstypes_bertyverifiablecreds_proto_goTypes = []interface{}{ +var file_verifiablecredstypes_bertyverifiablecreds_proto_goTypes = []any{ (FlowType)(0), // 0: weshnet.account.v1.FlowType (CodeStrategy)(0), // 1: weshnet.account.v1.CodeStrategy (*StateChallenge)(nil), // 2: weshnet.account.v1.StateChallenge @@ -445,7 +445,7 @@ func file_verifiablecredstypes_bertyverifiablecreds_proto_init() { return } if !protoimpl.UnsafeEnabled { - file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[0].Exporter = func(v any, i int) any { switch v := v.(*StateChallenge); i { case 0: return &v.state @@ -457,7 +457,7 @@ func file_verifiablecredstypes_bertyverifiablecreds_proto_init() { return nil } } - file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[1].Exporter = func(v any, i int) any { switch v := v.(*StateCode); i { case 0: return &v.state @@ -469,7 +469,7 @@ func file_verifiablecredstypes_bertyverifiablecreds_proto_init() { return nil } } - file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_verifiablecredstypes_bertyverifiablecreds_proto_msgTypes[2].Exporter = func(v any, i int) any { switch v := v.(*AccountCryptoChallenge); i { case 0: return &v.state