Application: gvSIG desktop

/*

 * 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.downloader.swing.scribejava.keycloak;

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

import javax.json.JsonObject;

import org.gvsig.downloader.DownloaderAuthenticationConfig;

import org.gvsig.downloader.DownloaderCredentials;

import org.gvsig.downloader.spi.AbstractDownloaderCredentials;

import org.gvsig.json.Json;

/**

 *

 * @author jjdelcerro

 */

public class DownloaderKeycloakCredentials

        extends AbstractDownloaderCredentials

        implements DownloaderCredentials

    {

    private final OAuth2AccessToken oauthToken;

    private final String userid;

    private long time;

    private JsonObject jsonResponse;

    public DownloaderKeycloakCredentials(DownloaderAuthenticationConfig config, OAuth2AccessToken oauthToken, String userid, long time) {

        super(userid, config.getServiceUrl());

        this.oauthToken = oauthToken;

        this.userid = userid;

        this.time = time;

        this.jsonResponse = null;

    }

    public OAuth2AccessToken getToken() {

        return oauthToken;

    }

    @Override

    public String getAuthorizationToken() {

        return "Bearer " + oauthToken.getAccessToken();

    }

    @Override

    public String getUserid() {

        return userid;

    }

    public boolean isAccessTokenExpired() {

        try {

            long now = System.currentTimeMillis();

            long expires_in = this.getResponseValueInt("expires_in", -1); // secs

            if( expires_in<0 ) {

                return true;

            }

            return time+(expires_in*1000) < now;

        } catch(Exception ex) {

            return true;

        }

    }

    public boolean isRefreshTokenExpired() {

        try {

            long now = System.currentTimeMillis();

            long refresh_expires_in = this.getResponseValueInt("refresh_expires_in", -1); // secs

            if( refresh_expires_in<0 ) {

                return true;

            }

            return time+(refresh_expires_in*1000) < now;

        } catch(Exception ex) {

            return false;

        }

    }

    private String getResponseValueString(String name) {

        if( this.jsonResponse == null ) {

            this.jsonResponse = Json.createObject(this.oauthToken.getRawResponse());

        }

        return this.jsonResponse.getString(name, null);

    }

    private int getResponseValueInt(String name, int defaultValue) {

        if( this.jsonResponse == null ) {

            this.jsonResponse = Json.createObject(this.oauthToken.getRawResponse());

        }

        return this.jsonResponse.getInt(name, defaultValue);

    }

}