(james-project) 01/02: [ENHANCEMENT] SessionId onto IMAP ID log

[rcordier]

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

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

commit be0c63b39e41d209252b117d7aabbe06bdd34e6c
Author: Benoit TELLIER <btell...@linagora.com>
AuthorDate: Tue Oct 29 22:26:45 2024 +0100

    [ENHANCEMENT] SessionId onto IMAP ID log
    
    Allow correlating user to his MUA
---
 .../main/java/org/apache/james/imap/processor/IdProcessor.java   | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdProcessor.java 
b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdProcessor.java
index 38207b74db..a0c00e8520 100644
--- 
a/protocols/imap/src/main/java/org/apache/james/imap/processor/IdProcessor.java
+++ 
b/protocols/imap/src/main/java/org/apache/james/imap/processor/IdProcessor.java
@@ -32,6 +32,7 @@ import org.apache.james.mailbox.MailboxManager;
 import org.apache.james.metrics.api.MetricFactory;
 import org.apache.james.util.MDCBuilder;
 import org.apache.james.util.MDCStructuredLogger;
+import org.apache.james.util.ReactorUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -50,13 +51,11 @@ public class IdProcessor extends 
AbstractMailboxProcessor<IDRequest> implements
 
     @Override
     protected Mono<Void> processRequestReactive(IDRequest request, ImapSession 
session, Responder responder) {
-        MDCStructuredLogger.forLogger(LOGGER)
-            .field("parameters", 
request.getParameters().map(Object::toString).orElse("NIL"))
-            .log(logger -> logger.info("Received id information"));
-
         responder.respond(new IdResponse());
 
-        return unsolicitedResponses(session, responder, false)
+        return ReactorUtils.logAsMono(() -> 
MDCStructuredLogger.forLogger(LOGGER)
+            .field("parameters", 
request.getParameters().map(Object::toString).orElse("NIL"))
+            .log(logger -> logger.info("Received id 
information"))).then(unsolicitedResponses(session, responder, false))
             .then(Mono.fromRunnable(() -> okComplete(request, responder)));
     }
 


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