Handle client errors according to NeoFS SDK RC-9 (#2468)

CHANGELOG.md

@@ -18,6 +18,7 @@ Changelog for NeoFS Node
 - Session inactivity on object PUT request relay (#2460)
 - Missing connection retries on IR node startup when the first configured mainnet RPC node is not in sync (#2474)
 - Storage node no longer ignores unhealthy shards on startup (#2464)
+- Processing of status errors returned by API client from NeoFS SDK RC-9 (#2465)
 
 ### Removed
 - Deprecated `morph.rpc_endpoint` SN and `morph.endpoint.client` IR config sections (#2400)

cmd/neofs-cli/internal/common/exit.go

@@ -28,15 +28,11 @@ func ExitOnErr(cmd *cobra.Command, errFmt string, err error) {
 		aclDenied
 	)
 
-	var (
-		code int
-
-		internalErr = new(sdkstatus.ServerInternal)
-		accessErr   = new(sdkstatus.ObjectAccessDenied)
-	)
+	var code int
+	var accessErr = new(sdkstatus.ObjectAccessDenied)
 
 	switch {
-	case errors.As(err, &internalErr):
+	case errors.Is(err, sdkstatus.ErrServerInternal):
 		code = internal
 	case errors.As(err, &accessErr):
 		code = aclDenied

pkg/services/object/get/remote.go

@@ -21,15 +21,11 @@ func (exec *execCtx) processNode(ctx context.Context, info client.NodeInfo) bool
 	obj, err := client.getObject(exec, info)
 
 	var errSplitInfo *objectSDK.SplitInfoError
-	var errRemoved *apistatus.ObjectAlreadyRemoved
-	var errOutOfRange *apistatus.ObjectOutOfRange
 
 	switch {
 	default:
-		var errNotFound apistatus.ObjectNotFound
-
 		exec.status = statusUndefined
-		exec.err = errNotFound
+		exec.err = apistatus.ErrObjectNotFound
 
 		exec.log.Debug("remote call failed",
 			zap.String("error", err.Error()),
@@ -45,12 +41,12 @@ func (exec *execCtx) processNode(ctx context.Context, info client.NodeInfo) bool
 			exec.collectedObject = obj
 			exec.writeCollectedObject()
 		}
-	case errors.As(err, &errRemoved):
+	case errors.Is(err, apistatus.ErrObjectAlreadyRemoved):
 		exec.status = statusINHUMED
-		exec.err = errRemoved
-	case errors.As(err, &errOutOfRange):
+		exec.err = err
+	case errors.Is(err, apistatus.ErrObjectOutOfRange):
 		exec.status = statusOutOfRange
-		exec.err = errOutOfRange
+		exec.err = err
 	case errors.As(err, &errSplitInfo):
 		exec.status = statusVIRTUAL
 		mergeSplitInfo(exec.splitInfo(), errSplitInfo.SplitInfo())

pkg/services/object/get/util.go

@@ -142,8 +142,7 @@ func (c *clientWrapper) getObject(exec *execCtx, info coreclient.NodeInfo) (*obj
 
 		res, err := internalclient.PayloadRange(prm)
 		if err != nil {
-			var errAccessDenied *apistatus.ObjectAccessDenied
-			if errors.As(err, &errAccessDenied) {
+			if errors.Is(err, apistatus.ErrObjectAccessDenied) {
 				// Current spec allows other storage node to deny access,
 				// fallback to GET here.
 				obj, err := c.get(exec, key)

pkg/services/object/head/remote.go

@@ -63,7 +63,9 @@ func (p *RemoteHeadPrm) WithObjectAddress(v oid.Address) *RemoteHeadPrm {
 	return p
 }
 
-// Head requests object header from the remote node.
+// Head requests object header from the remote node. Returns:
+//   - [apistatus.ErrObjectNotFound] error if the requested object is missing
+//   - [apistatus.ErrNodeUnderMaintenance] error if remote node is currently under maintenance
 func (h *RemoteHeader) Head(ctx context.Context, prm *RemoteHeadPrm) (*object.Object, error) {
 	key, err := h.keyStorage.GetKey(nil)
 	if err != nil {

pkg/services/object/internal/client/client.go

@@ -134,8 +134,8 @@ func (x GetObjectRes) Object() *object.Object {
 //
 // Returns any error which prevented the operation from completing correctly in error return.
 // Returns:
-//   - error of type *object.SplitInfoError if object raw flag is set and requested object is virtual;
-//   - error of type *apistatus.ObjectAlreadyRemoved if the requested object is marked to be removed.
+//   - error of type *object.SplitInfoError if object raw flag is set and requested object is virtual
+//   - [apistatus.ErrObjectAlreadyRemoved] error if the requested object is marked to be removed
 //
 // GetObject ignores the provided session if it is not related to the requested object.
 func GetObject(prm GetObjectPrm) (*GetObjectRes, error) {
@@ -228,9 +228,9 @@ func (x HeadObjectRes) Header() *object.Object {
 //
 // Returns any error which prevented the operation from completing correctly in error return.
 // Returns:
-//
-//	error of type *object.SplitInfoError if object raw flag is set and requested object is virtual;
-//	error of type *apistatus.ObjectAlreadyRemoved if the requested object is marked to be removed.
+//   - error of type *object.SplitInfoError if object raw flag is set and requested object is virtual
+//   - [apistatus.ErrObjectAlreadyRemoved] error if the requested object is marked to be removed
+//   - [apistatus.ErrNodeUnderMaintenance] error if remote node is currently under maintenance
 //
 // HeadObject ignores the provided session if it is not related to the requested object.
 func HeadObject(prm HeadObjectPrm) (*HeadObjectRes, error) {
@@ -321,10 +321,10 @@ const maxInitialBufferSize = 1024 * 1024 // 1 MiB
 //
 // Returns any error which prevented the operation from completing correctly in error return.
 // Returns:
-//
-//	error of type *object.SplitInfoError if object raw flag is set and requested object is virtual;
-//	error of type *apistatus.ObjectAlreadyRemoved if the requested object is marked to be removed;
-//	error of type *apistatus.ObjectOutOfRange if the requested range is too big.
+//   - error of type *object.SplitInfoError if object raw flag is set and requested object is virtual
+//   - [apistatus.ErrObjectAlreadyRemoved] error if the requested object is marked to be removed
+//   - [apistatus.ErrObjectOutOfRange] error if the requested range is too big
+//   - [apistatus.ErrObjectAccessDenied] error if access to the requested object is denied
 //
 // PayloadRange ignores the provided session if it is not related to the requested object.
 func PayloadRange(prm PayloadRangePrm) (*PayloadRangeRes, error) {