meta: index parent object the same way metabase does

It is the only way to get root object's header.

Signed-off-by: Pavel Karpy <[email protected]>

Author: carpawell

pkg/services/meta/containers.go

@@ -184,7 +184,7 @@ func (s *containerStorage) putRawIndexes(ctx context.Context, l *zap.Logger, ee
 
 		res <- evWithMpt
 
-		fillObjectIndex(batch, h)
+		fillObjectIndex(batch, h, false)
 	}
 
 	return finalErr
@@ -238,7 +238,7 @@ func isOpAllowed(db storage.Store, e objEvent) error {
 
 const binPropertyMarker = "1" // ROOT, PHY, etc.
 
-func fillObjectIndex(batch map[string][]byte, h objectsdk.Object) {
+func fillObjectIndex(batch map[string][]byte, h objectsdk.Object, isParent bool) {
 	id := h.GetID()
 	typ := h.Type()
 	owner := h.Owner()
@@ -247,7 +247,7 @@ func fillObjectIndex(batch map[string][]byte, h objectsdk.Object) {
 	fPart := h.GetFirstID()
 	parID := h.GetParentID()
 	hasParent := h.Parent() != nil
-	phy := hasParent || (fPart.IsZero() && parID.IsZero())
+	phy := !isParent
 	pldHash, _ := h.PayloadChecksum()
 	var ver version.Version
 	if v := h.Version(); v != nil {
@@ -275,7 +275,7 @@ func fillObjectIndex(batch map[string][]byte, h objectsdk.Object) {
 	if !parID.IsZero() {
 		putPlainAttribute(batch, id, objectsdk.FilterParentID, string(parID[:]))
 	}
-	if !hasParent && typ == objectsdk.TypeRegular {
+	if !hasParent && fPart.IsZero() && typ == objectsdk.TypeRegular {
 		putPlainAttribute(batch, id, objectsdk.FilterRoot, binPropertyMarker)
 	}
 	if phy {
@@ -289,6 +289,10 @@ func fillObjectIndex(batch map[string][]byte, h objectsdk.Object) {
 			putPlainAttribute(batch, id, ak, av)
 		}
 	}
+
+	if hasParent {
+		fillObjectIndex(batch, *h.Parent(), true)
+	}
 }
 
 func deleteObjectsOps(dbKV map[string][]byte, s storage.Store, objects []byte, canDeleteLockObjects bool) (map[string][]byte, error) {

pkg/services/meta/notifications_test.go

@@ -415,6 +415,7 @@ func TestObjectPut(t *testing.T) {
 		size := uint64(testObjectSize)
 
 		o := objecttest.Object()
+		o.ResetRelations()
 		o.SetContainerID(cID)
 		o.SetID(objToDeleteOID)
 		o.SetPayloadSize(size)
@@ -480,7 +481,7 @@ func TestObjectPut(t *testing.T) {
 			}
 
 			tempM := make(map[string][]byte)
-			fillObjectIndex(tempM, o)
+			fillObjectIndex(tempM, o, false)
 			// dbKeys := maps.Keys(tempM) // go 1.23+
 			dbKeys := make([][]byte, 0, len(tempM))
 			for k := range tempM {
@@ -619,6 +620,7 @@ func TestValidation(t *testing.T) {
 func TestCompatibility(t *testing.T) {
 	o := objecttest.Object()
 	o.SetSplitID(nil) // no split info is expected for split V2 era
+	o.ResetRelations()
 
 	// database from engine's metabases
 
@@ -649,7 +651,7 @@ func TestCompatibility(t *testing.T) {
 	// batch for meta-data service
 
 	serviceMap := make(map[string][]byte)
-	fillObjectIndex(serviceMap, o)
+	fillObjectIndex(serviceMap, o, false)
 
 	require.Equal(t, len(metabaseMap), len(serviceMap))
 	for k := range metabaseMap {