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

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

公開メンバ関数
void	persist (UmaRPT rpt)
UmaRPT	getRPTByCode (String rptCode)
void	deleteByCode (String rptCode)
void	cleanup (final Date now)
void	addPermissionToRPT (UmaRPT rpt, Collection< UmaPermission > permissions)
void	addPermissionToRPT (UmaRPT rpt, UmaPermission... permission)
List< UmaPermission >	getRptPermissions (UmaRPT p_rpt)
UmaRPT	createRPT (String clientId)
Date	rptExpirationDate ()
UmaRPT	createRPTAndPersist (String clientId)
UmaPermission	getPermissionFromRPTByResourceId (UmaRPT rpt, String resourceId)
void	addBranch (String clientDn)
void	addBranchIfNeeded (String clientDn)
boolean	containsBranch (String clientDn)

静的公開メンバ関数
static String	getDn (String clientDn, String uniqueIdentifier)
static String	branchDn (String clientDn)

静的公開変数類
static final int	DEFAULT_RPT_LIFETIME = 3600

非公開メンバ関数
Filter	getExpiredUmaRptFilter (Date date)

非公開変数類
Logger	log
PersistenceEntryManager	ldapEntryManager
TokenService	tokenService
AuthorizationGrantList	authorizationGrantList
AppConfiguration	appConfiguration
StaticConfiguration	staticConfiguration
ClientService	clientService

静的非公開変数類
static final String	ORGUNIT_OF_RPT = "uma_rpt"

詳解

RPT manager component

著者

Yuriy Zabrovarnyy

Javier Rojas Blum

バージョン

June 28, 2017

関数詳解

addBranch()

void org.xdi.oxauth.uma.service.UmaRptService.addBranch ( String  clientDn )

inline

                                           {
        final SimpleBranch branch = new SimpleBranch();
        branch.setOrganizationalUnitName(ORGUNIT_OF_RPT);
        branch.setDn(branchDn(clientDn));
        ldapEntryManager.persist(branch);
    }

addBranchIfNeeded()

void org.xdi.oxauth.uma.service.UmaRptService.addBranchIfNeeded ( String  clientDn )

inline

                                                   {
        if (!containsBranch(clientDn)) {
            addBranch(clientDn);
        }
    }

addPermissionToRPT() [1/2]

void org.xdi.oxauth.uma.service.UmaRptService.addPermissionToRPT ( UmaRPT  rpt, Collection< UmaPermission >  permissions  )

inline

                                                                                      {
        addPermissionToRPT(rpt, permissions.toArray(new UmaPermission[permissions.size()]));
    }

addPermissionToRPT() [2/2]

void org.xdi.oxauth.uma.service.UmaRptService.addPermissionToRPT ( UmaRPT  rpt, UmaPermission...  permission  )

inline

                                                                            {
        if (ArrayUtils.isEmpty(permission)) {
            return;
        }

        final List<String> permissions = new ArrayList<String>();
        if (rpt.getPermissions() != null) {
            permissions.addAll(rpt.getPermissions());
        }

        for (UmaPermission p : permission) {
            permissions.add(p.getDn());
        }

        rpt.setPermissions(permissions);

        try {
            ldapEntryManager.merge(rpt);
            log.trace("Persisted RPT: " + rpt);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }

branchDn()

static String org.xdi.oxauth.uma.service.UmaRptService.branchDn ( String  clientDn )

inlinestatic

                                                   {
        return String.format("ou=%s,%s", ORGUNIT_OF_RPT, clientDn);
    }

cleanup()

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

inline

                                        {
        BatchOperation<UmaRPT> rptBatchService = new ProcessBatchOperation<UmaRPT>() {
            @Override
            public void performAction(List<UmaRPT> entries) {
                for (UmaRPT p : entries) {
                    try {
                        ldapEntryManager.remove(p);
                    } catch (Exception e) {
                        log.error("Failed to remove entry", e);
                    }
                }
            }
        };
        ldapEntryManager.findEntries(staticConfiguration.getBaseDn().getClients(), UmaRPT.class, getExpiredUmaRptFilter(now), SearchScope.SUB, new String[] { "" }, rptBatchService, 0, 0, CleanerTimer.BATCH_SIZE);
    }

containsBranch()

boolean org.xdi.oxauth.uma.service.UmaRptService.containsBranch ( String  clientDn )

inline

                                                   {
        return ldapEntryManager.contains(SimpleBranch.class, branchDn(clientDn));
    }

createRPT()

UmaRPT org.xdi.oxauth.uma.service.UmaRptService.createRPT ( String  clientId )

inline

                                             {
        try {
            String code = UUID.randomUUID().toString() + "_" + INumGenerator.generate(8);
            return new UmaRPT(code, new Date(), rptExpirationDate(), null, clientId);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
            throw new RuntimeException("Failed to generate RPT, clientId: " + clientId, e);
        }
    }

createRPTAndPersist()

UmaRPT org.xdi.oxauth.uma.service.UmaRptService.createRPTAndPersist ( String  clientId )

inline

                                                       {
        UmaRPT rpt = createRPT(clientId);
        persist(rpt);
        return rpt;
    }

deleteByCode()

void org.xdi.oxauth.uma.service.UmaRptService.deleteByCode ( String  rptCode )

inline

                                             {
        try {
            final UmaRPT t = getRPTByCode(rptCode);
            if (t != null) {
                ldapEntryManager.remove(t);
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }

getDn()

static String org.xdi.oxauth.uma.service.UmaRptService.getDn ( String  clientDn, String  uniqueIdentifier  )

inlinestatic

                                                                         {
        return String.format("uniqueIdentifier=%s,%s", uniqueIdentifier, branchDn(clientDn));
    }

getExpiredUmaRptFilter()

Filter org.xdi.oxauth.uma.service.UmaRptService.getExpiredUmaRptFilter ( Date  date )

inlineprivate

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

getPermissionFromRPTByResourceId()

UmaPermission org.xdi.oxauth.uma.service.UmaRptService.getPermissionFromRPTByResourceId ( UmaRPT  rpt, String  resourceId  )

inline

                                                                                         {
        try {
            if (Util.allNotBlank(resourceId)) {
                 for (UmaPermission permission : getRptPermissions(rpt)) {
                    if (resourceId.equals(permission.getResourceId())) {
                        return permission;
                    }
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return null;
    }

getRPTByCode()

UmaRPT org.xdi.oxauth.uma.service.UmaRptService.getRPTByCode ( String  rptCode )

inline

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

getRptPermissions()

List<UmaPermission> org.xdi.oxauth.uma.service.UmaRptService.getRptPermissions ( UmaRPT  p_rpt )

inline

                                                               {
        final List<UmaPermission> result = new ArrayList<UmaPermission>();
        try {
            if (p_rpt != null && p_rpt.getPermissions() != null) {
                final List<String> permissionDns = p_rpt.getPermissions();
                for (String permissionDn : permissionDns) {
                    final UmaPermission permissionObject = ldapEntryManager.find(UmaPermission.class, permissionDn);
                    if (permissionObject != null) {
                        result.add(permissionObject);
                    }
                }
            }
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return result;
    }

persist()

void org.xdi.oxauth.uma.service.UmaRptService.persist ( UmaRPT  rpt )

inline

                                    {
        try {
            Preconditions.checkNotNull(rpt.getClientId());

            Client client = clientService.getClient(rpt.getClientId());

            addBranchIfNeeded(client.getDn());
            String id = UUID.randomUUID().toString();
            rpt.setId(id);
            rpt.setDn(getDn(client.getDn(), id));
            ldapEntryManager.persist(rpt);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
    }

rptExpirationDate()

Date org.xdi.oxauth.uma.service.UmaRptService.rptExpirationDate ( )

inline

                                    {
        int lifeTime = appConfiguration.getUmaRptLifetime();
        if (lifeTime <= 0) {
            lifeTime = DEFAULT_RPT_LIFETIME;
        }

        final Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.SECOND, lifeTime);
        return calendar.getTime();
    }

メンバ詳解

appConfiguration

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

private

authorizationGrantList

AuthorizationGrantList org.xdi.oxauth.uma.service.UmaRptService.authorizationGrantList

private

clientService

ClientService org.xdi.oxauth.uma.service.UmaRptService.clientService

private

DEFAULT_RPT_LIFETIME

final int org.xdi.oxauth.uma.service.UmaRptService.DEFAULT_RPT_LIFETIME = 3600

static

ldapEntryManager

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

private

log

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

private

ORGUNIT_OF_RPT

final String org.xdi.oxauth.uma.service.UmaRptService.ORGUNIT_OF_RPT = "uma_rpt"

staticprivate

staticConfiguration

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

private

tokenService

TokenService org.xdi.oxauth.uma.service.UmaRptService.tokenService

private

---

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

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