package wrapper import ( "crypto/sha256" "errors" "fmt" "github.com/nspcc-dev/neofs-api-go/pkg" "github.com/nspcc-dev/neofs-api-go/pkg/container" cid "github.com/nspcc-dev/neofs-api-go/pkg/container/id" "github.com/nspcc-dev/neofs-api-go/pkg/owner" "github.com/nspcc-dev/neofs-api-go/pkg/session" v2refs "github.com/nspcc-dev/neofs-api-go/v2/refs" core "github.com/nspcc-dev/neofs-node/pkg/core/container" client "github.com/nspcc-dev/neofs-node/pkg/morph/client/container" ) var ( errNilArgument = errors.New("empty argument") errUnsupported = errors.New("unsupported structure version") ) // Put marshals container, and passes it to Wrapper's Put method // along with sig.Key() and sig.Sign(). // // Returns error if container is nil. func Put(w *Wrapper, cnr *container.Container) (*cid.ID, error) { if cnr == nil { return nil, errNilArgument } data, err := cnr.Marshal() if err != nil { return nil, fmt.Errorf("can't marshal container: %w", err) } binToken, err := cnr.SessionToken().Marshal() if err != nil { return nil, fmt.Errorf("could not marshal session token: %w", err) } sig := cnr.Signature() err = w.Put(data, sig.Key(), sig.Sign(), binToken) if err != nil { return nil, err } id := cid.New() id.SetSHA256(sha256.Sum256(data)) return id, nil } // Put saves binary container with its session token, key and signature // in NeoFS system through Container contract call. // // Returns calculated container identifier and any error // encountered that caused the saving to interrupt. // // If TryNotary is provided, call notary contract. func (w *Wrapper) Put(cnr, key, sig, token []byte) error { if len(sig) == 0 || len(key) == 0 { return errNilArgument } var args client.PutArgs args.SetContainer(cnr) args.SetSignature(sig) args.SetPublicKey(key) args.SetSessionToken(token) err := w.client.Put(args) if err != nil { return err } return nil } type containerSource Wrapper func (x *containerSource) Get(cid *container.ID) (*container.Container, error) { return Get((*Wrapper)(x), cid) } // AsContainerSource provides container Source interface // from Wrapper instance. func AsContainerSource(w *Wrapper) core.Source { return (*containerSource)(w) } // Get marshals container ID, and passes it to Wrapper's Get method. // // Returns error if cid is nil. func Get(w *Wrapper, cid *container.ID) (*container.Container, error) { return w.Get(cid.ToV2().GetValue()) } // Get reads the container from NeoFS system by binary identifier // through Container contract call. // // If an empty slice is returned for the requested identifier, // storage.ErrNotFound error is returned. func (w *Wrapper) Get(cid []byte) (*container.Container, error) { var args client.GetArgs args.SetCID(cid) // ask RPC neo node to get serialized container rpcAnswer, err := w.client.Get(args) if err != nil { return nil, err } // In #37 we've decided to remove length check, because smart contract would // fail on casting `nil` value from storage to `[]byte` producing FAULT state. // Apparently it does not fail, so we have to check length explicitly. if len(rpcAnswer.Container()) == 0 { return nil, core.ErrNotFound } // unmarshal container cnr := container.New() if err := cnr.Unmarshal(rpcAnswer.Container()); err != nil { // use other major version if there any return nil, fmt.Errorf("can't unmarshal container: %w", err) } binToken := rpcAnswer.SessionToken() if len(binToken) > 0 { tok := session.NewToken() err = tok.Unmarshal(binToken) if err != nil { return nil, fmt.Errorf("could not unmarshal session token: %w", err) } cnr.SetSessionToken(tok) } sig := pkg.NewSignature() sig.SetKey(rpcAnswer.PublicKey()) sig.SetSign(rpcAnswer.Signature()) cnr.SetSignature(sig) return cnr, nil } // Delete marshals container ID, and passes it to Wrapper's Delete method // along with signature and session token. // // Returns error if container ID is nil. func Delete(w *Wrapper, witness core.RemovalWitness) error { id := witness.ContainerID() if id == nil { return errNilArgument } binToken, err := witness.SessionToken().Marshal() if err != nil { return fmt.Errorf("could not marshal session token: %w", err) } return w.Delete(id.ToV2().GetValue(), witness.Signature(), binToken) } // Delete removes the container from NeoFS system // through Container contract call. // // Returns any error encountered that caused // the removal to interrupt. // // If TryNotary is provided, calls notary contract. func (w *Wrapper) Delete(cid, signature, token []byte) error { if len(signature) == 0 { return errNilArgument } var args client.DeleteArgs args.SetSignature(signature) args.SetCID(cid) args.SetSessionToken(token) return w.client.Delete(args) } // List returns a list of container identifiers belonging // to the specified owner of NeoFS system. The list is composed // through Container contract call. // // Returns the identifiers of all NeoFS containers if pointer // to owner identifier is nil. func (w *Wrapper) List(ownerID *owner.ID) ([]*container.ID, error) { args := client.ListArgs{} if ownerID == nil { args.SetOwnerID([]byte{}) } else if v2 := ownerID.ToV2(); v2 == nil { return nil, errUnsupported // use other major version if there any } else { args.SetOwnerID(v2.GetValue()) } // ask RPC neo node to get serialized container rpcAnswer, err := w.client.List(args) if err != nil { return nil, err } rawIDs := rpcAnswer.CIDList() result := make([]*container.ID, 0, len(rawIDs)) for i := range rawIDs { v2 := new(v2refs.ContainerID) v2.SetValue(rawIDs[i]) cid := container.NewIDFromV2(v2) result = append(result, cid) } return result, nil } // AnnounceLoad saves container size estimation calculated by storage node // with key in NeoFS system through Container contract call. // // Returns any error encountered that caused the saving to interrupt. func (w *Wrapper) AnnounceLoad(a container.UsedSpaceAnnouncement, key []byte) error { v2 := a.ContainerID().ToV2() if v2 == nil { return errUnsupported // use other major version if there any } args := client.PutSizeArgs{} args.SetContainerID(v2.GetValue()) args.SetEpoch(a.Epoch()) args.SetSize(a.UsedSpace()) args.SetReporterKey(key) return w.client.PutSize(args) } // EstimationID is an identity of container load estimation inside Container contract. type EstimationID []byte // ListLoadEstimationsByEpoch returns a list of container load estimations for to the specified epoch. // The list is composed through Container contract call. func (w *Wrapper) ListLoadEstimationsByEpoch(epoch uint64) ([]EstimationID, error) { args := client.ListSizesArgs{} args.SetEpoch(epoch) // ask RPC neo node to get serialized container rpcAnswer, err := w.client.ListSizes(args) if err != nil { return nil, err } rawIDs := rpcAnswer.IDList() result := make([]EstimationID, 0, len(rawIDs)) for i := range rawIDs { result = append(result, rawIDs[i]) } return result, nil } // Estimation is a structure of single container load estimation // reported by storage node. type Estimation struct { Size uint64 Reporter []byte } // Estimation is a structure of grouped container load estimation inside Container contract. type Estimations struct { ContainerID *container.ID Values []Estimation } // GetUsedSpaceEstimations returns a list of container load estimations by ID. // The list is composed through Container contract call. func (w *Wrapper) GetUsedSpaceEstimations(id EstimationID) (*Estimations, error) { args := client.GetSizeArgs{} args.SetID(id) rpcAnswer, err := w.client.GetContainerSize(args) if err != nil { return nil, err } es := rpcAnswer.Estimations() v2 := new(v2refs.ContainerID) v2.SetValue(es.ContainerID) res := &Estimations{ ContainerID: container.NewIDFromV2(v2), Values: make([]Estimation, 0, len(es.Estimations)), } for i := range es.Estimations { res.Values = append(res.Values, Estimation{ Size: uint64(es.Estimations[i].Size), Reporter: es.Estimations[i].Reporter, }) } return res, nil }