X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fserver%2FJettyServer.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fserver%2FJettyServer.java;h=4d063106f07316258df7636ec7e7263d5bfe4746;hb=a05efb7b7b3cfc77f5e3fda11e8434834829f56a;hp=0000000000000000000000000000000000000000;hpb=256e95421e478b6fe7a9af77f5681255329cab99;p=dmaap%2Fdbcapi.git

diff --git a/src/main/java/org/onap/dmaap/dbcapi/server/JettyServer.java b/src/main/java/org/onap/dmaap/dbcapi/server/JettyServer.java
new file mode 100644
index 0000000..4d06310
--- /dev/null
+++ b/src/main/java/org/onap/dmaap/dbcapi/server/JettyServer.java
@@ -0,0 +1,151 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.dmaap.dbcapi.server;
+
+
+import java.util.Properties;
+
+import javax.net.ssl.SSLContext;
+
+import org.apache.log4j.Logger;
+import org.eclipse.jetty.security.SecurityHandler;
+import org.eclipse.jetty.server.Connector;
+import org.eclipse.jetty.server.HttpConfiguration;
+import org.eclipse.jetty.server.HttpConnectionFactory;
+import org.eclipse.jetty.server.SecureRequestCustomizer;
+import org.eclipse.jetty.server.Server;
+import org.eclipse.jetty.server.ServerConnector;
+import org.eclipse.jetty.server.SslConnectionFactory;
+import org.eclipse.jetty.servlet.DefaultServlet;
+import org.eclipse.jetty.servlet.ServletContextHandler;
+import org.eclipse.jetty.servlet.ServletHolder;
+import org.eclipse.jetty.util.ssl.SslContextFactory;
+ 
+
+
+
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+
+import org.onap.dmaap.dbcapi.aaf.database.LoadSchema;
+import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
+/**
+ * A  Jetty server which supports:
+ * 	- http and https (simultaneously for dev env)
+ *  - REST API context
+ *  - static html pages (for documentation).
+ */
+public class JettyServer extends BaseLoggingClass {
+
+    public JettyServer( Properties params ) throws Exception {
+
+        Server server = new Server();
+    	int httpPort = Integer.valueOf(params.getProperty("IntHttpPort", "80" ));
+       	int sslPort = Integer.valueOf(params.getProperty("IntHttpsPort", "443" ));
+       	boolean allowHttp = Boolean.valueOf(params.getProperty("HttpAllowed", "false"));
+    	serverLogger.info( "port params: http=" + httpPort + " https=" + sslPort );
+    	serverLogger.info( "allowHttp=" + allowHttp );
+        
+        // HTTP Server
+
+    	HttpConfiguration http_config = new HttpConfiguration();
+    	http_config.setSecureScheme("https");
+    	http_config.setSecurePort(sslPort);
+    	http_config.setOutputBufferSize(32768);
+
+    	
+    	
+        ServerConnector httpConnector = new ServerConnector(server, new HttpConnectionFactory(http_config));
+        httpConnector.setPort(httpPort);  
+        httpConnector.setIdleTimeout(30000);
+  
+        
+        // HTTPS Server
+ 
+        HttpConfiguration https_config = new HttpConfiguration(http_config);
+        https_config.addCustomizer(new SecureRequestCustomizer());
+        SslContextFactory sslContextFactory = new SslContextFactory();
+        String keystore = params.getProperty("KeyStoreFile", "etc/keystore");
+        logger.info( "https Server using keystore at " + keystore );
+        String keystorePwd = params.getProperty( "KeyStorePassword", "changeit");
+        String keyPwd = params.getProperty("KeyPassword", "changeit");
+ 
+
+        sslContextFactory.setKeyStorePath(keystore);
+        sslContextFactory.setKeyStorePassword(keystorePwd);
+        sslContextFactory.setKeyManagerPassword(keyPwd);     
+
+  
+		ServerConnector sslConnector = null;
+		if ( sslPort != 0 ) {
+			sslConnector = new ServerConnector(server,
+					new SslConnectionFactory(sslContextFactory, "http/1.1"),
+					new HttpConnectionFactory(https_config));
+			sslConnector.setPort(sslPort);
+        	if ( allowHttp ) {
+            	logger.info("Starting httpConnector on port " + httpPort );
+            	logger.info("Starting sslConnector on port " +   sslPort + " for https");
+        		server.setConnectors( new Connector[] { httpConnector, sslConnector });
+        	} else {
+            	logger.info("NOT starting httpConnector because HttpAllowed param is " + allowHttp  );	
+            	logger.info("Starting sslConnector on port " +   sslPort + " for https");
+          		server.setConnectors( new Connector[] { sslConnector });     	
+        	}
+		}
+		else {
+            serverLogger.info("NOT starting sslConnector on port " +   sslPort + " for https");
+        	if ( allowHttp ) {
+            	serverLogger.info("Starting httpConnector on port " + httpPort );
+        		server.setConnectors( new Connector[] { httpConnector });
+			} 
+        } 
+ 
+        // Set context for servlet.  This is shared for http and https
+       	ServletContextHandler context = new ServletContextHandler(ServletContextHandler.SESSIONS);
+    	context.setContextPath("/");
+        server.setHandler( context );
+
+        ServletHolder jerseyServlet = context.addServlet( org.glassfish.jersey.servlet.ServletContainer.class, "/webapi/*");
+        jerseyServlet.setInitOrder(1);
+        jerseyServlet.setInitParameter("jersey.config.server.provider.packages", "org.onap.dmaap.dbcapi.resources" );   
+        jerseyServlet.setInitParameter("javax.ws.rs.Application", "org.onap.dmaap.dbcapi.server.ApplicationConfig" );
+        
+        // also serve up some static pages...
+        ServletHolder staticServlet = context.addServlet(DefaultServlet.class,"/*");
+        staticServlet.setInitParameter("resourceBase","www");
+        staticServlet.setInitParameter("pathInfoOnly","true");
+
+        try {
+
+            serverLogger.info("Starting jetty server");
+        	server.start();
+        	server.dumpStdErr();
+            server.join();
+        } catch ( Exception e ) {
+        	errorLogger.error( "Exception " + e );
+        	errorLogger.error( "possibly unable to use keystore " + keystore + " with passwords " + keystorePwd +  " and " + keyPwd );
+        	//System.exit(1);
+        } finally {
+        	server.destroy();
+        }
+        
+    }
+}