From 50886350c8d24ccdf7b9c7b24b7a49b3e63571dc Mon Sep 17 00:00:00 2001
From: Pavel Karpy <carpawell@nspcc.ru>
Date: Wed, 26 Feb 2025 23:34:44 +0300
Subject: [PATCH] node/meta: add meta indexes compatibility test

Refs #3139.

Signed-off-by: Pavel Karpy <carpawell@nspcc.ru>
---
 pkg/services/meta/notifications_test.go | 46 +++++++++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/pkg/services/meta/notifications_test.go b/pkg/services/meta/notifications_test.go
index 3553e26c12..1c646e6790 100644
--- a/pkg/services/meta/notifications_test.go
+++ b/pkg/services/meta/notifications_test.go
@@ -7,6 +7,7 @@ import (
 	"maps"
 	"math/big"
 	"os"
+	"path"
 	"sync"
 	"testing"
 	"time"
@@ -20,6 +21,7 @@ import (
 	"github.com/nspcc-dev/neo-go/pkg/util"
 	"github.com/nspcc-dev/neo-go/pkg/vm/stackitem"
 	"github.com/nspcc-dev/neofs-node/pkg/core/object"
+	meta "github.com/nspcc-dev/neofs-node/pkg/local_object_storage/metabase"
 	utilcore "github.com/nspcc-dev/neofs-node/pkg/util"
 	cid "github.com/nspcc-dev/neofs-sdk-go/container/id"
 	objectsdk "github.com/nspcc-dev/neofs-sdk-go/object"
@@ -27,6 +29,7 @@ import (
 	oidtest "github.com/nspcc-dev/neofs-sdk-go/object/id/test"
 	objecttest "github.com/nspcc-dev/neofs-sdk-go/object/test"
 	"github.com/stretchr/testify/require"
+	"go.etcd.io/bbolt"
 	"go.uber.org/zap/zaptest"
 )
 
@@ -499,3 +502,46 @@ func TestObjectPut(t *testing.T) {
 		}, 3*time.Second, time.Millisecond*100, "object was not deleted")
 	})
 }
+
+func TestCompatibility(t *testing.T) {
+	o := objecttest.Object()
+	o.SetSplitID(nil) // no split info is expected for split V2 era
+
+	// database from engine's metabases
+
+	db, err := bbolt.Open(path.Join(t.TempDir(), "db.db"), 0600, bbolt.DefaultOptions)
+	require.NoError(t, err)
+	t.Cleanup(func() {
+		_ = db.Close()
+	})
+
+	metabaseMap := make(map[string][]byte)
+
+	err = db.Update(func(tx *bbolt.Tx) error {
+		err = meta.PutMetadataForObject(tx, o, true, true)
+		require.NoError(t, err)
+
+		cID := o.GetContainerID()
+		metaBucketKey := []byte{255}
+		metaBucketKey = append(metaBucketKey, cID[:]...)
+
+		b := tx.Bucket(metaBucketKey)
+		return b.ForEach(func(k, v []byte) error {
+			metabaseMap[string(k)] = v
+			return nil
+		})
+	})
+	require.NoError(t, err)
+
+	// batch for meta-data service
+
+	serviceMap := make(map[string][]byte)
+	err = fillObjectIndex(serviceMap, o)
+	require.NoError(t, err)
+
+	require.Equal(t, len(metabaseMap), len(serviceMap))
+	for k := range metabaseMap {
+		_, found := serviceMap[k]
+		require.Truef(t, found, "%s key not found: %v", k, []byte(k))
+	}
+}