nes-proj/regression-tests/12-ipv6-apps/rest_rpl_coap.js

156 lines
4.1 KiB
JavaScript

TIMEOUT(300000);
/* conf */
ADDRESS_ROUTER = "aaaa::212:7401:1:101";
ADDRESS_SERVER = "aaaa::212:7402:2:202";
NR_PINGS = 10;
CMD_PING_PREFIX = "ping6 -c " + NR_PINGS + " -I tun0 ";
CMD_TUNNEL = "make connect-router-cooja";
CMD_WGET_ROUTER = "wget -t 1 -T 10 -O - http:\/\/[" + ADDRESS_ROUTER + "]";
CMD_WGET_SERVER = "wget -t 1 -T 10 -O - http:\/\/[" + ADDRESS_SERVER + "]";
COAP_SAMPLECLIENT_JAR = "/home/user/Californium/ExampleClient.jar";
/* delay */
msg = "";
GENERATE_MSG(5000, "continue");
WAIT_UNTIL(msg.equals("continue"));
/* override simulation speed limit to realtime */
sim.setSpeedLimit(1.0);
/* create tunnel interface */
log.log("create tunnel interface\n");
launcher = new java.lang.ProcessBuilder["(java.lang.String[])"](['sh','-c',CMD_TUNNEL]);
launcher.directory(new java.io.File("../../examples/er-rest-example"));
launcher.redirectErrorStream(true);
tunProcess = launcher.start();
tunRunnable = new Object();
tunRunnable.run = function() {
var stdIn = new java.io.BufferedReader(new java.io.InputStreamReader(tunProcess.getInputStream()));
while ((line = stdIn.readLine()) != null) {
if (line != null && !line.trim().equals("")) {
log.log("TUN> " + line + "\n");
}
}
tunProcess.destroy();
}
new java.lang.Thread(new java.lang.Runnable(tunRunnable)).start();
/* delay */
msg = "";
GENERATE_MSG(5000, "continue");
WAIT_UNTIL(msg.equals("continue"));
/* help function for executing commands */
processOutput = "";
executeAndWait = function(cmd) {
log.log("EXEC>> " + cmd + "\n");
launcher = new java.lang.ProcessBuilder["(java.lang.String[])"](['sh','-c',cmd]);
launcher.redirectErrorStream(true);
process = launcher.start();
runnable = new Object();
runnable.run = function() {
var stdIn = new java.io.BufferedReader(new java.io.InputStreamReader(process.getInputStream()));
while ((line = stdIn.readLine()) != null) {
if (line != null && !line.trim().equals("")) {
log.log("PROCESS> " + line + "\n");
processOutput += line + "\n";
}
}
process.destroy();
}
t = new java.lang.Thread(new java.lang.Runnable(runnable));
t.start();
while (t.isAlive()) {
msg = "";
GENERATE_MSG(1000, "continue");
WAIT_UNTIL(msg.equals("continue"));
}
}
/* PERFORM TESTS */
testSummary = "";
testFailed = false;
/* ping tests */
testname = "ping border router";
log.log(testname + "\n");
testSummary += testname;
processOutput = "";
executeAndWait(CMD_PING_PREFIX + ADDRESS_ROUTER);
if (processOutput.indexOf("64 bytes from") != -1) {
testSummary += ": OK\n";
} else {
testSummary += ": FAILED\n";
testFailed = true;
}
testname = "ping rest router";
log.log(testname + "\n");
testSummary += testname;
processOutput = "";
executeAndWait(CMD_PING_PREFIX + ADDRESS_SERVER);
if (processOutput.indexOf("64 bytes from") != -1) {
testSummary += ": OK\n";
} else {
testSummary += ": FAILED\n";
testFailed = true;
}
/* wget tests */
testname = "wget border router";
log.log(testname + "\n");
testSummary += testname;
processOutput = "";
executeAndWait(CMD_WGET_ROUTER);
if (processOutput.indexOf("<title>ContikiRPL</title>") != -1) {
testSummary += ": OK\n";
} else {
testSummary += ": FAILED\n";
testFailed = true;
}
/* coap tests: uses pre-downloaded dapaulid/JCoAP project's SampleClient.jar */
testname = "coap discovery";
log.log(testname + "\n");
testSummary += testname;
processOutput = "";
executeAndWait("java -jar " + COAP_SAMPLECLIENT_JAR + " DISCOVER coap:\/\/[" + ADDRESS_SERVER + "]");
if (processOutput.indexOf("+[.well-known/core]") != -1) {
testSummary += ": OK\n";
} else {
testSummary += ": FAILED\n";
testFailed = true;
}
testname = "coap get hello";
log.log(testname + "\n");
testSummary += testname;
processOutput = "";
executeAndWait("java -jar " + COAP_SAMPLECLIENT_JAR + " GET coap:\/\/[" + ADDRESS_SERVER + "]/hello");
if (processOutput.indexOf("Hello World!") != -1) {
testSummary += ": OK\n";
} else {
testSummary += ": FAILED\n";
testFailed = true;
}
log.log("\n\nTest finished. Summary:\n");
log.log(testSummary + "\n");
tunProcess.destroy();
if (testFailed) {
log.testFailed();
} else {
log.testOK();
}