X-Git-Url: http://git.nikiroo.be/?a=blobdiff_plain;f=src%2Fbe%2Fnikiroo%2Futils%2Ftest%2FSerialTest.java;h=0221e6523ee63219afda9529daddf19b9588a739;hb=edeff2abd7f57e62c478a07c7dc2d138c96f408e;hp=4233a7bde2bd336f875ce1a29cc464e8d487acde;hpb=08a58812f12617289463b00161c98d7c59490bf2;p=nikiroo-utils.git diff --git a/src/be/nikiroo/utils/test/SerialTest.java b/src/be/nikiroo/utils/test/SerialTest.java index 4233a7b..0221e65 100644 --- a/src/be/nikiroo/utils/test/SerialTest.java +++ b/src/be/nikiroo/utils/test/SerialTest.java @@ -1,238 +1,21 @@ package be.nikiroo.utils.test; -import be.nikiroo.utils.Version; -import be.nikiroo.utils.serial.ConnectActionClient; -import be.nikiroo.utils.serial.ConnectActionServer; +import java.net.URL; + import be.nikiroo.utils.serial.Exporter; import be.nikiroo.utils.serial.Importer; -import be.nikiroo.utils.serial.Server; class SerialTest extends TestLauncher { - @SuppressWarnings("unused") - private void not_used() { - // TODO: test Server ; but this will at least help dependency checking - try { - Server server = new Server(0, false) { - @Override - protected Object onRequest(ConnectActionServer action, - Version clientVersion, Object data) throws Exception { - return null; - } - }; - } catch (Exception e) { - } - } - - private SerialTest() { - super("Serial test", null); - } - - private TestCase[] createServerTestCases(final boolean ssl) { - final String ssls = (ssl ? "(ssl)" : "(plain text)"); - return new TestCase[] { - new TestCase("Client/Server simple connection " + ssls) { - @Override - public void test() throws Exception { - final Object[] rec = new Object[1]; - - Server server = new Server("testy", 0, ssl) { - @Override - protected Object onRequest( - ConnectActionServer action, - Version clientVersion, Object data) - throws Exception { - return null; - } - }; - - assertEquals("A port should have been assigned", true, - server.getPort() > 0); - - server.start(); - - try { - new ConnectActionClient(null, server.getPort(), ssl) { - @Override - public void action(Version serverVersion) - throws Exception { - rec[0] = true; - } - }.connect(); - } finally { - server.stop(); - } - - assertNotNull("The client action was not run", rec[0]); - assertEquals(true, (boolean) ((Boolean) rec[0])); - } - }, // - new TestCase("Client/Server simple exchange " + ssls) { - final Object[] rec = new Object[3]; - - @Override - public void test() throws Exception { - Server server = new Server("testy", 0, ssl) { - @Override - protected Object onRequest( - ConnectActionServer action, - Version clientVersion, Object data) - throws Exception { - rec[0] = data; - return "pong"; - } - - @Override - protected void onError(Exception e) { - super.onError(e); - rec[2] = e; - } - }; - - assertEquals("A port should have been assigned", true, - server.getPort() > 0); - - server.start(); - - try { - new ConnectActionClient(null, server.getPort(), ssl) { - @Override - public void action(Version serverVersion) - throws Exception { - rec[1] = send("ping"); - } - }.connect(); - } finally { - server.stop(); - } - - if (rec[2] != null) { - fail("An exception was thrown: " - + ((Exception) rec[2]).getMessage()); - } - - assertEquals("ping", rec[0]); - assertEquals("pong", rec[1]); - } - }, // - new TestCase("Client/Server multiple exchanges " + ssls) { - final Object[] sent = new Object[3]; - final Object[] recd = new Object[3]; - final Exception[] err = new Exception[1]; - - @Override - public void test() throws Exception { - Server server = new Server("testy", 0, ssl) { - @Override - protected Object onRequest( - ConnectActionServer action, - Version clientVersion, Object data) - throws Exception { - sent[0] = data; - action.send("pong"); - sent[1] = action.flush(); - return "pong2"; - } - - @Override - protected void onError(Exception e) { - super.onError(e); - err[0] = e; - } - }; - - server.start(); - - try { - new ConnectActionClient(null, server.getPort(), ssl) { - @Override - public void action(Version serverVersion) - throws Exception { - recd[0] = send("ping"); - recd[1] = send("ping2"); - } - }.connect(); - } finally { - server.stop(); - } - - if (err[0] != null) { - fail("An exception was thrown: " - + err[0].getMessage()); - } - - assertEquals("ping", sent[0]); - assertEquals("pong", recd[0]); - assertEquals("ping2", sent[1]); - assertEquals("pong2", recd[1]); - } - }, // - new TestCase("Client/Server multiple call from client " + ssls) { - final Object[] sent = new Object[3]; - final Object[] recd = new Object[3]; - final Exception[] err = new Exception[1]; - - @Override - public void test() throws Exception { - Server server = new Server("testy", 0, ssl) { - @Override - protected Object onRequest( - ConnectActionServer action, - Version clientVersion, Object data) - throws Exception { - sent[(Integer) data] = data; - return ((Integer) data) * 2; - } - - @Override - protected void onError(Exception e) { - super.onError(e); - err[0] = e; - } - }; - - server.start(); - - try { - new ConnectActionClient(null, server.getPort(), ssl) { - @Override - public void action(Version serverVersion) - throws Exception { - for (int i = 0; i < 3; i++) { - recd[i] = send(i); - } - } - }.connect(); - } finally { - server.stop(); - } - - if (err[0] != null) { - fail("An exception was thrown: " - + err[0].getMessage()); - } - - assertEquals(0, sent[0]); - assertEquals(0, recd[0]); - assertEquals(1, sent[1]); - assertEquals(2, recd[1]); - assertEquals(2, sent[2]); - assertEquals(4, recd[2]); - } - }, // - }; + /** + * Required for Import/Export of objects. + */ + public SerialTest() { + this(null); } public SerialTest(String[] args) { super("Serial test", args); - for (TestCase test : createServerTestCases(false)) { - addTest(test); - } - - for (TestCase test : createServerTestCases(true)) { - addTest(test); - } - addTest(new TestCase("Simple class Import/Export") { @Override public void test() throws Exception { @@ -247,6 +30,102 @@ class SerialTest extends TestLauncher { } }); + addTest(new TestCase() { + @SuppressWarnings("unused") + private TestCase me = setName("Anonymous inner class"); + + @Override + public void test() throws Exception { + Data data = new Data() { + }; + + String encoded = new Exporter().append(data).toString(false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata) + .toString(false); + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + } + }); + + addTest(new TestCase() { + @SuppressWarnings("unused") + private TestCase me = setName("Array of anonymous inner classes"); + + @Override + public void test() throws Exception { + Data[] data = new Data[] { new Data() { + } }; + + String encoded = new Exporter().append(data).toString(false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata) + .toString(false); + + // Comparing the 2 strings won't be useful, because the @REFs + // will be ZIP-encoded; so we parse and re-encode the object + encoded = new Exporter().append(data[0]).toString(false); + try { + reencoded = new Exporter().append(((Data[]) redata)[0]) + .toString(false); + } catch (Exception e) { + fail("Cannot cast the returned data into its original object", + e); + } + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + } + }); + + addTest(new TestCase("URL Import/Export") { + @Override + public void test() throws Exception { + URL data = new URL("https://fanfan.be/"); + String encoded = new Exporter().append(data).toString(false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata) + .toString(false); + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + } + }); + + addTest(new TestCase("URL-String Import/Export") { + @Override + public void test() throws Exception { + String data = new URL("https://fanfan.be/").toString(); + String encoded = new Exporter().append(data).toString(false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata) + .toString(false); + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + assertEquals(data, redata); + } + }); + + addTest(new TestCase("URL/URL-String arrays Import/Export") { + @Override + public void test() throws Exception { + final String url = "https://fanfan.be/"; + + Object[] data = new Object[] { new URL(url), url }; + String encoded = new Exporter().append(data).toString(false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata) + .toString(false); + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + assertEquals(data[0], ((Object[]) redata)[0]); + assertEquals(data[1], ((Object[]) redata)[1]); + } + }); + addTest(new TestCase("Import/Export with nested objects") { @Override public void test() throws Exception {