Anoke/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Pull requests Activity

[#64] core/object: Claim TombstoneContent in tombstone payload

Browse source 
Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2020-10-01 20:14:10 +03:00 committed by Alex Vanin
parent 21bdc82fb5
commit 33ca88f85f
2 changed files with 11 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
pkg/core/object/fmt.go
View file

@ -89,15 +89,17 @@ func (v *FormatValidator) ValidateContent(t object.Type, payload []byte) error {
return errors.Errorf("(%T) empty payload in tombstone", v) return errors.Errorf("(%T) empty payload in tombstone", v)
} }
addr, err := object.AddressFromBytes(payload) content, err := TombstoneContentFromBytes(payload)
if err != nil { if err != nil {
return errors.Wrapf(err, "(%T) could not parse object address from tombstone", v) return errors.Wrapf(err, "(%T) could not parse tombstone content", err)
} }
for _, addr := range content.GetAddressList() {
if addr.GetContainerID() == nil || addr.GetObjectID() == nil { if addr.GetContainerID() == nil || addr.GetObjectID() == nil {
return errors.Errorf("(%T) empty address reference in tombstone", v) return errors.Errorf("(%T) empty address reference in tombstone", v)
} }
} }
}
return nil return nil
} }

7
pkg/core/object/fmt_test.go
View file

@ -109,7 +109,10 @@ func TestFormatValidator_Validate(t *testing.T) {
addr := object.NewAddress() addr := object.NewAddress()
data, err := addr.ToV2().StableMarshal(nil) content := NewTombstoneContent()
content.SetAddressList(addr)
data, err := content.MarshalBinary()
require.NoError(t, err) require.NoError(t, err)
require.Error(t, v.ValidateContent(object.TypeTombstone, data)) require.Error(t, v.ValidateContent(object.TypeTombstone, data))
@ -117,7 +120,7 @@ func TestFormatValidator_Validate(t *testing.T) {
addr.SetContainerID(testContainerID(t)) addr.SetContainerID(testContainerID(t))
addr.SetObjectID(testObjectID(t)) addr.SetObjectID(testObjectID(t))
data, err = addr.ToV2().StableMarshal(nil) data, err = content.MarshalBinary()
require.NoError(t, err) require.NoError(t, err)
require.NoError(t, v.ValidateContent(object.TypeTombstone, data)) require.NoError(t, v.ValidateContent(object.TypeTombstone, data))