org.keycloak.storage.ldap.LDAPIdentityStoreRegistry クラス

org.keycloak.storage.ldap.LDAPIdentityStoreRegistry 連携図

クラス
class	LDAPIdentityStoreContext

公開メンバ関数
LDAPIdentityStore	getLdapStore (KeycloakSession session, ComponentModel ldapModel, Map< ComponentModel, LDAPConfigDecorator > configDecorators)

静的公開メンバ関数
static LDAPIdentityStore	createLdapIdentityStore (LDAPConfig cfg)

非公開メンバ関数
void	logLDAPConfig (KeycloakSession session, ComponentModel ldapModel, LDAPConfig ldapConfig)

静的非公開メンバ関数
static void	checkSystemProperty (String name, String cfgValue, String defaultValue)

非公開変数類
Map< String, LDAPIdentityStoreContext >	ldapStores = new ConcurrentHashMap<>()

静的非公開変数類
static final Logger	logger = Logger.getLogger(LDAPIdentityStoreRegistry.class)

詳解

著者

Marek Posolda

関数詳解

checkSystemProperty()

static void org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.checkSystemProperty ( String  name, String  cfgValue, String  defaultValue  )

inlinestaticprivate

                                                                                               {
        String value = System.getProperty(name);
        if(cfgValue != null) {
            value = cfgValue;
        }
        if(value == null) {
            value = defaultValue;
        }
        System.setProperty(name, value);
    }

createLdapIdentityStore()

static LDAPIdentityStore org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.createLdapIdentityStore ( LDAPConfig  cfg )

inlinestatic

Create LDAPIdentityStore to be cached in the local registry

                                                                            {
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.authentication", cfg.getConnectionPoolingAuthentication(), "none simple");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.initsize", cfg.getConnectionPoolingInitSize(), "1");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.maxsize", cfg.getConnectionPoolingMaxSize(), "1000");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.prefsize", cfg.getConnectionPoolingPrefSize(), "5");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.timeout", cfg.getConnectionPoolingTimeout(), "300000");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.protocol", cfg.getConnectionPoolingProtocol(), "plain");
        checkSystemProperty("com.sun.jndi.ldap.connect.pool.debug", cfg.getConnectionPoolingDebug(), "off");

        return new LDAPIdentityStore(cfg);
    }

getLdapStore()

LDAPIdentityStore org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.getLdapStore ( KeycloakSession  session, ComponentModel  ldapModel, Map< ComponentModel, LDAPConfigDecorator >  configDecorators  )

inline

                                                                                                                                                        {
        LDAPIdentityStoreContext context = ldapStores.get(ldapModel.getId());

        // Ldap config might have changed for the realm. In this case, we must re-initialize
        MultivaluedHashMap<String, String> configModel = ldapModel.getConfig();
        LDAPConfig ldapConfig = new LDAPConfig(configModel);
        for (Map.Entry<ComponentModel, LDAPConfigDecorator> entry : configDecorators.entrySet()) {
            ComponentModel mapperModel = entry.getKey();
            LDAPConfigDecorator decorator = entry.getValue();

            decorator.updateLDAPConfig(ldapConfig, mapperModel);
        }

        if (context == null || !ldapConfig.equals(context.config)) {
            logLDAPConfig(session, ldapModel, ldapConfig);

            LDAPIdentityStore store = createLdapIdentityStore(ldapConfig);
            context = new LDAPIdentityStoreContext(ldapConfig, store);
            ldapStores.put(ldapModel.getId(), context);
        }
        return context.store;
    }

logLDAPConfig()

void org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.logLDAPConfig ( KeycloakSession  session, ComponentModel  ldapModel, LDAPConfig  ldapConfig  )

inlineprivate

                                                                                                         {
        logger.infof("Creating new LDAP Store for the LDAP storage provider: '%s', LDAP Configuration: %s", ldapModel.getName(), ldapConfig.toString());

        if (logger.isDebugEnabled()) {
            RealmModel realm = session.realms().getRealm(ldapModel.getParentId());
            List<ComponentModel> mappers = realm.getComponents(ldapModel.getId());
            mappers.stream().forEach((ComponentModel c) -> {

                logger.debugf("Mapper for provider: %s, Mapper name: %s, Provider: %s, Mapper configuration: %s", ldapModel.getName(), c.getName(), c.getProviderId(), c.getConfig().toString());

            });
        }
    }

メンバ詳解

ldapStores

Map<String, LDAPIdentityStoreContext> org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.ldapStores = new ConcurrentHashMap<>()

private

logger

final Logger org.keycloak.storage.ldap.LDAPIdentityStoreRegistry.logger = Logger.getLogger(LDAPIdentityStoreRegistry.class)

staticprivate

---

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

• D:/AppData/doxygen/keycloak/federation/src/federation/ldap/src/main/java/org/keycloak/storage/ldap/LDAPIdentityStoreRegistry.java