Added scenarioExecution_id
This commit is contained in:
@@ -10,7 +10,9 @@ import org.springframework.web.bind.annotation.RestController;
|
|||||||
import com.olympus.hermione.dto.ScenarioExecutionInput;
|
import com.olympus.hermione.dto.ScenarioExecutionInput;
|
||||||
import com.olympus.hermione.dto.ScenarioOutput;
|
import com.olympus.hermione.dto.ScenarioOutput;
|
||||||
import com.olympus.hermione.models.Scenario;
|
import com.olympus.hermione.models.Scenario;
|
||||||
|
import com.olympus.hermione.models.ScenarioExecution;
|
||||||
import com.olympus.hermione.repository.ScenarioRepository;
|
import com.olympus.hermione.repository.ScenarioRepository;
|
||||||
|
import com.olympus.hermione.repository.ScenarioExecutionRepository;
|
||||||
import com.olympus.hermione.services.ScenarioExecutionService;
|
import com.olympus.hermione.services.ScenarioExecutionService;
|
||||||
|
|
||||||
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestBody;
|
||||||
@@ -23,6 +25,8 @@ public class ScenarioController {
|
|||||||
@Autowired
|
@Autowired
|
||||||
ScenarioRepository scenarioRepository;
|
ScenarioRepository scenarioRepository;
|
||||||
@Autowired
|
@Autowired
|
||||||
|
ScenarioExecutionRepository scenarioExecutionRepository;
|
||||||
|
@Autowired
|
||||||
ScenarioExecutionService scenarioExecutionService;
|
ScenarioExecutionService scenarioExecutionService;
|
||||||
|
|
||||||
@GetMapping("/scenarios")
|
@GetMapping("/scenarios")
|
||||||
@@ -40,6 +44,10 @@ public class ScenarioController {
|
|||||||
return scenarioExecutionService.executeScenario(scenarioExecutionInput);
|
return scenarioExecutionService.executeScenario(scenarioExecutionInput);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@GetMapping("/scenarios/execute/{id}")
|
||||||
|
public ScenarioExecution getScenarioExecution(@PathVariable String id) {
|
||||||
|
return scenarioExecutionRepository.findById(id).get();
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
package com.olympus.hermione.dto;
|
package com.olympus.hermione.dto;
|
||||||
|
|
||||||
|
import com.olympus.hermione.models.ScenarioExecution;
|
||||||
|
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
|
|
||||||
@@ -7,6 +9,8 @@ import lombok.Setter;
|
|||||||
@Setter
|
@Setter
|
||||||
public class ScenarioOutput {
|
public class ScenarioOutput {
|
||||||
private String stringOutput;
|
private String stringOutput;
|
||||||
|
//private ScenarioExecution scenarioExecution;
|
||||||
|
private String scenarioExecution_id;
|
||||||
private String status;
|
private String status;
|
||||||
private String message;
|
private String message;
|
||||||
}
|
}
|
||||||
@@ -110,12 +110,14 @@ public class ScenarioExecutionService {
|
|||||||
executeScenarioStep(step, scenarioExecution, step.getOrder());
|
executeScenarioStep(step, scenarioExecution, step.getOrder());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
scenarioOutput.setScenarioExecution_id(scenarioExecution.getId());
|
||||||
scenarioOutput.setStringOutput(scenarioExecution.getExecSharedMap().get("scenario_output").toString());
|
scenarioOutput.setStringOutput(scenarioExecution.getExecSharedMap().get("scenario_output").toString());
|
||||||
scenarioOutput.setStatus("OK");
|
scenarioOutput.setStatus("OK");
|
||||||
return scenarioOutput;
|
return scenarioOutput;
|
||||||
|
|
||||||
}else{
|
}else{
|
||||||
logger.error("Scenario not found with id: " + scenarioId);
|
logger.error("Scenario not found with id: " + scenarioId);
|
||||||
|
scenarioOutput.setScenarioExecution_id(null);
|
||||||
scenarioOutput.setStatus("ERROR");
|
scenarioOutput.setStatus("ERROR");
|
||||||
scenarioOutput.setMessage("Scenario not found");
|
scenarioOutput.setMessage("Scenario not found");
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user