Use local fs for non-retention tests
Switch kopia package tests that don't require retention to use the local file system for speed. Tests that do check retention settings require S3.
This commit is contained in:
parent
933ce690ca
commit
deaa48f472
@ -22,6 +22,20 @@ import (
|
|||||||
storeTD "github.com/alcionai/corso/src/pkg/storage/testdata"
|
storeTD "github.com/alcionai/corso/src/pkg/storage/testdata"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
func openLocalKopiaRepo(
|
||||||
|
t tester.TestT,
|
||||||
|
ctx context.Context, //revive:disable-line:context-as-argument
|
||||||
|
) (*conn, error) {
|
||||||
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
|
|
||||||
|
k := NewConn(st)
|
||||||
|
if err := k.Initialize(ctx, repository.Options{}, repository.Retention{}); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return k, nil
|
||||||
|
}
|
||||||
|
|
||||||
func openKopiaRepo(
|
func openKopiaRepo(
|
||||||
t tester.TestT,
|
t tester.TestT,
|
||||||
ctx context.Context, //revive:disable-line:context-as-argument
|
ctx context.Context, //revive:disable-line:context-as-argument
|
||||||
@ -81,7 +95,7 @@ func (suite *WrapperIntegrationSuite) TestRepoExistsError() {
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
st := storeTD.NewPrefixedS3Storage(t)
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
k := NewConn(st)
|
k := NewConn(st)
|
||||||
|
|
||||||
err := k.Initialize(ctx, repository.Options{}, repository.Retention{})
|
err := k.Initialize(ctx, repository.Options{}, repository.Retention{})
|
||||||
@ -101,7 +115,7 @@ func (suite *WrapperIntegrationSuite) TestBadProviderErrors() {
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
st := storeTD.NewPrefixedS3Storage(t)
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
st.Provider = storage.ProviderUnknown
|
st.Provider = storage.ProviderUnknown
|
||||||
k := NewConn(st)
|
k := NewConn(st)
|
||||||
|
|
||||||
@ -115,7 +129,7 @@ func (suite *WrapperIntegrationSuite) TestConnectWithoutInitErrors() {
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
st := storeTD.NewPrefixedS3Storage(t)
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
k := NewConn(st)
|
k := NewConn(st)
|
||||||
|
|
||||||
err := k.Connect(ctx, repository.Options{})
|
err := k.Connect(ctx, repository.Options{})
|
||||||
@ -408,7 +422,7 @@ func (suite *WrapperIntegrationSuite) TestSetUserAndHost() {
|
|||||||
Host: "bar",
|
Host: "bar",
|
||||||
}
|
}
|
||||||
|
|
||||||
st := storeTD.NewPrefixedS3Storage(t)
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
k := NewConn(st)
|
k := NewConn(st)
|
||||||
|
|
||||||
err := k.Initialize(ctx, opts, repository.Retention{})
|
err := k.Initialize(ctx, opts, repository.Retention{})
|
||||||
|
|||||||
@ -29,7 +29,7 @@ type fooModel struct {
|
|||||||
|
|
||||||
//revive:disable-next-line:context-as-argument
|
//revive:disable-next-line:context-as-argument
|
||||||
func getModelStore(t *testing.T, ctx context.Context) *ModelStore {
|
func getModelStore(t *testing.T, ctx context.Context) *ModelStore {
|
||||||
c, err := openKopiaRepo(t, ctx)
|
c, err := openLocalKopiaRepo(t, ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
return &ModelStore{c: c, modelVersion: globalModelVersion}
|
return &ModelStore{c: c, modelVersion: globalModelVersion}
|
||||||
@ -856,7 +856,7 @@ func openConnAndModelStore(
|
|||||||
t *testing.T,
|
t *testing.T,
|
||||||
ctx context.Context, //revive:disable-line:context-as-argument
|
ctx context.Context, //revive:disable-line:context-as-argument
|
||||||
) (*conn, *ModelStore) {
|
) (*conn, *ModelStore) {
|
||||||
st := storeTD.NewPrefixedS3Storage(t)
|
st := storeTD.NewFilesystemStorage(t)
|
||||||
c := NewConn(st)
|
c := NewConn(st)
|
||||||
|
|
||||||
err := c.Initialize(ctx, repository.Options{}, repository.Retention{})
|
err := c.Initialize(ctx, repository.Options{}, repository.Retention{})
|
||||||
|
|||||||
@ -184,7 +184,7 @@ func (suite *BasicKopiaIntegrationSuite) TestMaintenance_FirstRun_NoChanges() {
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
k, err := openKopiaRepo(t, ctx)
|
k, err := openLocalKopiaRepo(t, ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
w := &Wrapper{k}
|
w := &Wrapper{k}
|
||||||
@ -204,7 +204,7 @@ func (suite *BasicKopiaIntegrationSuite) TestMaintenance_WrongUser_NoForce_Fails
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
k, err := openKopiaRepo(t, ctx)
|
k, err := openLocalKopiaRepo(t, ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
w := &Wrapper{k}
|
w := &Wrapper{k}
|
||||||
@ -241,7 +241,7 @@ func (suite *BasicKopiaIntegrationSuite) TestMaintenance_WrongUser_Force_Succeed
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
k, err := openKopiaRepo(t, ctx)
|
k, err := openLocalKopiaRepo(t, ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
w := &Wrapper{k}
|
w := &Wrapper{k}
|
||||||
@ -754,7 +754,7 @@ func (suite *KopiaIntegrationSuite) SetupTest() {
|
|||||||
t := suite.T()
|
t := suite.T()
|
||||||
suite.ctx, suite.flush = tester.NewContext(t)
|
suite.ctx, suite.flush = tester.NewContext(t)
|
||||||
|
|
||||||
c, err := openKopiaRepo(t, suite.ctx)
|
c, err := openLocalKopiaRepo(t, suite.ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
suite.w = &Wrapper{c}
|
suite.w = &Wrapper{c}
|
||||||
@ -1245,7 +1245,7 @@ func (suite *KopiaIntegrationSuite) TestRestoreAfterCompressionChange() {
|
|||||||
ctx, flush := tester.NewContext(t)
|
ctx, flush := tester.NewContext(t)
|
||||||
defer flush()
|
defer flush()
|
||||||
|
|
||||||
k, err := openKopiaRepo(t, ctx)
|
k, err := openLocalKopiaRepo(t, ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
err = k.Compression(ctx, "s2-default")
|
err = k.Compression(ctx, "s2-default")
|
||||||
@ -1559,7 +1559,7 @@ func (suite *KopiaSimpleRepoIntegrationSuite) SetupTest() {
|
|||||||
//nolint:forbidigo
|
//nolint:forbidigo
|
||||||
suite.ctx, _ = logger.CtxOrSeed(context.Background(), ls)
|
suite.ctx, _ = logger.CtxOrSeed(context.Background(), ls)
|
||||||
|
|
||||||
c, err := openKopiaRepo(t, suite.ctx)
|
c, err := openLocalKopiaRepo(t, suite.ctx)
|
||||||
require.NoError(t, err, clues.ToCore(err))
|
require.NoError(t, err, clues.ToCore(err))
|
||||||
|
|
||||||
suite.w = &Wrapper{c}
|
suite.w = &Wrapper{c}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user