diff --git a/pkg/networkservice/chains/nsmgr/server.go b/pkg/networkservice/chains/nsmgr/server.go index 76995ec0e..eaf4ac4ed 100644 --- a/pkg/networkservice/chains/nsmgr/server.go +++ b/pkg/networkservice/chains/nsmgr/server.go @@ -272,8 +272,8 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, options var nseRegistry = chain.NewNetworkServiceEndpointRegistryServer( grpcmetadata.NewNetworkServiceEndpointRegistryServer(), - updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), begin.NewNetworkServiceEndpointRegistryServer(), + updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), opts.authorizeNSERegistryServer, registryclientinfo.NewNetworkServiceEndpointRegistryServer(), expire.NewNetworkServiceEndpointRegistryServer(ctx, time.Minute), diff --git a/pkg/networkservice/chains/nsmgrproxy/server.go b/pkg/networkservice/chains/nsmgrproxy/server.go index 512c7bd9b..d8c2b99b9 100644 --- a/pkg/networkservice/chains/nsmgrproxy/server.go +++ b/pkg/networkservice/chains/nsmgrproxy/server.go @@ -292,8 +292,8 @@ func NewServer(ctx context.Context, regURL, proxyURL *url.URL, tokenGenerator to var nseServerChain = chain.NewNetworkServiceEndpointRegistryServer( grpcmetadata.NewNetworkServiceEndpointRegistryServer(), - updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), begin.NewNetworkServiceEndpointRegistryServer(), + updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), opts.authorizeNSERegistryServer, clienturl.NewNetworkServiceEndpointRegistryServer(proxyURL), interdomainBypassNSEServer, diff --git a/pkg/registry/chains/memory/server.go b/pkg/registry/chains/memory/server.go index 141953495..c35b84595 100644 --- a/pkg/registry/chains/memory/server.go +++ b/pkg/registry/chains/memory/server.go @@ -136,8 +136,8 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, options nseChain := chain.NewNetworkServiceEndpointRegistryServer( grpcmetadata.NewNetworkServiceEndpointRegistryServer(), - updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), begin.NewNetworkServiceEndpointRegistryServer(), + updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), opts.authorizeNSERegistryServer, switchcase.NewNetworkServiceEndpointRegistryServer(switchcase.NSEServerCase{ Condition: func(c context.Context, nse *registry.NetworkServiceEndpoint) bool { diff --git a/pkg/registry/chains/proxydns/server.go b/pkg/registry/chains/proxydns/server.go index 38fad4401..b5bcd136a 100644 --- a/pkg/registry/chains/proxydns/server.go +++ b/pkg/registry/chains/proxydns/server.go @@ -110,8 +110,8 @@ func NewServer(ctx context.Context, tokenGenerator token.GeneratorFunc, dnsResol nseChain := chain.NewNetworkServiceEndpointRegistryServer( grpcmetadata.NewNetworkServiceEndpointRegistryServer(), - updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), begin.NewNetworkServiceEndpointRegistryServer(), + updatepath.NewNetworkServiceEndpointRegistryServer(tokenGenerator), opts.authorizeNSERegistryServer, dnsresolve.NewNetworkServiceEndpointRegistryServer(dnsresolve.WithResolver(dnsResolver)), connect.NewNetworkServiceEndpointRegistryServer(