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

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

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

公開メンバ関数
Policy	create (AbstractPolicyRepresentation representation, ResourceServer resourceServer)
void	delete (String id)
Policy	findById (String id, String resourceServerId)
Policy	findByName (String name, String resourceServerId)
List< Policy >	findByResourceServer (String resourceServerId)
List< Policy >	findByResourceServer (Map< String, String[]> attributes, String resourceServerId, int firstResult, int maxResult)
List< Policy >	findByResource (String resourceId, String resourceServerId)
void	findByResource (String resourceId, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByResourceType (String resourceType, String resourceServerId)
void	findByResourceType (String resourceType, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByScopeIds (List< String > scopeIds, String resourceServerId)
List< Policy >	findByScopeIds (List< String > scopeIds, String resourceId, String resourceServerId)
void	findByScopeIds (List< String > scopeIds, String resourceId, String resourceServerId, Consumer< Policy > consumer)
List< Policy >	findByType (String type, String resourceServerId)
List< Policy >	findDependentPolicies (String id, String resourceServerId)

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

詳解

関数詳解

cacheQuery()

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

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);
                if (consumer != null) {
                    for (R policy: model) {
                        consumer.accept(policy);
                    }
                }
                return model;
            } else if (query.isInvalid(invalidations)) {
                List<R> policies = resultSupplier.get();

                if (consumer != null) {
                    for (R policy : policies) {
                        consumer.accept(policy);
                    }
                }

                return policies;
            } else {
                Set<String> policies = query.getPolicies();

                if (consumer != null) {
                    for (String id : policies) {
                        consumer.accept((R) findById(id, resourceServerId));
                    }

                    return null;
                }

                return policies.stream().map(resourceId -> (R) findById(resourceId, resourceServerId)).collect(Collectors.toList());
            }
        }

create()

Policy org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.create ( AbstractPolicyRepresentation  representation, ResourceServer  resourceServer  )

inline

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

                                                                                                         {
            Policy policy = getPolicyStoreDelegate().create(representation, resourceServer);
            Policy cached = findById(policy.getId(), resourceServer.getId());
            registerPolicyInvalidation(policy.getId(), representation.getName(), representation.getResources(), representation.getScopes(), null, resourceServer.getId());
            if (cached == null) {
                cached = findById(policy.getId(), resourceServer.getId());
            }
            return cached;
        }

delete()

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

inline

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

                                      {
            if (id == null) return;
            Policy policy = findById(id, null);
            if (policy == null) return;

            cache.invalidateObject(id);
            Set<String> resources = policy.getResources().stream().map(resource -> resource.getId()).collect(Collectors.toSet());
            ResourceServer resourceServer = policy.getResourceServer();
            Set<String> resourceTypes = getResourceTypes(resources, resourceServer.getId());
            String defaultResourceType = policy.getConfig().get("defaultResourceType");
            if (Objects.nonNull(defaultResourceType)) {
                resourceTypes.add(defaultResourceType);
            }
            Set<String> scopes = policy.getScopes().stream().map(scope -> scope.getId()).collect(Collectors.toSet());
            invalidationEvents.add(PolicyRemovedEvent.create(id, policy.getName(), resources, resourceTypes, scopes, resourceServer.getId()));
            cache.policyRemoval(id, policy.getName(), resources, resourceTypes, scopes, resourceServer.getId(), invalidations);
            getPolicyStoreDelegate().delete(id);

        }

findById()

Policy org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findById ( String  id, String  resourceServerId  )

inline

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

                                                                   {
            if (id == null) return null;

            CachedPolicy cached = cache.get(id, CachedPolicy.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;
                Policy model = getPolicyStoreDelegate().findById(id, resourceServerId);
                if (model == null) {
                    setModelDoesNotExists(id, loaded);
                    return null;
                }
                if (invalidations.contains(id)) return model;
                cached = new CachedPolicy(loaded, model);
                cache.addRevisioned(cached, startupRevision);
            } else if (invalidations.contains(id)) {
                return getPolicyStoreDelegate().findById(id, resourceServerId);
            } else if (managedPolicies.containsKey(id)) {
                return managedPolicies.get(id);
            }
            PolicyAdapter adapter = new PolicyAdapter(cached, StoreFactoryCacheSession.this);
            managedPolicies.put(id, adapter);
            return adapter;
        }

findByName()

Policy org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByName ( String  name, String  resourceServerId  )

inline

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

                                                                       {
            if (name == null) return null;
            String cacheKey = getPolicyByNameCacheKey(name, resourceServerId);
            List<Policy> result = cacheQuery(cacheKey, PolicyListQuery.class, () -> {
                Policy policy = getPolicyStoreDelegate().findByName(name, resourceServerId);

                if (policy == null) {
                    return Collections.emptyList();
                }

                return Arrays.asList(policy);
            }, (revision, policies) -> new PolicyListQuery(revision, cacheKey, policies.stream().map(policy -> policy.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, null);

            if (result.isEmpty()) {
                return null;
            }

            return result.get(0);
        }

findByResource() [1/2]

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

inline

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

                                                                                       {
            String cacheKey = getPolicyByResource(resourceId, resourceServerId);
            return cacheQuery(cacheKey, PolicyResourceListQuery.class, () -> getPolicyStoreDelegate().findByResource(resourceId, resourceServerId),
                    (revision, policies) -> new PolicyResourceListQuery(revision, cacheKey, resourceId, policies.stream().map(policy -> policy.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, null);
        }

findByResource() [2/2]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByResource ( String  resourceId, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

                                                                                                          {
            String cacheKey = getPolicyByResource(resourceId, resourceServerId);
            cacheQuery(cacheKey, PolicyResourceListQuery.class, () -> getPolicyStoreDelegate().findByResource(resourceId, resourceServerId),
                    (revision, policies) -> new PolicyResourceListQuery(revision, cacheKey, resourceId, policies.stream().map(policy -> policy.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
        }

findByResourceServer() [1/2]

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

inline

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

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

findByResourceServer() [2/2]

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByResourceServer ( Map< String, String[]>  attributes, String  resourceServerId, int  firstResult, int  maxResult  )

inline

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

                                                                                                                                            {
            return getPolicyStoreDelegate().findByResourceServer(attributes, resourceServerId, firstResult, maxResult);
        }

findByResourceType() [1/2]

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByResourceType ( String  resourceType, String  resourceServerId  )

inline

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

                                                                                             {
            String cacheKey = getPolicyByResourceType(resourceType, resourceServerId);
            return cacheQuery(cacheKey, PolicyResourceListQuery.class, () -> getPolicyStoreDelegate().findByResourceType(resourceType, resourceServerId),
                    (revision, policies) -> new PolicyResourceListQuery(revision, cacheKey, resourceType, policies.stream().map(policy -> policy.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, null);
        }

findByResourceType() [2/2]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByResourceType ( String  resourceType, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

                                                                                                                {
            String cacheKey = getPolicyByResourceType(resourceType, resourceServerId);
            cacheQuery(cacheKey, PolicyResourceListQuery.class, () -> getPolicyStoreDelegate().findByResourceType(resourceType, resourceServerId),
                    (revision, policies) -> new PolicyResourceListQuery(revision, cacheKey, resourceType, policies.stream().map(policy -> policy.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
        }

findByScopeIds() [1/3]

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByScopeIds ( List< String >  scopeIds, String  resourceServerId  )

inline

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

                                                                                           {
            if (scopeIds == null) return null;
            Set<Policy> result = new HashSet<>();

            for (String id : scopeIds) {
                String cacheKey = getPolicyByScope(id, resourceServerId);
                result.addAll(cacheQuery(cacheKey, PolicyScopeListQuery.class, () -> getPolicyStoreDelegate().findByScopeIds(Arrays.asList(id), resourceServerId), (revision, resources) -> new PolicyScopeListQuery(revision, cacheKey, id, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, null));
            }

            return new ArrayList<>(result);
        }

findByScopeIds() [2/3]

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByScopeIds ( List< String >  scopeIds, String  resourceId, String  resourceServerId  )

inline

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

                                                                                                              {
            if (scopeIds == null) return null;
            Set<Policy> result = new HashSet<>();

            for (String id : scopeIds) {
                String cacheKey = getPolicyByResourceScope(id, resourceId, resourceServerId);
                result.addAll(cacheQuery(cacheKey, PolicyScopeListQuery.class, () -> getPolicyStoreDelegate().findByScopeIds(Arrays.asList(id), resourceId, resourceServerId), (revision, resources) -> new PolicyScopeListQuery(revision, cacheKey, id, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, null));
            }

            return new ArrayList<>(result);
        }

findByScopeIds() [3/3]

void org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByScopeIds ( List< String >  scopeIds, String  resourceId, String  resourceServerId, Consumer< Policy >  consumer  )

inline

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

                                                                                                                                 {
            for (String id : scopeIds) {
                String cacheKey = getPolicyByResourceScope(id, resourceId, resourceServerId);
                cacheQuery(cacheKey, PolicyScopeListQuery.class, () -> getPolicyStoreDelegate().findByScopeIds(Arrays.asList(id), resourceId, resourceServerId), (revision, resources) -> new PolicyScopeListQuery(revision, cacheKey, id, resources.stream().map(resource -> resource.getId()).collect(Collectors.toSet()), resourceServerId), resourceServerId, consumer);
            }
        }

findByType()

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findByType ( String  type, String  resourceServerId  )

inline

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

                                                                             {
            return getPolicyStoreDelegate().findByType(type, resourceServerId);
        }

findDependentPolicies()

List<Policy> org.keycloak.models.cache.infinispan.authorization.StoreFactoryCacheSession.PolicyCache.findDependentPolicies ( String  id, String  resourceServerId  )

inline

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

                                                                                      {
            return getPolicyStoreDelegate().findDependentPolicies(id, resourceServerId);
        }

---

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

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