Fix/relay requests (#3014)

CHANGELOG.md

@@ -29,6 +29,7 @@ attribute, which is used for container domain name in NNS contracts (#2954)
 - RPC client reconnection failures leading to complete SN failure (#2797)
 - `meta.DB.Open(readOnly)` moves metabase in RO mode (#3000)
 - Panic in event listener related to inability to switch RPC node (#2970)
+- Non-container nodes never check placement policy on PUT, SEARCH requests (#3014)
 
 ### Changed
 - `ObjectService`'s `Put` RPC handler caches up to 10K lists of per-object sorted container nodes (#2901)

pkg/services/object/put/distributed.go

@@ -325,6 +325,7 @@ func (x placementIterator) iterateNodesForObject(obj oid.ID, f func(nodeDesc) er
 						return
 					}
 				}); err != nil {
+					wg.Done()
 					svcutil.LogWorkerPoolError(x.log, "PUT", err)
 					err = fmt.Errorf("submit next job to save an object to the worker pool: %w", err)
 					if e, _ := lastRespErr.Load().(error); e != nil {

pkg/services/object/put/v2/streamer.go

@@ -9,11 +9,13 @@ import (
 	rawclient "github.com/nspcc-dev/neofs-api-go/v2/rpc/client"
 	sessionV2 "github.com/nspcc-dev/neofs-api-go/v2/session"
 	"github.com/nspcc-dev/neofs-api-go/v2/signature"
+	"github.com/nspcc-dev/neofs-api-go/v2/status"
 	"github.com/nspcc-dev/neofs-node/pkg/core/client"
 	"github.com/nspcc-dev/neofs-node/pkg/network"
 	"github.com/nspcc-dev/neofs-node/pkg/services/object/internal"
 	internalclient "github.com/nspcc-dev/neofs-node/pkg/services/object/internal/client"
 	putsvc "github.com/nspcc-dev/neofs-node/pkg/services/object/put"
+	apistatus "github.com/nspcc-dev/neofs-sdk-go/client/status"
 )
 
 type streamer struct {
@@ -178,8 +180,21 @@ func (s *streamer) relayRequest(info client.NodeInfo, c client.MultiAddressClien
 			err = fmt.Errorf("response verification failed: %w", err)
 		}
 
+		err = checkStatus(resp.GetMetaHeader().GetStatus())
+		if err != nil {
+			err = fmt.Errorf("remote node response: %w", err)
+		}
+
 		return
 	})
 
 	return firstErr
 }
+
+func checkStatus(stV2 *status.Status) error {
+	if !status.IsSuccess(stV2.Code()) {
+		return apistatus.ErrorFromV2(stV2)
+	}
+
+	return nil
+}

pkg/services/object/search/v2/util.go

@@ -11,12 +11,14 @@ import (
 	rpcclient "github.com/nspcc-dev/neofs-api-go/v2/rpc/client"
 	"github.com/nspcc-dev/neofs-api-go/v2/session"
 	"github.com/nspcc-dev/neofs-api-go/v2/signature"
+	"github.com/nspcc-dev/neofs-api-go/v2/status"
 	"github.com/nspcc-dev/neofs-node/pkg/core/client"
 	"github.com/nspcc-dev/neofs-node/pkg/network"
 	objectSvc "github.com/nspcc-dev/neofs-node/pkg/services/object"
 	"github.com/nspcc-dev/neofs-node/pkg/services/object/internal"
 	searchsvc "github.com/nspcc-dev/neofs-node/pkg/services/object/search"
 	"github.com/nspcc-dev/neofs-node/pkg/services/object/util"
+	apistatus "github.com/nspcc-dev/neofs-sdk-go/client/status"
 	cid "github.com/nspcc-dev/neofs-sdk-go/container/id"
 	"github.com/nspcc-dev/neofs-sdk-go/object"
 	oid "github.com/nspcc-dev/neofs-sdk-go/object/id"
@@ -116,6 +118,10 @@ func (s *Service) toPrm(req *objectV2.SearchRequest, stream objectSvc.SearchStre
 					return nil, fmt.Errorf("could not verify %T: %w", resp, err)
 				}
 
+				if err := checkStatus(resp.GetMetaHeader().GetStatus()); err != nil {
+					return nil, fmt.Errorf("remote node response: %w", err)
+				}
+
 				chunk := resp.GetBody().GetIDList()
 				var id oid.ID
 
@@ -139,6 +145,14 @@ func (s *Service) toPrm(req *objectV2.SearchRequest, stream objectSvc.SearchStre
 	return p, nil
 }
 
+func checkStatus(stV2 *status.Status) error {
+	if !status.IsSuccess(stV2.Code()) {
+		return apistatus.ErrorFromV2(stV2)
+	}
+
+	return nil
+}
+
 func groupAddressRequestForwarder(f func(network.Address, client.MultiAddressClient, []byte) ([]oid.ID, error)) searchsvc.RequestForwarder {
 	return func(info client.NodeInfo, c client.MultiAddressClient) ([]oid.ID, error) {
 		var (