LightPIT: src/main/java/de/uapcore/lightpit/AbstractLightPITServlet.java@e722861558bb (annotated)

src/main/java/de/uapcore/lightpit/AbstractLightPITServlet.java@e722861558bb (annotated)

src/main/java/de/uapcore/lightpit/AbstractLightPITServlet.java

Tue, 12 May 2020 22:03:00 +0200

author: Mike Becker <universe@uap-core.de>
date: Tue, 12 May 2020 22:03:00 +0200
changeset 39: e722861558bb
parent 38: cf85ef18f231
child 40: 276ef00a336d
permissions: -rw-r--r--

fixes minor issues that were reported by default inspection

 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
  *
  * Copyright 2018 Mike Becker. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are met:
  *
  *   1. Redistributions of source code must retain the above copyright
  *      notice, this list of conditions and the following disclaimer.
  *
  *   2. Redistributions in binary form must reproduce the above copyright
  *      notice, this list of conditions and the following disclaimer in the
  *      documentation and/or other materials provided with the distribution.
  *
  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  * POSSIBILITY OF SUCH DAMAGE.
  *
  */
 package de.uapcore.lightpit;
 import de.uapcore.lightpit.dao.DataAccessObjects;
 import de.uapcore.lightpit.dao.postgres.PGDataAccessObjects;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import javax.servlet.ServletException;
 import javax.servlet.http.HttpServlet;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.servlet.http.HttpSession;
 import java.io.IOException;
 import java.lang.reflect.Method;
 import java.lang.reflect.Modifier;
 import java.sql.Connection;
 import java.sql.SQLException;
 import java.util.*;
 /**
  * A special implementation of a HTTPServlet which is focused on implementing
  * the necessary functionality for {@link LightPITModule}s.
  */
 public abstract class AbstractLightPITServlet extends HttpServlet {
     private static final Logger LOG = LoggerFactory.getLogger(AbstractLightPITServlet.class);
     private static final String HTML_FULL_DISPATCHER = Functions.jspPath("html_full");
     /**
      * The EL proxy is necessary, because the EL resolver cannot handle annotation properties.
      */
     private LightPITModule.ELProxy moduleInfo = null;
     /**
      * Invocation mapping gathered from the {@link RequestMapping} annotations.
      * <p>
      * Paths in this map must always start with a leading slash, although
      * the specification in the annotation must not start with a leading slash.
      * <p>
      * The reason for this is the different handling of empty paths in
      * {@link HttpServletRequest#getPathInfo()}.
      */
     private final Map<HttpMethod, Map<String, Method>> mappings = new HashMap<>();
     /**
      * Gives implementing modules access to the {@link ModuleManager}.
      *
      * @return the module manager
      */
     protected final ModuleManager getModuleManager() {
         return (ModuleManager) getServletContext().getAttribute(ModuleManager.SC_ATTR_NAME);
     }
     /**
      * Creates a set of data access objects for the specified connection.
      *
      * @param connection the SQL connection
      * @return a set of data access objects
      */
     private DataAccessObjects createDataAccessObjects(Connection connection) throws SQLException {
         final var df = (DatabaseFacade) getServletContext().getAttribute(DatabaseFacade.SC_ATTR_NAME);
         if (df.getSQLDialect() == DatabaseFacade.Dialect.Postgres) {
             return new PGDataAccessObjects(connection);
         }
         throw new AssertionError("Non-exhaustive if-else - this is a bug.");
     }
     private ResponseType invokeMapping(Method method, HttpServletRequest req, HttpServletResponse resp, DataAccessObjects dao) throws IOException {
         try {
             LOG.trace("invoke {}#{}", method.getDeclaringClass().getName(), method.getName());
             return (ResponseType) method.invoke(this, req, resp, dao);
         } catch (ReflectiveOperationException | ClassCastException ex) {
             LOG.error("invocation of method {} failed: {}", method.getName(), ex.getMessage());
             LOG.debug("Details: ", ex);
             resp.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
             return ResponseType.NONE;
         }
     }
     @Override
     public void init() throws ServletException {
         moduleInfo = Optional.ofNullable(this.getClass().getAnnotation(LightPITModule.class))
                 .map(LightPITModule.ELProxy::new).orElse(null);
         if (moduleInfo != null) {
             scanForRequestMappings();
         }
         LOG.trace("{} initialized", getServletName());
     }
     private void scanForRequestMappings() {
         try {
             Method[] methods = getClass().getDeclaredMethods();
             for (Method method : methods) {
                 Optional<RequestMapping> mapping = Optional.ofNullable(method.getAnnotation(RequestMapping.class));
                 if (mapping.isPresent()) {
                     if (!Modifier.isPublic(method.getModifiers())) {
                         LOG.warn("{} is annotated with {} but is not public",
                                 method.getName(), RequestMapping.class.getSimpleName()
                         );
                         continue;
                     }
                     if (Modifier.isAbstract(method.getModifiers())) {
                         LOG.warn("{} is annotated with {} but is abstract",
                                 method.getName(), RequestMapping.class.getSimpleName()
                         );
                         continue;
                     }
                     if (!ResponseType.class.isAssignableFrom(method.getReturnType())) {
                         LOG.warn("{} is annotated with {} but has the wrong return type - 'ResponseType' required",
                                 method.getName(), RequestMapping.class.getSimpleName()
                         );
                         continue;
                     }
                     Class<?>[] params = method.getParameterTypes();
                     if (params.length == 3
                             && HttpServletRequest.class.isAssignableFrom(params[0])
                             && HttpServletResponse.class.isAssignableFrom(params[1])
                             && DataAccessObjects.class.isAssignableFrom(params[2])) {
                         final String requestPath = "/" + mapping.get().requestPath();
                         if (mappings
                                 .computeIfAbsent(mapping.get().method(), k -> new HashMap<>())
                                 .putIfAbsent(requestPath, method) != null) {
                             LOG.warn("{} {} has multiple mappings",
                                     mapping.get().method(),
                                     mapping.get().requestPath()
                             );
                         }
                         LOG.debug("{} {} maps to {}::{}",
                                 mapping.get().method(),
                                 requestPath,
                                 getClass().getSimpleName(),
                                 method.getName()
                         );
                     } else {
                         LOG.warn("{} is annotated with {} but has the wrong parameters - (HttpServletRequest,HttpServletResponse) required",
                                 method.getName(), RequestMapping.class.getSimpleName()
                         );
                     }
                 }
             }
         } catch (SecurityException ex) {
             LOG.error("Scan for request mappings on declared methods failed.", ex);
         }
     }
     @Override
     public void destroy() {
         mappings.clear();
         LOG.trace("{} destroyed", getServletName());
     }
     /**
      * Sets the name of the dynamic fragment.
      * <p>
      * It is sufficient to specify the name without any extension. The extension
      * is added automatically if not specified.
      * <p>
      * The fragment must be located in the dynamic fragments folder.
      *
      * @param req          the servlet request object
      * @param fragmentName the name of the fragment
      * @see Constants#DYN_FRAGMENT_PATH_PREFIX
      */
     public void setDynamicFragment(HttpServletRequest req, String fragmentName) {
         req.setAttribute(Constants.REQ_ATTR_FRAGMENT, Functions.dynFragmentPath(fragmentName));
     }
     /**
      * Specifies the name of an additional stylesheet used by the module.
      * <p>
      * Setting an additional stylesheet is optional, but quite common for HTML
      * output.
      * <p>
      * It is sufficient to specify the name without any extension. The extension
      * is added automatically if not specified.
      *
      * @param req        the servlet request object
      * @param stylesheet the name of the stylesheet
      */
     public void setStylesheet(HttpServletRequest req, String stylesheet) {
         req.setAttribute(Constants.REQ_ATTR_STYLESHEET, Functions.enforceExt(stylesheet, ".css"));
     }
     private void forwardToFullView(HttpServletRequest req, HttpServletResponse resp)
             throws IOException, ServletException {
         req.setAttribute(Constants.REQ_ATTR_MENU, getModuleManager().getMainMenu());
         req.getRequestDispatcher(HTML_FULL_DISPATCHER).forward(req, resp);
     }
     private Optional<Method> findMapping(HttpMethod method, HttpServletRequest req) {
         return Optional.ofNullable(mappings.get(method))
                 .map(rm -> rm.get(Optional.ofNullable(req.getPathInfo()).orElse("/"))
                 );
     }
     private void forwardAsSpecified(ResponseType type, HttpServletRequest req, HttpServletResponse resp)
             throws ServletException, IOException {
         switch (type) {
             case NONE:
                 return;
             case HTML_FULL:
                 forwardToFullView(req, resp);
                 return;
             // TODO: implement remaining response types
             default:
                 throw new AssertionError("ResponseType switch is not exhaustive - this is a bug!");
         }
     }
     private void doProcess(HttpMethod method, HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
         // choose the requested language as session language (if available) or fall back to english, otherwise
         HttpSession session = req.getSession();
         if (session.getAttribute(Constants.SESSION_ATTR_LANGUAGE) == null) {
             Optional<List<String>> availableLanguages = Functions.availableLanguages(getServletContext()).map(Arrays::asList);
             Optional<Locale> reqLocale = Optional.of(req.getLocale());
             Locale sessionLocale = reqLocale.filter((rl) -> availableLanguages.map((al) -> al.contains(rl.getLanguage())).orElse(false)).orElse(Locale.ENGLISH);
             session.setAttribute(Constants.SESSION_ATTR_LANGUAGE, sessionLocale);
             LOG.debug("Setting language for new session {}: {}", session.getId(), sessionLocale.getDisplayLanguage());
         } else {
             Locale sessionLocale = (Locale) session.getAttribute(Constants.SESSION_ATTR_LANGUAGE);
             resp.setLocale(sessionLocale);
             LOG.trace("Continuing session {} with language {}", session.getId(), sessionLocale);
         }
         // set some internal request attributes
         req.setAttribute(Constants.REQ_ATTR_PATH, Functions.fullPath(req));
         req.setAttribute(Constants.REQ_ATTR_MODULE_CLASSNAME, this.getClass().getName());
         Optional.ofNullable(moduleInfo).ifPresent((proxy) -> req.setAttribute(Constants.REQ_ATTR_MODULE_INFO, proxy));
         // obtain a connection and create the data access objects
         final var db = (DatabaseFacade) req.getServletContext().getAttribute(DatabaseFacade.SC_ATTR_NAME);
         try (final var connection = db.getDataSource().getConnection()) {
             final var dao = createDataAccessObjects(connection);
             try {
                 connection.setAutoCommit(false);
                 // call the handler, if available, or send an HTTP 404 error
                 final var mapping = findMapping(method, req);
                 if (mapping.isPresent()) {
                     forwardAsSpecified(invokeMapping(mapping.get(), req, resp, dao), req, resp);
                 } else {
                     resp.sendError(HttpServletResponse.SC_NOT_FOUND);
                 }
                 connection.commit();
             } catch (SQLException ex) {
                 LOG.warn("Database transaction failed (Code {}): {}", ex.getErrorCode(), ex.getMessage());
                 LOG.debug("Details: ", ex);
                 resp.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, "Unhandled Transaction Error - Code:" + ex.getErrorCode());
                 connection.rollback();
             }
         } catch (SQLException ex) {
             LOG.error("Severe Database Exception (Code {}): {}", ex.getErrorCode(), ex.getMessage());
             LOG.debug("Details: ", ex);
             resp.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, "Database Error - Code:" + ex.getErrorCode());
         }
     }
     @Override
     protected final void doGet(HttpServletRequest req, HttpServletResponse resp)
             throws ServletException, IOException {
         doProcess(HttpMethod.GET, req, resp);
     }
     @Override
     protected final void doPost(HttpServletRequest req, HttpServletResponse resp)
             throws ServletException, IOException {
         doProcess(HttpMethod.POST, req, resp);
     }
 }

Mercurial > hg > LightPIT / annotate

src/main/java/de/uapcore/lightpit/AbstractLightPITServlet.java@e722861558bb (annotated)

src/main/java/de/uapcore/lightpit/AbstractLightPITServlet.java