Added publish check endpoint

Author: Michael-Dratch

builder-api/src/main/java/org/acme/controller/EligibilityCheckResource.java

@@ -216,7 +216,6 @@ public Response createCustomCheck(@Context SecurityIdentity identity,
         newCheck.setOwnerId(userId);
         newCheck.setPublic(false);
         newCheck.setVersion(1);
-        newCheck.setPublished(false);
         try {
             eligibilityCheckRepository.saveWorkingCustomCheck(newCheck);
             return Response.ok(newCheck, MediaType.APPLICATION_JSON).build();
@@ -231,9 +230,12 @@ public Response createCustomCheck(@Context SecurityIdentity identity,
     @Path("/custom-checks")
     public Response updateCustomCheck(@Context SecurityIdentity identity,
                                 EligibilityCheck updateCheck){
+        // Authorization
         String userId = AuthUtils.getUserId(identity);
+        if (!userId.equals(updateCheck.getOwnerId())){
+            return Response.status(Response.Status.UNAUTHORIZED).build();
+        }
 
-        // TODO: Add authorization to update check
         try {
             eligibilityCheckRepository.updateWorkingCustomCheck(updateCheck);
             return Response.ok().entity(updateCheck).build();
@@ -243,4 +245,53 @@ public Response updateCustomCheck(@Context SecurityIdentity identity,
                     .build();
         }
     }
+
+    @POST
+    @Path("/publish-check/{checkId}")
+    public Response publishCustomCheck(@Context SecurityIdentity identity, @PathParam("checkId") String checkId){
+
+        String userId = AuthUtils.getUserId(identity);
+        Optional<EligibilityCheck> checkOpt = eligibilityCheckRepository.getWorkingCustomCheck(userId, checkId);
+        if (checkOpt.isEmpty()){
+            return Response.status(Response.Status.NOT_FOUND).build();
+        }
+
+        EligibilityCheck check = checkOpt.get();
+
+        // Authorization
+        if (!userId.equals(check.getOwnerId())){
+            return Response.status(Response.Status.UNAUTHORIZED).build();
+        }
+
+        // Update workingCheck so that the incremented version number is saved
+        check.setVersion(check.getVersion() + 1);
+        try {
+            eligibilityCheckRepository.updateWorkingCustomCheck(check);
+        } catch (Exception e){
+            return Response.status(Response.Status.INTERNAL_SERVER_ERROR)
+                    .entity(Map.of("error", "could not update working Check, published check version was not created"))
+                    .build();
+        }
+
+        // Create new published custom check
+        check.setId(check.getPublishedId());
+        try {
+            // save published check meta data document
+            eligibilityCheckRepository.savePublishedCustomCheck(check);
+
+            // save published check DMN to storage
+            Optional<String> workingDmnOpt = storageService.getStringFromStorage(storageService.getCheckDmnModelPath(userId, check.getWorkingId()));
+            if (workingDmnOpt.isPresent()){
+                String workingDmn = workingDmnOpt.get();
+                storageService.writeStringToStorage(storageService.getCheckDmnModelPath(userId, check.getPublishedId()), workingDmn, "application/xml");
+
+            }
+        } catch (Exception e){
+            return Response.status(Response.Status.INTERNAL_SERVER_ERROR)
+                    .entity(Map.of("error", "could not create new published custom check version"))
+                    .build();
+        }
+
+        return Response.ok(check, MediaType.APPLICATION_JSON).build();
+    }
 }

builder-api/src/main/java/org/acme/model/domain/EligibilityCheck.java

@@ -20,20 +20,23 @@ public class EligibilityCheck {
     private String ownerId;
     @JsonProperty("isPublic")
     private Boolean isPublic;
-    private Boolean isPublished;
 
     public String getWorkingId() {
         return CheckStatus.WORKING.getCode() + "-" + ownerId + "-" + module + "-" + name;
     }
 
     public String getPublishedId() {
-        return CheckStatus.PUBLISHED.getCode() + "-" + ownerId + "-" + module + "-" + name;
+        return CheckStatus.PUBLISHED.getCode() + "-" + ownerId + "-" + module + "-" + name + "-" + version.toString();
     }
 
     public String getId() {
         return this.id;
     }
 
+    public void setId(String id) {
+        this.id = id;
+    }
+
     public String getName() {
         return name;
     }
@@ -114,7 +117,5 @@ public void setPublic(Boolean aPublic) {
         isPublic = aPublic;
     }
 
-    public void setPublished(Boolean published) {
-        isPublished = published;
-    }
+
 }

builder-api/src/main/java/org/acme/persistence/GoogleStorageService.java

@@ -26,7 +26,7 @@ public class GoogleStorageService implements StorageService {
     String bucketName;
 
     @Override
-    public void writeStringToStorage(String filePath, String content, String contentType){
+    public void writeStringToStorage(String filePath, String content, String contentType) throws Exception {
         try {
             BlobId blobId = BlobId.of(bucketName, filePath);
             BlobInfo blobInfo = BlobInfo.newBuilder(blobId)
@@ -37,6 +37,7 @@ public void writeStringToStorage(String filePath, String content, String content
             Log.info("Uploaded to GCS: " + filePath);
         } catch (Exception e){
             Log.error("Error writing string to GCS: " + e.getMessage());
+            throw new Exception(e);
         }
     }
 

builder-api/src/main/java/org/acme/persistence/StorageService.java

@@ -7,7 +7,7 @@
 import java.util.Optional;
 
 public interface StorageService {
-    void writeStringToStorage(String filePath, String content, String contentType);
+    void writeStringToStorage(String filePath, String content, String contentType) throws Exception;
 
     void writeBytesToStorage(String filePath, byte[] content, String contentType);