*: Cache network settings

Closes #247.

Caching data for the half epoch duration time.

Signed-off-by: Evgenii Baidakov <[email protected]>

cmd/neofs-rest-gw/config.go

@@ -596,6 +596,7 @@ func newNeofsAPI(ctx context.Context, logger *zap.Logger, v *viper.Viper) (*hand
 	}
 
 	apiPrm.DefaultTimestamp = v.GetBool(cfgPoolDefaultTimestamp)
+	apiPrm.EpochUpdateInterval = time.Duration(int64(ni.EpochDuration())/2*ni.MsPerBlock()) * time.Millisecond
 
 	return handlers.NewAPI(&apiPrm)
 }

go.mod

@@ -5,6 +5,7 @@ go 1.22
 require (
 	github.com/getkin/kin-openapi v0.127.0
 	github.com/google/uuid v1.6.0
+	github.com/hashicorp/golang-lru/v2 v2.0.7
 	github.com/labstack/echo/v4 v4.12.0
 	github.com/nspcc-dev/neo-go v0.106.3
 	github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12
@@ -33,7 +34,6 @@ require (
 	github.com/go-openapi/swag v0.23.0 // indirect
 	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
 	github.com/gorilla/mux v1.8.1 // indirect
-	github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect
 	github.com/invopop/yaml v0.3.1 // indirect
 	github.com/klauspost/compress v1.17.9 // indirect
 	github.com/labstack/gommon v0.4.2 // indirect

handlers/api.go

@@ -11,8 +11,10 @@ import (
 	"github.com/labstack/echo/v4"
 	"github.com/nspcc-dev/neo-go/pkg/crypto/keys"
 	"github.com/nspcc-dev/neofs-rest-gw/handlers/apiserver"
+	"github.com/nspcc-dev/neofs-rest-gw/internal/cache"
 	"github.com/nspcc-dev/neofs-rest-gw/internal/util"
 	"github.com/nspcc-dev/neofs-rest-gw/metrics"
+	"github.com/nspcc-dev/neofs-sdk-go/netmap"
 	"github.com/nspcc-dev/neofs-sdk-go/pool"
 	"github.com/nspcc-dev/neofs-sdk-go/session"
 	"github.com/nspcc-dev/neofs-sdk-go/user"
@@ -32,6 +34,7 @@ type PrmAPI struct {
 	PrometheusService      *metrics.Service
 	PprofService           *metrics.Service
 	ServiceShutdownTimeout time.Duration
+	EpochUpdateInterval    time.Duration
 }
 
 type BearerToken struct {
@@ -45,6 +48,10 @@ type SessionToken struct {
 	Verb session.ContainerVerb
 }
 
+type networkInfoGetter interface {
+	NetworkInfo(ctx context.Context) (netmap.NetworkInfo, error)
+}
+
 const (
 	// bearerCookieName is the name of the bearer cookie.
 	bearerCookieName = "Bearer"
@@ -75,6 +82,7 @@ func NewAPI(prm *PrmAPI) (*RestAPI, error) {
 		pprofService:           prm.PprofService,
 		gateMetric:             prm.GateMetric,
 		serviceShutdownTimeout: prm.ServiceShutdownTimeout,
+		networkInfoGetter:      cache.NewNetworkInfoCache(prm.Pool, prm.EpochUpdateInterval),
 	}, nil
 }
 
@@ -141,6 +149,7 @@ type RestAPI struct {
 	prometheusService      *metrics.Service
 	pprofService           *metrics.Service
 	serviceShutdownTimeout time.Duration
+	networkInfoGetter      networkInfoGetter
 }
 
 func (a *RestAPI) StartCallback() {

handlers/containers.go

@@ -64,7 +64,7 @@ func (a *RestAPI) PutContainer(ctx echo.Context, params apiserver.PutContainerPa
 		return ctx.JSON(http.StatusBadRequest, resp)
 	}
 
-	cnrID, err := createContainer(ctx.Request().Context(), a.pool, stoken, body, params, a.signer)
+	cnrID, err := createContainer(ctx.Request().Context(), a.pool, stoken, body, params, a.signer, a.networkInfoGetter)
 	if err != nil {
 		resp := a.logAndGetErrorResponse("create container", err)
 		return ctx.JSON(http.StatusBadRequest, resp)
@@ -381,7 +381,7 @@ func getContainerEACL(ctx context.Context, p *pool.Pool, cnrID cid.ID) (*apiserv
 	return tableResp, nil
 }
 
-func createContainer(ctx context.Context, p *pool.Pool, stoken session.Container, request apiserver.ContainerPutInfo, params apiserver.PutContainerParams, signer user.Signer) (cid.ID, error) {
+func createContainer(ctx context.Context, p *pool.Pool, stoken session.Container, request apiserver.ContainerPutInfo, params apiserver.PutContainerParams, signer user.Signer, networkInfoGetter networkInfoGetter) (cid.ID, error) {
 	if request.PlacementPolicy == "" {
 		request.PlacementPolicy = defaultPlacementPolicy
 	}
@@ -406,6 +406,15 @@ func createContainer(ctx context.Context, p *pool.Pool, stoken session.Container
 	cnr.SetBasicACL(basicACL)
 	cnr.SetOwner(stoken.Issuer())
 
+	ni, err := networkInfoGetter.NetworkInfo(ctx)
+	if err != nil {
+		return cid.ID{}, fmt.Errorf("couldn't get network info: %w", err)
+	}
+
+	if ni.HomomorphicHashingDisabled() {
+		cnr.DisableHomomorphicHashing()
+	}
+
 	cnr.SetCreationTime(time.Now())
 
 	if request.ContainerName != "" {

internal/cache/networkinfo.go

@@ -0,0 +1,46 @@
+package cache
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	"github.com/hashicorp/golang-lru/v2/expirable"
+	"github.com/nspcc-dev/neofs-sdk-go/client"
+	"github.com/nspcc-dev/neofs-sdk-go/netmap"
+	"github.com/nspcc-dev/neofs-sdk-go/pool"
+)
+
+type (
+	// NetworkInfo is cache wrapper for the network info.
+	NetworkInfo struct {
+		p     *pool.Pool
+		cache *expirable.LRU[string, netmap.NetworkInfo]
+	}
+)
+
+const (
+	networkInfoKey = "networkInfoKey"
+)
+
+func NewNetworkInfoCache(p *pool.Pool, ttl time.Duration) *NetworkInfo {
+	return &NetworkInfo{
+		p:     p,
+		cache: expirable.NewLRU[string, netmap.NetworkInfo](1, nil, ttl),
+	}
+}
+
+func (n *NetworkInfo) NetworkInfo(ctx context.Context) (netmap.NetworkInfo, error) {
+	v, ok := n.cache.Get(networkInfoKey)
+	if ok {
+		return v, nil
+	}
+
+	ni, err := n.p.NetworkInfo(ctx, client.PrmNetworkInfo{})
+	if err != nil {
+		return netmap.NetworkInfo{}, fmt.Errorf("get network info: %w", err)
+	}
+
+	n.cache.Add(networkInfoKey, ni)
+	return ni, nil
+}