org.xdi.oxd.server.service.RpService クラス

org.xdi.oxd.server.service.RpService 連携図

公開メンバ関数
	RpService (ValidationService validationService, PersistenceService persistenceService, ConfigurationService configurationService)
void	removeAllRps ()
void	load ()
Rp	getRp (String oxdId)
Rp	getFirstSetupClient ()
Rp	getRpByClientId (String clientId)
Map< String, Rp >	getRps ()
void	update (Rp rp) throws IOException
void	updateSilently (Rp rp)
void	create (Rp rp) throws IOException
boolean	remove (String oxdId)

非公開メンバ関数
void	checkClientExpiredWithException (Rp rp)
boolean	checkClientExpired (Rp rp)
Rp	put (Rp rp)

非公開変数類
final Map< String, Rp >	rpMap = Maps.newConcurrentMap()
ValidationService	validationService
PersistenceService	persistenceService
ConfigurationService	configurationService

静的非公開変数類
static final Logger	LOG = LoggerFactory.getLogger(RpService.class)

詳解

著者

Yuriy Zabrovarnyy

構築子と解体子

RpService()

org.xdi.oxd.server.service.RpService.RpService ( ValidationService  validationService, PersistenceService  persistenceService, ConfigurationService  configurationService  )

inline

                                                                                                                                            {
        this.validationService = validationService;
        this.persistenceService = persistenceService;
        this.configurationService = configurationService;
    }

関数詳解

checkClientExpired()

boolean org.xdi.oxd.server.service.RpService.checkClientExpired ( Rp  rp )

inlineprivate

                                              {
        if (CoreUtils.isExpired(rp.getClientSecretExpiresAt())) {
            try {
                Boolean removeExpiredClients = configurationService.get().getRemoveExpiredClients();
                if (removeExpiredClients != null && removeExpiredClients) {
                    LOG.debug("Removing client because it's expired ... rp: " + rp);
                    rpMap.remove(rp.getOxdId());
                    persistenceService.remove(rp.getOxdId());
                    LOG.debug("Removed client because it's expired, rp: " + rp);
                }
            } catch (Exception e) {
                LOG.error("Failed to remove expired client, rp: " + rp, e);
            }
            return true;
        }
        return false;
    }

checkClientExpiredWithException()

void org.xdi.oxd.server.service.RpService.checkClientExpiredWithException ( Rp  rp )

inlineprivate

                                                        {
        if (checkClientExpired(rp)) {
            throw new ErrorResponseException(ErrorResponseCode.EXPIRED_CLIENT);
        }
    }

create()

void org.xdi.oxd.server.service.RpService.create ( Rp  rp ) throws IOException

inline

                                                 {
        if (StringUtils.isBlank(rp.getOxdId())) {
            rp.setOxdId(UUID.randomUUID().toString());
        }

        if (rpMap.get(rp.getOxdId()) == null) {
            put(rp);
            persistenceService.create(rp);
        } else {
            LOG.error("RP already exists in database, oxd_id: " + rp.getOxdId());
        }
    }

getFirstSetupClient()

Rp org.xdi.oxd.server.service.RpService.getFirstSetupClient ( )

inline

                                    {
        for (Rp rp : rpMap.values()) {
            try {
                if (rp.getSetupClient() != null && rp.getSetupClient()) {
                    checkClientExpiredWithException(rp);
                    return rp;
                }
            } catch (Throwable e) {// ignore
            }
        }
        return null;
    }

getRp()

Rp org.xdi.oxd.server.service.RpService.getRp ( String  oxdId )

inline

                                  {
        Preconditions.checkNotNull(oxdId);
        Preconditions.checkState(!Strings.isNullOrEmpty(oxdId));

        Rp rp = rpMap.get(oxdId);
        if (rp == null) {
            rp = persistenceService.getRp(oxdId);
            if (rp != null) {
                rpMap.put(oxdId, rp);
            }
        }
        rp = validationService.validate(rp);
        checkClientExpiredWithException(rp);
        return rp;
    }

getRpByClientId()

Rp org.xdi.oxd.server.service.RpService.getRpByClientId ( String  clientId )

inline

                                               {
        for (Rp rp : rpMap.values()) {
            if (StringUtils.isNotBlank(rp.getClientId()) && rp.getClientId().equalsIgnoreCase(clientId)) {
                return rp;
            }
        }
        return null;
    }

getRps()

Map<String, Rp> org.xdi.oxd.server.service.RpService.getRps ( )

inline

                                    {
        return Maps.newHashMap(rpMap);
    }

load()

void org.xdi.oxd.server.service.RpService.load ( )

inline

                       {
        for (Rp rp : persistenceService.getRps()) {
            put(rp);
        }
    }

put()

Rp org.xdi.oxd.server.service.RpService.put ( Rp  rp )

inlineprivate

                          {
        return rpMap.put(rp.getOxdId(), rp);
    }

remove()

boolean org.xdi.oxd.server.service.RpService.remove ( String  oxdId )

inline

                                        {
        boolean ok = persistenceService.remove(oxdId);
        if (ok) {
            rpMap.remove(oxdId);
        }
        return ok;
    }

removeAllRps()

void org.xdi.oxd.server.service.RpService.removeAllRps ( )

inline

                               {
        persistenceService.removeAllRps();
    }

update()

void org.xdi.oxd.server.service.RpService.update ( Rp  rp ) throws IOException

inline

                                                 {
        put(rp);
        persistenceService.update(rp);
    }

updateSilently()

void org.xdi.oxd.server.service.RpService.updateSilently ( Rp  rp )

inline

                                      {
        try {
            update(rp);
        } catch (IOException e) {
            LOG.error("Failed to update site configuration: " + rp, e);
        }
    }

メンバ詳解

configurationService

ConfigurationService org.xdi.oxd.server.service.RpService.configurationService

private

LOG

final Logger org.xdi.oxd.server.service.RpService.LOG = LoggerFactory.getLogger(RpService.class)

staticprivate

Logger

persistenceService

PersistenceService org.xdi.oxd.server.service.RpService.persistenceService

private

rpMap

final Map<String, Rp> org.xdi.oxd.server.service.RpService.rpMap = Maps.newConcurrentMap()

private

validationService

ValidationService org.xdi.oxd.server.service.RpService.validationService

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxd/oxd-server/src/main/java/org/xdi/oxd/server/service/RpService.java