org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache クラス

org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache の継承関係図

org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache 連携図

公開メンバ関数
PermissionTicket	create (String resourceId, String scopeId, String requester, ResourceServer resourceServer)
void	delete (String id)
PermissionTicket	findById (String id, String resourceServerId)
List< PermissionTicket >	findByResourceServer (String resourceServerId)
List< PermissionTicket >	findByResource (String resourceId, String resourceServerId)
List< PermissionTicket >	findByScope (String scopeId, String resourceServerId)
List< PermissionTicket >	find (Map< String, String > attributes, String resourceServerId, int firstResult, int maxResult)
List< PermissionTicket >	findGranted (String userId, String resourceServerId)
List< PermissionTicket >	findByOwner (String owner, String resourceServerId)

関数
private< R, Q extends PermissionTicketQuery > List< R >	cacheQuery (String cacheKey, Class< Q > queryType, Supplier< List< R >> resultSupplier, BiFunction< Long, List< R >, Q > querySupplier, String resourceServerId)

詳解

関数詳解

cacheQuery()

private<R, Q extends PermissionTicketQuery> List<R> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.cacheQuery ( String  cacheKey, Class< Q >  queryType, Supplier< List< R >>  resultSupplier, BiFunction< Long, List< R >, Q >  querySupplier, String  resourceServerId  )

inlinepackage

                                                                                                                                                                                                                    {
            Q query = cache.get(cacheKey, queryType);
            if (query != null) {
                logger.tracev("cache hit for key: {0}", cacheKey);
            }
            if (query == null) {
                Long loaded = cache.getCurrentRevision(cacheKey);
                List<R> model = resultSupplier.get();
                if (model == null) return null;
                if (invalidations.contains(cacheKey)) return model;
                query = querySupplier.apply(loaded, model);
                cache.addRevisioned(query, startupRevision);
                return model;
            } else if (query.isInvalid(invalidations)) {
                return resultSupplier.get();
            } else {
                return query.getPermissions().stream().map(resourceId -> (R) findById(resourceId, resourceServerId)).collect(Collectors.toList());
            }
        }

create()

PermissionTicket org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.create ( String  resourceId, String  scopeId, String  requester, ResourceServer  resourceServer  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                                                           {
            PermissionTicket created = getPermissionTicketStoreDelegate().create(resourceId, scopeId, requester, resourceServer);
            registerPermissionTicketInvalidation(created.getId(), created.getOwner(), created.getRequester(), created.getResource().getId(), scopeId, created.getResourceServer().getId());
            return created;
        }

delete()

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.delete ( String  id )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                      {
            if (id == null) return;
            PermissionTicket permission = findById(id, null);
            if (permission == null) return;

            cache.invalidateObject(id);
            String scopeId = null;
            if (permission.getScope() != null) {
                scopeId = permission.getScope().getId();
            }
            invalidationEvents.add(PermissionTicketRemovedEvent.create(id, permission.getOwner(), permission.getRequester(), permission.getResource().getId(), scopeId, permission.getResourceServer().getId()));
            cache.permissionTicketRemoval(id, permission.getOwner(), permission.getRequester(), permission.getResource().getId(), scopeId, permission.getResourceServer().getId(), invalidations);
            getPermissionTicketStoreDelegate().delete(id);
            UserManagedPermissionUtil.removePolicy(permission, StoreFactoryCacheSession.this);

        }

find()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.find ( Map< String, String >  attributes, String  resourceServerId, int  firstResult, int  maxResult  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                                                                    {
            return getPermissionTicketStoreDelegate().find(attributes, resourceServerId, firstResult, maxResult);
        }

findById()

PermissionTicket org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findById ( String  id, String  resourceServerId  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                             {
            if (id == null) return null;

            CachedPermissionTicket cached = cache.get(id, CachedPermissionTicket.class);
            if (cached != null) {
                logger.tracev("by id cache hit: {0}", cached.getId());
            }
            if (cached == null) {
                Long loaded = cache.getCurrentRevision(id);
                if (! modelMightExist(id)) return null;
                PermissionTicket model = getPermissionTicketStoreDelegate().findById(id, resourceServerId);
                if (model == null) {
                    setModelDoesNotExists(id, loaded);
                    return null;
                }
                if (invalidations.contains(id)) return model;
                cached = new CachedPermissionTicket(loaded, model);
                cache.addRevisioned(cached, startupRevision);
            } else if (invalidations.contains(id)) {
                return getPermissionTicketStoreDelegate().findById(id, resourceServerId);
            } else if (managedPermissionTickets.containsKey(id)) {
                return managedPermissionTickets.get(id);
            }
            PermissionTicketAdapter adapter = new PermissionTicketAdapter(cached, StoreFactoryCacheSession.this);
            managedPermissionTickets.put(id, adapter);
            return adapter;
        }

findByOwner()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findByOwner ( String  owner, String  resourceServerId  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                         {
            String cacheKey = getPermissionTicketByOwner(owner, resourceServerId);
            return cacheQuery(cacheKey, PermissionTicketListQuery.class, () -> getPermissionTicketStoreDelegate().findByOwner(owner, resourceServerId),
                    (revision, permissions) -> new PermissionTicketListQuery(revision, cacheKey, permissions.stream().map(permission -> permission.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

findByResource()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findByResource ( String  resourceId, String  resourceServerId  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                                 {
            String cacheKey = getPermissionTicketByResource(resourceId, resourceServerId);
            return cacheQuery(cacheKey, PermissionTicketResourceListQuery.class, () -> getPermissionTicketStoreDelegate().findByResource(resourceId, resourceServerId),
                    (revision, permissions) -> new PermissionTicketResourceListQuery(revision, cacheKey, resourceId, permissions.stream().map(permission -> permission.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

findByResourceServer()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findByResourceServer ( String  resourceServerId )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                    {
            return getPermissionTicketStoreDelegate().findByResourceServer(resourceServerId);
        }

findByScope()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findByScope ( String  scopeId, String  resourceServerId  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                           {
            String cacheKey = getPermissionTicketByScope(scopeId, resourceServerId);
            return cacheQuery(cacheKey, PermissionTicketScopeListQuery.class, () -> getPermissionTicketStoreDelegate().findByScope(scopeId, resourceServerId),
                    (revision, permissions) -> new PermissionTicketScopeListQuery(revision, cacheKey, scopeId, permissions.stream().map(permission -> permission.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

findGranted()

List<PermissionTicket> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PermissionTicketCache.findGranted ( String  userId, String  resourceServerId  )

inline

org.keycloak.authorization.store.PermissionTicketStoreを実装しています。

                                                                                          {
            String cacheKey = getPermissionTicketByGranted(userId, resourceServerId);
            return cacheQuery(cacheKey, PermissionTicketListQuery.class, () -> getPermissionTicketStoreDelegate().findGranted(userId, resourceServerId),
                    (revision, permissions) -> new PermissionTicketListQuery(revision, cacheKey, permissions.stream().map(permission -> permission.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId);
        }

---

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

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/models/cache/infinispan/authorization/StoreFactoryCacheSession.java