Return Checkers in WorkFlowDefinitions

integration-tests/src/test/java/com/redhat/parodos/flows/PrebuiltWorkFlowTest.java

@@ -2,6 +2,7 @@
 
 import java.util.Arrays;
 import java.util.List;
+import java.util.Optional;
 import java.util.function.Consumer;
 
 import com.redhat.parodos.flows.common.WorkFlowTestBuilder;
@@ -79,12 +80,13 @@ private Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResponseCon
 
 			assertNotNull(workFlowDefinition.getWorks());
 			assertEquals(1, workFlowDefinition.getWorks().size());
-			assertEquals("notificationTask", workFlowDefinition.getWorks().get(0).getName());
-			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK,
-					workFlowDefinition.getWorks().get(0).getWorkType());
-			assertTrue(CollectionUtils.isEmpty(workFlowDefinition.getWorks().get(0).getWorks()));
-			assertNull(workFlowDefinition.getWorks().get(0).getProcessingType());
-			assertNotNull(workFlowDefinition.getWorks().get(0).getParameters());
+			Optional<WorkDefinitionResponseDTO> firstWork = workFlowDefinition.getWorks().stream().findFirst();
+			assertTrue(firstWork.isPresent());
+			assertEquals("notificationTask", firstWork.get().getName());
+			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK, firstWork.get().getWorkType());
+			assertTrue(CollectionUtils.isEmpty(firstWork.get().getWorks()));
+			assertNull(firstWork.get().getProcessingType());
+			assertNotNull(firstWork.get().getParameters());
 		};
 	}
 

integration-tests/src/test/java/com/redhat/parodos/flows/SimpleWorkFlowTest.java

@@ -90,19 +90,18 @@ private static Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResp
 
 			assertNotNull(workFlowDefinition.getWorks());
 			assertEquals(2, workFlowDefinition.getWorks().size());
-			assertEquals("restCallTask", workFlowDefinition.getWorks().get(0).getName());
-			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK,
-					workFlowDefinition.getWorks().get(0).getWorkType());
-			assertTrue(CollectionUtils.isEmpty(workFlowDefinition.getWorks().get(0).getWorks()));
-			assertNull(workFlowDefinition.getWorks().get(0).getProcessingType());
-			assertNotNull(workFlowDefinition.getWorks().get(0).getParameters());
-
-			assertEquals("loggingTask", workFlowDefinition.getWorks().get(1).getName());
-			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK,
-					workFlowDefinition.getWorks().get(1).getWorkType());
-			assertTrue(CollectionUtils.isEmpty(workFlowDefinition.getWorks().get(1).getWorks()));
-			assertNull(workFlowDefinition.getWorks().get(1).getProcessingType());
-			assertNotNull(workFlowDefinition.getWorks().get(1).getParameters());
+			List<WorkDefinitionResponseDTO> works = workFlowDefinition.getWorks().stream().toList();
+			assertEquals("restCallTask", works.get(0).getName());
+			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK, works.get(0).getWorkType());
+			assertTrue(CollectionUtils.isEmpty(works.get(0).getWorks()));
+			assertNull(works.get(0).getProcessingType());
+			assertNotNull(works.get(0).getParameters());
+
+			assertEquals("loggingTask", works.get(1).getName());
+			assertEquals(WorkDefinitionResponseDTO.WorkTypeEnum.TASK, works.get(1).getWorkType());
+			assertTrue(CollectionUtils.isEmpty(works.get(1).getWorks()));
+			assertNull(works.get(1).getProcessingType());
+			assertNotNull(works.get(1).getParameters());
 		};
 	}
 

integration-tests/src/test/java/com/redhat/parodos/flows/negative/FailedWithAlertMessageWorkFlowTest.java

@@ -1,5 +1,6 @@
 package com.redhat.parodos.flows.negative;
 
+import java.util.List;
 import java.util.function.Consumer;
 
 import com.redhat.parodos.flows.common.WorkFlowTestBuilder;
@@ -86,13 +87,13 @@ private static Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResp
 
 			assertThat(workFlowDefinition.getWorks()).isNotNull();
 			assertThat(workFlowDefinition.getWorks()).hasSize(2);
-			assertThat(workFlowDefinition.getWorks().get(1).getName()).isEqualTo("doNothingAgainWorkFlowTask");
-			assertThat(workFlowDefinition.getWorks().get(1).getWorkType())
-					.isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
-			assertThat(workFlowDefinition.getWorks().get(1).getWorks()).isNullOrEmpty();
-			assertThat(workFlowDefinition.getWorks().get(1).getProcessingType()).isNull();
-			assertThat(workFlowDefinition.getWorks().get(1).getParameters()).isNotNull();
-			assertThat(workFlowDefinition.getWorks().get(0).getName()).isEqualTo("failedWithAlertMessageWorkFlowTask");
+			List<WorkDefinitionResponseDTO> works = workFlowDefinition.getWorks().stream().toList();
+			assertThat(works.get(1).getName()).isEqualTo("doNothingAgainWorkFlowTask");
+			assertThat(works.get(1).getWorkType()).isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
+			assertThat(works.get(1).getWorks()).isNullOrEmpty();
+			assertThat(works.get(1).getProcessingType()).isNull();
+			assertThat(works.get(1).getParameters()).isNotNull();
+			assertThat(works.get(0).getName()).isEqualTo("failedWithAlertMessageWorkFlowTask");
 		};
 	}
 

integration-tests/src/test/java/com/redhat/parodos/flows/negative/PendingWithAlertMessageWorkFlowTest.java

@@ -1,5 +1,6 @@
 package com.redhat.parodos.flows.negative;
 
+import java.util.List;
 import java.util.function.Consumer;
 
 import com.redhat.parodos.flows.common.WorkFlowTestBuilder;
@@ -86,13 +87,13 @@ private static Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResp
 
 			assertThat(workFlowDefinition.getWorks()).isNotNull();
 			assertThat(workFlowDefinition.getWorks()).hasSize(2);
-			assertThat(workFlowDefinition.getWorks().get(1).getName()).isEqualTo("doNothingWorkFlowTask");
-			assertThat(workFlowDefinition.getWorks().get(1).getWorkType())
-					.isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
-			assertThat(workFlowDefinition.getWorks().get(1).getWorks()).isNullOrEmpty();
-			assertThat(workFlowDefinition.getWorks().get(1).getProcessingType()).isNull();
-			assertThat(workFlowDefinition.getWorks().get(1).getParameters()).isNotNull();
-			assertThat(workFlowDefinition.getWorks().get(0).getName()).isEqualTo("pendingWithAlertMessageWorkFlowTask");
+			List<WorkDefinitionResponseDTO> works = workFlowDefinition.getWorks().stream().toList();
+			assertThat(works.get(1).getName()).isEqualTo("doNothingWorkFlowTask");
+			assertThat(works.get(1).getWorkType()).isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
+			assertThat(works.get(1).getWorks()).isNullOrEmpty();
+			assertThat(works.get(1).getProcessingType()).isNull();
+			assertThat(works.get(1).getParameters()).isNotNull();
+			assertThat(works.get(0).getName()).isEqualTo("pendingWithAlertMessageWorkFlowTask");
 		};
 	}
 

integration-tests/src/test/java/com/redhat/parodos/flows/negative/SequentialFailedWithExceptionWorkFlowTest.java

@@ -1,5 +1,6 @@
 package com.redhat.parodos.flows.negative;
 
+import java.util.Optional;
 import java.util.function.Consumer;
 
 import com.redhat.parodos.flows.common.WorkFlowTestBuilder;
@@ -21,6 +22,7 @@
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 @Slf4j
 public class SequentialFailedWithExceptionWorkFlowTest {
@@ -77,12 +79,13 @@ private static Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResp
 
 			assertThat(workFlowDefinition.getWorks()).isNotNull();
 			assertThat(workFlowDefinition.getWorks()).hasSize(1);
-			assertThat(workFlowDefinition.getWorks().get(0).getName()).isEqualTo("failedWithExceptionWorkFlowTask");
-			assertThat(workFlowDefinition.getWorks().get(0).getWorkType())
-					.isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
-			assertThat(workFlowDefinition.getWorks().get(0).getWorks()).isNullOrEmpty();
-			assertThat(workFlowDefinition.getWorks().get(0).getProcessingType()).isNull();
-			assertThat(workFlowDefinition.getWorks().get(0).getParameters()).isNotNull();
+			Optional<WorkDefinitionResponseDTO> firstWork = workFlowDefinition.getWorks().stream().findFirst();
+			assertTrue(firstWork.isPresent());
+			assertThat(firstWork.get().getName()).isEqualTo("failedWithExceptionWorkFlowTask");
+			assertThat(firstWork.get().getWorkType()).isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
+			assertThat(firstWork.get().getWorks()).isNullOrEmpty();
+			assertThat(firstWork.get().getProcessingType()).isNull();
+			assertThat(firstWork.get().getParameters()).isNotNull();
 		};
 	}
 

integration-tests/src/test/java/com/redhat/parodos/flows/negative/SequentialFailedWorkFlowTest.java

@@ -1,5 +1,6 @@
 package com.redhat.parodos.flows.negative;
 
+import java.util.Optional;
 import java.util.function.Consumer;
 
 import com.redhat.parodos.flows.common.WorkFlowTestBuilder;
@@ -21,6 +22,7 @@
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertTrue;
 
 @Slf4j
 public class SequentialFailedWorkFlowTest {
@@ -74,12 +76,13 @@ private static Consumer<WorkFlowDefinitionResponseDTO> getWorkFlowDefinitionResp
 
 			assertThat(workFlowDefinition.getWorks()).isNotNull();
 			assertThat(workFlowDefinition.getWorks()).hasSize(1);
-			assertThat(workFlowDefinition.getWorks().get(0).getName()).isEqualTo("failedWorkFlowTask");
-			assertThat(workFlowDefinition.getWorks().get(0).getWorkType())
-					.isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
-			assertThat(workFlowDefinition.getWorks().get(0).getWorks()).isNullOrEmpty();
-			assertThat(workFlowDefinition.getWorks().get(0).getProcessingType()).isNull();
-			assertThat(workFlowDefinition.getWorks().get(0).getParameters()).isNotNull();
+			Optional<WorkDefinitionResponseDTO> firstWork = workFlowDefinition.getWorks().stream().findFirst();
+			assertTrue(firstWork.isPresent());
+			assertThat(firstWork.get().getName()).isEqualTo("failedWorkFlowTask");
+			assertThat(firstWork.get().getWorkType()).isEqualTo(WorkDefinitionResponseDTO.WorkTypeEnum.TASK);
+			assertThat(firstWork.get().getWorks()).isNullOrEmpty();
+			assertThat(firstWork.get().getProcessingType()).isNull();
+			assertThat(firstWork.get().getParameters()).isNotNull();
 		};
 	}
 

parodos-model-api/src/main/java/com/redhat/parodos/workflow/enums/WorkType.java

@@ -24,6 +24,6 @@
  */
 public enum WorkType {
 
-	TASK, WORKFLOW
+	TASK, WORKFLOW, CHECKER
 
 }

workflow-service-sdk/README.md

@@ -163,10 +163,11 @@ Class | Method | HTTP request | Description
  - [WorkStatusResponseDTO](docs/WorkStatusResponseDTO.md)
 
 
+<a id="documentation-for-authorization"></a>
 ## Documentation for Authorization
 
-All endpoints do not require authorization.
-Authentication schemes defined for the API:
+Endpoints do not require authorization.
+
 
 ## Recommendation
 

workflow-service-sdk/api/openapi.yaml

@@ -1133,11 +1133,13 @@ components:
           enum:
           - TASK
           - WORKFLOW
+          - CHECKER
           type: string
         works:
           items:
             $ref: '#/components/schemas/WorkDefinitionResponseDTO'
           type: array
+          uniqueItems: true
       type: object
     WorkFlowCheckerTaskRequestDTO:
       example:
@@ -1248,6 +1250,7 @@ components:
       type: object
     WorkFlowDefinitionResponseDTO:
       example:
+        cronExpression: cronExpression
         processingType: SEQUENTIAL
         rollbackWorkflow: rollbackWorkflow
         works:
@@ -1296,6 +1299,8 @@ components:
         createDate:
           format: date-time
           type: string
+        cronExpression:
+          type: string
         id:
           format: uuid
           type: string
@@ -1331,6 +1336,7 @@ components:
           items:
             $ref: '#/components/schemas/WorkDefinitionResponseDTO'
           type: array
+          uniqueItems: true
       type: object
     WorkFlowExecutionResponseDTO:
       example:
@@ -1670,6 +1676,7 @@ components:
           enum:
           - TASK
           - WORKFLOW
+          - CHECKER
           type: string
         workName:
           type: string
@@ -1703,6 +1710,7 @@ components:
           enum:
           - TASK
           - WORKFLOW
+          - CHECKER
           type: string
         works:
           items:

workflow-service-sdk/docs/LoginApi.md

@@ -7,7 +7,7 @@ All URIs are relative to *http://localhost:8080*
 | [**login**](LoginApi.md#login) | **GET** /api/v1/login | Login |
 
 
-<a name="login"></a>
+<a id="login"></a>
 # **login**
 > login()
 

workflow-service-sdk/docs/ProjectAccessApi.md

@@ -8,7 +8,7 @@ All URIs are relative to *http://localhost:8080*
 | [**updateProjectAccessStatus**](ProjectAccessApi.md#updateProjectAccessStatus) | **POST** /api/v1/projects/access/{id}/status | Update status of a specified project access request |
 
 
-<a name="getProjectAccessStatus"></a>
+<a id="getProjectAccessStatus"></a>
 # **getProjectAccessStatus**
 > AccessStatusResponseDTO getProjectAccessStatus(id)
 
@@ -72,7 +72,7 @@ No authorization required
 | **404** | Not found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="updateProjectAccessStatus"></a>
+<a id="updateProjectAccessStatus"></a>
 # **updateProjectAccessStatus**
 > updateProjectAccessStatus(id, accessStatusRequestDTO)
 

workflow-service-sdk/docs/ProjectApi.md

@@ -12,7 +12,7 @@ All URIs are relative to *http://localhost:8080*
 | [**updateUserRolesToProject**](ProjectApi.md#updateUserRolesToProject) | **POST** /api/v1/projects/{id}/users | Update user roles in project |
 
 
-<a name="createAccessRequestToProject"></a>
+<a id="createAccessRequestToProject"></a>
 # **createAccessRequestToProject**
 > AccessResponseDTO createAccessRequestToProject(id, accessRequestDTO)
 
@@ -78,7 +78,7 @@ No authorization required
 | **404** | Not found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="createProject"></a>
+<a id="createProject"></a>
 # **createProject**
 > ProjectResponseDTO createProject(projectRequestDTO)
 
@@ -142,7 +142,7 @@ No authorization required
 | **404** | Not Found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="getProjectById"></a>
+<a id="getProjectById"></a>
 # **getProjectById**
 > ProjectResponseDTO getProjectById(id)
 
@@ -207,7 +207,7 @@ No authorization required
 | **404** | Not found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="getProjects"></a>
+<a id="getProjects"></a>
 # **getProjects**
 > List&lt;ProjectResponseDTO&gt; getProjects()
 
@@ -269,7 +269,7 @@ No authorization required
 | **404** | Not Found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="removeUsersFromProject"></a>
+<a id="removeUsersFromProject"></a>
 # **removeUsersFromProject**
 > ProjectUserRoleResponseDTO removeUsersFromProject(id, requestBody)
 
@@ -335,7 +335,7 @@ No authorization required
 | **404** | Not found |  -  |
 | **409** | Conflict |  -  |
 
-<a name="updateUserRolesToProject"></a>
+<a id="updateUserRolesToProject"></a>
 # **updateUserRolesToProject**
 > ProjectUserRoleResponseDTO updateUserRolesToProject(id, userRoleRequestDTO)
 

workflow-service-sdk/docs/WorkDefinitionResponseDTO.md

@@ -14,7 +14,7 @@
 |**parameters** | **Map<String, Map<String, Object>>** |  |  [optional] |
 |**processingType** | [**ProcessingTypeEnum**](#ProcessingTypeEnum) |  |  [optional] |
 |**workType** | [**WorkTypeEnum**](#WorkTypeEnum) |  |  [optional] |
-|**works** | [**List<WorkDefinitionResponseDTO>**](WorkDefinitionResponseDTO.md) |  |  [optional] |
+|**works** | [**Set<WorkDefinitionResponseDTO>**](WorkDefinitionResponseDTO.md) |  |  [optional] |
 
 
 
@@ -45,6 +45,7 @@
 |---- | -----|
 | TASK | "TASK" |
 | WORKFLOW | "WORKFLOW" |
+| CHECKER | "CHECKER" |
 
 
 

workflow-service-sdk/docs/WorkFlowDefinitionResponseDTO.md

@@ -9,6 +9,7 @@
 |------------ | ------------- | ------------- | -------------|
 |**author** | **String** |  |  [optional] |
 |**createDate** | **Date** |  |  [optional] |
+|**cronExpression** | **String** |  |  [optional] |
 |**id** | **UUID** |  |  [optional] |
 |**modifyDate** | **Date** |  |  [optional] |
 |**name** | **String** |  |  [optional] |
@@ -17,7 +18,7 @@
 |**properties** | [**WorkFlowPropertiesDefinitionDTO**](WorkFlowPropertiesDefinitionDTO.md) |  |  [optional] |
 |**rollbackWorkflow** | **String** |  |  [optional] |
 |**type** | [**TypeEnum**](#TypeEnum) |  |  [optional] |
-|**works** | [**List<WorkDefinitionResponseDTO>**](WorkDefinitionResponseDTO.md) |  |  [optional] |
+|**works** | [**Set<WorkDefinitionResponseDTO>**](WorkDefinitionResponseDTO.md) |  |  [optional] |
 
 
 

workflow-service-sdk/docs/WorkRequestDTO.md

@@ -19,6 +19,7 @@
 |---- | -----|
 | TASK | "TASK" |
 | WORKFLOW | "WORKFLOW" |
+| CHECKER | "CHECKER" |
 
 
 

workflow-service-sdk/docs/WorkStatusResponseDTO.md

@@ -34,6 +34,7 @@
 |---- | -----|
 | TASK | "TASK" |
 | WORKFLOW | "WORKFLOW" |
+| CHECKER | "CHECKER" |