APPS-1469-azure-list-objects-fix

- fix ListObject method for azure and gcp
aerospike · Jan 22, 2025 · 412150d · 412150d
1 parent 590d729
commit 412150d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/io/azure/blob/reader.go b/io/azure/blob/reader.go
@@ -313,6 +313,10 @@ func (r *Reader) checkRestoreDirectory(ctx context.Context, path string) error {
 
 // ListObjects list all object in the path.
 func (r *Reader) ListObjects(ctx context.Context, path string) ([]string, error) {
+	if !strings.HasSuffix(path, "/") {
+		path += "/"
+	}
+
 	result := make([]string, 0)
 
 	pager := r.client.NewListBlobsFlatPager(r.containerName, &azblob.ListBlobsFlatOptions{

diff --git a/io/gcp/storage/reader.go b/io/gcp/storage/reader.go
@@ -320,6 +320,10 @@ func (r *Reader) checkRestoreDirectory(ctx context.Context, path string) error {
 
 // ListObjects list all object in the path.
 func (r *Reader) ListObjects(ctx context.Context, path string) ([]string, error) {
+	if !strings.HasSuffix(path, "/") {
+		path += "/"
+	}
+
 	result := make([]string, 0)
 
 	it := r.bucketHandle.Objects(ctx, &storage.Query{