Provide request ID

Author: sven1103

project-management/src/main/java/life/qbic/projectmanagement/application/api/AsyncProjectService.java

@@ -1,5 +1,6 @@
 package life.qbic.projectmanagement.application.api;
 
+import java.util.UUID;
 import reactor.core.publisher.Mono;
 
 /**
@@ -62,6 +63,24 @@ sealed interface UpdateResponseBody permits ProjectDesign {
 
   }
 
+  /**
+   * Cacheable requests provide a unique identifier so cache implementations can unambiguously
+   * manage the requests.
+   *
+   * @since 1.9.0
+   */
+  sealed interface CacheableRequest permits ProjectUpdateRequest {
+
+    /**
+     * Returns an ID that is unique to the request.
+     *
+     * @return the id
+     * @since 1.9.0
+     */
+    String requestId();
+
+  }
+
   /**
    * Container for passing information in an {@link UpdateRequestBody} or
    * {@link UpdateResponseBody}.
@@ -82,8 +101,17 @@ record ProjectDesign(String title, String objective) implements UpdateRequestBod
    * @param requestBody the information to be updated.
    * @since 1.9.0
    */
-  record ProjectUpdateRequest(String projectId, UpdateRequestBody requestBody) {
+  record ProjectUpdateRequest(String projectId, UpdateRequestBody requestBody, String id) implements
+      CacheableRequest {
 
+    public ProjectUpdateRequest(String projectId, UpdateRequestBody requestBody) {
+      this(projectId, requestBody, UUID.randomUUID().toString());
+    }
+
+    @Override
+    public String requestId() {
+      return id;
+    }
   }
 
   /**
@@ -93,7 +121,7 @@ record ProjectUpdateRequest(String projectId, UpdateRequestBody requestBody) {
    * @param responseBody the information that was updated.
    * @since 1.9.0
    */
-  record ProjectUpdateResponse(String projectId, UpdateResponseBody responseBody) {
+  record ProjectUpdateResponse(String projectId, UpdateResponseBody responseBody, String requestId) {
 
   }
 

project-management/src/main/java/life/qbic/projectmanagement/application/api/AsyncProjectServiceImpl.java

@@ -40,7 +40,7 @@ public Mono<ProjectUpdateResponse> update(@NonNull ProjectUpdateRequest request)
       case ProjectDesign design:
         return
             withSecurityContext(SecurityContextHolder.getContext(),
-                () -> updateProjectDesign(projectId, design)).subscribeOn(scheduler);
+                () -> updateProjectDesign(projectId, design, request.requestId())).subscribeOn(scheduler);
       default:
         return Mono.error(new UnknownRequestException("Invalid request body"));
     }
@@ -59,13 +59,13 @@ private Mono<ProjectUpdateResponse> withSecurityContext(SecurityContext sctx,
     }).contextWrite(rcontext);
   }
 
-  private Mono<ProjectUpdateResponse> updateProjectDesign(String projectId, ProjectDesign design) {
+  private Mono<ProjectUpdateResponse> updateProjectDesign(String projectId, ProjectDesign design, String requestId) {
     return Mono.create(sink -> {
       try {
         var id = ProjectId.parse(projectId);
         projectService.updateTitle(id, design.title());
         projectService.updateObjective(id, design.objective());
-        sink.success(new ProjectUpdateResponse(projectId, design));
+        sink.success(new ProjectUpdateResponse(projectId, design, requestId));
       } catch (IllegalArgumentException e) {
         sink.error(new RequestFailedException("Invalid project id: " + projectId));
       } catch (org.springframework.security.access.AccessDeniedException e) {