| | |
| | | */ |
| | | @Override |
| | | public UserModel authenticate(HttpServletRequest httpRequest, boolean requiresCertificate) { |
| | | |
| | | // Check if this request has already been authenticated, and trust that instead of re-processing |
| | | String reqAuthUser = (String) httpRequest.getAttribute(Constants.ATTRIB_AUTHUSER); |
| | | if (!StringUtils.isEmpty(reqAuthUser)) { |
| | | logger.warn("Called servlet authenticate when request is already authenticated."); |
| | | return userManager.getUserModel(reqAuthUser); |
| | | } |
| | | |
| | | // try to authenticate by servlet container principal |
| | | if (!requiresCertificate) { |
| | | Principal principal = httpRequest.getUserPrincipal(); |
| | |
| | | UserModel user = userManager.getUserModel(username); |
| | | if (user != null) { |
| | | // existing user |
| | | flagSession(httpRequest, AuthenticationType.CONTAINER); |
| | | flagRequest(httpRequest, AuthenticationType.CONTAINER, user.username); |
| | | logger.debug(MessageFormat.format("{0} authenticated by servlet container principal from {1}", |
| | | user.username, httpRequest.getRemoteAddr())); |
| | | return validateAuthentication(user, AuthenticationType.CONTAINER); |
| | |
| | | user.displayName = username; |
| | | user.password = Constants.EXTERNAL_ACCOUNT; |
| | | user.accountType = AccountType.CONTAINER; |
| | | |
| | | // Try to extract user's informations for the session |
| | | // it uses "realm.container.autoAccounts.*" as the attribute name to look for |
| | | HttpSession session = httpRequest.getSession(); |
| | | String emailAddress = resolveAttribute(session, Keys.realm.container.autoAccounts.emailAddress); |
| | | if(emailAddress != null) { |
| | | user.emailAddress = emailAddress; |
| | | } |
| | | String displayName = resolveAttribute(session, Keys.realm.container.autoAccounts.displayName); |
| | | if(displayName != null) { |
| | | user.displayName = displayName; |
| | | } |
| | | String userLocale = resolveAttribute(session, Keys.realm.container.autoAccounts.locale); |
| | | if(userLocale != null) { |
| | | user.getPreferences().setLocale(userLocale); |
| | | } |
| | | String adminRole = settings.getString(Keys.realm.container.autoAccounts.adminRole, null); |
| | | if(adminRole != null && ! adminRole.isEmpty()) { |
| | | if(httpRequest.isUserInRole(adminRole)) { |
| | | user.canAdmin = true; |
| | | } |
| | | } |
| | | |
| | | userManager.updateUserModel(user); |
| | | flagSession(httpRequest, AuthenticationType.CONTAINER); |
| | | flagRequest(httpRequest, AuthenticationType.CONTAINER, user.username); |
| | | logger.debug(MessageFormat.format("{0} authenticated and created by servlet container principal from {1}", |
| | | user.username, httpRequest.getRemoteAddr())); |
| | | return validateAuthentication(user, AuthenticationType.CONTAINER); |
| | |
| | | UserModel user = userManager.getUserModel(model.username); |
| | | X509Metadata metadata = HttpUtils.getCertificateMetadata(httpRequest); |
| | | if (user != null) { |
| | | flagSession(httpRequest, AuthenticationType.CERTIFICATE); |
| | | flagRequest(httpRequest, AuthenticationType.CERTIFICATE, user.username); |
| | | logger.debug(MessageFormat.format("{0} authenticated by client certificate {1} from {2}", |
| | | user.username, metadata.serialNumber, httpRequest.getRemoteAddr())); |
| | | return validateAuthentication(user, AuthenticationType.CERTIFICATE); |
| | |
| | | if (!StringUtils.isEmpty(cookie)) { |
| | | user = userManager.getUserModel(cookie.toCharArray()); |
| | | if (user != null) { |
| | | flagSession(httpRequest, AuthenticationType.COOKIE); |
| | | flagRequest(httpRequest, AuthenticationType.COOKIE, user.username); |
| | | logger.debug(MessageFormat.format("{0} authenticated by cookie from {1}", |
| | | user.username, httpRequest.getRemoteAddr())); |
| | | return validateAuthentication(user, AuthenticationType.COOKIE); |
| | |
| | | if (values.length == 2) { |
| | | String username = values[0]; |
| | | char[] password = values[1].toCharArray(); |
| | | user = authenticate(username, password); |
| | | user = authenticate(username, password, httpRequest.getRemoteAddr()); |
| | | if (user != null) { |
| | | flagSession(httpRequest, AuthenticationType.CREDENTIALS); |
| | | flagRequest(httpRequest, AuthenticationType.CREDENTIALS, user.username); |
| | | logger.debug(MessageFormat.format("{0} authenticated by BASIC request header from {1}", |
| | | user.username, httpRequest.getRemoteAddr())); |
| | | return validateAuthentication(user, AuthenticationType.CREDENTIALS); |
| | | } else { |
| | | logger.warn(MessageFormat.format("Failed login attempt for {0}, invalid credentials from {1}", |
| | | username, httpRequest.getRemoteAddr())); |
| | | } |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | * Extract given attribute from the session and return it's content |
| | | * it return null if attributeMapping is empty, or if the value is |
| | | * empty |
| | | * |
| | | * @param session The user session |
| | | * @param attributeMapping |
| | | * @return |
| | | */ |
| | | private String resolveAttribute(HttpSession session, String attributeMapping) { |
| | | String attributeName = settings.getString(attributeMapping, null); |
| | | if(StringUtils.isEmpty(attributeName)) { |
| | | return null; |
| | | } |
| | | Object attributeValue = session.getAttribute(attributeName); |
| | | if(attributeValue == null) { |
| | | return null; |
| | | } |
| | | String value = attributeValue.toString(); |
| | | if(value.isEmpty()) { |
| | | return null; |
| | | } |
| | | return value; |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | |
| | | /** |
| | | * Return the UserModel for already authenticated user. |
| | | * |
| | | * This implementation assumes that the authentication has already take place |
| | | * (e.g. SSHDaemon) and that this is a validation/verification of the user. |
| | | * |
| | | * @param username |
| | | * @return a user object or null |
| | | */ |
| | | @Override |
| | | public UserModel authenticate(String username) { |
| | | if (username != null) { |
| | | if (!StringUtils.isEmpty(username)) { |
| | | UserModel user = userManager.getUserModel(username); |
| | | if (user != null) { |
| | | // existing user |
| | | logger.debug(MessageFormat.format("{0} authenticated externally", user.username)); |
| | | return validateAuthentication(user, AuthenticationType.CONTAINER); |
| | | } |
| | | logger.warn(MessageFormat.format("Failed to find UserModel for {0} during external authentication", |
| | | username)); |
| | | } |
| | | } else { |
| | | logger.warn("Empty user passed to AuthenticationManager.authenticate!"); |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * This method allows the authentication manager to reject authentication |
| | | * attempts. It is called after the username/secret have been verified to |
| | | * ensure that the authentication technique has been logged. |
| | |
| | | return user; |
| | | } |
| | | |
| | | protected void flagSession(HttpServletRequest httpRequest, AuthenticationType authenticationType) { |
| | | httpRequest.getSession().setAttribute(Constants.AUTHENTICATION_TYPE, authenticationType); |
| | | protected void flagRequest(HttpServletRequest httpRequest, AuthenticationType authenticationType, String authedUsername) { |
| | | httpRequest.setAttribute(Constants.ATTRIB_AUTHUSER, authedUsername); |
| | | httpRequest.setAttribute(Constants.ATTRIB_AUTHTYPE, authenticationType); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @return a user object or null |
| | | */ |
| | | @Override |
| | | public UserModel authenticate(String username, char[] password) { |
| | | public UserModel authenticate(String username, char[] password, String remoteIP) { |
| | | if (StringUtils.isEmpty(username)) { |
| | | // can not authenticate empty username |
| | | return null; |
| | |
| | | |
| | | // try local authentication |
| | | if (user != null && user.isLocalAccount()) { |
| | | return authenticateLocal(user, password); |
| | | } |
| | | |
| | | // try registered external authentication providers |
| | | for (AuthenticationProvider provider : authenticationProviders) { |
| | | if (provider instanceof UsernamePasswordAuthenticationProvider) { |
| | | UserModel returnedUser = provider.authenticate(usernameDecoded, password); |
| | | if (returnedUser != null) { |
| | | // user authenticated |
| | | returnedUser.accountType = provider.getAccountType(); |
| | | return validateAuthentication(returnedUser, AuthenticationType.CREDENTIALS); |
| | | UserModel returnedUser = authenticateLocal(user, password); |
| | | if (returnedUser != null) { |
| | | // user authenticated |
| | | return returnedUser; |
| | | } |
| | | } else { |
| | | // try registered external authentication providers |
| | | for (AuthenticationProvider provider : authenticationProviders) { |
| | | if (provider instanceof UsernamePasswordAuthenticationProvider) { |
| | | UserModel returnedUser = provider.authenticate(usernameDecoded, password); |
| | | if (returnedUser != null) { |
| | | // user authenticated |
| | | returnedUser.accountType = provider.getAccountType(); |
| | | return validateAuthentication(returnedUser, AuthenticationType.CREDENTIALS); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | // could not authenticate locally or with a provider |
| | | logger.warn(MessageFormat.format("Failed login attempt for {0}, invalid credentials from {1}", username, |
| | | remoteIP != null ? remoteIP : "unknown")); |
| | | |
| | | return null; |
| | | } |
| | | |
| | |
| | | @Override |
| | | public void setCookie(HttpServletRequest request, HttpServletResponse response, UserModel user) { |
| | | if (settings.getBoolean(Keys.web.allowCookieAuthentication, true)) { |
| | | HttpSession session = request.getSession(); |
| | | AuthenticationType authenticationType = (AuthenticationType) session.getAttribute(Constants.AUTHENTICATION_TYPE); |
| | | boolean standardLogin = authenticationType.isStandard(); |
| | | boolean standardLogin = true; |
| | | |
| | | if (null != request) { |
| | | // Pull the auth type from the request, it is set there if container managed |
| | | AuthenticationType authenticationType = (AuthenticationType) request.getAttribute(Constants.ATTRIB_AUTHTYPE); |
| | | |
| | | if (null != authenticationType) |
| | | standardLogin = authenticationType.isStandard(); |
| | | } |
| | | |
| | | if (standardLogin) { |
| | | Cookie userCookie; |