X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=osgi%2Fequinox%2Forg.argeo.cms.lib.equinox%2Fsrc%2Forg%2Fargeo%2Fequinox%2Fjetty%2FCmsJettyCustomizer.java;fp=osgi%2Fequinox%2Forg.argeo.cms.lib.equinox%2Fsrc%2Forg%2Fargeo%2Fequinox%2Fjetty%2FCmsJettyCustomizer.java;h=7be23fc0f595017f3147d8fd4fc6bd06eef1b140;hb=40ae72d5e9f2e15ea2d1ac6bbed7f0f2e312cbdc;hp=0000000000000000000000000000000000000000;hpb=eabc24d98b287d3292cd6e5b678bbbd7d22a0f24;p=lgpl%2Fargeo-commons.git

diff --git a/osgi/equinox/org.argeo.cms.lib.equinox/src/org/argeo/equinox/jetty/CmsJettyCustomizer.java b/osgi/equinox/org.argeo.cms.lib.equinox/src/org/argeo/equinox/jetty/CmsJettyCustomizer.java
new file mode 100644
index 000000000..7be23fc0f
--- /dev/null
+++ b/osgi/equinox/org.argeo.cms.lib.equinox/src/org/argeo/equinox/jetty/CmsJettyCustomizer.java
@@ -0,0 +1,65 @@
+package org.argeo.equinox.jetty;
+
+import java.util.Dictionary;
+
+import javax.servlet.ServletContext;
+import javax.websocket.DeploymentException;
+import javax.websocket.server.ServerContainer;
+
+import org.eclipse.equinox.http.jetty.JettyCustomizer;
+import org.eclipse.jetty.server.ConnectionFactory;
+import org.eclipse.jetty.server.ServerConnector;
+import org.eclipse.jetty.server.SslConnectionFactory;
+import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.util.ssl.SslContextFactory;
+import org.eclipse.jetty.websocket.javax.server.config.JavaxWebSocketServletContainerInitializer;
+import org.eclipse.jetty.websocket.javax.server.config.JavaxWebSocketServletContainerInitializer.Configurator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.FrameworkUtil;
+
+/** Customises the Jetty HTTP server. */
+public class CmsJettyCustomizer extends JettyCustomizer {
+	static final String SSL_TRUSTSTORE = "ssl.truststore";
+	static final String SSL_TRUSTSTOREPASSWORD = "ssl.truststorepassword";
+	static final String SSL_TRUSTSTORETYPE = "ssl.truststoretype";
+
+	private BundleContext bc = FrameworkUtil.getBundle(CmsJettyCustomizer.class).getBundleContext();
+
+	public final static String WEBSOCKET_ENABLED = "argeo.websocket.enabled";
+
+	@Override
+	public Object customizeContext(Object context, Dictionary<String, ?> settings) {
+		// WebSocket
+		Object webSocketEnabled = settings.get(WEBSOCKET_ENABLED);
+		if (webSocketEnabled != null && webSocketEnabled.toString().equals("true")) {
+			ServletContextHandler servletContextHandler = (ServletContextHandler) context;
+			JavaxWebSocketServletContainerInitializer.configure(servletContextHandler, new Configurator() {
+
+				@Override
+				public void accept(ServletContext servletContext, ServerContainer serverContainer)
+						throws DeploymentException {
+					bc.registerService(javax.websocket.server.ServerContainer.class, serverContainer, null);
+				}
+			});
+		}
+		return super.customizeContext(context, settings);
+
+	}
+
+	@Override
+	public Object customizeHttpsConnector(Object connector, Dictionary<String, ?> settings) {
+		ServerConnector httpsConnector = (ServerConnector) connector;
+		if (httpsConnector != null)
+			for (ConnectionFactory connectionFactory : httpsConnector.getConnectionFactories()) {
+				if (connectionFactory instanceof SslConnectionFactory) {
+					SslContextFactory.Server sslContextFactory = ((SslConnectionFactory) connectionFactory)
+							.getSslContextFactory();
+					sslContextFactory.setTrustStorePath((String) settings.get(SSL_TRUSTSTORE));
+					sslContextFactory.setTrustStoreType((String) settings.get(SSL_TRUSTSTORETYPE));
+					sslContextFactory.setTrustStorePassword((String) settings.get(SSL_TRUSTSTOREPASSWORD));
+				}
+			}
+		return super.customizeHttpsConnector(connector, settings);
+	}
+
+}