gvSIG projects pool

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.online.swing.scribejava.keycloak.callbacks;

import com.github.scribejava.core.model.OAuth2AccessToken;

import com.github.scribejava.core.model.OAuth2Authorization;

import com.github.scribejava.core.model.OAuthRequest;

import com.github.scribejava.core.model.Response;

import com.github.scribejava.core.model.Verb;

import com.github.scribejava.core.oauth.OAuth20Service;

import com.sun.net.httpserver.HttpExchange;

import com.sun.net.httpserver.HttpHandler;

import java.io.IOException;

import javax.json.JsonObject;

import org.gvsig.json.Json;

import org.gvsig.online.swing.scribejava.keycloak.UserIdentificationKeycloak;

import org.gvsig.online.swing.scribejava.keycloak.UserIdentificationKeycloakConfig;

/**

 *

 * @author jjdelcerro

 */

@SuppressWarnings("UseSpecificCatch")

public class CallbackAuthorizationHandler extends AbstractCallback implements HttpHandler {

    public CallbackAuthorizationHandler(UserIdentificationKeycloak identificationRequester, OAuth20Service service, String contextPath) {

        super(identificationRequester, service, contextPath);

    }

    @Override

    public void handle(HttpExchange t) throws IOException {

        String requestURL = "Unknown";

        try {

            requestURL = t.getRequestURI().toString();

            this.identificationRequester.setAuthorization(null);

            this.identificationRequester.setUserId(null);

            OAuth2Authorization auth = service.extractAuthorization(t.getRequestURI().toString());

            if (auth.getCode() == null) {

                response(t, 200, message("Can't autthenticate user\n"));

                return;

            }

            final OAuth2AccessToken accessToken = service.getAccessToken(auth.getCode());

            this.identificationRequester.setAuthorization(accessToken.getAccessToken());

            String userId = null;

            JsonObject userinfo = this.identificationRequester.userInfo(service);

            if (userinfo!=null) {

                userId = userinfo.getString("preferred_username", null);

//                    System.out.println("userid: " + userId);

//                    System.out.println("name: " + userinfo.getString("name", null));

//                    System.out.println("email: " + userinfo.getString("email", null));

//                    System.out.println("roles: " + userinfo.get("gvsigol_roles").toString());

//                    System.out.println("grupos: " + userinfo.get("groups").toString());

                this.identificationRequester.setUserId(userId);

            }

            response(t, 200, message_and_close((userId == null)?"User autthenticate\n":"User " + userId + " authenticated\n"));

        } catch (Exception ex) {

            LOGGER.warn("Can't process callback authorization (contextPath '" + contextPath + "', request URL '" + requestURL + "')", ex);

            responseQuietly(t, 500, message("Can't authenticate user\n" + ex.getMessage()));

        } finally {

            this.stopWaitingForResponse();

        }

    }

}