cqrenet/mxids
3
0
Fork 0
Code Pull Requests 10 Actions Releases Activity

Handle multiple LDAP entries in results

Browse Source
This commit is contained in:
Maxime Dor
2017-06-27 00:10:37 +02:00
parent d44d6c5408
commit acb9407450
1 changed files with 28 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/main/groovy/io/kamax/mxisd/lookup/provider/LdapProvider.groovy
View File

@@ -28,6 +28,7 @@ import org.apache.commons.lang.StringUtils
import org.apache.directory.api.ldap.model.cursor.CursorLdapReferralException
import org.apache.directory.api.ldap.model.cursor.EntryCursor
import org.apache.directory.api.ldap.model.entry.Attribute
import org.apache.directory.api.ldap.model.entry.Entry
import org.apache.directory.api.ldap.model.message.SearchScope
import org.apache.directory.ldap.client.api.LdapConnection
import org.apache.directory.ldap.client.api.LdapNetworkConnection
@@ -75,13 +76,20 @@ class LdapProvider implements IThreePidProvider {
String searchQuery = queryOpt.get().replaceAll("%3pid", value)
EntryCursor cursor = conn.search(ldapCfg.getBaseDn(), searchQuery, SearchScope.SUBTREE, ldapCfg.getAttribute())
try {
if (cursor.next()) {
Attribute attribute = cursor.get().get(ldapCfg.getAttribute())
if (attribute != null) {
while (cursor.next()) {
Entry entry = cursor.get()
log.info("Found possible match, DN: {}", entry.getDn().getName())
Attribute attribute = entry.get(ldapCfg.getAttribute())
if (attribute == null) {
log.info("DN {}: no attribute {}, skpping", ldapCfg.getAttribute())
continue
}
String data = attribute.get().toString()
if (data.length() < 1) {
log.warn("Bind was found but value is empty")
return Optional.empty()
log.info("DN {}: empty attribute {}, skipping", ldapCfg.getAttribute())
continue
}
StringBuilder matrixId = new StringBuilder()
@@ -91,14 +99,13 @@ class LdapProvider implements IThreePidProvider {
} else if (StringUtils.equals(MATRIX_ID, ldapCfg.getType())) {
matrixId.append(data)
} else {
log.warn("Bind was found but type ${ldapCfg.getType()} is not supported")
return Optional.empty()
log.warn("Bind was found but type {} is not supported", ldapCfg.getType())
continue
}
log.info("Found a match in LDAP")
log.info("DN {} is a valid match", entry.getDn().getName())
return Optional.of(matrixId.toString())
}
}
} catch (CursorLdapReferralException e) {
log.warn("3PID {} is only available via referral, skipping", value)
} finally {