From: Niki Roo Date: Mon, 22 Apr 2019 09:15:00 +0000 (+0200) Subject: server: fix traces, auth errors X-Git-Tag: fanfix-3.0.0~74 X-Git-Url: https://git.nikiroo.be/?a=commitdiff_plain;h=49f3dec53ec85b1720dbbfb62a2d495011b66622;p=fanfix.git server: fix traces, auth errors --- diff --git a/libs/nikiroo-utils-4.7.2-dev-sources.jar b/libs/nikiroo-utils-4.7.2-dev-sources.jar index 4b72c09..dd97f47 100644 Binary files a/libs/nikiroo-utils-4.7.2-dev-sources.jar and b/libs/nikiroo-utils-4.7.2-dev-sources.jar differ diff --git a/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java b/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java index b1aebb3..f0d5f7a 100644 --- a/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java +++ b/src/be/nikiroo/fanfix/library/RemoteLibraryServer.java @@ -26,8 +26,7 @@ import be.nikiroo.utils.serial.server.ServerObject; *

* All commands, including PING, will first return a random value to you that * you must hash with your key and return before processing the rest; if the - * value is OK, it will return "true", if not, it will return NULL and stop the - * connection. + * value not correct, the connection will be closed. *

* BTW: this system is by no means secure. It is just slightly * obfuscated, and operate on clear text (because Google decided not to support @@ -102,32 +101,26 @@ public class RemoteLibraryServer extends ServerObject { for (Object arg : args) { trace += arg + " "; } - getTraceHandler().trace(trace); + System.out.println(trace); // Authentication: String random = StringUtils.getMd5Hash(Double.toString(Math.random())); action.send(random); - String answer = ""; - try { - answer += action.rec(); - } catch (NullPointerException e) { - return null; - } + String answer = "" + action.rec(); - if (answer.equals(RemoteLibrary.hashKey(key, random))) { - action.send(true); - } else { - getTraceHandler().trace("Key rejected."); + if (!answer.equals(RemoteLibrary.hashKey(key, random))) { + System.out.println("Key rejected."); + action.close(); return null; } + // Object rep = doRequest(action, command, args); String rec = StringUtils.formatNumber(action.getBytesReceived()) + "b"; String sent = StringUtils.formatNumber(action.getBytesSent()) + "b"; - getTraceHandler().trace( - String.format("[>%s]: (%s sent, %s rec) in %d ms", command, - sent, rec, (new Date().getTime() - start))); + System.out.println(String.format("[>%s]: (%s sent, %s rec) in %d ms", + command, sent, rec, (new Date().getTime() - start))); return rep; } @@ -326,8 +319,7 @@ public class RemoteLibraryServer extends ServerObject { * * @return the {@link Progress} */ - private static Progress createPgForwarder( - final ConnectActionServerObject action) { + private Progress createPgForwarder(final ConnectActionServerObject action) { final Boolean[] isDoneForwarded = new Boolean[] { false }; final Progress pg = new Progress() { @Override @@ -360,7 +352,7 @@ public class RemoteLibraryServer extends ServerObject { action.send(new Integer[] { min, max, relativeProgress }); action.rec(); } catch (Exception e) { - Instance.getTraceHandler().error(e); + getTraceHandler().error(e); } lastTime[0] = new Date().getTime(); @@ -374,14 +366,14 @@ public class RemoteLibraryServer extends ServerObject { } // with 30 seconds timeout - private static void forcePgDoneSent(Progress pg) { + private void forcePgDoneSent(Progress pg) { long start = new Date().getTime(); pg.done(); while (!pg.isDone() && new Date().getTime() - start < 30000) { try { Thread.sleep(100); } catch (InterruptedException e) { - Instance.getTraceHandler().error(e); + getTraceHandler().error(e); } } }