From 281ca19842197985ff85ecd0aa9a7e870d76c9be Mon Sep 17 00:00:00 2001 From: D4ryl00 Date: Mon, 26 Jun 2023 11:47:26 +0200 Subject: [PATCH 1/3] fix: update to go1.19 in the Dockerfile and add asdf support Signed-off-by: D4ryl00 --- Makefile | 2 +- docs/Makefile | 2 +- tool/docker-protoc/Dockerfile | 18 +++++++++++++----- tool/docker-protoc/Makefile | 2 +- 4 files changed, 16 insertions(+), 8 deletions(-) diff --git a/Makefile b/Makefile index 97136f0f..7045c0d9 100644 --- a/Makefile +++ b/Makefile @@ -154,7 +154,7 @@ $(gen_sum): $(gen_src) --workdir="/go/src/berty.tech/weshnet" \ --entrypoint="sh" \ --rm \ - bertytech/buf:1 \ + bertytech/buf:2 \ -xec 'make generate_local'; \ $(MAKE) tidy \ ) diff --git a/docs/Makefile b/docs/Makefile index 8a5c1315..67023960 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:1 \ + bertytech/buf:2 \ -xec 'make generate_local' \ ) .PHONY: generate diff --git a/tool/docker-protoc/Dockerfile b/tool/docker-protoc/Dockerfile index a120f7a7..1cedf00b 100644 --- a/tool/docker-protoc/Dockerfile +++ b/tool/docker-protoc/Dockerfile @@ -1,14 +1,20 @@ FROM moul/protoc-gen-gotemplate:latest as pgg # build image -FROM golang:1.18-alpine as builder +FROM golang:1.19-alpine as builder # install deps -RUN apk --no-cache add make git go rsync libc-dev openssh docker npm +RUN apk --no-cache add make git go rsync libc-dev openssh docker npm bash curl +# ensure we use bash for all RUN commands +SHELL ["/bin/bash", "-c"] +RUN git clone https://github.com/asdf-vm/asdf.git ~/.asdf --branch v0.12.0 && \ + echo -e '\n. $HOME/.asdf/asdf.sh' >> ~/.bashrc # install compilers WORKDIR $GOPATH/src/berty.tech/weshnet -COPY go.mod go.sum ./ +COPY go.mod go.sum .tool-versions ./ +# ensure modifications to bashrc are properly sourced +ENV BASH_ENV=~/.bashrc +# @TODO(gfanton): use asdf version RUN go install -mod=readonly \ - github.com/bufbuild/buf/cmd/buf \ # @TODO(gfanton): use asdf version google.golang.org/protobuf/cmd/protoc-gen-go \ github.com/gogo/protobuf/protoc-gen-gogo \ google.golang.org/grpc/cmd/protoc-gen-go-grpc \ @@ -16,9 +22,11 @@ RUN go install -mod=readonly \ github.com/grpc-ecosystem/grpc-gateway/protoc-gen-swagger \ github.com/pseudomuto/protoc-gen-doc/cmd/protoc-gen-doc \ golang.org/x/tools/cmd/goimports +RUN asdf plugin add buf && asdf install buf && \ + cp $(asdf which buf) /go/bin/buf # runtime -FROM golang:1.18-alpine +FROM golang:1.19-alpine RUN apk --no-cache add git openssh make protobuf gcc libc-dev nodejs npm yarn sudo perl-utils tar sed grep \ && mkdir -p /.cache/go-build \ && chmod -R 777 /.cache \ diff --git a/tool/docker-protoc/Makefile b/tool/docker-protoc/Makefile index f38f00c5..772bd8e3 100644 --- a/tool/docker-protoc/Makefile +++ b/tool/docker-protoc/Makefile @@ -1,5 +1,5 @@ IMAGE ?= bertytech/buf -VERSION ?= 1 +VERSION ?= 2 build: cd ../../ && docker build -f ./tool/docker-protoc/Dockerfile -t $(IMAGE):$(VERSION) -t $(IMAGE):latest . From 828bb2038d3603e784b902be437c8710e07759bd Mon Sep 17 00:00:00 2001 From: D4ryl00 Date: Mon, 26 Jun 2023 12:01:42 +0200 Subject: [PATCH 2/3] chore: make go.fmt Signed-off-by: D4ryl00 --- account_export_test.go | 2 +- deactivate_test.go | 2 +- internal/handshake/handshake_util_test.go | 2 +- orbitdb_test.go | 2 +- pkg/rendezvous/emitterio_sync_test.go | 2 +- pkg/tinder/driver_mock_test.go | 2 +- pkg/tinder/driver_service_test.go | 2 +- pkg/tinder/service_mocked_test.go | 2 +- pkg/tinder/testing_test.go | 2 +- testing.go | 2 +- 10 files changed, 10 insertions(+), 10 deletions(-) diff --git a/account_export_test.go b/account_export_test.go index 2ace38ff..9de3f0f8 100644 --- a/account_export_test.go +++ b/account_export_test.go @@ -7,10 +7,10 @@ import ( "os" "testing" + mocknet "github.com/berty/go-libp2p-mock" "github.com/ipfs/go-cid" ds "github.com/ipfs/go-datastore" dsync "github.com/ipfs/go-datastore/sync" - mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/require" orbitdb "berty.tech/go-orbit-db" diff --git a/deactivate_test.go b/deactivate_test.go index d120cbb6..4c2d4e9e 100644 --- a/deactivate_test.go +++ b/deactivate_test.go @@ -5,9 +5,9 @@ import ( "testing" "time" + libp2p_mocknet "github.com/berty/go-libp2p-mock" ds "github.com/ipfs/go-datastore" dsync "github.com/ipfs/go-datastore/sync" - libp2p_mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/require" "berty.tech/weshnet" diff --git a/internal/handshake/handshake_util_test.go b/internal/handshake/handshake_util_test.go index 5b831b3c..6af948eb 100644 --- a/internal/handshake/handshake_util_test.go +++ b/internal/handshake/handshake_util_test.go @@ -7,11 +7,11 @@ import ( "testing" "time" + p2pmocknet "github.com/berty/go-libp2p-mock" ggio "github.com/gogo/protobuf/io" p2pcrypto "github.com/libp2p/go-libp2p/core/crypto" p2pnetwork "github.com/libp2p/go-libp2p/core/network" p2ppeer "github.com/libp2p/go-libp2p/core/peer" - p2pmocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/require" "berty.tech/weshnet/pkg/ipfsutil" diff --git a/orbitdb_test.go b/orbitdb_test.go index a017b319..7892a150 100644 --- a/orbitdb_test.go +++ b/orbitdb_test.go @@ -8,9 +8,9 @@ import ( "testing" "time" + mocknet "github.com/berty/go-libp2p-mock" datastore "github.com/ipfs/go-datastore" sync_ds "github.com/ipfs/go-datastore/sync" - mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "go.uber.org/zap" diff --git a/pkg/rendezvous/emitterio_sync_test.go b/pkg/rendezvous/emitterio_sync_test.go index 108abff6..a146d0c4 100644 --- a/pkg/rendezvous/emitterio_sync_test.go +++ b/pkg/rendezvous/emitterio_sync_test.go @@ -8,11 +8,11 @@ import ( "testing" "time" + mocknet "github.com/berty/go-libp2p-mock" rendezvous "github.com/berty/go-libp2p-rendezvous" db "github.com/berty/go-libp2p-rendezvous/db/sqlcipher" "github.com/berty/go-libp2p-rendezvous/test_utils" "github.com/libp2p/go-libp2p/core/host" - mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/require" "go.uber.org/zap" diff --git a/pkg/tinder/driver_mock_test.go b/pkg/tinder/driver_mock_test.go index 2f2f0562..6edf2a1c 100644 --- a/pkg/tinder/driver_mock_test.go +++ b/pkg/tinder/driver_mock_test.go @@ -5,8 +5,8 @@ import ( "testing" "time" - "github.com/libp2p/go-libp2p/core/peer" mocknet "github.com/berty/go-libp2p-mock" + "github.com/libp2p/go-libp2p/core/peer" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" ) diff --git a/pkg/tinder/driver_service_test.go b/pkg/tinder/driver_service_test.go index b5b07362..25dbbdaa 100644 --- a/pkg/tinder/driver_service_test.go +++ b/pkg/tinder/driver_service_test.go @@ -7,11 +7,11 @@ import ( "testing" "time" + mocknet "github.com/berty/go-libp2p-mock" rendezvous "github.com/berty/go-libp2p-rendezvous" dht "github.com/libp2p/go-libp2p-kad-dht" "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" - mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/require" "go.uber.org/zap" diff --git a/pkg/tinder/service_mocked_test.go b/pkg/tinder/service_mocked_test.go index 5b49682d..98766831 100644 --- a/pkg/tinder/service_mocked_test.go +++ b/pkg/tinder/service_mocked_test.go @@ -6,9 +6,9 @@ import ( "testing" "time" + mocknet "github.com/berty/go-libp2p-mock" "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" - mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "go.uber.org/zap" diff --git a/pkg/tinder/testing_test.go b/pkg/tinder/testing_test.go index c06e9c03..f9f658f8 100644 --- a/pkg/tinder/testing_test.go +++ b/pkg/tinder/testing_test.go @@ -6,12 +6,12 @@ import ( "testing" "time" + mocknet "github.com/berty/go-libp2p-mock" rendezvous "github.com/berty/go-libp2p-rendezvous" dbrdvp "github.com/berty/go-libp2p-rendezvous/db/sqlite" p2putil "github.com/libp2p/go-libp2p-testing/netutil" "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" - mocknet "github.com/berty/go-libp2p-mock" ma "github.com/multiformats/go-multiaddr" "github.com/stretchr/testify/require" ) diff --git a/testing.go b/testing.go index 023388b4..03e02ad2 100644 --- a/testing.go +++ b/testing.go @@ -12,6 +12,7 @@ import ( "testing" "time" + libp2p_mocknet "github.com/berty/go-libp2p-mock" grpc_middleware "github.com/grpc-ecosystem/go-grpc-middleware" grpc_zap "github.com/grpc-ecosystem/go-grpc-middleware/logging/zap" grpc_ctxtags "github.com/grpc-ecosystem/go-grpc-middleware/tags" @@ -19,7 +20,6 @@ import ( ds_sync "github.com/ipfs/go-datastore/sync" "github.com/libp2p/go-libp2p/core/crypto" "github.com/libp2p/go-libp2p/core/peer" - libp2p_mocknet "github.com/berty/go-libp2p-mock" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" "go.uber.org/zap" From 8f6ff3b193fd7147c8b7794db2e1217ddb14cc29 Mon Sep 17 00:00:00 2001 From: D4ryl00 Date: Mon, 26 Jun 2023 12:02:09 +0200 Subject: [PATCH 3/3] chore: make regenerate Signed-off-by: D4ryl00 --- docs/gen.sum | 2 +- gen.sum | 2 +- pkg/protocoltypes/protocoltypes_grpc.pb.go | 201 +++++++++++------- pkg/pushtypes/pushtypes_grpc.pb.go | 17 +- .../bertyreplication_grpc.pb.go | 22 +- 5 files changed, 156 insertions(+), 88 deletions(-) diff --git a/docs/gen.sum b/docs/gen.sum index 9651b5e2..4d99fddf 100644 --- a/docs/gen.sum +++ b/docs/gen.sum @@ -1 +1 @@ -fd233387bb19ad6a4a06e49222ac87281e188859 Makefile +1874a7a933c38866216b36435e426d3f7c74561e Makefile diff --git a/gen.sum b/gen.sum index e3686c0e..fa0f5670 100644 --- a/gen.sum +++ b/gen.sum @@ -1 +1 @@ -6b8c13153a0ba512493dcc98cbf8217aba3fe330 Makefile +c714df94280e709f9b80d62edd8b39632d16f679 Makefile diff --git a/pkg/protocoltypes/protocoltypes_grpc.pb.go b/pkg/protocoltypes/protocoltypes_grpc.pb.go index e60c9048..d20a1b42 100644 --- a/pkg/protocoltypes/protocoltypes_grpc.pb.go +++ b/pkg/protocoltypes/protocoltypes_grpc.pb.go @@ -1,4 +1,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.3.0 +// - protoc (unknown) +// source: protocoltypes.proto package protocoltypes @@ -14,6 +18,51 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + ProtocolService_ServiceExportData_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ServiceExportData" + ProtocolService_ServiceGetConfiguration_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ServiceGetConfiguration" + ProtocolService_ContactRequestReference_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestReference" + ProtocolService_ContactRequestDisable_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestDisable" + ProtocolService_ContactRequestEnable_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestEnable" + ProtocolService_ContactRequestResetReference_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestResetReference" + ProtocolService_ContactRequestSend_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestSend" + ProtocolService_ContactRequestAccept_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestAccept" + ProtocolService_ContactRequestDiscard_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactRequestDiscard" + ProtocolService_ContactBlock_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactBlock" + ProtocolService_ContactUnblock_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactUnblock" + ProtocolService_ContactAliasKeySend_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ContactAliasKeySend" + ProtocolService_MultiMemberGroupCreate_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupCreate" + ProtocolService_MultiMemberGroupJoin_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupJoin" + ProtocolService_MultiMemberGroupLeave_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupLeave" + ProtocolService_MultiMemberGroupAliasResolverDisclose_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAliasResolverDisclose" + ProtocolService_MultiMemberGroupAdminRoleGrant_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAdminRoleGrant" + ProtocolService_MultiMemberGroupInvitationCreate_FullMethodName = "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupInvitationCreate" + ProtocolService_AppMetadataSend_FullMethodName = "/weshnet.protocol.v1.ProtocolService/AppMetadataSend" + ProtocolService_AppMessageSend_FullMethodName = "/weshnet.protocol.v1.ProtocolService/AppMessageSend" + ProtocolService_GroupMetadataList_FullMethodName = "/weshnet.protocol.v1.ProtocolService/GroupMetadataList" + ProtocolService_GroupMessageList_FullMethodName = "/weshnet.protocol.v1.ProtocolService/GroupMessageList" + ProtocolService_GroupInfo_FullMethodName = "/weshnet.protocol.v1.ProtocolService/GroupInfo" + ProtocolService_ActivateGroup_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ActivateGroup" + ProtocolService_DeactivateGroup_FullMethodName = "/weshnet.protocol.v1.ProtocolService/DeactivateGroup" + ProtocolService_GroupDeviceStatus_FullMethodName = "/weshnet.protocol.v1.ProtocolService/GroupDeviceStatus" + ProtocolService_DebugListGroups_FullMethodName = "/weshnet.protocol.v1.ProtocolService/DebugListGroups" + ProtocolService_DebugInspectGroupStore_FullMethodName = "/weshnet.protocol.v1.ProtocolService/DebugInspectGroupStore" + ProtocolService_DebugGroup_FullMethodName = "/weshnet.protocol.v1.ProtocolService/DebugGroup" + ProtocolService_DebugAuthServiceSetToken_FullMethodName = "/weshnet.protocol.v1.ProtocolService/DebugAuthServiceSetToken" + ProtocolService_SystemInfo_FullMethodName = "/weshnet.protocol.v1.ProtocolService/SystemInfo" + ProtocolService_AuthServiceInitFlow_FullMethodName = "/weshnet.protocol.v1.ProtocolService/AuthServiceInitFlow" + ProtocolService_AuthServiceCompleteFlow_FullMethodName = "/weshnet.protocol.v1.ProtocolService/AuthServiceCompleteFlow" + ProtocolService_CredentialVerificationServiceInitFlow_FullMethodName = "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceInitFlow" + ProtocolService_CredentialVerificationServiceCompleteFlow_FullMethodName = "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceCompleteFlow" + ProtocolService_VerifiedCredentialsList_FullMethodName = "/weshnet.protocol.v1.ProtocolService/VerifiedCredentialsList" + ProtocolService_ServicesTokenList_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ServicesTokenList" + ProtocolService_ReplicationServiceRegisterGroup_FullMethodName = "/weshnet.protocol.v1.ProtocolService/ReplicationServiceRegisterGroup" + ProtocolService_PeerList_FullMethodName = "/weshnet.protocol.v1.ProtocolService/PeerList" + ProtocolService_OutOfStoreReceive_FullMethodName = "/weshnet.protocol.v1.ProtocolService/OutOfStoreReceive" + ProtocolService_OutOfStoreSeal_FullMethodName = "/weshnet.protocol.v1.ProtocolService/OutOfStoreSeal" + ProtocolService_RefreshContactRequest_FullMethodName = "/weshnet.protocol.v1.ProtocolService/RefreshContactRequest" +) + // 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. @@ -108,7 +157,7 @@ func NewProtocolServiceClient(cc grpc.ClientConnInterface) ProtocolServiceClient } 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], "/weshnet.protocol.v1.ProtocolService/ServiceExportData", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[0], ProtocolService_ServiceExportData_FullMethodName, opts...) if err != nil { return nil, err } @@ -141,7 +190,7 @@ func (x *protocolServiceServiceExportDataClient) Recv() (*ServiceExportData_Repl func (c *protocolServiceClient) ServiceGetConfiguration(ctx context.Context, in *ServiceGetConfiguration_Request, opts ...grpc.CallOption) (*ServiceGetConfiguration_Reply, error) { out := new(ServiceGetConfiguration_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ServiceGetConfiguration", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ServiceGetConfiguration_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -150,7 +199,7 @@ func (c *protocolServiceClient) ServiceGetConfiguration(ctx context.Context, in func (c *protocolServiceClient) ContactRequestReference(ctx context.Context, in *ContactRequestReference_Request, opts ...grpc.CallOption) (*ContactRequestReference_Reply, error) { out := new(ContactRequestReference_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestReference", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestReference_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -159,7 +208,7 @@ func (c *protocolServiceClient) ContactRequestReference(ctx context.Context, in func (c *protocolServiceClient) ContactRequestDisable(ctx context.Context, in *ContactRequestDisable_Request, opts ...grpc.CallOption) (*ContactRequestDisable_Reply, error) { out := new(ContactRequestDisable_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestDisable", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDisable_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -168,7 +217,7 @@ 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) { out := new(ContactRequestEnable_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestEnable", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestEnable_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -177,7 +226,7 @@ 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) { out := new(ContactRequestResetReference_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestResetReference", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestResetReference_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -186,7 +235,7 @@ func (c *protocolServiceClient) ContactRequestResetReference(ctx context.Context func (c *protocolServiceClient) ContactRequestSend(ctx context.Context, in *ContactRequestSend_Request, opts ...grpc.CallOption) (*ContactRequestSend_Reply, error) { out := new(ContactRequestSend_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestSend", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestSend_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -195,7 +244,7 @@ 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) { out := new(ContactRequestAccept_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestAccept", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestAccept_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -204,7 +253,7 @@ 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) { out := new(ContactRequestDiscard_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactRequestDiscard", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactRequestDiscard_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -213,7 +262,7 @@ func (c *protocolServiceClient) ContactRequestDiscard(ctx context.Context, in *C func (c *protocolServiceClient) ContactBlock(ctx context.Context, in *ContactBlock_Request, opts ...grpc.CallOption) (*ContactBlock_Reply, error) { out := new(ContactBlock_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactBlock", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactBlock_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -222,7 +271,7 @@ 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) { out := new(ContactUnblock_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactUnblock", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactUnblock_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -231,7 +280,7 @@ 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) { out := new(ContactAliasKeySend_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ContactAliasKeySend", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ContactAliasKeySend_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -240,7 +289,7 @@ 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) { out := new(MultiMemberGroupCreate_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupCreate", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupCreate_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -249,7 +298,7 @@ func (c *protocolServiceClient) MultiMemberGroupCreate(ctx context.Context, in * func (c *protocolServiceClient) MultiMemberGroupJoin(ctx context.Context, in *MultiMemberGroupJoin_Request, opts ...grpc.CallOption) (*MultiMemberGroupJoin_Reply, error) { out := new(MultiMemberGroupJoin_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupJoin", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupJoin_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -258,7 +307,7 @@ 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) { out := new(MultiMemberGroupLeave_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupLeave", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupLeave_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -267,7 +316,7 @@ 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) { out := new(MultiMemberGroupAliasResolverDisclose_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAliasResolverDisclose", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAliasResolverDisclose_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -276,7 +325,7 @@ func (c *protocolServiceClient) MultiMemberGroupAliasResolverDisclose(ctx contex func (c *protocolServiceClient) MultiMemberGroupAdminRoleGrant(ctx context.Context, in *MultiMemberGroupAdminRoleGrant_Request, opts ...grpc.CallOption) (*MultiMemberGroupAdminRoleGrant_Reply, error) { out := new(MultiMemberGroupAdminRoleGrant_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAdminRoleGrant", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupAdminRoleGrant_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -285,7 +334,7 @@ func (c *protocolServiceClient) MultiMemberGroupAdminRoleGrant(ctx context.Conte func (c *protocolServiceClient) MultiMemberGroupInvitationCreate(ctx context.Context, in *MultiMemberGroupInvitationCreate_Request, opts ...grpc.CallOption) (*MultiMemberGroupInvitationCreate_Reply, error) { out := new(MultiMemberGroupInvitationCreate_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupInvitationCreate", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_MultiMemberGroupInvitationCreate_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -294,7 +343,7 @@ func (c *protocolServiceClient) MultiMemberGroupInvitationCreate(ctx context.Con func (c *protocolServiceClient) AppMetadataSend(ctx context.Context, in *AppMetadataSend_Request, opts ...grpc.CallOption) (*AppMetadataSend_Reply, error) { out := new(AppMetadataSend_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/AppMetadataSend", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AppMetadataSend_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -303,7 +352,7 @@ 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) { out := new(AppMessageSend_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/AppMessageSend", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AppMessageSend_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -311,7 +360,7 @@ func (c *protocolServiceClient) AppMessageSend(ctx context.Context, in *AppMessa } 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], "/weshnet.protocol.v1.ProtocolService/GroupMetadataList", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[1], ProtocolService_GroupMetadataList_FullMethodName, opts...) if err != nil { return nil, err } @@ -343,7 +392,7 @@ func (x *protocolServiceGroupMetadataListClient) Recv() (*GroupMetadataEvent, er } 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], "/weshnet.protocol.v1.ProtocolService/GroupMessageList", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[2], ProtocolService_GroupMessageList_FullMethodName, opts...) if err != nil { return nil, err } @@ -376,7 +425,7 @@ func (x *protocolServiceGroupMessageListClient) Recv() (*GroupMessageEvent, erro func (c *protocolServiceClient) GroupInfo(ctx context.Context, in *GroupInfo_Request, opts ...grpc.CallOption) (*GroupInfo_Reply, error) { out := new(GroupInfo_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/GroupInfo", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_GroupInfo_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -385,7 +434,7 @@ 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) { out := new(ActivateGroup_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ActivateGroup", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ActivateGroup_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -394,7 +443,7 @@ 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) { out := new(DeactivateGroup_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/DeactivateGroup", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DeactivateGroup_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -402,7 +451,7 @@ func (c *protocolServiceClient) DeactivateGroup(ctx context.Context, in *Deactiv } 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], "/weshnet.protocol.v1.ProtocolService/GroupDeviceStatus", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[3], ProtocolService_GroupDeviceStatus_FullMethodName, opts...) if err != nil { return nil, err } @@ -434,7 +483,7 @@ func (x *protocolServiceGroupDeviceStatusClient) Recv() (*GroupDeviceStatus_Repl } 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], "/weshnet.protocol.v1.ProtocolService/DebugListGroups", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[4], ProtocolService_DebugListGroups_FullMethodName, opts...) if err != nil { return nil, err } @@ -466,7 +515,7 @@ func (x *protocolServiceDebugListGroupsClient) Recv() (*DebugListGroups_Reply, e } 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], "/weshnet.protocol.v1.ProtocolService/DebugInspectGroupStore", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[5], ProtocolService_DebugInspectGroupStore_FullMethodName, opts...) if err != nil { return nil, err } @@ -499,7 +548,7 @@ func (x *protocolServiceDebugInspectGroupStoreClient) Recv() (*DebugInspectGroup func (c *protocolServiceClient) DebugGroup(ctx context.Context, in *DebugGroup_Request, opts ...grpc.CallOption) (*DebugGroup_Reply, error) { out := new(DebugGroup_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/DebugGroup", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DebugGroup_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -508,7 +557,7 @@ func (c *protocolServiceClient) DebugGroup(ctx context.Context, in *DebugGroup_R func (c *protocolServiceClient) DebugAuthServiceSetToken(ctx context.Context, in *DebugAuthServiceSetToken_Request, opts ...grpc.CallOption) (*DebugAuthServiceSetToken_Reply, error) { out := new(DebugAuthServiceSetToken_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/DebugAuthServiceSetToken", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_DebugAuthServiceSetToken_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -517,7 +566,7 @@ func (c *protocolServiceClient) DebugAuthServiceSetToken(ctx context.Context, in func (c *protocolServiceClient) SystemInfo(ctx context.Context, in *SystemInfo_Request, opts ...grpc.CallOption) (*SystemInfo_Reply, error) { out := new(SystemInfo_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/SystemInfo", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_SystemInfo_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -526,7 +575,7 @@ func (c *protocolServiceClient) SystemInfo(ctx context.Context, in *SystemInfo_R func (c *protocolServiceClient) AuthServiceInitFlow(ctx context.Context, in *AuthServiceInitFlow_Request, opts ...grpc.CallOption) (*AuthServiceInitFlow_Reply, error) { out := new(AuthServiceInitFlow_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/AuthServiceInitFlow", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AuthServiceInitFlow_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -535,7 +584,7 @@ func (c *protocolServiceClient) AuthServiceInitFlow(ctx context.Context, in *Aut func (c *protocolServiceClient) AuthServiceCompleteFlow(ctx context.Context, in *AuthServiceCompleteFlow_Request, opts ...grpc.CallOption) (*AuthServiceCompleteFlow_Reply, error) { out := new(AuthServiceCompleteFlow_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/AuthServiceCompleteFlow", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_AuthServiceCompleteFlow_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -544,7 +593,7 @@ func (c *protocolServiceClient) AuthServiceCompleteFlow(ctx context.Context, in func (c *protocolServiceClient) CredentialVerificationServiceInitFlow(ctx context.Context, in *CredentialVerificationServiceInitFlow_Request, opts ...grpc.CallOption) (*CredentialVerificationServiceInitFlow_Reply, error) { out := new(CredentialVerificationServiceInitFlow_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceInitFlow", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceInitFlow_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -553,7 +602,7 @@ func (c *protocolServiceClient) CredentialVerificationServiceInitFlow(ctx contex func (c *protocolServiceClient) CredentialVerificationServiceCompleteFlow(ctx context.Context, in *CredentialVerificationServiceCompleteFlow_Request, opts ...grpc.CallOption) (*CredentialVerificationServiceCompleteFlow_Reply, error) { out := new(CredentialVerificationServiceCompleteFlow_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceCompleteFlow", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_CredentialVerificationServiceCompleteFlow_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -561,7 +610,7 @@ func (c *protocolServiceClient) CredentialVerificationServiceCompleteFlow(ctx co } 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], "/weshnet.protocol.v1.ProtocolService/VerifiedCredentialsList", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[6], ProtocolService_VerifiedCredentialsList_FullMethodName, opts...) if err != nil { return nil, err } @@ -593,7 +642,7 @@ func (x *protocolServiceVerifiedCredentialsListClient) Recv() (*VerifiedCredenti } func (c *protocolServiceClient) ServicesTokenList(ctx context.Context, in *ServicesTokenList_Request, opts ...grpc.CallOption) (ProtocolService_ServicesTokenListClient, error) { - stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[7], "/weshnet.protocol.v1.ProtocolService/ServicesTokenList", opts...) + stream, err := c.cc.NewStream(ctx, &ProtocolService_ServiceDesc.Streams[7], ProtocolService_ServicesTokenList_FullMethodName, opts...) if err != nil { return nil, err } @@ -626,7 +675,7 @@ func (x *protocolServiceServicesTokenListClient) Recv() (*ServicesTokenList_Repl func (c *protocolServiceClient) ReplicationServiceRegisterGroup(ctx context.Context, in *ReplicationServiceRegisterGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceRegisterGroup_Reply, error) { out := new(ReplicationServiceRegisterGroup_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/ReplicationServiceRegisterGroup", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_ReplicationServiceRegisterGroup_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -635,7 +684,7 @@ func (c *protocolServiceClient) ReplicationServiceRegisterGroup(ctx context.Cont func (c *protocolServiceClient) PeerList(ctx context.Context, in *PeerList_Request, opts ...grpc.CallOption) (*PeerList_Reply, error) { out := new(PeerList_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/PeerList", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_PeerList_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -644,7 +693,7 @@ 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) { out := new(OutOfStoreReceive_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/OutOfStoreReceive", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreReceive_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -653,7 +702,7 @@ 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) { out := new(OutOfStoreSeal_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/OutOfStoreSeal", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_OutOfStoreSeal_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -662,7 +711,7 @@ 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) { out := new(RefreshContactRequest_Reply) - err := c.cc.Invoke(ctx, "/weshnet.protocol.v1.ProtocolService/RefreshContactRequest", in, out, opts...) + err := c.cc.Invoke(ctx, ProtocolService_RefreshContactRequest_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -929,7 +978,7 @@ func _ProtocolService_ServiceGetConfiguration_Handler(srv interface{}, ctx conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ServiceGetConfiguration", + FullMethod: ProtocolService_ServiceGetConfiguration_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ServiceGetConfiguration(ctx, req.(*ServiceGetConfiguration_Request)) @@ -947,7 +996,7 @@ func _ProtocolService_ContactRequestReference_Handler(srv interface{}, ctx conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestReference", + FullMethod: ProtocolService_ContactRequestReference_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestReference(ctx, req.(*ContactRequestReference_Request)) @@ -965,7 +1014,7 @@ func _ProtocolService_ContactRequestDisable_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestDisable", + FullMethod: ProtocolService_ContactRequestDisable_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestDisable(ctx, req.(*ContactRequestDisable_Request)) @@ -983,7 +1032,7 @@ func _ProtocolService_ContactRequestEnable_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestEnable", + FullMethod: ProtocolService_ContactRequestEnable_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestEnable(ctx, req.(*ContactRequestEnable_Request)) @@ -1001,7 +1050,7 @@ func _ProtocolService_ContactRequestResetReference_Handler(srv interface{}, ctx } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestResetReference", + FullMethod: ProtocolService_ContactRequestResetReference_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestResetReference(ctx, req.(*ContactRequestResetReference_Request)) @@ -1019,7 +1068,7 @@ func _ProtocolService_ContactRequestSend_Handler(srv interface{}, ctx context.Co } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestSend", + FullMethod: ProtocolService_ContactRequestSend_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestSend(ctx, req.(*ContactRequestSend_Request)) @@ -1037,7 +1086,7 @@ func _ProtocolService_ContactRequestAccept_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestAccept", + FullMethod: ProtocolService_ContactRequestAccept_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestAccept(ctx, req.(*ContactRequestAccept_Request)) @@ -1055,7 +1104,7 @@ func _ProtocolService_ContactRequestDiscard_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactRequestDiscard", + FullMethod: ProtocolService_ContactRequestDiscard_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactRequestDiscard(ctx, req.(*ContactRequestDiscard_Request)) @@ -1073,7 +1122,7 @@ func _ProtocolService_ContactBlock_Handler(srv interface{}, ctx context.Context, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactBlock", + FullMethod: ProtocolService_ContactBlock_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactBlock(ctx, req.(*ContactBlock_Request)) @@ -1091,7 +1140,7 @@ func _ProtocolService_ContactUnblock_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactUnblock", + FullMethod: ProtocolService_ContactUnblock_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactUnblock(ctx, req.(*ContactUnblock_Request)) @@ -1109,7 +1158,7 @@ func _ProtocolService_ContactAliasKeySend_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ContactAliasKeySend", + FullMethod: ProtocolService_ContactAliasKeySend_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ContactAliasKeySend(ctx, req.(*ContactAliasKeySend_Request)) @@ -1127,7 +1176,7 @@ func _ProtocolService_MultiMemberGroupCreate_Handler(srv interface{}, ctx contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupCreate", + FullMethod: ProtocolService_MultiMemberGroupCreate_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupCreate(ctx, req.(*MultiMemberGroupCreate_Request)) @@ -1145,7 +1194,7 @@ func _ProtocolService_MultiMemberGroupJoin_Handler(srv interface{}, ctx context. } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupJoin", + FullMethod: ProtocolService_MultiMemberGroupJoin_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupJoin(ctx, req.(*MultiMemberGroupJoin_Request)) @@ -1163,7 +1212,7 @@ func _ProtocolService_MultiMemberGroupLeave_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupLeave", + FullMethod: ProtocolService_MultiMemberGroupLeave_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupLeave(ctx, req.(*MultiMemberGroupLeave_Request)) @@ -1181,7 +1230,7 @@ func _ProtocolService_MultiMemberGroupAliasResolverDisclose_Handler(srv interfac } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAliasResolverDisclose", + FullMethod: ProtocolService_MultiMemberGroupAliasResolverDisclose_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupAliasResolverDisclose(ctx, req.(*MultiMemberGroupAliasResolverDisclose_Request)) @@ -1199,7 +1248,7 @@ func _ProtocolService_MultiMemberGroupAdminRoleGrant_Handler(srv interface{}, ct } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupAdminRoleGrant", + FullMethod: ProtocolService_MultiMemberGroupAdminRoleGrant_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupAdminRoleGrant(ctx, req.(*MultiMemberGroupAdminRoleGrant_Request)) @@ -1217,7 +1266,7 @@ func _ProtocolService_MultiMemberGroupInvitationCreate_Handler(srv interface{}, } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/MultiMemberGroupInvitationCreate", + FullMethod: ProtocolService_MultiMemberGroupInvitationCreate_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).MultiMemberGroupInvitationCreate(ctx, req.(*MultiMemberGroupInvitationCreate_Request)) @@ -1235,7 +1284,7 @@ func _ProtocolService_AppMetadataSend_Handler(srv interface{}, ctx context.Conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/AppMetadataSend", + FullMethod: ProtocolService_AppMetadataSend_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).AppMetadataSend(ctx, req.(*AppMetadataSend_Request)) @@ -1253,7 +1302,7 @@ func _ProtocolService_AppMessageSend_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/AppMessageSend", + FullMethod: ProtocolService_AppMessageSend_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).AppMessageSend(ctx, req.(*AppMessageSend_Request)) @@ -1313,7 +1362,7 @@ func _ProtocolService_GroupInfo_Handler(srv interface{}, ctx context.Context, de } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/GroupInfo", + FullMethod: ProtocolService_GroupInfo_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).GroupInfo(ctx, req.(*GroupInfo_Request)) @@ -1331,7 +1380,7 @@ func _ProtocolService_ActivateGroup_Handler(srv interface{}, ctx context.Context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ActivateGroup", + FullMethod: ProtocolService_ActivateGroup_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ActivateGroup(ctx, req.(*ActivateGroup_Request)) @@ -1349,7 +1398,7 @@ func _ProtocolService_DeactivateGroup_Handler(srv interface{}, ctx context.Conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/DeactivateGroup", + FullMethod: ProtocolService_DeactivateGroup_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).DeactivateGroup(ctx, req.(*DeactivateGroup_Request)) @@ -1430,7 +1479,7 @@ func _ProtocolService_DebugGroup_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/DebugGroup", + FullMethod: ProtocolService_DebugGroup_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).DebugGroup(ctx, req.(*DebugGroup_Request)) @@ -1448,7 +1497,7 @@ func _ProtocolService_DebugAuthServiceSetToken_Handler(srv interface{}, ctx cont } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/DebugAuthServiceSetToken", + FullMethod: ProtocolService_DebugAuthServiceSetToken_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).DebugAuthServiceSetToken(ctx, req.(*DebugAuthServiceSetToken_Request)) @@ -1466,7 +1515,7 @@ func _ProtocolService_SystemInfo_Handler(srv interface{}, ctx context.Context, d } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/SystemInfo", + FullMethod: ProtocolService_SystemInfo_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).SystemInfo(ctx, req.(*SystemInfo_Request)) @@ -1484,7 +1533,7 @@ func _ProtocolService_AuthServiceInitFlow_Handler(srv interface{}, ctx context.C } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/AuthServiceInitFlow", + FullMethod: ProtocolService_AuthServiceInitFlow_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).AuthServiceInitFlow(ctx, req.(*AuthServiceInitFlow_Request)) @@ -1502,7 +1551,7 @@ func _ProtocolService_AuthServiceCompleteFlow_Handler(srv interface{}, ctx conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/AuthServiceCompleteFlow", + FullMethod: ProtocolService_AuthServiceCompleteFlow_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).AuthServiceCompleteFlow(ctx, req.(*AuthServiceCompleteFlow_Request)) @@ -1520,7 +1569,7 @@ func _ProtocolService_CredentialVerificationServiceInitFlow_Handler(srv interfac } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceInitFlow", + FullMethod: ProtocolService_CredentialVerificationServiceInitFlow_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).CredentialVerificationServiceInitFlow(ctx, req.(*CredentialVerificationServiceInitFlow_Request)) @@ -1538,7 +1587,7 @@ func _ProtocolService_CredentialVerificationServiceCompleteFlow_Handler(srv inte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/CredentialVerificationServiceCompleteFlow", + FullMethod: ProtocolService_CredentialVerificationServiceCompleteFlow_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).CredentialVerificationServiceCompleteFlow(ctx, req.(*CredentialVerificationServiceCompleteFlow_Request)) @@ -1598,7 +1647,7 @@ func _ProtocolService_ReplicationServiceRegisterGroup_Handler(srv interface{}, c } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/ReplicationServiceRegisterGroup", + FullMethod: ProtocolService_ReplicationServiceRegisterGroup_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).ReplicationServiceRegisterGroup(ctx, req.(*ReplicationServiceRegisterGroup_Request)) @@ -1616,7 +1665,7 @@ func _ProtocolService_PeerList_Handler(srv interface{}, ctx context.Context, dec } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/PeerList", + FullMethod: ProtocolService_PeerList_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).PeerList(ctx, req.(*PeerList_Request)) @@ -1634,7 +1683,7 @@ func _ProtocolService_OutOfStoreReceive_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/OutOfStoreReceive", + FullMethod: ProtocolService_OutOfStoreReceive_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).OutOfStoreReceive(ctx, req.(*OutOfStoreReceive_Request)) @@ -1652,7 +1701,7 @@ func _ProtocolService_OutOfStoreSeal_Handler(srv interface{}, ctx context.Contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/OutOfStoreSeal", + FullMethod: ProtocolService_OutOfStoreSeal_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).OutOfStoreSeal(ctx, req.(*OutOfStoreSeal_Request)) @@ -1670,7 +1719,7 @@ func _ProtocolService_RefreshContactRequest_Handler(srv interface{}, ctx context } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.protocol.v1.ProtocolService/RefreshContactRequest", + FullMethod: ProtocolService_RefreshContactRequest_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ProtocolServiceServer).RefreshContactRequest(ctx, req.(*RefreshContactRequest_Request)) diff --git a/pkg/pushtypes/pushtypes_grpc.pb.go b/pkg/pushtypes/pushtypes_grpc.pb.go index 718fb2d8..274fadb8 100644 --- a/pkg/pushtypes/pushtypes_grpc.pb.go +++ b/pkg/pushtypes/pushtypes_grpc.pb.go @@ -1,4 +1,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.3.0 +// - protoc (unknown) +// source: pushtypes/pushtypes.proto package pushtypes @@ -14,6 +18,11 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + PushService_ServerInfo_FullMethodName = "/weshnet.push.v1.PushService/ServerInfo" + PushService_Send_FullMethodName = "/weshnet.push.v1.PushService/Send" +) + // PushServiceClient is the client API for PushService 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. @@ -34,7 +43,7 @@ func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient { func (c *pushServiceClient) ServerInfo(ctx context.Context, in *PushServiceServerInfo_Request, opts ...grpc.CallOption) (*PushServiceServerInfo_Reply, error) { out := new(PushServiceServerInfo_Reply) - err := c.cc.Invoke(ctx, "/weshnet.push.v1.PushService/ServerInfo", in, out, opts...) + err := c.cc.Invoke(ctx, PushService_ServerInfo_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -43,7 +52,7 @@ func (c *pushServiceClient) ServerInfo(ctx context.Context, in *PushServiceServe func (c *pushServiceClient) Send(ctx context.Context, in *PushServiceSend_Request, opts ...grpc.CallOption) (*PushServiceSend_Reply, error) { out := new(PushServiceSend_Reply) - err := c.cc.Invoke(ctx, "/weshnet.push.v1.PushService/Send", in, out, opts...) + err := c.cc.Invoke(ctx, PushService_Send_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -94,7 +103,7 @@ func _PushService_ServerInfo_Handler(srv interface{}, ctx context.Context, dec f } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.push.v1.PushService/ServerInfo", + FullMethod: PushService_ServerInfo_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PushServiceServer).ServerInfo(ctx, req.(*PushServiceServerInfo_Request)) @@ -112,7 +121,7 @@ func _PushService_Send_Handler(srv interface{}, ctx context.Context, dec func(in } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.push.v1.PushService/Send", + FullMethod: PushService_Send_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(PushServiceServer).Send(ctx, req.(*PushServiceSend_Request)) diff --git a/pkg/replicationtypes/bertyreplication_grpc.pb.go b/pkg/replicationtypes/bertyreplication_grpc.pb.go index db1963a8..33ff7c9a 100644 --- a/pkg/replicationtypes/bertyreplication_grpc.pb.go +++ b/pkg/replicationtypes/bertyreplication_grpc.pb.go @@ -1,4 +1,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. +// versions: +// - protoc-gen-go-grpc v1.3.0 +// - protoc (unknown) +// source: replicationtypes/bertyreplication.proto package replicationtypes @@ -14,6 +18,12 @@ import ( // Requires gRPC-Go v1.32.0 or later. const _ = grpc.SupportPackageIsVersion7 +const ( + ReplicationService_ReplicateGroup_FullMethodName = "/weshnet.replication.v1.ReplicationService/ReplicateGroup" + ReplicationService_ReplicateGlobalStats_FullMethodName = "/weshnet.replication.v1.ReplicationService/ReplicateGlobalStats" + ReplicationService_ReplicateGroupStats_FullMethodName = "/weshnet.replication.v1.ReplicationService/ReplicateGroupStats" +) + // 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. @@ -34,7 +44,7 @@ func NewReplicationServiceClient(cc grpc.ClientConnInterface) ReplicationService func (c *replicationServiceClient) ReplicateGroup(ctx context.Context, in *ReplicationServiceReplicateGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceReplicateGroup_Reply, error) { out := new(ReplicationServiceReplicateGroup_Reply) - err := c.cc.Invoke(ctx, "/weshnet.replication.v1.ReplicationService/ReplicateGroup", in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroup_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -43,7 +53,7 @@ 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) { out := new(ReplicateGlobalStats_Reply) - err := c.cc.Invoke(ctx, "/weshnet.replication.v1.ReplicationService/ReplicateGlobalStats", in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGlobalStats_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -52,7 +62,7 @@ func (c *replicationServiceClient) ReplicateGlobalStats(ctx context.Context, in func (c *replicationServiceClient) ReplicateGroupStats(ctx context.Context, in *ReplicateGroupStats_Request, opts ...grpc.CallOption) (*ReplicateGroupStats_Reply, error) { out := new(ReplicateGroupStats_Reply) - err := c.cc.Invoke(ctx, "/weshnet.replication.v1.ReplicationService/ReplicateGroupStats", in, out, opts...) + err := c.cc.Invoke(ctx, ReplicationService_ReplicateGroupStats_FullMethodName, in, out, opts...) if err != nil { return nil, err } @@ -106,7 +116,7 @@ func _ReplicationService_ReplicateGroup_Handler(srv interface{}, ctx context.Con } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.replication.v1.ReplicationService/ReplicateGroup", + FullMethod: ReplicationService_ReplicateGroup_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ReplicationServiceServer).ReplicateGroup(ctx, req.(*ReplicationServiceReplicateGroup_Request)) @@ -124,7 +134,7 @@ func _ReplicationService_ReplicateGlobalStats_Handler(srv interface{}, ctx conte } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.replication.v1.ReplicationService/ReplicateGlobalStats", + FullMethod: ReplicationService_ReplicateGlobalStats_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ReplicationServiceServer).ReplicateGlobalStats(ctx, req.(*ReplicateGlobalStats_Request)) @@ -142,7 +152,7 @@ func _ReplicationService_ReplicateGroupStats_Handler(srv interface{}, ctx contex } info := &grpc.UnaryServerInfo{ Server: srv, - FullMethod: "/weshnet.replication.v1.ReplicationService/ReplicateGroupStats", + FullMethod: ReplicationService_ReplicateGroupStats_FullMethodName, } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(ReplicationServiceServer).ReplicateGroupStats(ctx, req.(*ReplicateGroupStats_Request))