This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 108235f02 Add bucketVersioningEnabled helper methods
108235f02 is described below
commit 108235f0259b3e01230214904abc2271985dfd3d
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sat Apr 29 16:50:36 2023 +0200
Add bucketVersioningEnabled helper methods
---
.../scala/org/apache/pekko/stream/connectors/s3/model.scala | 12 ++++++++++++
.../stream/connectors/s3/scaladsl/S3IntegrationSpec.scala | 2 ++
2 files changed, 14 insertions(+)
diff --git
a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala
b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala
index d4c522846..aab05f161 100644
--- a/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala
+++ b/s3/src/main/scala/org/apache/pekko/stream/connectors/s3/model.scala
@@ -146,6 +146,12 @@ final class BucketVersioningResult private (val status:
Option[BucketVersioningS
def withMfaDelete(value: Boolean): BucketVersioningResult =
copy(mfaDelete = Some(value))
+ /** Java API */
+ def getBucketVersioningEnabled: Boolean = bucketVersioningEnabled
+
+ /** Scala API */
+ def bucketVersioningEnabled: Boolean =
status.contains(BucketVersioningStatus.Enabled)
+
private def copy(
status: Option[BucketVersioningStatus] = status, mfaDelete:
Option[Boolean] = mfaDelete): BucketVersioningResult =
new BucketVersioningResult(
@@ -194,6 +200,12 @@ final class BucketVersioning private (val status:
Option[BucketVersioningStatus]
/** Java API */
def getMfaDelete: java.util.Optional[MFAStatus] = mfaDelete.asJava
+ /** Java API */
+ def getBucketVersioningEnabled: Boolean = bucketVersioningEnabled
+
+ /** Scala API */
+ def bucketVersioningEnabled: Boolean =
status.contains(BucketVersioningStatus.Enabled)
+
def withStatus(value: BucketVersioningStatus): BucketVersioning =
copy(status = Some(value))
def withMfaDelete(value: MFAStatus): BucketVersioning = copy(mfaDelete =
Some(value))
diff --git
a/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
b/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
index eeeede4be..f39a17627 100644
---
a/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
+++
b/s3/src/test/scala/org/apache/pekko/stream/connectors/s3/scaladsl/S3IntegrationSpec.scala
@@ -845,7 +845,9 @@ trait S3IntegrationSpec
whenReady(request) { case (firstValue, secondValue) =>
firstValue shouldEqual BucketVersioningResult()
+ firstValue.bucketVersioningEnabled shouldEqual false
secondValue shouldEqual
BucketVersioningResult().withStatus(BucketVersioningStatus.Enabled)
+ secondValue.bucketVersioningEnabled shouldEqual true
S3.putBucketVersioning(bucketName,
BucketVersioning().withStatus(BucketVersioningStatus.Suspended)).futureValue
shouldBe Done
S3.deleteBucket(bucketName).futureValue
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
