Function RestoreTestBucket

cpp/src/arrow/filesystem/s3fs_test.cc:678–720

  }

  Status RestoreTestBucket() {
    // First empty the test bucket, and then re-upload initial test files.

    Aws::S3::Model::Delete delete_object;
    {
      // Mostly taken from
      // https://github.com/awsdocs/aws-doc-sdk-examples/blob/main/cpp/example_code/s3/list_objects.cpp
      Aws::S3::Model::ListObjectsV2Request req;
      req.SetBucket(Aws::String{"bucket"});

      Aws::String continuation_token;
      do {
        if (!continuation_token.empty()) {
          req.SetContinuationToken(continuation_token);
        }

        auto outcome = client_->ListObjectsV2(req);

        if (!outcome.IsSuccess()) {
          return OutcomeToStatus("ListObjectsV2", outcome);
        } else {
          Aws::Vector<Aws::S3::Model::Object> objects = outcome.GetResult().GetContents();
          for (const auto& object : objects) {
            delete_object.AddObjects(
                Aws::S3::Model::ObjectIdentifier().WithKey(object.GetKey()));
          }

          continuation_token = outcome.GetResult().GetNextContinuationToken();
        }
      } while (!continuation_token.empty());
    }

    {
      Aws::S3::Model::DeleteObjectsRequest req;

      req.SetDelete(std::move(delete_object));
      req.SetBucket(Aws::String{"bucket"});

      RETURN_NOT_OK(OutcomeToStatus("DeleteObjects", client_->DeleteObjects(req)));
    }

    return PopulateTestBucket();
  }

  Result<std::shared_ptr<S3FileSystem>> MakeNewFileSystem(
      io::IOContext io_context = io::default_io_context()) {