1deb3f3d01
In previous implementation wrapper over the Container contract's client accepted the signature of the eACL table in addition to itself. After recent changes in API Go lib table carries its signature. Thus, it is redundant to pass the eACL table signature separately. Make `wrapper.PutEACL` method to accept `eacl.Table` only. Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
120 lines
3.2 KiB
Go
120 lines
3.2 KiB
Go
package container
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/nspcc-dev/neofs-api-go/pkg"
|
|
eaclSDK "github.com/nspcc-dev/neofs-api-go/pkg/acl/eacl"
|
|
containerSDK "github.com/nspcc-dev/neofs-api-go/pkg/container"
|
|
"github.com/nspcc-dev/neofs-api-go/pkg/owner"
|
|
"github.com/nspcc-dev/neofs-api-go/v2/container"
|
|
"github.com/nspcc-dev/neofs-api-go/v2/refs"
|
|
"github.com/nspcc-dev/neofs-node/pkg/morph/client/container/wrapper"
|
|
containerSvc "github.com/nspcc-dev/neofs-node/pkg/services/container"
|
|
)
|
|
|
|
type morphExecutor struct {
|
|
wrapper *wrapper.Wrapper
|
|
}
|
|
|
|
func NewExecutor(w *wrapper.Wrapper) containerSvc.ServiceExecutor {
|
|
return &morphExecutor{
|
|
wrapper: w,
|
|
}
|
|
}
|
|
|
|
func (s *morphExecutor) Put(ctx context.Context, body *container.PutRequestBody) (*container.PutResponseBody, error) {
|
|
cnr, err := containerSDK.NewVerifiedFromV2(body.GetContainer())
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid format of the container structure: %w", err)
|
|
}
|
|
|
|
cnr.SetSignature(
|
|
pkg.NewSignatureFromV2(body.GetSignature()),
|
|
)
|
|
|
|
cid, err := wrapper.Put(s.wrapper, cnr)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
res := new(container.PutResponseBody)
|
|
res.SetContainerID(cid.ToV2())
|
|
|
|
return res, nil
|
|
}
|
|
|
|
func (s *morphExecutor) Delete(ctx context.Context, body *container.DeleteRequestBody) (*container.DeleteResponseBody, error) {
|
|
cid := containerSDK.NewIDFromV2(body.GetContainerID())
|
|
sig := pkg.NewSignatureFromV2(body.GetSignature())
|
|
|
|
err := wrapper.Delete(s.wrapper, cid, sig)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return new(container.DeleteResponseBody), nil
|
|
}
|
|
|
|
func (s *morphExecutor) Get(ctx context.Context, body *container.GetRequestBody) (*container.GetResponseBody, error) {
|
|
cid := containerSDK.NewIDFromV2(body.GetContainerID())
|
|
|
|
cnr, err := wrapper.Get(s.wrapper, cid)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
res := new(container.GetResponseBody)
|
|
res.SetContainer(cnr.ToV2())
|
|
res.SetSignature(cnr.Signature().ToV2())
|
|
res.SetSessionToken(cnr.SessionToken().ToV2())
|
|
|
|
return res, nil
|
|
}
|
|
|
|
func (s *morphExecutor) List(ctx context.Context, body *container.ListRequestBody) (*container.ListResponseBody, error) {
|
|
oid := owner.NewIDFromV2(body.GetOwnerID())
|
|
|
|
cnrs, err := s.wrapper.List(oid)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
cidList := make([]*refs.ContainerID, 0, len(cnrs))
|
|
for i := range cnrs {
|
|
cidList = append(cidList, cnrs[i].ToV2())
|
|
}
|
|
|
|
res := new(container.ListResponseBody)
|
|
res.SetContainerIDs(cidList)
|
|
|
|
return res, nil
|
|
}
|
|
|
|
func (s *morphExecutor) SetExtendedACL(ctx context.Context, body *container.SetExtendedACLRequestBody) (*container.SetExtendedACLResponseBody, error) {
|
|
table := eaclSDK.NewTableFromV2(body.GetEACL())
|
|
sign := pkg.NewSignatureFromV2(body.GetSignature())
|
|
|
|
table.SetSignature(sign)
|
|
|
|
err := wrapper.PutEACL(s.wrapper, table)
|
|
|
|
return new(container.SetExtendedACLResponseBody), err
|
|
}
|
|
|
|
func (s *morphExecutor) GetExtendedACL(ctx context.Context, body *container.GetExtendedACLRequestBody) (*container.GetExtendedACLResponseBody, error) {
|
|
cid := containerSDK.NewIDFromV2(body.GetContainerID())
|
|
|
|
table, err := s.wrapper.GetEACL(cid)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
res := new(container.GetExtendedACLResponseBody)
|
|
res.SetEACL(table.ToV2())
|
|
res.SetSignature(table.Signature().ToV2())
|
|
res.SetSessionToken(table.SessionToken().ToV2())
|
|
|
|
return res, nil
|
|
}
|