0ct0pu5/fess
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

update test cases

Browse source
This commit is contained in:
Shinsuke Sugaya 2017-08-10 17:11:04 +09:00
parent c14f477866
commit cf48dd366e
2 changed files with 22 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/test/java/org/codelibs/fess/it/ITBase.java
View file

@ -55,6 +55,10 @@ public class ITBase {
given().delete(getEsUrl() + "/.fess_config/access_token/" + DEFAULT_TEST_TOKEN_ID);
}
public static void refresh() {
given().post(getEsUrl() + "/_refresh");
}
public static String getFessUrl() {
return System.getProperty("test.fess.url", DEFAULT_FESS_URL);
}

25
src/test/java/org/codelibs/fess/it/admin/CrawlerLogTests.java
View file

@ -64,12 +64,12 @@ public class CrawlerLogTests extends ITBase {
try {
createWebConfig();
logger.info("WebConfig is created");
Thread.sleep(10000);
refresh();
webConfigId = getWebConfigId();
createJob();
logger.info("Job is created");
Thread.sleep(30000);
refresh();
startJob();
@ -175,11 +175,21 @@ public class CrawlerLogTests extends ITBase {
}
private static void startJob() {
final Map<String, Object> requestBody = new HashMap<>();
final String schedulerId = getSchedulerId();
final Response response = checkMethodBase(requestBody).post("/api/admin/scheduler/" + schedulerId + "/start");
response.then().body("response.status", equalTo(0));
logger.info("Start scheduler \"" + schedulerId + "\"");
for (int i = 0; i < 30; i++) {
final Map<String, Object> requestBody = new HashMap<>();
final String schedulerId = getSchedulerId();
final Response response = checkMethodBase(requestBody).post("/api/admin/scheduler/" + schedulerId + "/start");
if (response.getBody().jsonPath().getInt("response.status") == 0) {
logger.info("Start scheduler \"" + schedulerId + "\"");
return;
}
try {
Thread.sleep(1000L);
} catch (InterruptedException e) {
// ignore
}
}
assertTrue(false, "could not start job.");
}
private static void waitJob() throws InterruptedException {
@ -320,6 +330,7 @@ public class CrawlerLogTests extends ITBase {
requestBody.put("q", "Example Domain");
checkMethodBase(requestBody).delete("/api/admin/searchlist/query").then().body("response.status", equalTo(0));
refresh();
final List<Map<String, Object>> results = getSearchResults();
assertTrue(results.size() == 0);