From c56af9f87c086ce27f81f34387ed013468487fad Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Fri, 15 Jul 2022 12:35:54 +0300 Subject: [PATCH] remove drpc --- cmd/client/client.go | 52 ------------- cmd/node/node.go | 1 - go.mod | 15 ++-- go.sum | 13 +--- service/server/drpc.go | 99 ------------------------ syncproto/service_drpc.pb.go | 146 ----------------------------------- 6 files changed, 9 insertions(+), 317 deletions(-) delete mode 100644 service/server/drpc.go delete mode 100644 syncproto/service_drpc.pb.go diff --git a/cmd/client/client.go b/cmd/client/client.go index 0f9cce60..de5eee2e 100644 --- a/cmd/client/client.go +++ b/cmd/client/client.go @@ -9,9 +9,6 @@ import ( "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" "log" - "net" - "storj.io/drpc" - "storj.io/drpc/drpcconn" "time" ) @@ -25,7 +22,6 @@ func main() { panic(err) } benchGrpc(conf) - benchDrpc(conf) } func benchGrpc(conf *config.Config) { @@ -69,51 +65,3 @@ func benchGrpc(conf *config.Config) { dur := time.Since(st) fmt.Printf("%d req for %v (%d per sec)\n", n, dur, int(float64(n)/dur.Seconds())) } - -func benchDrpc(conf *config.Config) { - rawconn, err := net.Dial("tcp", conf.GrpcServer.ListenAddrs[1]) - if err != nil { - panic(err) - } - conn := drpcconn.New(rawconn) - defer conn.Close() - client := syncproto.NewDRPCAnytypeSyncClient(conn) - - stream, err := client.Ping(context.TODO()) - if err != nil { - panic(err) - } - - st := time.Now() - n := 100000 - - for i := 0; i < n; i++ { - if err = stream.MsgSend(&syncproto.PingRequest{ - Seq: int64(i), - }, enc{}); err != nil { - panic(err) - } - msg := &syncproto.PingResponse{} - err := stream.MsgRecv(msg, enc{}) - if err != nil { - panic(err) - } - } - dur := time.Since(st) - fmt.Printf("%d req for %v (%d per sec)\n", n, dur, int(float64(n)/dur.Seconds())) -} - -type enc struct { -} - -func (e enc) Marshal(msg drpc.Message) ([]byte, error) { - return msg.(interface { - Marshal() ([]byte, error) - }).Marshal() -} - -func (e enc) Unmarshal(buf []byte, msg drpc.Message) error { - return msg.(interface { - Unmarshal(buf []byte) error - }).Unmarshal(buf) -} diff --git a/cmd/node/node.go b/cmd/node/node.go index a6700e75..161daa88 100644 --- a/cmd/node/node.go +++ b/cmd/node/node.go @@ -81,5 +81,4 @@ func main() { func Bootstrap(a *app.App) { a.Register(server.New()) - a.Register(server.NewDRPC()) } diff --git a/go.mod b/go.mod index c06a0cc1..972a6472 100644 --- a/go.mod +++ b/go.mod @@ -6,16 +6,15 @@ require ( github.com/awalterschulze/gographviz v0.0.0-20190522210029-fa59802746ab github.com/goccy/go-graphviz v0.0.9 github.com/gogo/protobuf v1.3.2 + github.com/ipfs/go-cid v0.0.7 github.com/libp2p/go-libp2p-core v0.8.5 github.com/mr-tron/base58 v1.2.0 - github.com/multiformats/go-base32 v0.0.3 - github.com/multiformats/go-multiaddr v0.3.3 - github.com/multiformats/go-multiaddr-dns v0.3.1 - github.com/multiformats/go-multibase v0.0.3 github.com/multiformats/go-multihash v0.0.15 github.com/prometheus/common v0.18.0 github.com/stretchr/testify v1.7.0 github.com/textileio/go-threads v1.0.2-0.20210304072541-d0f91da84404 + go.uber.org/zap v1.21.0 + google.golang.org/grpc v1.48.0 gopkg.in/yaml.v3 v3.0.1 ) @@ -31,33 +30,31 @@ require ( github.com/golang/freetype v0.0.0-20170609003504-e2365dfdc4a0 // indirect github.com/golang/protobuf v1.5.2 // indirect github.com/grpc-ecosystem/go-grpc-middleware v1.2.1 // indirect - github.com/ipfs/go-cid v0.0.7 // indirect github.com/klauspost/cpuid/v2 v2.0.4 // indirect github.com/konsorten/go-windows-terminal-sequences v1.0.3 // indirect github.com/libp2p/go-buffer-pool v0.0.2 // indirect github.com/libp2p/go-openssl v0.0.7 // indirect github.com/minio/blake2b-simd v0.0.0-20160723061019-3f5f724cb5b1 // indirect github.com/minio/sha256-simd v1.0.0 // indirect + github.com/multiformats/go-base32 v0.0.3 // indirect github.com/multiformats/go-base36 v0.1.0 // indirect + github.com/multiformats/go-multiaddr v0.3.3 // indirect + github.com/multiformats/go-multibase v0.0.3 // indirect github.com/multiformats/go-varint v0.0.6 // indirect github.com/pkg/errors v0.9.1 // indirect github.com/pmezard/go-difflib v1.0.0 // indirect github.com/sirupsen/logrus v1.6.0 // indirect github.com/spacemonkeygo/spacelog v0.0.0-20180420211403-2296661a0572 // indirect - github.com/zeebo/errs v1.2.2 // indirect go.uber.org/atomic v1.9.0 // indirect go.uber.org/multierr v1.8.0 // indirect - go.uber.org/zap v1.21.0 // indirect golang.org/x/crypto v0.0.0-20210322153248-0c34fe9e7dc2 // indirect golang.org/x/image v0.0.0-20200119044424-58c23975cae1 // indirect golang.org/x/net v0.0.0-20210423184538-5f58ad60dda6 // indirect golang.org/x/sys v0.0.0-20210510120138-977fb7262007 // indirect golang.org/x/text v0.3.6 // indirect google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect - google.golang.org/grpc v1.48.0 // indirect google.golang.org/protobuf v1.27.1 // indirect gopkg.in/alecthomas/kingpin.v2 v2.2.6 // indirect - storj.io/drpc v0.0.32 // indirect ) replace github.com/textileio/go-threads => github.com/anytypeio/go-threads v1.1.0-rc1.0.20220223104843-a67245cee80e diff --git a/go.sum b/go.sum index e9440306..8b742ebd 100644 --- a/go.sum +++ b/go.sum @@ -50,6 +50,7 @@ github.com/aws/aws-sdk-go v1.29.15/go.mod h1:1KvfttTE3SPKMpo8g2c6jL3ZKfXtFvKscTg github.com/aws/aws-sdk-go-v2 v0.18.0/go.mod h1:JWVYvqSMppoMJC0x5wdwiImzgXTI9FuZwxzkQq9wy+g= github.com/benbjohnson/clock v1.0.2/go.mod h1:bGMdMPoPVvcYyt1gHDf4J2KE153Yf9BuiUKYMaxlTDM= github.com/benbjohnson/clock v1.0.3/go.mod h1:bGMdMPoPVvcYyt1gHDf4J2KE153Yf9BuiUKYMaxlTDM= +github.com/benbjohnson/clock v1.1.0 h1:Q92kusRqC1XV2MjkWETPvjJVqKetz1OzxZB7mHJLju8= github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA= github.com/beorn7/perks v0.0.0-20180321164747-3a771d992973/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= github.com/beorn7/perks v1.0.0/go.mod h1:KWe93zE9D1o94FZ5RNwFwVgaQK1VOXiVxmqh+CedLV8= @@ -231,7 +232,6 @@ github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:W github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= -github.com/golang/protobuf v1.4.3 h1:JjCZWpVbqXDqFVmTfYWEVTMIYrL/NPdPSCHPJ0T/raM= github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw= @@ -246,7 +246,6 @@ github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMyw github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.3/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= -github.com/google/go-cmp v0.5.4 h1:L8R9j+yAqZuZjsqh/z+F1NCffTKKLShY6zXTItVIZ8M= github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ= @@ -1044,8 +1043,6 @@ github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77/go.mod h1: github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74= github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k= -github.com/zeebo/errs v1.2.2 h1:5NFypMTuSdoySVTqlNs1dEoU21QVamMQJxW/Fii5O7g= -github.com/zeebo/errs v1.2.2/go.mod h1:sgbWHsvVuTPHcqJJGQ1WhI5KbWlHYz+2+2C/LSEtCw4= go.etcd.io/bbolt v1.3.3/go.mod h1:IbVyRI1SCnLcuJnV2u8VeU0CEYM7e686BmAb1XKL+uU= go.etcd.io/etcd v0.0.0-20191023171146-3cf2f69b5738/go.mod h1:dnLIgRNXwCJa5e+c6mIZCrds/GIG4ncV9HhK5PX7jPg= go.mongodb.org/mongo-driver v1.4.0/go.mod h1:llVBH2pkj9HywK0Dtdt6lDikOjFLbceHVu/Rc0iMKLs= @@ -1067,6 +1064,7 @@ go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE= go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/goleak v1.0.0/go.mod h1:8a7PlsEVH3e/a/GLqe5IIrQx6GzcnRmZEufDUTk4A7A= +go.uber.org/goleak v1.1.11 h1:wy28qYRKZgnJTxGxvye5/wgWr1EKjmUDGYox5mGlRlI= go.uber.org/goleak v1.1.11/go.mod h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ= go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0= go.uber.org/multierr v1.3.0/go.mod h1:VgVr7evmIr6uPjLBxg28wmKNXyqE9akIJ5XnfpiKl+4= @@ -1249,7 +1247,6 @@ golang.org/x/sys v0.0.0-20210315160823-c6e025ad8005/go.mod h1:h1NjWce9XRLGQEsW7w golang.org/x/sys v0.0.0-20210317225723-c4fcb01b228e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= -golang.org/x/sys v0.0.0-20210426080607-c94f62235c83 h1:kHSDPqCtsHZOg0nVylfTo20DDhE9gG4Y0jn7hKQ0QAM= golang.org/x/sys v0.0.0-20210426080607-c94f62235c83/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210510120138-977fb7262007 h1:gG67DSER+11cZvqIMb8S8bt0vZtiN6xWYARwirrOSfE= golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -1339,7 +1336,6 @@ google.golang.org/grpc v1.28.1/go.mod h1:rpkK4SK4GF4Ach/+MFLZUBavHOvF2JJB5uozKKa google.golang.org/grpc v1.29.1/go.mod h1:itym6AZVZYACWQqET3MqgPpjcuV5QH3BxFS3IjizoKk= google.golang.org/grpc v1.31.1/go.mod h1:N36X2cJ7JwdamYAgDz+s+rVMFjt3numwzf/HckM8pak= google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0= -google.golang.org/grpc v1.33.2 h1:EQyQC3sa8M+p6Ulc8yy9SWSS2GVwyRc83gAbG8lrl4o= google.golang.org/grpc v1.33.2/go.mod h1:JMHMWHQWaTccqQQlmk3MJZS+GWXOdAesneDmEnv2fbc= google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= google.golang.org/grpc v1.48.0 h1:rQOsyJ/8+ufEDJd/Gdsz7HG220Mh9HAhFHRGnIjda0w= @@ -1352,7 +1348,6 @@ google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzi google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= -google.golang.org/protobuf v1.25.0 h1:Ejskq+SyPohKW+1uil0JJMtmHCgJPJ/qWTxr8qp+R4c= google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= @@ -1382,8 +1377,8 @@ gopkg.in/yaml.v2 v2.2.3/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.4/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.5/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v2 v2.3.0 h1:clyUAQHOM3G0M3f5vQj7LuJrETvjVot3Z5el9nffUtU= gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= -gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= @@ -1400,5 +1395,3 @@ sigs.k8s.io/yaml v1.1.0/go.mod h1:UJmg0vDUVViEyp3mgSv9WPwZCDxu4rQW1olrI1uml+o= sourcegraph.com/sourcegraph/appdash v0.0.0-20190731080439-ebfcffb1b5c0/go.mod h1:hI742Nqp5OhwiqlzhgfbWU4mW4yO10fP+LoT9WOswdU= sourcegraph.com/sourcegraph/go-diff v0.5.0/go.mod h1:kuch7UrkMzY0X+p9CRK03kfuPQ2zzQcaEFbx8wA8rck= sourcegraph.com/sqs/pbtypes v0.0.0-20180604144634-d3ebe8f20ae4/go.mod h1:ketZ/q3QxT9HOBeFhu6RdvsftgpsbFHBF5Cas6cDKZ0= -storj.io/drpc v0.0.32 h1:5p5ZwsK/VOgapaCu+oxaPVwO6UwIs+iwdMiD50+R4PI= -storj.io/drpc v0.0.32/go.mod h1:6rcOyR/QQkSTX/9L5ZGtlZaE2PtXTTZl8d+ulSeeYEg= diff --git a/service/server/drpc.go b/service/server/drpc.go deleted file mode 100644 index 479392e6..00000000 --- a/service/server/drpc.go +++ /dev/null @@ -1,99 +0,0 @@ -package server - -import ( - "context" - "github.com/anytypeio/go-anytype-infrastructure-experiments/app" - "github.com/anytypeio/go-anytype-infrastructure-experiments/config" - "github.com/anytypeio/go-anytype-infrastructure-experiments/syncproto" - "io" - "net" - "storj.io/drpc" - "storj.io/drpc/drpcmux" - "storj.io/drpc/drpcserver" - "time" -) - -const CNameDRPC = "serverDrpc" - -func NewDRPC() *ServerDrpc { - return &ServerDrpc{} -} - -type ServerDrpc struct { - config config.GrpcServer - grpcServerDrpc *drpcserver.Server - cancel func() -} - -func (s *ServerDrpc) Init(ctx context.Context, a *app.App) (err error) { - s.config = a.MustComponent(config.CName).(*config.Config).GrpcServer - return nil -} - -func (s *ServerDrpc) Name() (name string) { - return CNameDRPC -} - -func (s *ServerDrpc) Run(ctx context.Context) (err error) { - m := drpcmux.New() - lis, err := net.Listen("tcp", s.config.ListenAddrs[1]) - if err != nil { - return err - } - err = syncproto.DRPCRegisterAnytypeSync(m, s) - if err != nil { - return err - } - ctx, s.cancel = context.WithCancel(ctx) - s.grpcServerDrpc = drpcserver.New(m) - var errCh = make(chan error) - go func() { - errCh <- s.grpcServerDrpc.Serve(ctx, lis) - }() - select { - case <-time.After(time.Second / 4): - case err = <-errCh: - } - log.Sugar().Infof("drpc server started at: %v", s.config.ListenAddrs[1]) - return -} - -func (s *ServerDrpc) Ping(stream syncproto.DRPCAnytypeSync_PingStream) error { - for { - var in = &syncproto.PingRequest{} - err := stream.MsgRecv(in, enc{}) - if err == io.EOF { - return nil - } - if err != nil { - return err - } - if err := stream.MsgSend(&syncproto.PingResponse{ - Seq: in.Seq, - }, enc{}); err != nil { - return err - } - } -} - -func (s *ServerDrpc) Close(ctx context.Context) (err error) { - if s.cancel != nil { - s.cancel() - } - return -} - -type enc struct { -} - -func (e enc) Marshal(msg drpc.Message) ([]byte, error) { - return msg.(interface { - Marshal() ([]byte, error) - }).Marshal() -} - -func (e enc) Unmarshal(buf []byte, msg drpc.Message) error { - return msg.(interface { - Unmarshal(buf []byte) error - }).Unmarshal(buf) -} diff --git a/syncproto/service_drpc.pb.go b/syncproto/service_drpc.pb.go deleted file mode 100644 index 694868b4..00000000 --- a/syncproto/service_drpc.pb.go +++ /dev/null @@ -1,146 +0,0 @@ -// Code generated by protoc-gen-go-drpc. DO NOT EDIT. -// protoc-gen-go-drpc version: v0.0.32 -// source: syncproto/proto/service.proto - -package syncproto - -import ( - context "context" - errors "errors" - protojson "google.golang.org/protobuf/encoding/protojson" - proto "google.golang.org/protobuf/proto" - drpc "storj.io/drpc" - drpcerr "storj.io/drpc/drpcerr" -) - -type drpcEncoding_File_syncproto_proto_service_proto struct{} - -func (drpcEncoding_File_syncproto_proto_service_proto) Marshal(msg drpc.Message) ([]byte, error) { - return proto.Marshal(msg.(proto.Message)) -} - -func (drpcEncoding_File_syncproto_proto_service_proto) MarshalAppend(buf []byte, msg drpc.Message) ([]byte, error) { - return proto.MarshalOptions{}.MarshalAppend(buf, msg.(proto.Message)) -} - -func (drpcEncoding_File_syncproto_proto_service_proto) Unmarshal(buf []byte, msg drpc.Message) error { - return proto.Unmarshal(buf, msg.(proto.Message)) -} - -func (drpcEncoding_File_syncproto_proto_service_proto) JSONMarshal(msg drpc.Message) ([]byte, error) { - return protojson.Marshal(msg.(proto.Message)) -} - -func (drpcEncoding_File_syncproto_proto_service_proto) JSONUnmarshal(buf []byte, msg drpc.Message) error { - return protojson.Unmarshal(buf, msg.(proto.Message)) -} - -type DRPCAnytypeSyncClient interface { - DRPCConn() drpc.Conn - - Ping(ctx context.Context) (DRPCAnytypeSync_PingClient, error) -} - -type drpcAnytypeSyncClient struct { - cc drpc.Conn -} - -func NewDRPCAnytypeSyncClient(cc drpc.Conn) DRPCAnytypeSyncClient { - return &drpcAnytypeSyncClient{cc} -} - -func (c *drpcAnytypeSyncClient) DRPCConn() drpc.Conn { return c.cc } - -func (c *drpcAnytypeSyncClient) Ping(ctx context.Context) (DRPCAnytypeSync_PingClient, error) { - stream, err := c.cc.NewStream(ctx, "/anytype.AnytypeSync/Ping", drpcEncoding_File_syncproto_proto_service_proto{}) - if err != nil { - return nil, err - } - x := &drpcAnytypeSync_PingClient{stream} - return x, nil -} - -type DRPCAnytypeSync_PingClient interface { - drpc.Stream - Send(*PingRequest) error - Recv() (*PingResponse, error) -} - -type drpcAnytypeSync_PingClient struct { - drpc.Stream -} - -func (x *drpcAnytypeSync_PingClient) Send(m *PingRequest) error { - return x.MsgSend(m, drpcEncoding_File_syncproto_proto_service_proto{}) -} - -func (x *drpcAnytypeSync_PingClient) Recv() (*PingResponse, error) { - m := new(PingResponse) - if err := x.MsgRecv(m, drpcEncoding_File_syncproto_proto_service_proto{}); err != nil { - return nil, err - } - return m, nil -} - -func (x *drpcAnytypeSync_PingClient) RecvMsg(m *PingResponse) error { - return x.MsgRecv(m, drpcEncoding_File_syncproto_proto_service_proto{}) -} - -type DRPCAnytypeSyncServer interface { - Ping(DRPCAnytypeSync_PingStream) error -} - -type DRPCAnytypeSyncUnimplementedServer struct{} - -func (s *DRPCAnytypeSyncUnimplementedServer) Ping(DRPCAnytypeSync_PingStream) error { - return drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented) -} - -type DRPCAnytypeSyncDescription struct{} - -func (DRPCAnytypeSyncDescription) NumMethods() int { return 1 } - -func (DRPCAnytypeSyncDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) { - switch n { - case 0: - return "/anytype.AnytypeSync/Ping", drpcEncoding_File_syncproto_proto_service_proto{}, - func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) { - return nil, srv.(DRPCAnytypeSyncServer). - Ping( - &drpcAnytypeSync_PingStream{in1.(drpc.Stream)}, - ) - }, DRPCAnytypeSyncServer.Ping, true - default: - return "", nil, nil, nil, false - } -} - -func DRPCRegisterAnytypeSync(mux drpc.Mux, impl DRPCAnytypeSyncServer) error { - return mux.Register(impl, DRPCAnytypeSyncDescription{}) -} - -type DRPCAnytypeSync_PingStream interface { - drpc.Stream - Send(*PingResponse) error - Recv() (*PingRequest, error) -} - -type drpcAnytypeSync_PingStream struct { - drpc.Stream -} - -func (x *drpcAnytypeSync_PingStream) Send(m *PingResponse) error { - return x.MsgSend(m, drpcEncoding_File_syncproto_proto_service_proto{}) -} - -func (x *drpcAnytypeSync_PingStream) Recv() (*PingRequest, error) { - m := new(PingRequest) - if err := x.MsgRecv(m, drpcEncoding_File_syncproto_proto_service_proto{}); err != nil { - return nil, err - } - return m, nil -} - -func (x *drpcAnytypeSync_PingStream) RecvMsg(m *PingRequest) error { - return x.MsgRecv(m, drpcEncoding_File_syncproto_proto_service_proto{}) -}