51 lines
1.3 KiB
Go
51 lines
1.3 KiB
Go
package blobstortest
|
|
|
|
import (
|
|
"context"
|
|
"math/rand"
|
|
"testing"
|
|
|
|
objectCore "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/core/object"
|
|
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/common"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
// TestControl checks correctness of a read-only mode.
|
|
// cons must return a storage which is NOT opened.
|
|
func TestControl(t *testing.T, cons Constructor, min, max uint64) {
|
|
s := cons(t)
|
|
require.NoError(t, s.Open(false))
|
|
require.NoError(t, s.Init())
|
|
|
|
objects := prepare(t, 10, s, min, max)
|
|
require.NoError(t, s.Close())
|
|
|
|
require.NoError(t, s.Open(true))
|
|
for i := range objects {
|
|
var prm common.GetPrm
|
|
prm.Address = objects[i].addr
|
|
prm.StorageID = objects[i].storageID
|
|
prm.Raw = true
|
|
|
|
_, err := s.Get(context.Background(), prm)
|
|
require.NoError(t, err)
|
|
}
|
|
|
|
t.Run("put fails", func(t *testing.T) {
|
|
var prm common.PutPrm
|
|
prm.Object = NewObject(min + uint64(rand.Intn(int(max-min+1))))
|
|
prm.Address = objectCore.AddressOf(prm.Object)
|
|
|
|
_, err := s.Put(context.Background(), prm)
|
|
require.ErrorIs(t, err, common.ErrReadOnly)
|
|
})
|
|
t.Run("delete fails", func(t *testing.T) {
|
|
var prm common.DeletePrm
|
|
prm.Address = objects[0].addr
|
|
prm.StorageID = objects[0].storageID
|
|
|
|
_, err := s.Delete(context.Background(), prm)
|
|
require.ErrorIs(t, err, common.ErrReadOnly)
|
|
})
|
|
}
|