package blobstor import ( "io/ioutil" "os" "path" objectSDK "github.com/nspcc-dev/neofs-api-go/pkg/object" "github.com/pkg/errors" ) // PutPrm groups the parameters of Put operation. type PutPrm struct { rwObject } // PutRes groups resulting values of Put operation. type PutRes struct { roBlobovniczaID } // Put saves the object in BLOB storage. // // If object is "big", BlobStor saves the object in shallow dir. // Otherwise, BlobStor saves the object in blobonicza. In this // case the identifier of blobovnicza is returned. // // Returns any error encountered that // did not allow to completely save the object. func (b *BlobStor) Put(prm *PutPrm) (*PutRes, error) { // marshal object data, err := prm.obj.Marshal() if err != nil { return nil, errors.Wrap(err, "could not marshal the object") } if b.isBig(data) { // compress object data data = b.compressor(data) // save object in shallow dir return new(PutRes), b.fsTree.put(prm.obj.Address(), data) } else { // save object in blobovnicza res, err := b.blobovniczas.put(prm.obj.Address(), data) if err != nil { return nil, err } return &PutRes{ roBlobovniczaID: roBlobovniczaID{ blobovniczaID: res, }, }, nil } } func (t *fsTree) put(addr *objectSDK.Address, data []byte) error { p := t.treePath(addr) if err := os.MkdirAll(path.Dir(p), t.Permissions); err != nil { return err } return ioutil.WriteFile(p, data, t.Permissions) } // checks if object is "big". func (b *BlobStor) isBig(data []byte) bool { return uint64(len(data)) > b.smallSizeLimit }