org.xdi.oxauth.uma.service.UmaPctService クラス

org.xdi.oxauth.uma.service.UmaPctService 連携図

公開メンバ関数
UmaPCT	updateClaims (UmaPCT pct, Jwt idToken, String clientId, List< UmaPermission > permissions)
UmaPCT	getByCode (String pctCode)
UmaPCT	createPct (String clientId)
UmaPCT	createPctAndPersist (String clientId)
int	pctLifetime ()
void	persist (UmaPCT pct)
void	remove (UmaPCT umaPCT)
void	remove (String pctCode)
void	remove (List< UmaPCT > pctList)
void	addBranch ()
String	dn (String pctCode)
String	branchBaseDn ()
void	cleanup (final Date now)
void	merge (UmaPCT pct)

静的公開変数類
static final int	DEFAULT_PCT_LIFETIME = 2592000

非公開メンバ関数
void	prepareBranch ()
Filter	gethExpiredUmaPctFilter (Date date)

非公開変数類
Logger	log
PersistenceEntryManager	ldapEntryManager
StaticConfiguration	staticConfiguration
AppConfiguration	appConfiguration

詳解

著者

yuriyz on 05/31/2017.

関数詳解

addBranch()

void org.xdi.oxauth.uma.service.UmaPctService.addBranch ( )

inline

                            {
        SimpleBranch branch = new SimpleBranch();
        branch.setOrganizationalUnitName("pct");
        branch.setDn(branchBaseDn());

        ldapEntryManager.persist(branch);
    }

branchBaseDn()

String org.xdi.oxauth.uma.service.UmaPctService.branchBaseDn ( )

inline

                                 {
        final String umaBaseDn = staticConfiguration.getBaseDn().getUmaBase(); // "ou=uma,o=@!1111,o=gluu"
        return String.format("ou=pct,%s", umaBaseDn);
    }

cleanup()

void org.xdi.oxauth.uma.service.UmaPctService.cleanup ( final Date  now )

inline

                                        {
        prepareBranch();

        BatchOperation<UmaPCT> batchService = new ProcessBatchOperation<UmaPCT>() {
            @Override
            public void performAction(List<UmaPCT> entries) {
                for (UmaPCT p : entries) {
                    try {
                        remove(p);
                    } catch (Exception e) {
                        log.error("Failed to remove entry", e);
                    }
                }
            }

        };
        ldapEntryManager.findEntries(branchBaseDn(), UmaPCT.class, gethExpiredUmaPctFilter(now), SearchScope.SUB, new String[] { "" }, batchService, 0, 0, CleanerTimer.BATCH_SIZE);
    }

createPct()

UmaPCT org.xdi.oxauth.uma.service.UmaPctService.createPct ( String  clientId )

inline

                                             {
        String code = UUID.randomUUID().toString() + "_" + INumGenerator.generate(8);

        UmaPCT pct = new UmaPCT(pctLifetime());
        pct.setCode(code);
        pct.setDn(dn(pct.getCode()));
        pct.setClientId(clientId);
        return pct;
    }

createPctAndPersist()

UmaPCT org.xdi.oxauth.uma.service.UmaPctService.createPctAndPersist ( String  clientId )

inline

                                                       {
        UmaPCT pct = createPct(clientId);
        persist(pct);
        return pct;
    }

dn()

String org.xdi.oxauth.uma.service.UmaPctService.dn ( String  pctCode )

inline

                                     {
        if (StringUtils.isBlank(pctCode)) {
            throw new IllegalArgumentException("PCT code is null or blank.");
        }
        return String.format("oxAuthTokenCode=%s,%s", pctCode, branchBaseDn());
    }

getByCode()

UmaPCT org.xdi.oxauth.uma.service.UmaPctService.getByCode ( String  pctCode )

inline

                                            {
        try {
            final Filter filter = Filter.create(String.format("&(oxAuthTokenCode=%s)", pctCode));
            final List<UmaPCT> entries = ldapEntryManager.findEntries(branchBaseDn(), UmaPCT.class, filter);
            if (entries != null && !entries.isEmpty()) {
                return entries.get(0);
            } else {
                log.error("Failed to find PCT by code: " + pctCode);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }

gethExpiredUmaPctFilter()

Filter org.xdi.oxauth.uma.service.UmaPctService.gethExpiredUmaPctFilter ( Date  date )

inlineprivate

                                                      {
        return Filter.createLessOrEqualFilter("oxAuthExpiration", ldapEntryManager.encodeTime(date));
    }

merge()

void org.xdi.oxauth.uma.service.UmaPctService.merge ( UmaPCT  pct )

inline

                                  {
        try {
            ldapEntryManager.merge(pct);
        } catch (Exception e) {
            log.error("Failed to merge PCT, code: " + pct.getCode() + ". " + e.getMessage(), e);
        }
    }

pctLifetime()

int org.xdi.oxauth.uma.service.UmaPctService.pctLifetime ( )

inline

                             {
        int lifeTime = appConfiguration.getUmaPctLifetime();
        if (lifeTime <= 0) {
            lifeTime = DEFAULT_PCT_LIFETIME;
        }
        return lifeTime;
    }

persist()

void org.xdi.oxauth.uma.service.UmaPctService.persist ( UmaPCT  pct )

inline

                                    {
        try {
            prepareBranch();

            pct.setDn(dn(pct.getCode()));
            ldapEntryManager.persist(pct);
        } catch (Exception e) {
            log.error("Failed to persist PCT, code: " + pct.getCode() + ". " + e.getMessage(), e);
        }
    }

prepareBranch()

void org.xdi.oxauth.uma.service.UmaPctService.prepareBranch ( )

inlineprivate

                                 {
        if (!ldapEntryManager.contains(SimpleBranch.class, branchBaseDn())) {
            addBranch();
        }
    }

remove() [1/3]

void org.xdi.oxauth.uma.service.UmaPctService.remove ( UmaPCT  umaPCT )

inline

                                      {
        ldapEntryManager.remove(umaPCT);
    }

remove() [2/3]

void org.xdi.oxauth.uma.service.UmaPctService.remove ( String  pctCode )

inline

                                       {
        remove(getByCode(pctCode));
    }

remove() [3/3]

void org.xdi.oxauth.uma.service.UmaPctService.remove ( List< UmaPCT >  pctList )

inline

                                             {
        for (UmaPCT pct : pctList) {
            remove(pct);
        }
    }

updateClaims()

UmaPCT org.xdi.oxauth.uma.service.UmaPctService.updateClaims ( UmaPCT  pct, Jwt  idToken, String  clientId, List< UmaPermission >  permissions  )

inline

                                                                                                          {
        try {
            String ticketPctCode = permissions.get(0).getAttributes().get("pct");
            UmaPCT ticketPct = StringUtils.isNotBlank(ticketPctCode) ? getByCode(ticketPctCode) : null;

            boolean hasPct = pct != null;

            if (!hasPct) {
                if (ticketPct != null) {
                    pct = ticketPct;
                } else {
                    pct = createPctAndPersist(clientId);
                }
            }

            // copy claims from pctTicket into normal pct
            JwtClaims pctClaims = pct.getClaims();
            if (ticketPct != null && hasPct) {
                JwtClaims ticketClaims = ticketPct.getClaims();
                for (String key : ticketClaims.keys()) {
                    pctClaims.setClaimObject(key, ticketClaims.getClaim(key), false);
                }
                pct = ticketPct;
            }

            if (idToken != null && idToken.getClaims() != null) {
                for (String key : idToken.getClaims().keys()) {
                    pctClaims.setClaimObject(key, idToken.getClaims().getClaim(key), false);
                }
            }

            pct.setClaims(pctClaims);
            log.trace("PCT code: " + pct.getCode() + ", claims: " + pct.getClaimValuesAsJson());

            return ldapEntryManager.merge(pct);
        } catch (Exception e) {
            log.error("Failed to update PCT claims. " + e.getMessage(), e);
        }

        return pct;
    }

メンバ詳解

appConfiguration

AppConfiguration org.xdi.oxauth.uma.service.UmaPctService.appConfiguration

private

DEFAULT_PCT_LIFETIME

final int org.xdi.oxauth.uma.service.UmaPctService.DEFAULT_PCT_LIFETIME = 2592000

static

ldapEntryManager

PersistenceEntryManager org.xdi.oxauth.uma.service.UmaPctService.ldapEntryManager

private

log

Logger org.xdi.oxauth.uma.service.UmaPctService.log

private

staticConfiguration

StaticConfiguration org.xdi.oxauth.uma.service.UmaPctService.staticConfiguration

private

---

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

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/main/java/org/xdi/oxauth/uma/service/UmaPctService.java