Function TestTx_ListRecoveryWithMixedOperations

tx_list_test.go:677–715

TestTx_ListRecoveryWithMixedOperations tests recovery after complex operations

(t *testing.T)

// TestTx_ListRecoveryWithMixedOperations tests recovery after complex operations
func TestTx_ListRecoveryWithMixedOperations(t *testing.T) {
	bucket := "list_bucket"
	key := testutils.GetTestBytes(0)

	dir := filepath.Join(t.TempDir(), "test_nutsdb_list_recovery_mixed")
	defer func() { _ = os.RemoveAll(dir) }()

	opts := DefaultOptions
	opts.Dir = dir
	db, err := Open(opts)
	require.NoError(t, err)

	// Create bucket
	txCreateBucket(t, db, DataStructureList, bucket, nil)

	// RPush 5 elements: [0,1,2,3,4]
	for i := 0; i < 5; i++ {
		txPush(t, db, bucket, key, testutils.GetTestBytes(i), false, nil, nil)
	}

	// LPush 2 elements: [98,99,0,1,2,3,4]
	txPush(t, db, bucket, key, testutils.GetTestBytes(99), true, nil, nil)
	txPush(t, db, bucket, key, testutils.GetTestBytes(98), true, nil, nil)

	// Close and reopen
	err = db.Close()
	require.NoError(t, err)

	db, err = Open(opts)
	require.NoError(t, err)
	defer func() { _ = db.Close() }()

	// Verify recovered state - should have 7 elements
	txLSize(t, db, bucket, key, 7, nil)
	txLRange(t, db, bucket, key, 0, -1, 7, [][]byte{
		testutils.GetTestBytes(98), testutils.GetTestBytes(99), testutils.GetTestBytes(0), testutils.GetTestBytes(1),
		testutils.GetTestBytes(2), testutils.GetTestBytes(3), testutils.GetTestBytes(4),
	}, nil)
}

// TestTx_ListRecoveryMultipleLists tests recovery of multiple lists
func TestTx_ListRecoveryMultipleLists(t *testing.T) {