X-Git-Url: http://git.nikiroo.be/?p=fanfix.git;a=blobdiff_plain;f=Main.java;h=35365444682489d81adf7b25ed864416d6c47abe;hp=c0dd9e0db608b4b8c4394821d63c783926150251;hb=002972e9de731678035d56304d75a6d9e8233635;hpb=bb0c30accc7248ef6a0c79a75c40a225062cc6a3

diff --git a/Main.java b/Main.java
index c0dd9e0..3536544 100644
--- a/Main.java
+++ b/Main.java
@@ -19,6 +19,8 @@ import be.nikiroo.fanfix.library.CacheLibrary;
 import be.nikiroo.fanfix.library.LocalLibrary;
 import be.nikiroo.fanfix.library.RemoteLibrary;
 import be.nikiroo.fanfix.library.RemoteLibraryServer;
+import be.nikiroo.fanfix.library.WebLibrary;
+import be.nikiroo.fanfix.library.WebLibraryServer;
 import be.nikiroo.fanfix.output.BasicOutput;
 import be.nikiroo.fanfix.output.BasicOutput.OutputType;
 import be.nikiroo.fanfix.reader.BasicReader;
@@ -29,7 +31,6 @@ import be.nikiroo.fanfix.supported.SupportType;
 import be.nikiroo.utils.Progress;
 import be.nikiroo.utils.Version;
 import be.nikiroo.utils.VersionCheck;
-import be.nikiroo.utils.serial.server.ServerObject;
 
 /**
  * Main program entry point.
@@ -79,7 +80,7 @@ public class Main {
 	 * <li>--version: get the version of the program</li>
 	 * <li>--server: start the server mode (see config file for parameters)</li>
 	 * <li>--stop-server: stop the running server on this port if any</li>
-	 * <li>--remote [key] [host] [port]: use a the given remote library</li>
+	 * <li>--remote [key] [host] [port]: use the given remote library</li>
 	 * </ul>
 	 * 
 	 * @param args
@@ -351,7 +352,14 @@ public class Main {
 				} else if (port == null) {
 					port = Integer.parseInt(args[i]);
 
-					BasicLibrary lib = new RemoteLibrary(key, host, port);
+					BasicLibrary lib;
+					if (host.startsWith("http://")
+							|| host.startsWith("https://")) {
+						lib = new WebLibrary(key, host, port);
+					} else {
+						lib = new RemoteLibrary(key, host, port);
+					}
+					
 					lib = new CacheLibrary(
 							Instance.getInstance().getRemoteDir(host), lib,
 							Instance.getInstance().getUiConfig());
@@ -626,15 +634,8 @@ public class Main {
 				}
 				break;
 			case SERVER:
-				key = Instance.getInstance().getConfig().getString(Config.SERVER_KEY);
-				port = Instance.getInstance().getConfig().getInteger(Config.SERVER_PORT);
-				if (port == null) {
-					System.err.println("No port configured in the config file");
-					exitCode = 15;
-					break;
-				}
 				try {
-					startServer(key, port);
+					startServer();
 				} catch (IOException e) {
 					Instance.getInstance().getTraceHandler().error(e);
 				}
@@ -642,10 +643,36 @@ public class Main {
 				break;
 			case STOP_SERVER:
 				// Can be given via "--remote XX XX XX"
-				if (key == null)
-					key = Instance.getInstance().getConfig().getString(Config.SERVER_KEY);
-				if (port == null)
+				if (key == null) {
+					key = Instance.getInstance().getConfig()
+							.getString(Config.SERVER_KEY);
+					
+					// If a subkey in RW mode exists, use it
+					for (String subkey : Instance.getInstance().getConfig()
+							.getList(Config.SERVER_ALLOWED_SUBKEYS,
+									new ArrayList<String>())) {
+						if ((subkey + "|").contains("|rw|")) {
+							key = key + "|" + subkey;
+							break;
+						}
+					}
+				}
+				
+				if (port == null) {
 					port = Instance.getInstance().getConfig().getInteger(Config.SERVER_PORT);
+				}
+				
+				if (host == null) {
+					String mode = Instance.getInstance().getConfig()
+							.getString(Config.SERVER_MODE, "fanfix");
+					if ("http".equals(mode)) {
+						host = "http://localhost";
+					} else if ("https".equals(mode)) {
+						host = "https://localhost";
+					} else if ("fanfix".equals(mode)) {
+						host = "fanfix://localhost";
+					}
+				}
 
 				if (port == null) {
 					System.err.println("No port given nor configured in the config file");
@@ -1037,20 +1064,29 @@ public class Main {
 	/**
 	 * Start a Fanfix server.
 	 * 
-	 * @param key
-	 *            the key taht will be needed to contact the Fanfix server
-	 * @param port
-	 *            the port on which to run
-	 * 
 	 * @throws IOException
 	 *             in case of I/O errors
 	 * @throws SSLException
 	 *             when the key was not accepted
 	 */
-	private void startServer(String key, int port) throws IOException {
-		ServerObject server = new RemoteLibraryServer(key, port);
-		server.setTraceHandler(Instance.getInstance().getTraceHandler());
-		server.run();
+	private void startServer() throws IOException {
+		String mode = Instance.getInstance().getConfig()
+				.getString(Config.SERVER_MODE, "fanfix");
+		if (mode.equals("fanfix")) {
+			RemoteLibraryServer server = new RemoteLibraryServer();
+			server.setTraceHandler(Instance.getInstance().getTraceHandler());
+			server.run();
+		} else if (mode.equals("http")) {
+			WebLibraryServer server = new WebLibraryServer(false);
+			server.setTraceHandler(Instance.getInstance().getTraceHandler());
+			server.run();
+		} else if (mode.equals("https")) {
+			WebLibraryServer server = new WebLibraryServer(true);
+			server.setTraceHandler(Instance.getInstance().getTraceHandler());
+			server.run();
+		} else {
+			throw new IOException("Unknown server mode: " + mode);
+		}
 	}
 
 	/**
@@ -1059,7 +1095,7 @@ public class Main {
 	 * @param key
 	 *            the key to contact the Fanfix server
 	 * @param host
-	 *            the host on which it runs (NULL means localhost)
+	 *            the host on which it runs
 	 * @param port
 	 *            the port on which it runs
 	 *            
@@ -1068,10 +1104,13 @@ public class Main {
 	 * @throws SSLException
 	 *             when the key was not accepted
 	 */
-	private void stopServer(
-			String key, String host, Integer port)
+	private void stopServer(String key, String host, int port)
 			throws IOException, SSLException {
-		new RemoteLibrary(key, host, port).exit();
+		if (host.startsWith("http://") || host.startsWith("https://")) {
+			new WebLibrary(key, host, port).stop();
+		} else {
+			new RemoteLibrary(key, host, port).stop();
+		}
 	}
 
 	/**