From 163c0e4058012f8bdbf723737479ffd55a3a0c4e Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Sat, 4 Feb 2023 15:20:34 +0300 Subject: [PATCH] testrpc server implement app.Component --- net/rpc/rpctest/server.go | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/net/rpc/rpctest/server.go b/net/rpc/rpctest/server.go index 9a36d288..5efc596a 100644 --- a/net/rpc/rpctest/server.go +++ b/net/rpc/rpctest/server.go @@ -2,6 +2,8 @@ package rpctest import ( "context" + "github.com/anytypeio/any-sync/app" + "github.com/anytypeio/any-sync/net/rpc/server" "net" "storj.io/drpc" "storj.io/drpc/drpcconn" @@ -22,6 +24,22 @@ type TesServer struct { *drpcserver.Server } +func (ts *TesServer) Init(a *app.App) (err error) { + return nil +} + +func (ts *TesServer) Name() (name string) { + return server.CName +} + +func (ts *TesServer) Run(ctx context.Context) (err error) { + return nil +} + +func (ts *TesServer) Close(ctx context.Context) (err error) { + return nil +} + func (ts *TesServer) Dial(ctx context.Context) drpc.Conn { sc, cc := net.Pipe() go ts.Server.ServeOne(ctx, sc)