testrpc server implement app.Component

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)