X-Git-Url: http://git.nikiroo.be/?p=nikiroo-utils.git;a=blobdiff_plain;f=src%2Fbe%2Fnikiroo%2Futils%2Ftest%2FSerialTest.java;h=fdf599216bfb56522aa87f20efe7ef51c3bd951f;hp=4233a7bde2bd336f875ce1a29cc464e8d487acde;hb=b6d4ace81dc228c4dbb5c5fc218e508cd97df5de;hpb=08a58812f12617289463b00161c98d7c59490bf2 diff --git a/src/be/nikiroo/utils/test/SerialTest.java b/src/be/nikiroo/utils/test/SerialTest.java index 4233a7b..fdf5992 100644 --- a/src/be/nikiroo/utils/test/SerialTest.java +++ b/src/be/nikiroo/utils/test/SerialTest.java @@ -1,249 +1,138 @@ 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 { Data data = new Data(42); - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata).toString( + false, false); + + assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), + reencoded.replaceAll("@[0-9]*", "@REF")); + } + }); + + addTest(new TestCase() { + @SuppressWarnings("unused") + private TestCase me = setName("Anonymous inner class"); + + @Override + public void test() throws Exception { + Data data = new Data() { + @SuppressWarnings("unused") + int value = 42; + }; + + String encoded = new Exporter().append(data).toString(false, + false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata).toString( + false, 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() { + @SuppressWarnings("unused") + int value = 42; + } }; + + String encoded = new Exporter().append(data).toString(false, + false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata).toString( + false, 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, false); + try { + reencoded = new Exporter().append(((Data[]) redata)[0]) + .toString(false, 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, + false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata).toString( + false, 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, + false); + Object redata = new Importer().read(encoded).getValue(); + String reencoded = new Exporter().append(redata).toString( + false, 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, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); + assertEquals(data[0], ((Object[]) redata)[0]); + assertEquals(data[1], ((Object[]) redata)[1]); } }); @@ -251,10 +140,11 @@ class SerialTest extends TestLauncher { @Override public void test() throws Exception { Data data = new DataObject(new Data(21)); - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); @@ -268,10 +158,11 @@ class SerialTest extends TestLauncher { data.next = new DataLoop("level 2"); data.next.next = data; - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); @@ -282,10 +173,11 @@ class SerialTest extends TestLauncher { @Override public void test() throws Exception { Object data = new DataArray();// new String[] { "un", "deux" }; - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); @@ -296,10 +188,11 @@ class SerialTest extends TestLauncher { @Override public void test() throws Exception { Object data = new String[] { "un", "deux" }; - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); @@ -310,22 +203,80 @@ class SerialTest extends TestLauncher { @Override public void test() throws Exception { Object data = EnumToSend.FANFAN; - String encoded = new Exporter().append(data).toString(false); + String encoded = new Exporter().append(data).toString(false, + false); Object redata = new Importer().read(encoded).getValue(); - String reencoded = new Exporter().append(redata) - .toString(false); + String reencoded = new Exporter().append(redata).toString( + false, false); assertEquals(encoded.replaceAll("@[0-9]*", "@REF"), reencoded.replaceAll("@[0-9]*", "@REF")); } }); + + addTest(new TestCase("B64 and ZIP String test") { + @Override + public void test() throws Exception { + Object data = "Fanfan la tulipe"; + String encoded = new Exporter().append(data).toString(true, + false); + String redata = (String) new Importer().read(encoded) + .getValue(); + + assertEquals("Items not identical after B64", data, redata); + + encoded = new Exporter().append(data).toString(true, true); + redata = (String) new Importer().read(encoded).getValue(); + + assertEquals("Items not identical after ZIP", data, redata); + } + }); + + addTest(new TestCase("B64 and ZIP Data test") { + @Override + public void test() throws Exception { + Object data = new Data(55); + String encoded = new Exporter().append(data).toString(true, + false); + Data redata = (Data) new Importer().read(encoded).getValue(); + + assertEquals("Items not identical after B64", data, redata); + + encoded = new Exporter().append(data).toString(true, true); + redata = (Data) new Importer().read(encoded).getValue(); + + assertEquals("Items not identical after ZIP", data, redata); + } + }); + + addTest(new TestCase("B64 and ZIP 70000 chars test") { + @Override + public void test() throws Exception { + StringBuilder builder = new StringBuilder(); + for (int i = 0; i < 7000; i++) { + builder.append("0123456789"); + } + + Object data = builder.toString(); + String encoded = new Exporter().append(data).toString(true, + false); + String redata = (String) new Importer().read(encoded) + .getValue(); + + assertEquals("Items not identical after B64", data, redata); + + encoded = new Exporter().append(data).toString(true, true); + redata = (String) new Importer().read(encoded).getValue(); + + assertEquals("Items not identical after ZIP", data, redata); + } + }); } class DataArray { public String[] data = new String[] { "un", "deux" }; } - @SuppressWarnings("unused") class Data { private int value; @@ -335,6 +286,21 @@ class SerialTest extends TestLauncher { public Data(int value) { this.value = value; } + + @Override + public boolean equals(Object obj) { + if (obj instanceof Data) { + Data other = (Data) obj; + return other.value == this.value; + } + + return false; + } + + @Override + public int hashCode() { + return new Integer(value).hashCode(); + } } @SuppressWarnings("unused")