| | |
| | | package org.keycloak.protocol.cas; |
| | | |
| | | import jakarta.ws.rs.core.HttpHeaders; |
| | | import jakarta.ws.rs.core.Response; |
| | | import jakarta.ws.rs.core.UriInfo; |
| | | import org.apache.http.HttpEntity; |
| | | import org.jboss.logging.Logger; |
| | | import org.keycloak.common.util.KeycloakUriBuilder; |
| | | import org.keycloak.common.util.Time; |
| | | import org.keycloak.events.Details; |
| | | import org.keycloak.events.EventBuilder; |
| | | import org.keycloak.events.EventType; |
| | | import org.keycloak.forms.login.LoginFormsProvider; |
| | | import org.keycloak.models.*; |
| | | import org.keycloak.protocol.LoginProtocol; |
| | | import org.keycloak.protocol.cas.endpoints.AbstractValidateEndpoint; |
| | | import org.keycloak.protocol.cas.utils.LogoutHelper; |
| | | import org.keycloak.protocol.oidc.utils.OAuth2Code; |
| | | import org.keycloak.protocol.oidc.utils.OAuth2CodeParser; |
| | | import org.keycloak.services.ErrorPage; |
| | | import org.keycloak.services.managers.ResourceAdminManager; |
| | | import org.keycloak.sessions.AuthenticationSessionModel; |
| | | |
| | | import javax.ws.rs.core.HttpHeaders; |
| | | import javax.ws.rs.core.Response; |
| | | import javax.ws.rs.core.UriInfo; |
| | | import java.io.IOException; |
| | | import java.net.URI; |
| | | import java.util.UUID; |
| | | |
| | | public class CASLoginProtocol implements LoginProtocol { |
| | | private static final Logger logger = Logger.getLogger(CASLoginProtocol.class); |
| | |
| | | public static final String GATEWAY_PARAM = "gateway"; |
| | | public static final String TICKET_PARAM = "ticket"; |
| | | public static final String FORMAT_PARAM = "format"; |
| | | public static final String PGTURL_PARAM = "pgtUrl"; |
| | | public static final String TARGET_SERVICE_PARAM = "targetService"; |
| | | public static final String PGT_PARAM = "pgt"; |
| | | |
| | | public static final String TICKET_RESPONSE_PARAM = "ticket"; |
| | | public static final String SAMLART_RESPONSE_PARAM = "SAMLart"; |
| | | |
| | | public static final String SERVICE_TICKET_PREFIX = "ST-"; |
| | | public static final String PROXY_GRANTING_TICKET_IOU_PREFIX = "PGTIOU-"; |
| | | public static final String PROXY_GRANTING_TICKET_PREFIX = "PGT-"; |
| | | public static final String PROXY_TICKET_PREFIX = "PT-"; |
| | | public static final String SESSION_SERVICE_TICKET = "service_ticket"; |
| | | |
| | | public static final String LOGOUT_REDIRECT_URI = "CAS_LOGOUT_REDIRECT_URI"; |
| | |
| | | String service = authSession.getRedirectUri(); |
| | | //TODO validate service |
| | | |
| | | OAuth2Code codeData = new OAuth2Code(UUID.randomUUID(), |
| | | Time.currentTime() + userSession.getRealm().getAccessCodeLifespan(), |
| | | null, null, authSession.getRedirectUri(), null, null); |
| | | String code = OAuth2CodeParser.persistCode(session, clientSession, codeData); |
| | | |
| | | KeycloakUriBuilder uriBuilder = KeycloakUriBuilder.fromUri(service); |
| | | uriBuilder.queryParam(TICKET_RESPONSE_PARAM, SERVICE_TICKET_PREFIX + code); |
| | | |
| | | String loginTicket = AbstractValidateEndpoint.getST(session, clientSession, service); |
| | | |
| | | if (authSession.getClientNotes().containsKey(CASLoginProtocol.TARGET_PARAM)) { |
| | | // This was a SAML 1.1 auth request so return the ticket ID as "SAMLart" instead of "ticket" |
| | | uriBuilder.queryParam(SAMLART_RESPONSE_PARAM, loginTicket); |
| | | } else { |
| | | uriBuilder.queryParam(TICKET_RESPONSE_PARAM, loginTicket); |
| | | } |
| | | |
| | | URI redirectUri = uriBuilder.build(); |
| | | |
| | |
| | | sendSingleLogoutRequest(logoutUrl, serviceTicket); |
| | | } |
| | | ClientModel client = clientSession.getClient(); |
| | | new ResourceAdminManager(session).logoutClientSession(realm, client, clientSession); |
| | | new ResourceAdminManager(session).logoutClientSession(realm, client, clientSession).close(); |
| | | return Response.ok().build(); |
| | | } |
| | | |
| | | private void sendSingleLogoutRequest(String logoutUrl, String serviceTicket) { |
| | | HttpEntity requestEntity = LogoutHelper.buildSingleLogoutRequest(serviceTicket); |
| | | try { |
| | | HttpEntity requestEntity = LogoutHelper.buildSingleLogoutRequest(serviceTicket); |
| | | LogoutHelper.postWithRedirect(session, logoutUrl, requestEntity); |
| | | logger.debug("Sent CAS single logout for service " + logoutUrl); |
| | | } catch (IOException e) { |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Response finishLogout(UserSessionModel userSession) { |
| | | public Response finishBrowserLogout(UserSessionModel userSession, AuthenticationSessionModel logoutSession) { |
| | | String redirectUri = userSession.getNote(CASLoginProtocol.LOGOUT_REDIRECT_URI); |
| | | |
| | | event.event(EventType.LOGOUT); |
| | | event.user(userSession.getUser()).session(userSession).success(); |
| | | event.event(EventType.LOGOUT) |
| | | .user(userSession.getUser()) |
| | | .session(userSession) |
| | | .detail(Details.USERNAME, userSession.getUser().getUsername()); |
| | | |
| | | if (redirectUri != null) { |
| | | event.detail(Details.REDIRECT_URI, redirectUri); |
| | | event.success(); |
| | | return Response.status(302).location(URI.create(redirectUri)).build(); |
| | | } else { |
| | | LoginFormsProvider infoPage = session.getProvider(LoginFormsProvider.class).setSuccess("Logout successful"); |
| | | infoPage.setAttribute("skipLink", true); |
| | | return infoPage.createInfoPage(); |
| | | } |
| | | |
| | | event.success(); |
| | | |
| | | LoginFormsProvider infoPage = session.getProvider(LoginFormsProvider.class).setSuccess("Logout successful"); |
| | | infoPage.setAttribute("skipLink", true); |
| | | return infoPage.createInfoPage(); |
| | | } |
| | | |
| | | @Override |