Skip to content
This repository has been archived by the owner on Jul 23, 2024. It is now read-only.

Commit

Permalink
Reformat files
Browse files Browse the repository at this point in the history 
Signed-off-by: Gloria Ciavarrini <gciavarrini@redhat.com>
  • Loading branch information
@gciavarrini
gciavarrini committed Apr 12, 2023
1 parent b909c20 commit d727ecb
Show file tree
Hide file tree
Showing 3 changed files with 212 additions and 201 deletions.
226 changes: 114 additions & 112 deletions workflow-examples/src/test/java/com/redhat/parodos/examples/integration/SimpleWorkFlow.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -41,116 +41,118 @@
@Slf4j
public class SimpleWorkFlow {

private static final String projectName = "project-1";

private static final String projectDescription = "an example project";
private ApiClient apiClient;

@Before
public void setUp() throws IOException {
apiClient = Configuration.getDefaultApiClient();
apiClient.addDefaultHeader(HttpHeaders.AUTHORIZATION, "Basic " + CredUtils.getBase64Creds("test", "test"));

}

@Test
public void runSimpleWorkFlow() throws ApiException, InterruptedException {
log.info("Running simple flow");

ProjectApi projectApi = new ProjectApi(apiClient);

ExamplesUtils.waitProjectStart(projectApi);
log.info("Project is ✔️ on {}", apiClient.getBasePath());

ProjectResponseDTO testProject;

// RETRIEVE ALL PROJECTS AVAILABLE
log.info("Get all available projects");
List<ProjectResponseDTO> projects = projectApi.getProjects();

// CHECK IF testProject ALREADY EXISTS
testProject = getProjectByNameAndDescription(projects, projectName, projectDescription);

// CREATE PROJECT "Test Project Name" IF NOT EXISTS
if (testProject == null) {
log.info("There are no projects. Creating project {}", projectName);
// DEFINE A TEST PROJECT REQUEST
ProjectRequestDTO projectRequestDTO = new ProjectRequestDTO();
projectRequestDTO.setName(projectName);
projectRequestDTO.setDescription(projectDescription);

ProjectResponseDTO projectResponseDTO = projectApi.createProject(projectRequestDTO);
assertNotNull(projectResponseDTO);
assertEquals(projectName, projectResponseDTO.getName());
assertEquals(projectDescription, projectResponseDTO.getDescription());
log.info("Project {} successfully created", projectName);
}

// ASSERT PROJECT "testProject" IS PRESENT
projects = projectApi.getProjects();
log.debug("PROJECTS: {}", projects);
assertTrue(projects.size() > 0);
testProject = getProjectByNameAndDescription(projects, projectName, projectDescription);
assertNotNull(testProject);

// GET simpleSequentialWorkFlow DEFINITIONS
WorkflowDefinitionApi workflowDefinitionApi = new WorkflowDefinitionApi();
List<WorkFlowDefinitionResponseDTO> simpleSequentialWorkFlowDefinitions = workflowDefinitionApi
.getWorkFlowDefinitions("simpleSequentialWorkFlow" + WorkFlowConstants.INFRASTRUCTURE_WORKFLOW);
assertEquals(1, simpleSequentialWorkFlowDefinitions.size());

// GET WORKFLOW DEFINITION BY Id
WorkFlowDefinitionResponseDTO simpleSequentialWorkFlowDefinition = workflowDefinitionApi
.getWorkFlowDefinitionById(simpleSequentialWorkFlowDefinitions.get(0).getId().toString());

assertNotNull(simpleSequentialWorkFlowDefinition.getId());
assertEquals("simpleSequentialWorkFlow" + WorkFlowConstants.INFRASTRUCTURE_WORKFLOW,
simpleSequentialWorkFlowDefinition.getName());
assertEquals(WorkFlowProcessingType.SEQUENTIAL.toString(),
simpleSequentialWorkFlowDefinition.getProcessingType());
assertEquals(WorkFlowType.INFRASTRUCTURE.toString(), simpleSequentialWorkFlowDefinition.getType());

assertNotNull(simpleSequentialWorkFlowDefinition.getWorks());
assertTrue(simpleSequentialWorkFlowDefinition.getWorks().size() == 2);
assertEquals("restCallTask", simpleSequentialWorkFlowDefinition.getWorks().get(0).getName());
assertEquals(WorkType.TASK.toString(), simpleSequentialWorkFlowDefinition.getWorks().get(0).getWorkType());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getWorks());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getProcessingType());
assertNotNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getParameters());

assertEquals("loggingTask", simpleSequentialWorkFlowDefinition.getWorks().get(1).getName());
assertEquals(WorkType.TASK.toString(), simpleSequentialWorkFlowDefinition.getWorks().get(1).getWorkType());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getWorks());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getProcessingType());
assertNotNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getParameters());

// Define WorkRequests
WorkRequestDTO work1 = new WorkRequestDTO();
work1.setWorkName("restCallTask");
work1.setArguments(Arrays.asList(new ArgumentRequestDTO().key("url").value("https://httpbin.org/post"),
new ArgumentRequestDTO().key("payload").value("'Hello!'")));

WorkRequestDTO work2 = new WorkRequestDTO();
work2.setWorkName("loggingTask");
work2.setArguments(Arrays.asList(new ArgumentRequestDTO().key("user-id").value("test-user-id"),
new ArgumentRequestDTO().key("api-server").value("test-api-server")));

// Define WorkFlowRequest
WorkFlowRequestDTO workFlowRequestDTO = new WorkFlowRequestDTO();
workFlowRequestDTO.setProjectId(testProject.getId());
workFlowRequestDTO.setWorkFlowName("simpleSequentialWorkFlow_INFRASTRUCTURE_WORKFLOW");
workFlowRequestDTO.setWorks(Arrays.asList(work1, work2));

WorkflowApi workflowApi = new WorkflowApi();
log.info("******** Running The Simple Sequence Flow ********");
WorkFlowResponseDTO workFlowResponseDTO = workflowApi.execute(workFlowRequestDTO);

assertNotNull(workFlowResponseDTO.getWorkFlowExecutionId());
assertNull(workFlowResponseDTO.getWorkFlowOptions());
assertNotNull(workFlowResponseDTO.getWorkStatus());
assertEquals(WorkStatusEnum.COMPLETED, workFlowResponseDTO.getWorkStatus());

log.info("workflow finished successfully with response: {}", workFlowResponseDTO);
log.info("******** Simple Sequence Flow Completed ********");
}
private static final String projectName = "project-1";

private static final String projectDescription = "an example project";

private ApiClient apiClient;

@Before
public void setUp() throws IOException {
apiClient = Configuration.getDefaultApiClient();
apiClient.addDefaultHeader(HttpHeaders.AUTHORIZATION, "Basic " + CredUtils.getBase64Creds("test", "test"));

}

@Test
public void runSimpleWorkFlow() throws ApiException, InterruptedException {
log.info("Running simple flow");

ProjectApi projectApi = new ProjectApi(apiClient);

ExamplesUtils.waitProjectStart(projectApi);
log.info("Project is ✔️ on {}", apiClient.getBasePath());

ProjectResponseDTO testProject;

// RETRIEVE ALL PROJECTS AVAILABLE
log.info("Get all available projects");
List<ProjectResponseDTO> projects = projectApi.getProjects();

// CHECK IF testProject ALREADY EXISTS
testProject = getProjectByNameAndDescription(projects, projectName, projectDescription);

// CREATE PROJECT "Test Project Name" IF NOT EXISTS
if (testProject == null) {
log.info("There are no projects. Creating project {}", projectName);
// DEFINE A TEST PROJECT REQUEST
ProjectRequestDTO projectRequestDTO = new ProjectRequestDTO();
projectRequestDTO.setName(projectName);
projectRequestDTO.setDescription(projectDescription);

ProjectResponseDTO projectResponseDTO = projectApi.createProject(projectRequestDTO);
assertNotNull(projectResponseDTO);
assertEquals(projectName, projectResponseDTO.getName());
assertEquals(projectDescription, projectResponseDTO.getDescription());
log.info("Project {} successfully created", projectName);
}

// ASSERT PROJECT "testProject" IS PRESENT
projects = projectApi.getProjects();
log.debug("PROJECTS: {}", projects);
assertTrue(projects.size() > 0);
testProject = getProjectByNameAndDescription(projects, projectName, projectDescription);
assertNotNull(testProject);

// GET simpleSequentialWorkFlow DEFINITIONS
WorkflowDefinitionApi workflowDefinitionApi = new WorkflowDefinitionApi();
List<WorkFlowDefinitionResponseDTO> simpleSequentialWorkFlowDefinitions = workflowDefinitionApi
.getWorkFlowDefinitions("simpleSequentialWorkFlow" + WorkFlowConstants.INFRASTRUCTURE_WORKFLOW);
assertEquals(1, simpleSequentialWorkFlowDefinitions.size());

// GET WORKFLOW DEFINITION BY Id
WorkFlowDefinitionResponseDTO simpleSequentialWorkFlowDefinition = workflowDefinitionApi
.getWorkFlowDefinitionById(simpleSequentialWorkFlowDefinitions.get(0).getId().toString());

assertNotNull(simpleSequentialWorkFlowDefinition.getId());
assertEquals("simpleSequentialWorkFlow" + WorkFlowConstants.INFRASTRUCTURE_WORKFLOW,
simpleSequentialWorkFlowDefinition.getName());
assertEquals(WorkFlowProcessingType.SEQUENTIAL.toString(),
simpleSequentialWorkFlowDefinition.getProcessingType());
assertEquals(WorkFlowType.INFRASTRUCTURE.toString(), simpleSequentialWorkFlowDefinition.getType());

assertNotNull(simpleSequentialWorkFlowDefinition.getWorks());
assertTrue(simpleSequentialWorkFlowDefinition.getWorks().size() == 2);
assertEquals("restCallTask", simpleSequentialWorkFlowDefinition.getWorks().get(0).getName());
assertEquals(WorkType.TASK.toString(), simpleSequentialWorkFlowDefinition.getWorks().get(0).getWorkType());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getWorks());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getProcessingType());
assertNotNull(simpleSequentialWorkFlowDefinition.getWorks().get(0).getParameters());

assertEquals("loggingTask", simpleSequentialWorkFlowDefinition.getWorks().get(1).getName());
assertEquals(WorkType.TASK.toString(), simpleSequentialWorkFlowDefinition.getWorks().get(1).getWorkType());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getWorks());
assertNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getProcessingType());
assertNotNull(simpleSequentialWorkFlowDefinition.getWorks().get(1).getParameters());

// Define WorkRequests
WorkRequestDTO work1 = new WorkRequestDTO();
work1.setWorkName("restCallTask");
work1.setArguments(Arrays.asList(new ArgumentRequestDTO().key("url").value("https://httpbin.org/post"),
new ArgumentRequestDTO().key("payload").value("'Hello!'")));

WorkRequestDTO work2 = new WorkRequestDTO();
work2.setWorkName("loggingTask");
work2.setArguments(Arrays.asList(new ArgumentRequestDTO().key("user-id").value("test-user-id"),
new ArgumentRequestDTO().key("api-server").value("test-api-server")));

// Define WorkFlowRequest
WorkFlowRequestDTO workFlowRequestDTO = new WorkFlowRequestDTO();
workFlowRequestDTO.setProjectId(testProject.getId());
workFlowRequestDTO.setWorkFlowName("simpleSequentialWorkFlow_INFRASTRUCTURE_WORKFLOW");
workFlowRequestDTO.setWorks(Arrays.asList(work1, work2));

WorkflowApi workflowApi = new WorkflowApi();
log.info("******** Running The Simple Sequence Flow ********");
WorkFlowResponseDTO workFlowResponseDTO = workflowApi.execute(workFlowRequestDTO);

assertNotNull(workFlowResponseDTO.getWorkFlowExecutionId());
assertNull(workFlowResponseDTO.getWorkFlowOptions());
assertNotNull(workFlowResponseDTO.getWorkStatus());
assertEquals(WorkStatusEnum.COMPLETED, workFlowResponseDTO.getWorkStatus());

log.info("workflow finished successfully with response: {}", workFlowResponseDTO);
log.info("******** Simple Sequence Flow Completed ********");
}

}
Loading

0 comments on commit d727ecb

Please sign in to comment.