import java.net.URL;
-import be.nikiroo.utils.Version;
import be.nikiroo.utils.serial.server.ConnectActionClientObject;
import be.nikiroo.utils.serial.server.ConnectActionClientString;
import be.nikiroo.utils.serial.server.ConnectActionServerObject;
public SerialServerTest(String[] args) {
super("SerialServer test", args);
- for (String key : new String[] { null, "",
- "some real key with a few bytes in it" }) {
+ for (String key : new String[] { null,
+ "some super secret encryption key" }) {
for (boolean bridge : new Boolean[] { false, true }) {
final String skey = (key != null ? "(encrypted)"
: "(plain text)");
super(title + " " + skey + sbridge, args);
- addTest(new TestCase("Simple connection " + skey) {
- @Override
- public void test() throws Exception {
- final String[] rec = new String[1];
-
- ServerString server = new ServerString(this.getName(), 0, key) {
- @Override
- protected String onRequest(
- ConnectActionServerString action,
- Version clientVersion, String data)
- throws Exception {
- return null;
- }
-
- @Override
- protected void onError(Exception e) {
- }
- };
-
- int port = server.getPort();
- assertEquals("A port should have been assigned", true, port > 0);
-
- server.start();
-
- ServerBridge br = null;
- if (bridge) {
- br = new ServerBridge(0, key, "", port, key);
- br.setTraceHandler(null);
-
- port = br.getPort();
- assertEquals(
- "A port should have been assigned to the bridge",
- true, port > 0);
-
- br.start();
- }
-
- try {
- try {
- new ConnectActionClientObject(null, port, key) {
- @Override
- public void action(Version serverVersion)
- throws Exception {
- rec[0] = "ok";
- }
- }.connect();
- } finally {
- server.stop();
- }
- } finally {
- if (br != null) {
- br.stop();
- }
- }
-
- assertNotNull("The client action was not run", rec[0]);
- assertEquals("ok", rec[0]);
- }
- });
+ // addTest(new TestCase("Simple connection " + skey) {
+ // @Override
+ // public void test() throws Exception {
+ // final String[] rec = new String[1];
+ //
+ // ServerString server = new ServerString(this.getName(), 0, key) {
+ // @Override
+ // protected String onRequest(
+ // ConnectActionServerString action, String data)
+ // throws Exception {
+ // return null;
+ // }
+ //
+ // @Override
+ // protected void onError(Exception e) {
+ // }
+ // };
+ //
+ // int port = server.getPort();
+ // assertEquals("A port should have been assigned", true, port > 0);
+ //
+ // server.start();
+ //
+ // ServerBridge br = null;
+ // if (bridge) {
+ // br = new ServerBridge(0, key, "", port, key);
+ // br.setTraceHandler(null);
+ //
+ // port = br.getPort();
+ // assertEquals(
+ // "A port should have been assigned to the bridge",
+ // true, port > 0);
+ //
+ // br.start();
+ // }
+ //
+ // try {
+ // try {
+ // new ConnectActionClientObject(null, port, key) {
+ // @Override
+ // public void action() throws Exception {
+ // rec[0] = "ok";
+ // }
+ // }.connect();
+ // } finally {
+ // server.stop();
+ // }
+ // } finally {
+ // if (br != null) {
+ // br.stop();
+ // }
+ // }
+ //
+ // assertNotNull("The client action was not run", rec[0]);
+ // assertEquals("ok", rec[0]);
+ // }
+ // });
addTest(new TestCase("Simple exchange " + skey) {
final String[] sent = new String[1];
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action,
- Version clientVersion, String data)
+ ConnectActionServerString action, String data)
throws Exception {
sent[0] = data;
return "pong";
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
recd[0] = send("ping");
}
}.connect();
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals("ping", sent[0]);
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action,
- Version clientVersion, String data)
+ ConnectActionServerString action, String data)
throws Exception {
sent[0] = data;
action.send("pong");
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
recd[0] = send("ping");
recd[1] = send("ping2");
}
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals("ping", sent[0]);
ServerString server = new ServerString(this.getName(), 0, key) {
@Override
protected String onRequest(
- ConnectActionServerString action,
- Version clientVersion, String data)
+ ConnectActionServerString action, String data)
throws Exception {
sent[Integer.parseInt(data)] = data;
return "" + (Integer.parseInt(data) * 2);
try {
new ConnectActionClientString(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
for (int i = 0; i < 3; i++) {
recd[i] = send("" + i);
}
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals("0", sent[0]);
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action,
- Version clientVersion, Object data)
+ ConnectActionServerObject action, Object data)
throws Exception {
return null;
}
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
rec[0] = true;
}
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action,
- Version clientVersion, Object data)
+ ConnectActionServerObject action, Object data)
throws Exception {
sent[0] = data;
return "pong";
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
recd[0] = send("ping");
}
}.connect();
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals("ping", sent[0]);
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action,
- Version clientVersion, Object data)
+ ConnectActionServerObject action, Object data)
throws Exception {
sent[0] = data;
action.send("pong");
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
recd[0] = send("ping");
recd[1] = send("ping2");
}
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals("ping", sent[0]);
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action,
- Version clientVersion, Object data)
+ ConnectActionServerObject action, Object data)
throws Exception {
sent[0] = data;
return new Object[] { "ACK" };
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
recd[0] = send(new Object[] {
"key",
new URL(
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
Object[] sento = (Object[]) (sent[0]);
ServerObject server = new ServerObject(this.getName(), 0, key) {
@Override
protected Object onRequest(
- ConnectActionServerObject action,
- Version clientVersion, Object data)
+ ConnectActionServerObject action, Object data)
throws Exception {
sent[(Integer) data] = data;
return ((Integer) data) * 2;
try {
new ConnectActionClientObject(null, port, key) {
@Override
- public void action(Version serverVersion)
- throws Exception {
+ public void action() throws Exception {
for (int i = 0; i < 3; i++) {
recd[i] = send(i);
}
}
if (err[0] != null) {
- fail("An exception was thrown: " + err[0].getMessage());
+ fail("An exception was thrown: " + err[0].getMessage(),
+ err[0]);
}
assertEquals(0, sent[0]);