go.mod: upgrade to post-api-go SDK

This does the bare minimum to make it work. Conversions are simplified,
signatures are handled a bit differently. The expectation is that the
behaviour is the same. Notice that we still have api-go in go.mod for
control and tree services that use autogenerated code.

Signed-off-by: Roman Khimov <roman@nspcc.ru>

CHANGELOG.md

@@ -24,6 +24,7 @@ Changelog for NeoFS Node
 - Drop creating new eacl tables with public keys (#3096)
 
 ### Updated
+- SDK to the post-api-go version (#3103)
 
 ### Updating from v0.44.2
 Using public keys as a rule target in eACL tables was deprecated, and 

cmd/neofs-node/accounting.go

@@ -1,9 +1,9 @@
 package main
 
 import (
-	accountingGRPC "github.com/nspcc-dev/neofs-api-go/v2/accounting/grpc"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/client/balance"
 	accountingService "github.com/nspcc-dev/neofs-node/pkg/services/accounting"
+	protoaccounting "github.com/nspcc-dev/neofs-sdk-go/proto/accounting"
 )
 
 func initAccountingService(c *cfg) {
@@ -17,6 +17,6 @@ func initAccountingService(c *cfg) {
 	server := accountingService.New(&c.key.PrivateKey, c.networkState, balanceMorphWrapper)
 
 	for _, srv := range c.cfgGRPC.servers {
-		accountingGRPC.RegisterAccountingServiceServer(srv, server)
+		protoaccounting.RegisterAccountingServiceServer(srv, server)
 	}
 }

cmd/neofs-node/container.go

@@ -8,13 +8,6 @@ import (
 	"errors"
 	"fmt"
 
-	apicontainer "github.com/nspcc-dev/neofs-api-go/v2/container"
-	protocontainer "github.com/nspcc-dev/neofs-api-go/v2/container/grpc"
-	apirefs "github.com/nspcc-dev/neofs-api-go/v2/refs"
-	refs "github.com/nspcc-dev/neofs-api-go/v2/refs/grpc"
-	protosession "github.com/nspcc-dev/neofs-api-go/v2/session/grpc"
-	"github.com/nspcc-dev/neofs-api-go/v2/signature"
-	protostatus "github.com/nspcc-dev/neofs-api-go/v2/status/grpc"
 	containerrpc "github.com/nspcc-dev/neofs-contract/rpc/container"
 	"github.com/nspcc-dev/neofs-node/pkg/core/client"
 	containerCore "github.com/nspcc-dev/neofs-node/pkg/core/container"
@@ -33,9 +26,13 @@ import (
 	apiClient "github.com/nspcc-dev/neofs-sdk-go/client"
 	containerSDK "github.com/nspcc-dev/neofs-sdk-go/container"
 	cid "github.com/nspcc-dev/neofs-sdk-go/container/id"
+	neofscrypto "github.com/nspcc-dev/neofs-sdk-go/crypto"
 	"github.com/nspcc-dev/neofs-sdk-go/eacl"
 	"github.com/nspcc-dev/neofs-sdk-go/netmap"
 	oid "github.com/nspcc-dev/neofs-sdk-go/object/id"
+	protocontainer "github.com/nspcc-dev/neofs-sdk-go/proto/container"
+	protosession "github.com/nspcc-dev/neofs-sdk-go/proto/session"
+	protostatus "github.com/nspcc-dev/neofs-sdk-go/proto/status"
 	"github.com/nspcc-dev/neofs-sdk-go/session"
 	"github.com/nspcc-dev/neofs-sdk-go/user"
 	"github.com/nspcc-dev/neofs-sdk-go/version"
@@ -517,30 +514,24 @@ func (c *usedSpaceService) ExternalAddresses() []string {
 }
 
 func (c *usedSpaceService) makeResponse(body *protocontainer.AnnounceUsedSpaceResponse_Body, st *protostatus.Status) (*protocontainer.AnnounceUsedSpaceResponse, error) {
-	v := version.Current()
-	var v2 apirefs.Version
-	v.WriteToV2(&v2)
 	resp := &protocontainer.AnnounceUsedSpaceResponse{
 		Body: body,
 		MetaHeader: &protosession.ResponseMetaHeader{
-			Version: v2.ToGRPCMessage().(*refs.Version),
+			Version: version.Current().ProtoMessage(),
 			Epoch:   c.cfg.networkState.CurrentEpoch(),
 			Status:  st,
 		},
 	}
-	return util.SignResponse(&c.cfg.key.PrivateKey, resp, apicontainer.AnnounceUsedSpaceResponse{}), nil
+	resp.VerifyHeader = util.SignResponse(&c.cfg.key.PrivateKey, resp)
+	return resp, nil
 }
 
 func (c *usedSpaceService) makeStatusResponse(err error) (*protocontainer.AnnounceUsedSpaceResponse, error) {
 	return c.makeResponse(nil, util.ToStatus(err))
 }
 
 func (c *usedSpaceService) AnnounceUsedSpace(ctx context.Context, req *protocontainer.AnnounceUsedSpaceRequest) (*protocontainer.AnnounceUsedSpaceResponse, error) {
-	putReq := new(apicontainer.AnnounceUsedSpaceRequest)
-	if err := putReq.FromGRPCMessage(req); err != nil {
-		return nil, err
-	}
-	if err := signature.VerifyServiceMessage(putReq); err != nil {
+	if err := neofscrypto.VerifyRequestWithBuffer(req, nil); err != nil {
 		return c.makeStatusResponse(util.ToRequestSignatureVerificationError(err))
 	}
 
@@ -566,11 +557,7 @@ func (c *usedSpaceService) AnnounceUsedSpace(ctx context.Context, req *protocont
 	var est containerSDK.SizeEstimation
 
 	for _, a := range req.GetBody().GetAnnouncements() {
-		var a2 apicontainer.UsedSpaceAnnouncement
-		if err := a2.FromGRPCMessage(a); err != nil {
-			panic(err)
-		}
-		err = est.ReadFromV2(a2)
+		err = est.FromProtoMessage(a)
 		if err != nil {
 			return c.makeStatusResponse(fmt.Errorf("invalid size announcement: %w", err))
 		}

cmd/neofs-node/netmap.go

@@ -6,7 +6,6 @@ import (
 	"fmt"
 	"sync/atomic"
 
-	netmapGRPC "github.com/nspcc-dev/neofs-api-go/v2/netmap/grpc"
 	"github.com/nspcc-dev/neofs-node/pkg/metrics"
 	nmClient "github.com/nspcc-dev/neofs-node/pkg/morph/client/netmap"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/event"
@@ -15,6 +14,7 @@ import (
 	"github.com/nspcc-dev/neofs-node/pkg/services/control"
 	netmapService "github.com/nspcc-dev/neofs-node/pkg/services/netmap"
 	netmapSDK "github.com/nspcc-dev/neofs-sdk-go/netmap"
+	protonetmap "github.com/nspcc-dev/neofs-sdk-go/proto/netmap"
 	"go.uber.org/zap"
 )
 
@@ -171,7 +171,7 @@ func initNetmapService(c *cfg) {
 	server := netmapService.New(&c.key.PrivateKey, c)
 
 	for _, srv := range c.cfgGRPC.servers {
-		netmapGRPC.RegisterNetmapServiceServer(srv, server)
+		protonetmap.RegisterNetmapServiceServer(srv, server)
 	}
 
 	addNewEpochNotificationHandler(c, func(ev event.Event) {

cmd/neofs-node/object.go

@@ -10,7 +10,6 @@ import (
 
 	"github.com/google/uuid"
 	lru "github.com/hashicorp/golang-lru/v2"
-	objectGRPC "github.com/nspcc-dev/neofs-api-go/v2/object/grpc"
 	replicatorconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/replicator"
 	coreclient "github.com/nspcc-dev/neofs-node/pkg/core/client"
 	containercore "github.com/nspcc-dev/neofs-node/pkg/core/container"
@@ -39,6 +38,7 @@ import (
 	netmapsdk "github.com/nspcc-dev/neofs-sdk-go/netmap"
 	objectSDK "github.com/nspcc-dev/neofs-sdk-go/object"
 	oid "github.com/nspcc-dev/neofs-sdk-go/object/id"
+	protoobject "github.com/nspcc-dev/neofs-sdk-go/proto/object"
 	apireputation "github.com/nspcc-dev/neofs-sdk-go/reputation"
 	"github.com/nspcc-dev/neofs-sdk-go/user"
 	"go.uber.org/zap"
@@ -309,7 +309,7 @@ func initObjectService(c *cfg) {
 	server := objectService.New(objSvc, mNumber, fsChain, storage, c.shared.basics.key.PrivateKey, c.metricsCollector, aclChecker, aclSvc)
 
 	for _, srv := range c.cfgGRPC.servers {
-		objectGRPC.RegisterObjectServiceServer(srv, server)
+		protoobject.RegisterObjectServiceServer(srv, server)
 	}
 }
 

cmd/neofs-node/reputation.go

@@ -4,13 +4,6 @@ import (
 	"context"
 	"fmt"
 
-	apirefs "github.com/nspcc-dev/neofs-api-go/v2/refs"
-	refs "github.com/nspcc-dev/neofs-api-go/v2/refs/grpc"
-	v2reputation "github.com/nspcc-dev/neofs-api-go/v2/reputation"
-	protoreputation "github.com/nspcc-dev/neofs-api-go/v2/reputation/grpc"
-	protosession "github.com/nspcc-dev/neofs-api-go/v2/session/grpc"
-	"github.com/nspcc-dev/neofs-api-go/v2/signature"
-	protostatus "github.com/nspcc-dev/neofs-api-go/v2/status/grpc"
 	"github.com/nspcc-dev/neofs-node/cmd/neofs-node/reputation/common"
 	intermediatereputation "github.com/nspcc-dev/neofs-node/cmd/neofs-node/reputation/intermediate"
 	localreputation "github.com/nspcc-dev/neofs-node/cmd/neofs-node/reputation/local"
@@ -31,6 +24,10 @@ import (
 	localroutes "github.com/nspcc-dev/neofs-node/pkg/services/reputation/local/routes"
 	truststorage "github.com/nspcc-dev/neofs-node/pkg/services/reputation/local/storage"
 	"github.com/nspcc-dev/neofs-node/pkg/services/util"
+	neofscrypto "github.com/nspcc-dev/neofs-sdk-go/crypto"
+	protoreputation "github.com/nspcc-dev/neofs-sdk-go/proto/reputation"
+	protosession "github.com/nspcc-dev/neofs-sdk-go/proto/session"
+	protostatus "github.com/nspcc-dev/neofs-sdk-go/proto/status"
 	apireputation "github.com/nspcc-dev/neofs-sdk-go/reputation"
 	"github.com/nspcc-dev/neofs-sdk-go/version"
 	"go.uber.org/zap"
@@ -259,11 +256,8 @@ type reputationServer struct {
 }
 
 func (s *reputationServer) makeResponseMetaHeader(st *protostatus.Status) *protosession.ResponseMetaHeader {
-	v := version.Current()
-	var v2 apirefs.Version
-	v.WriteToV2(&v2)
 	return &protosession.ResponseMetaHeader{
-		Version: v2.ToGRPCMessage().(*refs.Version),
+		Version: version.Current().ProtoMessage(),
 		Epoch:   s.networkState.CurrentEpoch(),
 		Status:  st,
 	}
@@ -273,15 +267,12 @@ func (s *reputationServer) makeLocalResponse(err error) (*protoreputation.Announ
 	resp := &protoreputation.AnnounceLocalTrustResponse{
 		MetaHeader: s.makeResponseMetaHeader(util.ToStatus(err)),
 	}
-	return util.SignResponse(&s.key.PrivateKey, resp, v2reputation.AnnounceLocalTrustResponse{}), nil
+	resp.VerifyHeader = util.SignResponse(&s.key.PrivateKey, resp)
+	return resp, nil
 }
 
 func (s *reputationServer) AnnounceLocalTrust(ctx context.Context, req *protoreputation.AnnounceLocalTrustRequest) (*protoreputation.AnnounceLocalTrustResponse, error) {
-	req2 := new(v2reputation.AnnounceLocalTrustRequest)
-	if err := req2.FromGRPCMessage(req); err != nil {
-		return nil, err
-	}
-	if err := signature.VerifyServiceMessage(req2); err != nil {
+	if err := neofscrypto.VerifyRequestWithBuffer(req, nil); err != nil {
 		return s.makeLocalResponse(util.ToRequestSignatureVerificationError(err))
 	}
 
@@ -314,15 +305,12 @@ func (s *reputationServer) makeIntermediateResponse(err error) (*protoreputation
 	resp := &protoreputation.AnnounceIntermediateResultResponse{
 		MetaHeader: s.makeResponseMetaHeader(util.ToStatus(err)),
 	}
-	return util.SignResponse(&s.key.PrivateKey, resp, v2reputation.AnnounceIntermediateResultResponse{}), nil
+	resp.VerifyHeader = util.SignResponse(&s.key.PrivateKey, resp)
+	return resp, nil
 }
 
 func (s *reputationServer) AnnounceIntermediateResult(ctx context.Context, req *protoreputation.AnnounceIntermediateResultRequest) (*protoreputation.AnnounceIntermediateResultResponse, error) {
-	req2 := new(v2reputation.AnnounceIntermediateResultRequest)
-	if err := req2.FromGRPCMessage(req); err != nil {
-		return nil, err
-	}
-	if err := signature.VerifyServiceMessage(req2); err != nil {
+	if err := neofscrypto.VerifyRequestWithBuffer(req, nil); err != nil {
 		return s.makeIntermediateResponse(util.ToRequestSignatureVerificationError(err))
 	}
 

cmd/neofs-node/session.go

@@ -4,14 +4,14 @@ import (
 	"fmt"
 	"time"
 
-	sessionGRPC "github.com/nspcc-dev/neofs-api-go/v2/session/grpc"
 	nodeconfig "github.com/nspcc-dev/neofs-node/cmd/neofs-node/config/node"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/event"
 	"github.com/nspcc-dev/neofs-node/pkg/morph/event/netmap"
 	sessionSvc "github.com/nspcc-dev/neofs-node/pkg/services/session"
 	"github.com/nspcc-dev/neofs-node/pkg/services/session/storage"
 	"github.com/nspcc-dev/neofs-node/pkg/services/session/storage/persistent"
 	"github.com/nspcc-dev/neofs-node/pkg/services/session/storage/temporary"
+	protosession "github.com/nspcc-dev/neofs-sdk-go/proto/session"
 	"github.com/nspcc-dev/neofs-sdk-go/user"
 )
 
@@ -50,6 +50,6 @@ func initSessionService(c *cfg) {
 	server := sessionSvc.New(&c.key.PrivateKey, c, c.privateTokenStore)
 
 	for _, srv := range c.cfgGRPC.servers {
-		sessionGRPC.RegisterSessionServiceServer(srv, server)
+		protosession.RegisterSessionServiceServer(srv, server)
 	}
 }

cmd/neofs-node/transport.go

@@ -2,12 +2,12 @@ package main
 
 import (
 	"context"
+	"errors"
 	"fmt"
 
-	objectGRPC "github.com/nspcc-dev/neofs-api-go/v2/object/grpc"
-	"github.com/nspcc-dev/neofs-api-go/v2/status"
 	coreclient "github.com/nspcc-dev/neofs-node/pkg/core/client"
 	apistatus "github.com/nspcc-dev/neofs-sdk-go/client/status"
+	protoobject "github.com/nspcc-dev/neofs-sdk-go/proto/object"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/encoding"
 	"google.golang.org/grpc/encoding/proto"
@@ -25,18 +25,16 @@ func (x *transport) SendReplicationRequestToNode(ctx context.Context, req []byte
 		return nil, fmt.Errorf("connect to remote node: %w", err)
 	}
 
-	var resp objectGRPC.ReplicateResponse
-	err = c.ExecRaw(func(conn *grpc.ClientConn) error {
-		// this will be changed during NeoFS API Go deprecation. Code most likely be
-		// placed in SDK
-		err = conn.Invoke(ctx, objectGRPC.ObjectService_Replicate_FullMethodName, req, &resp, binaryMessageOnly)
-		if err != nil {
-			return fmt.Errorf("API transport (op=%s): %w", objectGRPC.ObjectService_Replicate_FullMethodName, err)
-		}
-		return err
-	})
+	var resp protoobject.ReplicateResponse
+	conn := c.Conn()
+	if conn == nil {
+		return nil, errors.New("can't get grpc connection to node")
+	}
+	// this will be changed during NeoFS API Go deprecation. Code most likely be
+	// placed in SDK
+	err = conn.Invoke(ctx, protoobject.ObjectService_Replicate_FullMethodName, req, &resp, binaryMessageOnly)
 	if err != nil {
-		return nil, err
+		return nil, fmt.Errorf("API transport (op=%s): %w", protoobject.ObjectService_Replicate_FullMethodName, err)
 	}
 
 	return replicationResultFromResponse(&resp)
@@ -65,17 +63,8 @@ func (protoCodecBinaryRequestOnly) Unmarshal(raw []byte, msg any) error {
 	return encoding.GetCodec(proto.Name).Unmarshal(raw, msg)
 }
 
-func replicationResultFromResponse(m *objectGRPC.ReplicateResponse) ([]byte, error) {
-	var st *status.Status
-	if mst := m.GetStatus(); mst != nil {
-		st = new(status.Status)
-		err := st.FromGRPCMessage(mst)
-		if err != nil {
-			return nil, fmt.Errorf("decode response status: %w", err)
-		}
-	}
-
-	err := apistatus.ErrorFromV2(st)
+func replicationResultFromResponse(m *protoobject.ReplicateResponse) ([]byte, error) {
+	err := apistatus.ToError(m.GetStatus())
 	if err != nil {
 		return nil, err
 	}

go.mod

@@ -18,7 +18,7 @@ require (
 	github.com/nspcc-dev/neo-go v0.107.1
 	github.com/nspcc-dev/neofs-api-go/v2 v2.14.1-0.20240827150555-5ce597aa14ea
 	github.com/nspcc-dev/neofs-contract v0.20.1-0.20241220193924-4da43dfb5a65
-	github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20241115192314-2da6182d23f5
+	github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20250130151303-051c6238eaea
 	github.com/nspcc-dev/tzhash v1.8.2
 	github.com/olekukonko/tablewriter v0.0.5
 	github.com/panjf2000/ants/v2 v2.9.0

go.sum

@@ -190,8 +190,8 @@ github.com/nspcc-dev/neofs-api-go/v2 v2.14.1-0.20240827150555-5ce597aa14ea h1:mK
 github.com/nspcc-dev/neofs-api-go/v2 v2.14.1-0.20240827150555-5ce597aa14ea/go.mod h1:YzhD4EZmC9Z/PNyd7ysC7WXgIgURc9uCG1UWDeV027Y=
 github.com/nspcc-dev/neofs-contract v0.20.1-0.20241220193924-4da43dfb5a65 h1:SruyrmzfmaIK+rx3EyLsG3hb9Ooh+cTkObucl0yTVxY=
 github.com/nspcc-dev/neofs-contract v0.20.1-0.20241220193924-4da43dfb5a65/go.mod h1:fwM6QoYPnsIuUQ4/GOwgzfQ9qoDKknqYgf4XWOqEdJw=
-github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20241115192314-2da6182d23f5 h1:hJvvhZDkU3I180TsJaEwGVOFvTbzBr8l9m2KZdAwv1k=
-github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20241115192314-2da6182d23f5/go.mod h1:INZZXiTr9L7gWFeg3RBuB1laH2h9+vnomvg1XE42zQU=
+github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20250130151303-051c6238eaea h1:la9jMy0nzHs+j7qkgvgiL8DmePSyRYXlQa6XqmMR5qo=
+github.com/nspcc-dev/neofs-sdk-go v1.0.0-rc.12.0.20250130151303-051c6238eaea/go.mod h1:Hd0zRo7mfGDf/S+yGPnRi9eWipxJNhec2Oik1w7lwQo=
 github.com/nspcc-dev/rfc6979 v0.2.3 h1:QNVykGZ3XjFwM/88rGfV3oj4rKNBy+nYI6jM7q19hDI=
 github.com/nspcc-dev/rfc6979 v0.2.3/go.mod h1:q3sCL1Ed7homjqYK8KmFSzEmm+7Ngyo7PePbZanhaDE=
 github.com/nspcc-dev/tzhash v1.8.2 h1:ebRCbPoEuoqrhC6sSZmrT/jI3h1SzCWakxxV6gp5QAg=

pkg/core/client/client.go

@@ -30,7 +30,7 @@ type Client interface {
 	ObjectHash(ctx context.Context, containerID cid.ID, objectID oid.ID, signer user.Signer, prm client.PrmObjectHash) ([][]byte, error)
 	AnnounceLocalTrust(ctx context.Context, epoch uint64, trusts []reputationSDK.Trust, prm client.PrmAnnounceLocalTrust) error
 	AnnounceIntermediateTrust(ctx context.Context, epoch uint64, trust reputationSDK.PeerToPeerTrust, prm client.PrmAnnounceIntermediateTrust) error
-	ExecRaw(f func(*grpc.ClientConn) error) error
+	Conn() *grpc.ClientConn
 	Close() error
 }
 

pkg/core/object/fmt.go

@@ -134,12 +134,7 @@ func (v *FormatValidator) Validate(obj *object.Object, unprepared bool) error {
 		} else {
 			// V2 split
 
-			if !firstSet {
-				// first part only
-				if obj.Parent() == nil {
-					return errors.New("v2 split: first object part does not have parent header")
-				}
-			} else {
+			if firstSet {
 				// 2nd+ parts
 
 				typ := obj.Type()

pkg/core/object/fmt_test.go

@@ -366,13 +366,6 @@ func TestLinkObjectSplitV2(t *testing.T) {
 	})
 
 	t.Run("V2 split", func(t *testing.T) {
-		obj.ResetRelations()
-		obj.SetParent(object.New())
-
-		t.Run("first object is not set", func(t *testing.T) {
-			require.ErrorContains(t, v.Validate(obj, true), "first object part does not have parent header")
-		})
-
 		t.Run("link object without finished parent", func(t *testing.T) {
 			obj.ResetRelations()
 			obj.SetParent(object.New())

pkg/innerring/processors/netmap/process_cleanup.go

@@ -2,7 +2,7 @@ package netmap
 
 import (
 	"github.com/nspcc-dev/neo-go/pkg/crypto/keys"
-	v2netmap "github.com/nspcc-dev/neofs-api-go/v2/netmap"
+	protonetmap "github.com/nspcc-dev/neofs-sdk-go/proto/netmap"
 	"go.uber.org/zap"
 )
 
@@ -35,7 +35,7 @@ func (np *Processor) processNetmapCleanupTick(ev netmapCleanupTick) {
 			uint32(ev.epoch),
 			nil,
 			methodUpdateStateNotary,
-			int64(v2netmap.Offline), key.Bytes(),
+			int64(protonetmap.NodeInfo_OFFLINE), key.Bytes(),
 		)
 		if err != nil {
 			np.log.Error("can't invoke netmap.UpdateState", zap.Error(err))

pkg/local_object_storage/metabase/select_test.go

@@ -166,7 +166,6 @@ func TestDB_SelectRootPhyParent(t *testing.T) {
 	firstChild := oidtest.ID()
 
 	leftChild := generateObjectWithCID(t, cnr)
-	leftChild.InitRelations()
 	leftChild.SetFirstID(firstChild)
 	err = putBig(db, leftChild)
 	require.NoError(t, err)