This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git


The following commit(s) were added to refs/heads/master by this push:
     new e8a335bdc9 [ENHANCEMENT] Allow overriding 
AttachmentIdAssignationStrategy (#2622)
e8a335bdc9 is described below

commit e8a335bdc9284320bf122738edc4819c349802e5
Author: Benoit TELLIER <btell...@linagora.com>
AuthorDate: Tue Feb 4 14:37:48 2025 +0100

    [ENHANCEMENT] Allow overriding AttachmentIdAssignationStrategy (#2622)
---
 .../mailbox/cassandra/CassandraMailboxSessionMapperFactory.java     | 6 ++----
 .../james/mailbox/cassandra/CassandraSubscriptionManagerTest.java   | 3 +++
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/CassandraMailboxSessionMapperFactory.java
 
b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/CassandraMailboxSessionMapperFactory.java
index 17abbdab44..b4552c62b2 100644
--- 
a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/CassandraMailboxSessionMapperFactory.java
+++ 
b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/CassandraMailboxSessionMapperFactory.java
@@ -26,7 +26,6 @@ import jakarta.inject.Inject;
 import 
org.apache.james.backends.cassandra.init.configuration.CassandraConfiguration;
 import org.apache.james.blob.api.BlobStore;
 import org.apache.james.mailbox.MailboxSession;
-import org.apache.james.mailbox.StringBackedAttachmentIdFactory;
 import org.apache.james.mailbox.cassandra.mail.ACLMapper;
 import org.apache.james.mailbox.cassandra.mail.CassandraAnnotationMapper;
 import org.apache.james.mailbox.cassandra.mail.CassandraApplicableFlagDAO;
@@ -105,7 +104,7 @@ public class CassandraMailboxSessionMapperFactory extends 
MailboxSessionMapperFa
                                                 CassandraUserMailboxRightsDAO 
userMailboxRightsDAO,
                                                 
RecomputeMailboxCountersService recomputeMailboxCountersService,
                                                 CassandraConfiguration 
cassandraConfiguration,
-                                                BatchSizes batchSizes,
+                                                BatchSizes batchSizes, 
CassandraAttachmentMapper.AttachmentIdAssignationStrategy 
attachmentIdAssignationStrategy,
                                                 Clock clock) {
         this.uidProvider = uidProvider;
         this.modSeqProvider = modSeqProvider;
@@ -132,8 +131,7 @@ public class CassandraMailboxSessionMapperFactory extends 
MailboxSessionMapperFa
             deletedMessageDAO);
         this.cassandraMailboxMapper = new CassandraMailboxMapper(mailboxDAO, 
mailboxPathV3DAO, userMailboxRightsDAO, aclMapper, cassandraConfiguration);
         this.cassandraSubscriptionMapper = new 
CassandraSubscriptionMapper(session);
-        this.cassandraAttachmentMapper = new 
CassandraAttachmentMapper(attachmentDAOV2, blobStore,
-            new 
CassandraAttachmentMapper.AttachmentIdAssignationStrategy.Default(new 
StringBackedAttachmentIdFactory()));
+        this.cassandraAttachmentMapper = new 
CassandraAttachmentMapper(attachmentDAOV2, blobStore, 
attachmentIdAssignationStrategy);
         this.cassandraMessageMapper = new CassandraMessageMapper(
             uidProvider,
             modSeqProvider,
diff --git 
a/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/CassandraSubscriptionManagerTest.java
 
b/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/CassandraSubscriptionManagerTest.java
index 21377ac4b6..07fd00820c 100644
--- 
a/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/CassandraSubscriptionManagerTest.java
+++ 
b/mailbox/cassandra/src/test/java/org/apache/james/mailbox/cassandra/CassandraSubscriptionManagerTest.java
@@ -38,6 +38,7 @@ import org.apache.james.mailbox.SubscriptionManagerContract;
 import org.apache.james.mailbox.cassandra.mail.CassandraACLMapper;
 import org.apache.james.mailbox.cassandra.mail.CassandraApplicableFlagDAO;
 import org.apache.james.mailbox.cassandra.mail.CassandraAttachmentDAOV2;
+import org.apache.james.mailbox.cassandra.mail.CassandraAttachmentMapper;
 import org.apache.james.mailbox.cassandra.mail.CassandraDeletedMessageDAO;
 import org.apache.james.mailbox.cassandra.mail.CassandraFirstUnseenDAO;
 import org.apache.james.mailbox.cassandra.mail.CassandraMailboxCounterDAO;
@@ -109,6 +110,7 @@ class CassandraSubscriptionManagerTest implements 
SubscriptionManagerContract {
         CassandraUidProvider uidProvider = null;
         CassandraModSeqProvider modSeqProvider = null;
         RecomputeMailboxCountersService recomputeMailboxCountersService = null;
+        CassandraAttachmentMapper.AttachmentIdAssignationStrategy 
attachmentIdAssignationStrategy = null;
 
         mailboxSessionMapperFactory =  new 
CassandraMailboxSessionMapperFactory(
             uidProvider,
@@ -133,6 +135,7 @@ class CassandraSubscriptionManagerTest implements 
SubscriptionManagerContract {
             recomputeMailboxCountersService,
             CassandraConfiguration.DEFAULT_CONFIGURATION,
             BatchSizes.defaultValues(),
+            attachmentIdAssignationStrategy,
             Clock.systemUTC());
 
         InVMEventBus eventBus = new InVMEventBus(new InVmEventDelivery(new 
RecordingMetricFactory()), EventBusTestFixture.RETRY_BACKOFF_CONFIGURATION, new 
MemoryEventDeadLetters());


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@james.apache.org
For additional commands, e-mail: notifications-h...@james.apache.org

Reply via email to