Added an event msg dispatch for updated district contact.

Author: chris.ditcher

api/src/main/java/ca/bc/gov/educ/api/institute/controller/v1/DistrictAPIController.java

@@ -174,10 +174,12 @@ public DistrictContact createDistrictContact(UUID districtId, DistrictContact co
   }
 
   @Override
-  public DistrictContact updateDistrictContact(UUID districtId, UUID contactId, DistrictContact contact) {
+  public DistrictContact updateDistrictContact(UUID districtId, UUID contactId, DistrictContact contact) throws JsonProcessingException {
     validatePayload(() -> this.districtContactPayloadValidator.validateUpdatePayload(contact));
     RequestUtil.setAuditColumnsForUpdate(contact);
-    return districtContactMapper.toStructure(districtService.updateDistrictContact(contact, districtId, contactId));
+    var pair = districtService.updateDistrictContact(contact, districtId, contactId);
+    publisher.dispatchChoreographyEvent(pair.getRight());
+    return districtContactMapper.toStructure(pair.getLeft());
   }
 
   @Override

api/src/main/java/ca/bc/gov/educ/api/institute/endpoint/v1/DistrictAPIEndpoint.java

@@ -112,7 +112,7 @@ CompletableFuture<Page<DistrictContact>> findAllContacts(@RequestParam(name = "p
   @ApiResponses(value = {@ApiResponse(responseCode = "201", description = "CREATED"), @ApiResponse(responseCode = "400", description = "BAD REQUEST")})
   @Tag(name = "District Contact Entity", description = "Endpoints for district contact entity.")
   @Schema(name = "DistrictContact", implementation = DistrictContact.class)
-  DistrictContact updateDistrictContact(@PathVariable UUID districtId, @PathVariable UUID contactId, @Validated @RequestBody DistrictContact contact);
+  DistrictContact updateDistrictContact(@PathVariable UUID districtId, @PathVariable UUID contactId, @Validated @RequestBody DistrictContact contact) throws JsonProcessingException;
 
   @DeleteMapping("/{districtId}/contact/{contactId}")
   @PreAuthorize("hasAuthority('SCOPE_DELETE_DISTRICT_CONTACT')")

api/src/main/java/ca/bc/gov/educ/api/institute/service/v1/DistrictService.java

@@ -172,7 +172,7 @@ public Pair<DistrictContactEntity, InstituteEvent> createDistrictContact(Distric
   }
 
   @Transactional(propagation = Propagation.REQUIRES_NEW)
-  public DistrictContactEntity updateDistrictContact(DistrictContact contact, UUID districtId, UUID contactId) {
+  public Pair<DistrictContactEntity, InstituteEvent> updateDistrictContact(DistrictContact contact, UUID districtId, UUID contactId) throws JsonProcessingException {
     var contactEntity = DistrictContactMapper.mapper.toModel(contact);
     if (contactId == null || !contactId.equals(contactEntity.getDistrictContactId())) {
       throw new EntityNotFoundException(DistrictContactEntity.class, CONTACT_ID_ATTR, String.valueOf(contactId));
@@ -195,7 +195,13 @@ public DistrictContactEntity updateDistrictContact(DistrictContact contact, UUID
       TransformUtil.uppercaseFields(currentContactEntity); // convert the input to upper case.
       currentContactEntity.setDistrictEntity(curDistrictEntityOptional.get());
       districtContactRepository.save(currentContactEntity);
-      return currentContactEntity;
+      final InstituteEvent instituteEvent = EventUtil.createInstituteEvent(
+              contact.getCreateUser(), contact.getUpdateUser(),
+              JsonUtil.getJsonStringFromObject(DistrictContactMapper.mapper.toStructure(contactEntity)),
+              UPDATE_CONTACT, CONTACT_UPDATED
+      );
+      instituteEventRepository.save(instituteEvent);
+      return Pair.of(contactEntity, instituteEvent);
     } else {
       throw new EntityNotFoundException(DistrictContactEntity.class, CONTACT_ID_ATTR, String.valueOf(contactId));
     }