LegacyFlowManagerService { public Map<String, Object> getFlowMlcpOptionsFromFile(String entityName, String flowName) throws IOException { Path destFolder = hubConfig.getHubProjectDir().resolve(PROJECT_TMP_FOLDER); Path filePath = getMlcpOptionsFilePath(destFolder, entityName, flowName); File file = filePath.toFile(); if(file.exists()) { return new ObjectMapper().readValue(file, Map.class); } Map<String, Object> result = new HashMap<>(); result.put("input_file_path", hubConfig.getHubProject().getProjectDirString()); return result; }  List<FlowModel> getFlows(String entityName, FlowType flowType); LegacyFlow getServerFlow(String entityName, String flowName, FlowType flowType); JobTicket runFlow(LegacyFlow flow, int batchSize, int threadCount, Map<String, Object> options, LegacyFlowStatusListener statusListener); Map<String, Object> getHarmonizeFlowOptionsFromFile(String entityName, String flowName); void saveOrUpdateHarmonizeFlowOptionsToFile(String entityName, String flowName, String harmonizeOptionsFileContent); void saveOrUpdateFlowMlcpOptionsToFile(String entityName, String flowName, String mlcpOptionsFileContent); Map<String, Object> getFlowMlcpOptionsFromFile(String entityName, String flowName); void runMlcp(LegacyFlow flow, JsonNode json, LegacyFlowStatusListener statusListener); LegacyFlowManager getFlowManager();  }
@Test public void getFlowMlcpOptionsFromFile() throws Exception { setEnvConfig(); Map<String, Object> options = fm.getFlowMlcpOptionsFromFile("test-entity", "test-flow"); JSONAssert.assertEquals("{ \"input_file_path\": " + hubConfig.getHubProject().getProjectDirString() + " }", new ObjectMapper().writeValueAsString(options), true); }