Wire async executor for record updates

Author: elmiomar

src/main/java/gov/nist/oar/distrib/web/RPAAsyncExecutor.java

@@ -6,6 +6,7 @@
 
 import gov.nist.oar.distrib.service.rpa.RPARequestHandler;
 import gov.nist.oar.distrib.service.rpa.exceptions.RequestProcessingException;
+import gov.nist.oar.distrib.service.rpa.model.Record;
 import gov.nist.oar.distrib.service.rpa.model.RecordWrapper;
 import gov.nist.oar.distrib.service.rpa.model.UserInfoWrapper;
 
@@ -40,4 +41,22 @@ public void handleAfterRecordCreationAsync(RecordWrapper wrapper, UserInfoWrappe
                     e.getMessage(), e);
         }
     }
+
+    /**
+     * Handle the post-processing of a record update (approval/decline) asynchronously.
+     * This method does not throw any exceptions; rather, it logs any errors and continues.
+     *
+     * @param record    The record that was updated.
+     * @param status    The approval status ("approved" or "declined").
+     * @param datasetId The ID of the dataset associated with the record.
+     */
+    @Async
+    public void handleAfterRecordUpdateAsync(Record record, String status, String datasetId) {
+        try {
+            handler.handleAfterRecordUpdate(record, status, datasetId);
+        } catch (RequestProcessingException e) {
+            LOGGER.error("Async post-processing failed for record update (record ID {}): {}",
+                    record.getId(), e.getMessage(), e);
+        }
+    }
 }

src/main/java/gov/nist/oar/distrib/web/RPARequestHandlerController.java

@@ -3,6 +3,7 @@
 import gov.nist.oar.distrib.service.RPACachingService;
 import gov.nist.oar.distrib.service.rpa.RPARequestHandler;
 import gov.nist.oar.distrib.service.rpa.RecordCreationResult;
+import gov.nist.oar.distrib.service.rpa.RecordUpdateResult;
 import gov.nist.oar.distrib.service.rpa.exceptions.InvalidRequestException;
 import gov.nist.oar.distrib.service.rpa.exceptions.RecaptchaClientException;
 import gov.nist.oar.distrib.service.rpa.exceptions.RecaptchaServerException;
@@ -398,12 +399,18 @@ public ResponseEntity<RecordStatus> updateRecord(@PathVariable String id, @Reque
             if (tokenDetails != null) {
                 LOGGER.debug("Updating record with ID: {}", id);
                 String smeId = tokenDetails.get("userEmail");
-                RecordStatus recordStatus = service.updateRecord(id, patch.getApprovalStatus(), smeId);
+                RecordUpdateResult result = service.updateRecord(id, patch.getApprovalStatus(), smeId);
+
+                // Trigger async post-processing (caching, email notifications)
+                asyncExecutor.handleAfterRecordUpdateAsync(
+                        result.getRecord(),
+                        patch.getApprovalStatus(),
+                        result.getDatasetId());
 
                 logUpdateAction(tokenDetails, id);
 
                 LOGGER.debug("Record successfully updated");
-                return new ResponseEntity<RecordStatus>(recordStatus, HttpStatus.OK);
+                return new ResponseEntity<RecordStatus>(result.getRecordStatus(), HttpStatus.OK);
             } else {
                 LOGGER.error("Token is invalid");
                 throw new UnauthorizedException("invalid token");