This is an automated email from the ASF dual-hosted git repository. quantranhong1999 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit e9feb821cebdb6e435f465fbe98bd0dcc83db8fd Author: Quan Tran <[email protected]> AuthorDate: Fri Sep 25 10:35:31 2026 +0700 JAMES-4222 Triage S3 Ceph against blob store DAO contract --- .../objectstorage/aws/DockerCephS3ContainerTest.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/DockerCephS3ContainerTest.java b/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/DockerCephS3ContainerTest.java index 6fc96665aa..0f6d2f2f5e 100644 --- a/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/DockerCephS3ContainerTest.java +++ b/server/blob/blob-s3/src/test/java/org/apache/james/blob/objectstorage/aws/DockerCephS3ContainerTest.java @@ -24,18 +24,22 @@ import static org.assertj.core.api.Assertions.assertThat; import java.util.UUID; +import org.apache.james.blob.api.BlobStoreDAO; +import org.apache.james.blob.api.BlobStoreDAOContract; +import org.apache.james.blob.api.MetadataAwareBlobStoreDAOContract; import org.apache.james.blob.api.TestBlobId; import org.apache.james.metrics.api.NoopGaugeRegistry; import org.apache.james.metrics.tests.RecordingMetricFactory; import org.junit.jupiter.api.AfterAll; import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import reactor.core.publisher.Mono; @ExtendWith(DockerCephS3Extension.class) -class DockerCephS3ContainerTest { +class DockerCephS3ContainerTest implements BlobStoreDAOContract, MetadataAwareBlobStoreDAOContract { private static S3ClientFactory s3ClientFactory; private static S3BlobStoreDAO testee; @@ -55,6 +59,16 @@ class DockerCephS3ContainerTest { s3ClientFactory.close(); } + @BeforeEach + void cleanBuckets() { + testee.deleteAllBuckets().block(); + } + + @Override + public BlobStoreDAO testee() { + return testee; + } + @Test void shouldSupportS3WriteAndRead() { TestBlobId blobId = new TestBlobId(UUID.randomUUID().toString()); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
