X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=bundles%2Forg.simantics.history.rest%2Fsrc%2Forg%2Fsimantics%2Fhistory%2Frest%2FHistoryRestServer.java;fp=bundles%2Forg.simantics.history.rest%2Fsrc%2Forg%2Fsimantics%2Fhistory%2Frest%2FHistoryRestServer.java;h=00b4a1dc73f8fba826d8a5dc001b67388f431e2b;hb=321f52f3c951a801d79b6c6a01967bc570845e22;hp=0000000000000000000000000000000000000000;hpb=cd608739ac877bffcb204d420f84331a235910cf;p=simantics%2Fplatform.git

diff --git a/bundles/org.simantics.history.rest/src/org/simantics/history/rest/HistoryRestServer.java b/bundles/org.simantics.history.rest/src/org/simantics/history/rest/HistoryRestServer.java
new file mode 100644
index 000000000..00b4a1dc7
--- /dev/null
+++ b/bundles/org.simantics.history.rest/src/org/simantics/history/rest/HistoryRestServer.java
@@ -0,0 +1,137 @@
+package org.simantics.history.rest;
+
+import java.util.EnumSet;
+import java.util.concurrent.Semaphore;
+
+import javax.servlet.DispatcherType;
+
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.ServerConnector;
+import org.eclipse.jetty.servlet.FilterHolder;
+import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.servlet.ServletHolder;
+import org.glassfish.jersey.jackson.JacksonFeature;
+import org.glassfish.jersey.server.ResourceConfig;
+import org.glassfish.jersey.servlet.ServletContainer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class HistoryRestServer {
+private static final Logger LOGGER = LoggerFactory.getLogger(HistoryRestServer.class);
+    
+    private static HistoryRestServer INSTANCE = null;
+    private static Server server;
+    private static ServiceServerThread serverThread;
+    
+    private static String allowOriginUrl = null; 
+    
+    private static String address = null;
+    
+    private HistoryRestServer(int port) {
+    	 ResourceConfig config = new ResourceConfig();
+         // JSON serialization/deserialization
+         config.register(JacksonFeature.class);
+         // Actual API
+         config.register(HistoryRestApi.class);
+         
+         ServletHolder holder = new ServletHolder(new ServletContainer(config));
+         
+         server = new Server();
+         ServerConnector connector = new ServerConnector(server);
+         connector.setPort(port);
+         
+         server.setConnectors(new Connector[] { connector });
+         
+         ServletContextHandler context = new ServletContextHandler(server, "/", ServletContextHandler.SESSIONS);
+         context.addServlet(holder, "/*");
+         
+         if (allowOriginUrl != null){
+ 	        org.eclipse.jetty.servlets.CrossOriginFilter cfilter = new org.eclipse.jetty.servlets.CrossOriginFilter();
+ 	        FilterHolder filterHolder = new FilterHolder(cfilter);
+ 	        filterHolder.setInitParameter(org.eclipse.jetty.servlets.CrossOriginFilter.ACCESS_CONTROL_ALLOW_ORIGIN_HEADER, allowOriginUrl);
+ 	        context.addFilter(filterHolder, "/*", EnumSet.allOf(DispatcherType.class));
+         }
+    }
+    
+    
+    private static class ServiceServerThread extends Thread {
+
+    	Semaphore s;
+        @Override
+        public void run() {
+            try {
+                server.start();
+                address = server.getURI().toString()+"history/";
+                if (s != null)
+                	s.release();
+                server.join();
+            } catch (Exception e) {
+                LOGGER.error("Could not start server ", e);
+            }
+        }
+        
+        public void startAndWait() {
+        	s = new Semaphore(0);
+        	this.start();
+        	try {
+        		s.acquire();
+        	} catch (InterruptedException e) {};
+        }
+    }
+    
+    private static synchronized HistoryRestServer getInstance(int port) {
+        try {
+            if (INSTANCE == null) {
+                INSTANCE = new HistoryRestServer(port);
+            }
+        } catch (Exception e) {
+            LOGGER.error("Could not initialize SCL REST server", e);
+        }
+        return INSTANCE;
+    }
+    
+    public static HistoryRestServer getRunningInstance() {
+    	return INSTANCE;
+    }
+    
+    public static void setAllowOrigin(String url) {
+    	allowOriginUrl = url;
+    }
+
+    public static synchronized void startAsync(int port) throws Exception {
+        // Ensure that an instance is created
+        getInstance(port);
+        if (serverThread == null && server != null) {
+            serverThread = new ServiceServerThread();
+            serverThread.start();
+        }
+    }
+    
+    public static synchronized void start(int port) throws Exception {
+        // Ensure that an instance is created
+        getInstance(port);
+        if (serverThread == null && server != null) {
+            serverThread = new ServiceServerThread();
+            serverThread.startAndWait();
+        }
+    }
+    
+    public static synchronized void stop() throws Exception {
+        if (server != null)
+            server.stop();
+        serverThread = null;
+        INSTANCE = null;
+        address = null;
+        
+    }
+    
+    public static synchronized boolean running() {
+    	return INSTANCE != null;
+    }
+    
+    public static synchronized String address() {
+    	return address;
+    }
+
+}