X-Git-Url: http://git.nikiroo.be/?a=blobdiff_plain;f=src%2Fbe%2Fnikiroo%2Futils%2Fserial%2Fserver%2FServerBridge.java;h=0b734c6bbd6ca105b852406b2a97ec64ee71b589;hb=aa9c3626f962e59ac7460d8ac6645a6e30a4d248;hp=4aa9c41fab5b7cbf9bd934008b4002f5fc366f75;hpb=d827da2aba3d8b0e4a76426b5a76a9045ca584b2;p=nikiroo-utils.git diff --git a/src/be/nikiroo/utils/serial/server/ServerBridge.java b/src/be/nikiroo/utils/serial/server/ServerBridge.java deleted file mode 100644 index 4aa9c41..0000000 --- a/src/be/nikiroo/utils/serial/server/ServerBridge.java +++ /dev/null @@ -1,322 +0,0 @@ -package be.nikiroo.utils.serial.server; - -import java.io.IOException; -import java.lang.reflect.Array; -import java.net.Socket; - -import be.nikiroo.utils.StringUtils; -import be.nikiroo.utils.TraceHandler; -import be.nikiroo.utils.Version; -import be.nikiroo.utils.serial.Importer; - -/** - * This class implements a simple server that can bridge two other - * {@link Server}s. - *

- * It can, of course, inspect the data that goes through it (by default, it - * prints traces of the data). - *

- * Note: this {@link ServerBridge} has to be discarded after use (cannot be - * started twice). - * - * @author niki - */ -public class ServerBridge extends Server { - private final String forwardToHost; - private final int forwardToPort; - private final boolean forwardToSsl; - - /** - * Create a new server that will start listening on the network when - * {@link ServerBridge#start()} is called. - * - * @param port - * the port to listen on, or 0 to assign any unallocated port - * found (which can later on be queried via - * {@link ServerBridge#getPort()} - * @param ssl - * use an SSL connection (or not) - * @param forwardToHost - * the host server to forward the calls to - * @param forwardToPort - * the host port to forward the calls to - * @param forwardToSsl - * use an SSL connection for the forward server or not - * - * @throws IOException - * in case of I/O error - */ - public ServerBridge(int port, boolean ssl, String forwardToHost, - int forwardToPort, boolean forwardToSsl) throws IOException { - super(port, ssl); - this.forwardToHost = forwardToHost; - this.forwardToPort = forwardToPort; - this.forwardToSsl = forwardToSsl; - } - - /** - * Create a new server that will start listening on the network when - * {@link ServerBridge#start()} is called. - * - * @param name - * the server name (only used for debug info and traces) - * @param port - * the port to listen on - * @param ssl - * use an SSL connection (or not) - * @param forwardToHost - * the host server to forward the calls to - * @param forwardToPort - * the host port to forward the calls to - * @param forwardToSsl - * use an SSL connection for the forward server or not - * - * @throws IOException - * in case of I/O error - */ - public ServerBridge(String name, int port, boolean ssl, - String forwardToHost, int forwardToPort, boolean forwardToSsl) - throws IOException { - super(name, port, ssl); - this.forwardToHost = forwardToHost; - this.forwardToPort = forwardToPort; - this.forwardToSsl = forwardToSsl; - } - - /** - * The traces handler for this {@link Server}. - *

- * The trace levels are handled as follow: - *

- * - * @param tracer - * the new traces handler - */ - @Override - public void setTraceHandler(TraceHandler tracer) { - super.setTraceHandler(tracer); - } - - @Override - protected ConnectActionServer createConnectActionServer(Socket s) { - return new ConnectActionServerString(s) { - @Override - public void action(final Version clientVersion) throws Exception { - onClientContact(clientVersion); - final ConnectActionServerString bridge = this; - - new ConnectActionClientString(forwardToHost, forwardToPort, - forwardToSsl, clientVersion) { - @Override - public void action(final Version serverVersion) - throws Exception { - onServerContact(serverVersion); - - for (String fromClient = bridge.rec(); fromClient != null; fromClient = bridge - .rec()) { - onRec(clientVersion, fromClient); - String fromServer = send(fromClient); - onSend(serverVersion, fromServer); - bridge.send(fromServer); - } - - getTraceHandler().trace("=== DONE", 1); - getTraceHandler().trace("", 1); - } - - @Override - protected void onError(Exception e) { - ServerBridge.this.onError(e); - } - }.connect(); - } - }; - } - - /** - * This is the method that is called each time a client contact us. - * - * @param clientVersion - * the client version - */ - protected void onClientContact(Version clientVersion) { - getTraceHandler().trace(">>> CLIENT " + clientVersion); - } - - /** - * This is the method that is called each time a client contact us. - * - * @param serverVersion - * the server version - */ - protected void onServerContact(Version serverVersion) { - getTraceHandler().trace("<<< SERVER " + serverVersion); - getTraceHandler().trace(""); - } - - /** - * This is the method that is called each time a client contact us. - * - * @param clientVersion - * the client version - * @param data - * the data sent by the client - */ - protected void onRec(Version clientVersion, String data) { - trace(">>> CLIENT (" + clientVersion + ")", data); - } - - /** - * This is the method that is called each time the forwarded server contact - * us. - * - * @param serverVersion - * the client version - * @param data - * the data sent by the client - */ - protected void onSend(Version serverVersion, String data) { - trace("<<< SERVER (" + serverVersion + ")", data); - } - - /** - * Trace the data with the given prefix. - * - * @param prefix - * the prefix (client, server, version...) - * @param data - * the data to trace - */ - private void trace(String prefix, String data) { - int size = data.length(); - String ssize = size + " byte"; - if (size > 1) { - ssize = size + " bytes"; - if (size >= 1000) { - size = size / 1000; - ssize = size + " kb"; - if (size > 1000) { - size = size / 1000; - ssize = size + " MB"; - } - } - } - - getTraceHandler().trace(prefix + ": " + ssize, 1); - - if (getTraceHandler().getTraceLevel() >= 2) { - try { - if (data.startsWith("ZIP:")) { - data = StringUtils.unzip64(data.substring(4)); - } - - Object obj = new Importer().read(data).getValue(); - if (obj == null) { - getTraceHandler().trace("NULL", 2); - getTraceHandler().trace("NULL", 3); - getTraceHandler().trace("NULL", 4); - } else { - if (obj.getClass().isArray()) { - getTraceHandler().trace( - "(" + obj.getClass() + ") with " - + Array.getLength(obj) + "element(s)", - 3); - } else { - getTraceHandler().trace("(" + obj.getClass() + ")", 2); - } - getTraceHandler().trace("" + obj.toString(), 3); - getTraceHandler().trace(data, 4); - } - } catch (NoSuchMethodException e) { - getTraceHandler().trace("(not an object)", 2); - getTraceHandler().trace(data, 3); - getTraceHandler().trace("", 4); - } catch (NoSuchFieldException e) { - getTraceHandler().trace( - "(incompatible: " + e.getMessage() + ")", 2); - getTraceHandler().trace(data, 3); - getTraceHandler().trace("", 4); - } catch (ClassNotFoundException e) { - getTraceHandler().trace( - "(unknown object: " + e.getMessage() + ")", 2); - getTraceHandler().trace(data, 3); - getTraceHandler().trace("", 4); - } catch (Exception e) { - getTraceHandler().trace( - "(decode error: " + e.getMessage() + ")", 2); - getTraceHandler().trace(data, 3); - getTraceHandler().trace("", 4); - } - - getTraceHandler().trace("", 2); - } - } - - /** - * Start a bridge between 2 servers. - * - * @param args - * an array containing: - * - */ - public static void main(String[] args) { - final TraceHandler tracer = new TraceHandler(true, false, 0); - try { - if (args.length < 6) { - tracer.error("Invalid syntax.\n" - + "Syntax: [name] [port] [ssl] [fhost] [fport] [fssl] ([trace level]) ([max])\n" - + "\tname: the bridge name\n" - + "\tport: the bridge port\n" - + "\tssl: TRUE for an SSL bridge, FALSE for plain text\n" - + "\tfhost: the forward server host\n" - + "\tfport: the forward server port\n" - + "\tfssl: TRUE for an SSL forward server, FALSE for plain text\n" - + "\ttrace level: the optional trace level (default is 1)\n" - + "\tmax: the maximum size after which to truncate data\n"); - return; - } - - int i = 0; - String name = args[i++]; - int port = Integer.parseInt(args[i++]); - boolean ssl = Boolean.parseBoolean(args[i++]); - String fhost = args[i++]; - int fport = Integer.parseInt(args[i++]); - boolean fssl = Boolean.parseBoolean(args[i++]); - - int traceLevel = 1; - if (args.length > 6) { - traceLevel = Integer.parseInt(args[i++]); - } - int maxPrintSize = 1; - if (args.length > 7) { - maxPrintSize = Integer.parseInt(args[i++]); - } - - ServerBridge bridge = new ServerBridge(name, port, ssl, fhost, - fport, fssl); - bridge.setTraceHandler(new TraceHandler(true, true, traceLevel, - maxPrintSize)); - bridge.run(); - } catch (Exception e) { - tracer.error(e); - } - } -}