2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
20 package org.onap.policy.drools.http.server.internal;
22 import java.net.InetAddress;
23 import java.net.UnknownHostException;
24 import java.util.HashMap;
26 import org.eclipse.jetty.servlet.ServletHolder;
27 import org.onap.policy.drools.utils.NetworkUtil;
28 import org.slf4j.LoggerFactory;
29 import org.slf4j.Logger;
31 import io.swagger.jersey.config.JerseyJaxrsConfig;
34 * REST Jetty Server that uses Jersey Servlets to support JAX-RS Web Services
36 public class JettyJerseyServer extends JettyServletServer {
39 * Swagger API Base Path
41 protected static final String SWAGGER_API_BASEPATH = "swagger.api.basepath";
46 protected static final String SWAGGER_CONTEXT_ID = "swagger.context.id";
51 protected static final String SWAGGER_SCANNER_ID = "swagger.scanner.id";
54 * Swagger Pretty Print
56 protected static final String SWAGGER_PRETTY_PRINT = "swagger.pretty.print";
61 protected static final String SWAGGER_INIT_PACKAGES_PARAM_VALUE = "io.swagger.jaxrs.listing";
64 * Jersey Packages Init Param Name
66 protected static final String JERSEY_INIT_PACKAGES_PARAM_NAME = "jersey.config.server.provider.packages";
69 * Jersey Packages Init Param Value
71 protected static final String JERSEY_INIT_PACKAGES_PARAM_VALUE = "com.fasterxml.jackson.jaxrs.json";
74 * Jersey Classes Init Param Name
76 protected static final String JERSEY_INIT_CLASSNAMES_PARAM_NAME = "jersey.config.server.provider.classnames";
79 * Jersey Jackson Classes Init Param Value
81 protected static final String JERSEY_JACKSON_INIT_CLASSNAMES_PARAM_VALUE = "com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider";
84 * Jersey Swagger Classes Init Param Value
86 protected static final String SWAGGER_INIT_CLASSNAMES_PARAM_VALUE = "io.swagger.jaxrs.listing.ApiListingResource," +
87 "io.swagger.jaxrs.listing.SwaggerSerializers";
91 protected static Logger logger = LoggerFactory.getLogger(JettyJerseyServer.class);
94 * Container for servlets
96 protected HashMap<String, ServletHolder> servlets = new HashMap<>();
101 protected String swaggerId = null;
107 * @param host host server host
108 * @param port port server port
109 * @param swagger support swagger?
110 * @param contextPath context path
112 * @throws IllegalArgumentException in invalid arguments are provided
114 public JettyJerseyServer(String name, String host, int port, String contextPath, boolean swagger) {
116 super(name, host, port, contextPath);
118 this.swaggerId = "swagger-" + this.port;
119 attachSwaggerServlet();
124 * attaches a swagger initialization servlet
126 protected void attachSwaggerServlet() {
128 ServletHolder swaggerServlet = context.addServlet(JerseyJaxrsConfig.class, "/");
130 String hostname = this.connector.getHost();
131 if (hostname == null || hostname.isEmpty() || hostname.equals(NetworkUtil.IPv4_WILDCARD_ADDRESS)) {
132 hostname = NetworkUtil.getHostname();
135 swaggerServlet.setInitParameter(SWAGGER_API_BASEPATH,
136 "http://" + hostname + ":" + this.connector.getPort() + "/");
137 swaggerServlet.setInitParameter(SWAGGER_CONTEXT_ID, swaggerId);
138 swaggerServlet.setInitParameter(SWAGGER_SCANNER_ID, swaggerId);
139 swaggerServlet.setInitParameter(SWAGGER_PRETTY_PRINT, "true");
140 swaggerServlet.setInitOrder(2);
142 if (logger.isDebugEnabled())
143 logger.debug("{}: Swagger Servlet has been attached: {}", this, swaggerServlet.dump());
147 * retrieves cached server based on servlet path
149 * @param servletPath servlet path
150 * @return the jetty servlet holder
152 * @throws IllegalArgumentException if invalid arguments are provided
154 protected synchronized ServletHolder getServlet(String servletPath) {
156 ServletHolder jerseyServlet = servlets.get(servletPath);
157 if (jerseyServlet == null) {
158 jerseyServlet = context.addServlet
159 (org.glassfish.jersey.servlet.ServletContainer.class, servletPath);
160 jerseyServlet.setInitOrder(0);
161 servlets.put(servletPath, jerseyServlet);
164 return jerseyServlet;
168 public synchronized void addServletPackage(String servletPath, String restPackage) {
169 String servPath = servletPath;
170 if (restPackage == null || restPackage.isEmpty())
171 throw new IllegalArgumentException("No discoverable REST package provided");
173 if (servPath == null || servPath.isEmpty())
176 ServletHolder jerseyServlet = this.getServlet(servPath);
179 jerseyServlet.getInitParameter(JERSEY_INIT_CLASSNAMES_PARAM_NAME);
180 if (initClasses != null && !initClasses.isEmpty())
181 logger.warn("Both packages and classes are used in Jetty+Jersey Configuration: {}", restPackage);
183 String initPackages =
184 jerseyServlet.getInitParameter(JERSEY_INIT_PACKAGES_PARAM_NAME);
185 if (initPackages == null) {
186 if (this.swaggerId != null) {
187 initPackages = JERSEY_INIT_PACKAGES_PARAM_VALUE + "," +
188 SWAGGER_INIT_PACKAGES_PARAM_VALUE + "," +
191 jerseyServlet.setInitParameter(SWAGGER_CONTEXT_ID, swaggerId);
192 jerseyServlet.setInitParameter(SWAGGER_SCANNER_ID, swaggerId);
194 initPackages = JERSEY_INIT_PACKAGES_PARAM_VALUE + "," +
198 initPackages = initPackages + "," + restPackage;
201 jerseyServlet.setInitParameter(JERSEY_INIT_PACKAGES_PARAM_NAME, initPackages);
203 if (logger.isDebugEnabled())
204 logger.debug("{}: added REST package: {}", this, jerseyServlet.dump());
208 public synchronized void addServletClass(String servletPath, String restClass) {
210 if (restClass == null || restClass.isEmpty())
211 throw new IllegalArgumentException("No discoverable REST class provided");
213 if (servletPath == null || servletPath.isEmpty())
216 ServletHolder jerseyServlet = this.getServlet(servletPath);
218 String initPackages =
219 jerseyServlet.getInitParameter(JERSEY_INIT_PACKAGES_PARAM_NAME);
220 if (initPackages != null && !initPackages.isEmpty())
221 logger.warn("Both classes and packages are used in Jetty+Jersey Configuration: {}", restClass);
224 jerseyServlet.getInitParameter(JERSEY_INIT_CLASSNAMES_PARAM_NAME);
225 if (initClasses == null) {
226 if (this.swaggerId != null) {
227 initClasses = JERSEY_JACKSON_INIT_CLASSNAMES_PARAM_VALUE + "," +
228 SWAGGER_INIT_CLASSNAMES_PARAM_VALUE + "," +
231 jerseyServlet.setInitParameter(SWAGGER_CONTEXT_ID, swaggerId);
232 jerseyServlet.setInitParameter(SWAGGER_SCANNER_ID, swaggerId);
234 initClasses = JERSEY_JACKSON_INIT_CLASSNAMES_PARAM_VALUE + "," + restClass;
237 initClasses = initClasses + "," + restClass;
240 jerseyServlet.setInitParameter(JERSEY_INIT_CLASSNAMES_PARAM_NAME, initClasses);
242 if (logger.isDebugEnabled())
243 logger.debug("{}: added REST class: {}", this, jerseyServlet.dump());
247 public String toString() {
248 StringBuilder builder = new StringBuilder();
249 builder.append("JettyJerseyServer [servlets=").append(servlets).append(", swaggerId=").append(swaggerId)
250 .append(", toString()=").append(super.toString()).append("]");
251 return builder.toString();