| | |
| | | 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.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.utils.LogoutHelper; |
| | | import org.keycloak.services.managers.ClientSessionCode; |
| | | 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.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); |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Response authenticated(UserSessionModel userSession, ClientSessionContext clientSessionCtx) { |
| | | public Response authenticated(AuthenticationSessionModel authSession, UserSessionModel userSession, ClientSessionContext clientSessionCtx) { |
| | | AuthenticatedClientSessionModel clientSession = clientSessionCtx.getClientSession(); |
| | | ClientSessionCode<AuthenticatedClientSessionModel> accessCode = new ClientSessionCode<>(session, realm, clientSession); |
| | | |
| | | String service = clientSession.getRedirectUri(); |
| | | String service = authSession.getRedirectUri(); |
| | | //TODO validate service |
| | | |
| | | String code = accessCode.getOrGenerateCode(); |
| | | 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); |
| | | |
| | |
| | | |
| | | @Override |
| | | public Response sendError(AuthenticationSessionModel authSession, Error error) { |
| | | return Response.serverError().entity(error).build(); |
| | | if (authSession.getClientNotes().containsKey(CASLoginProtocol.GATEWAY_PARAM)) { |
| | | if (error == Error.PASSIVE_INTERACTION_REQUIRED || error == Error.PASSIVE_LOGIN_REQUIRED) { |
| | | return Response.status(302).location(URI.create(authSession.getRedirectUri())).build(); |
| | | } |
| | | } |
| | | return ErrorPage.error(session, authSession, Response.Status.INTERNAL_SERVER_ERROR, error.name()); |
| | | } |
| | | |
| | | @Override |
| | | public void backchannelLogout(UserSessionModel userSession, AuthenticatedClientSessionModel clientSession) { |
| | | public Response backchannelLogout(UserSessionModel userSession, AuthenticatedClientSessionModel clientSession) { |
| | | String logoutUrl = clientSession.getRedirectUri(); |
| | | String serviceTicket = clientSession.getNote(CASLoginProtocol.SESSION_SERVICE_TICKET); |
| | | //check if session is fully authenticated (i.e. serviceValidate has been called) |
| | |
| | | sendSingleLogoutRequest(logoutUrl, serviceTicket); |
| | | } |
| | | ClientModel client = clientSession.getClient(); |
| | | new ResourceAdminManager(session).logoutClientSession(uriInfo.getRequestUri(), realm, client, clientSession); |
| | | new ResourceAdminManager(session).logoutClientSession(realm, client, clientSession); |
| | | return Response.ok().build(); |
| | | } |
| | | |
| | | private void sendSingleLogoutRequest(String logoutUrl, String serviceTicket) { |