aboutsummaryrefslogtreecommitdiff
path: root/tests/object_iterator_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/object_iterator_test.go')
-rw-r--r--tests/object_iterator_test.go53
1 files changed, 26 insertions, 27 deletions
diff --git a/tests/object_iterator_test.go b/tests/object_iterator_test.go
index 592d896..751efc8 100644
--- a/tests/object_iterator_test.go
+++ b/tests/object_iterator_test.go
@@ -20,7 +20,6 @@ package tests
import (
"bytes"
- "context"
"fmt"
"strings"
"testing"
@@ -41,52 +40,52 @@ func TestObjectIterator(t *testing.T) {
for idx := 1; idx <= 4; idx++ {
hdr := schwift.NewObjectHeaders()
hdr.ContentType().Set("application/json")
- err := c.Object(oname(idx)).Upload(context.TODO(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
+ err := c.Object(oname(idx)).Upload(t.Context(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
expectSuccess(t, err)
}
// test iteration with empty last page
iter := c.Objects()
iter.Prefix = "schwift-test-listing"
- os, err := iter.NextPage(context.TODO(), 2)
+ os, err := iter.NextPage(t.Context(), 2)
expectSuccess(t, err)
expectObjectNames(t, os, oname(1), oname(2))
- os, err = iter.NextPage(context.TODO(), 2)
+ os, err = iter.NextPage(t.Context(), 2)
expectSuccess(t, err)
expectObjectNames(t, os, oname(3), oname(4))
- os, err = iter.NextPage(context.TODO(), 2)
+ os, err = iter.NextPage(t.Context(), 2)
expectSuccess(t, err)
expectObjectNames(t, os)
- os, err = iter.NextPage(context.TODO(), 2)
+ os, err = iter.NextPage(t.Context(), 2)
expectSuccess(t, err)
expectObjectNames(t, os)
// test iteration with partial last page
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
- os, err = iter.NextPage(context.TODO(), 3)
+ os, err = iter.NextPage(t.Context(), 3)
expectSuccess(t, err)
expectObjectNames(t, os, oname(1), oname(2), oname(3))
- os, err = iter.NextPage(context.TODO(), 3)
+ os, err = iter.NextPage(t.Context(), 3)
expectSuccess(t, err)
expectObjectNames(t, os, oname(4))
- os, err = iter.NextPage(context.TODO(), 4)
+ os, err = iter.NextPage(t.Context(), 4)
expectSuccess(t, err)
expectObjectNames(t, os)
// test detailed iteration
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
- ois, err := iter.NextPageDetailed(context.TODO(), 2)
+ ois, err := iter.NextPageDetailed(t.Context(), 2)
expectSuccess(t, err)
expectObjectInfos(t, ois, oname(1), oname(2))
- ois, err = iter.NextPageDetailed(context.TODO(), 3)
+ ois, err = iter.NextPageDetailed(t.Context(), 3)
expectSuccess(t, err)
expectObjectInfos(t, ois, oname(3), oname(4))
- ois, err = iter.NextPageDetailed(context.TODO(), 3)
+ ois, err = iter.NextPageDetailed(t.Context(), 3)
expectSuccess(t, err)
expectObjectInfos(t, ois)
- ois, err = iter.NextPageDetailed(context.TODO(), 3)
+ ois, err = iter.NextPageDetailed(t.Context(), 3)
expectSuccess(t, err)
expectObjectInfos(t, ois)
@@ -95,7 +94,7 @@ func TestObjectIterator(t *testing.T) {
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
idx := 0
- expectSuccess(t, iter.Foreach(context.TODO(), func(o *schwift.Object) error {
+ expectSuccess(t, iter.Foreach(t.Context(), func(o *schwift.Object) error {
idx++
expectString(t, o.Name(), oname(idx))
return nil
@@ -108,7 +107,7 @@ func TestObjectIterator(t *testing.T) {
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
idx = 0
- expectSuccess(t, iter.ForeachDetailed(context.TODO(), func(info schwift.ObjectInfo) error {
+ expectSuccess(t, iter.ForeachDetailed(t.Context(), func(info schwift.ObjectInfo) error {
idx++
expectString(t, info.Object.Name(), oname(idx))
return nil
@@ -119,14 +118,14 @@ func TestObjectIterator(t *testing.T) {
// test Collect
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
- os, err = iter.Collect(context.TODO())
+ os, err = iter.Collect(t.Context())
expectSuccess(t, err)
expectObjectNames(t, os, oname(1), oname(2), oname(3), oname(4))
// test CollectDetailed
iter = c.Objects()
iter.Prefix = "schwift-test-listing"
- ois, err = iter.CollectDetailed(context.TODO())
+ ois, err = iter.CollectDetailed(t.Context())
expectSuccess(t, err)
expectObjectInfos(t, ois, oname(1), oname(2), oname(3), oname(4))
})
@@ -147,20 +146,20 @@ func TestPseudoDirectories(t *testing.T) {
for _, name := range objectNames {
hdr := schwift.NewObjectHeaders()
hdr.ContentType().Set("application/json")
- err := c.Object(name).Upload(context.TODO(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
+ err := c.Object(name).Upload(t.Context(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
expectSuccess(t, err)
}
// test iteration with Delimiter and no Prefix
iter := c.Objects()
iter.Delimiter = "/"
- os, err := iter.Collect(context.TODO())
+ os, err := iter.Collect(t.Context())
expectSuccess(t, err)
expectObjectNames(t, os, "foo/")
iter = c.Objects()
iter.Delimiter = "/"
- ois, err := iter.CollectDetailed(context.TODO())
+ ois, err := iter.CollectDetailed(t.Context())
expectSuccess(t, err)
expectObjectInfos(t, ois, "subdir:foo/")
@@ -168,14 +167,14 @@ func TestPseudoDirectories(t *testing.T) {
iter = c.Objects()
iter.Prefix = "foo/"
iter.Delimiter = "/"
- os, err = iter.Collect(context.TODO())
+ os, err = iter.Collect(t.Context())
expectSuccess(t, err)
expectObjectNames(t, os, "foo/1", "foo/2", "foo/3", "foo/bar", "foo/bar/")
iter = c.Objects()
iter.Prefix = "foo/"
iter.Delimiter = "/"
- ois, err = iter.CollectDetailed(context.TODO())
+ ois, err = iter.CollectDetailed(t.Context())
expectSuccess(t, err)
expectObjectInfos(t, ois, "foo/1", "foo/2", "foo/3", "foo/bar", "subdir:foo/bar/")
})
@@ -191,20 +190,20 @@ func TestObjectIteratorWithSymlinks(t *testing.T) {
for _, name := range objectNames {
hdr := schwift.NewObjectHeaders()
hdr.ContentType().Set("application/json")
- err := c.Object(name).Upload(context.TODO(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
+ err := c.Object(name).Upload(t.Context(), bytes.NewReader(objectExampleContent), nil, hdr.ToOpts())
expectSuccess(t, err)
}
// create a test symlink
- expectSuccess(t, c.Object("foo/2").SymlinkTo(context.TODO(), c.Object("foo/1"), nil, nil))
+ expectSuccess(t, c.Object("foo/2").SymlinkTo(t.Context(), c.Object("foo/1"), nil, nil))
iter := c.Objects()
- os, err := iter.Collect(context.TODO())
+ os, err := iter.Collect(t.Context())
expectSuccess(t, err)
expectObjectNames(t, os, "foo/1", "foo/2", "foo/3")
iter = c.Objects()
- ois, err := iter.CollectDetailed(context.TODO())
+ ois, err := iter.CollectDetailed(t.Context())
expectSuccess(t, err)
expectObjectInfos(t, ois, "foo/1", "symlink:foo/2>foo/1", "foo/3")
})
@@ -212,7 +211,7 @@ func TestObjectIteratorWithSymlinks(t *testing.T) {
func expectContainerHeadersCached(t *testing.T, c *schwift.Container) {
requestCountBefore := c.Account().Backend().(*RequestCountingBackend).Count
- _, err := c.Headers(context.TODO())
+ _, err := c.Headers(t.Context())
expectSuccess(t, err)
requestCountAfter := c.Account().Backend().(*RequestCountingBackend).Count
generated by cgit v1.3.1 (git 2.54.0) at 2026-08-03 07:13:43 +0000