forked from TrueCloudLab/frostfs-api-go
62 lines
1.8 KiB
Go
62 lines
1.8 KiB
Go
package container
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/binary"
|
|
|
|
"github.com/nspcc-dev/neofs-proto/internal"
|
|
"github.com/nspcc-dev/neofs-proto/refs"
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
type (
|
|
// CID type alias.
|
|
CID = refs.CID
|
|
// UUID type alias.
|
|
UUID = refs.UUID
|
|
// OwnerID type alias.
|
|
OwnerID = refs.OwnerID
|
|
// MessageID type alias.
|
|
MessageID = refs.MessageID
|
|
)
|
|
|
|
const (
|
|
// ErrNotFound is raised when container could not be found.
|
|
ErrNotFound = internal.Error("could not find container")
|
|
)
|
|
|
|
// SetSignature sets signature to PutRequest to satisfy SignedRequest interface.
|
|
func (m *PutRequest) SetSignature(v []byte) { m.Signature = v }
|
|
|
|
// SetSignature sets signature to DeleteRequest to satisfy SignedRequest interface.
|
|
func (m *DeleteRequest) SetSignature(v []byte) { m.Signature = v }
|
|
|
|
// PrepareData prepares bytes representation of PutRequest to satisfy SignedRequest interface.
|
|
func (m *PutRequest) PrepareData() ([]byte, error) {
|
|
var (
|
|
err error
|
|
buf = new(bytes.Buffer)
|
|
capBytes = make([]byte, 8)
|
|
)
|
|
|
|
binary.BigEndian.PutUint64(capBytes, m.Capacity)
|
|
|
|
if _, err = buf.Write(m.MessageID.Bytes()); err != nil {
|
|
return nil, errors.Wrap(err, "could not write message id")
|
|
} else if _, err = buf.Write(capBytes); err != nil {
|
|
return nil, errors.Wrap(err, "could not write capacity")
|
|
} else if _, err = buf.Write(m.OwnerID.Bytes()); err != nil {
|
|
return nil, errors.Wrap(err, "could not write pub")
|
|
} else if data, err := m.Rules.Marshal(); err != nil {
|
|
return nil, errors.Wrap(err, "could not marshal placement")
|
|
} else if _, err = buf.Write(data); err != nil {
|
|
return nil, errors.Wrap(err, "could not write placement")
|
|
}
|
|
|
|
return buf.Bytes(), nil
|
|
}
|
|
|
|
// PrepareData prepares bytes representation of DeleteRequest to satisfy SignedRequest interface.
|
|
func (m *DeleteRequest) PrepareData() ([]byte, error) {
|
|
return m.CID.Bytes(), nil
|
|
}
|