Add healing feature

pkg/networkservice/chains/client/client.go

@@ -23,6 +23,8 @@ import (
 	"github.com/google/uuid"
 	"github.com/networkservicemesh/api/pkg/api/networkservice"
 
+	"github.com/networkservicemesh/sdk/pkg/networkservice/common/trimpath"
+
 	"github.com/networkservicemesh/sdk/pkg/networkservice/common/begin"
 	"github.com/networkservicemesh/sdk/pkg/networkservice/common/clientconn"
 	"github.com/networkservicemesh/sdk/pkg/networkservice/common/clienturl"
@@ -43,6 +45,7 @@ func NewClient(ctx context.Context, clientOpts ...Option) networkservice.Network
 	var opts = &clientOptions{
 		name:            "client-" + uuid.New().String(),
 		authorizeClient: null.NewClient(),
+		healClient:      null.NewClient(),
 		refreshClient:   refresh.NewClient(ctx),
 	}
 	for _, opt := range clientOpts {
@@ -59,6 +62,7 @@ func NewClient(ctx context.Context, clientOpts ...Option) networkservice.Network
 				opts.refreshClient,
 				clienturl.NewClient(opts.clientURL),
 				clientconn.NewClient(opts.cc),
+				opts.healClient,
 				dial.NewClient(ctx,
 					dial.WithDialOptions(opts.dialOptions...),
 					dial.WithDialTimeout(opts.dialTimeout),
@@ -67,6 +71,7 @@ func NewClient(ctx context.Context, clientOpts ...Option) networkservice.Network
 			append(
 				opts.additionalFunctionality,
 				opts.authorizeClient,
+				trimpath.NewClient(),
 				connect.NewClient(),
 			)...,
 		)...,

pkg/networkservice/chains/client/options.go

@@ -33,6 +33,7 @@ type clientOptions struct {
 	additionalFunctionality []networkservice.NetworkServiceClient
 	authorizeClient         networkservice.NetworkServiceClient
 	refreshClient           networkservice.NetworkServiceClient
+	healClient              networkservice.NetworkServiceClient
 	dialOptions             []grpc.DialOption
 	dialTimeout             time.Duration
 }
@@ -78,6 +79,16 @@ func WithAuthorizeClient(authorizeClient networkservice.NetworkServiceClient) Op
 	})
 }
 
+// WithHealClient sets healClient for the client chain.
+func WithHealClient(healClient networkservice.NetworkServiceClient) Option {
+	if healClient == nil {
+		panic("healClient cannot be nil")
+	}
+	return Option(func(c *clientOptions) {
+		c.healClient = healClient
+	})
+}
+
 // WithDialOptions sets dial options
 func WithDialOptions(dialOptions ...grpc.DialOption) Option {
 	return Option(func(c *clientOptions) {

pkg/networkservice/chains/endpoint/server.go

@@ -25,6 +25,8 @@ import (
 
 	"google.golang.org/grpc"
 
+	"github.com/networkservicemesh/sdk/pkg/networkservice/common/trimpath"
+
 	"github.com/networkservicemesh/sdk/pkg/networkservice/utils/metadata"
 
 	"github.com/networkservicemesh/sdk/pkg/networkservice/common/begin"
@@ -112,7 +114,9 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, options
 			metadata.NewServer(),
 			timeout.NewServer(ctx),
 			monitor.NewServer(ctx, &rv.MonitorConnectionServer),
+			trimpath.NewServer(),
 		}, opts.additionalFunctionality...)...)
+
 	return rv
 }