X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.enterprise%2Fsrc%2Forg%2Fargeo%2Fosgi%2Fuseradmin%2FUserAdminConf.java;h=b3ead140c7b5aa641418d5ec54ca204ed853f585;hb=54e74b900b1c0f7b1de0def771de35e50a8d4071;hp=19426b6c5c072a8ee22108d22429597e0e1aa8a8;hpb=5b0051363ebe9bcf34282a3cd76e65b12166e073;p=lgpl%2Fargeo-commons.git diff --git a/org.argeo.enterprise/src/org/argeo/osgi/useradmin/UserAdminConf.java b/org.argeo.enterprise/src/org/argeo/osgi/useradmin/UserAdminConf.java index 19426b6c5..b3ead140c 100644 --- a/org.argeo.enterprise/src/org/argeo/osgi/useradmin/UserAdminConf.java +++ b/org.argeo.enterprise/src/org/argeo/osgi/useradmin/UserAdminConf.java @@ -4,6 +4,7 @@ import java.io.IOException; import java.net.InetAddress; import java.net.URI; import java.net.URISyntaxException; +import java.net.UnknownHostException; import java.util.Dictionary; import java.util.Enumeration; import java.util.Hashtable; @@ -48,6 +49,11 @@ public enum UserAdminConf { public final static String FACTORY_PID = "org.argeo.osgi.useradmin.config"; private final static Log log = LogFactory.getLog(UserAdminConf.class); + public final static String SCHEME_LDAP = "ldap"; + public final static String SCHEME_FILE = "file"; + public final static String SCHEME_OS = "os"; + public final static String SCHEME_IPA = "ipa"; + /** The default value. */ private Object def; @@ -124,28 +130,33 @@ public enum UserAdminConf { Hashtable res = new Hashtable(); URI u = new URI(uriStr); String scheme = u.getScheme(); - if (scheme != null && scheme.equals("ipa")) { + if (scheme != null && scheme.equals(SCHEME_IPA)) { u = convertIpaConfig(u); scheme = u.getScheme(); } String path = u.getPath(); // base DN String bDn = path.substring(path.lastIndexOf('/') + 1, path.length()); + if (bDn.equals("") && SCHEME_OS.equals(scheme)) { + bDn = getBaseDnFromHostname(); + } + if (bDn.endsWith(".ldif")) bDn = bDn.substring(0, bDn.length() - ".ldif".length()); String principal = null; String credentials = null; if (scheme != null) - if (scheme.equals("ldap") || scheme.equals("ldaps")) { + if (scheme.equals(SCHEME_LDAP) || scheme.equals("ldaps")) { // TODO additional checks if (u.getUserInfo() != null) { String[] userInfo = u.getUserInfo().split(":"); principal = userInfo.length > 0 ? userInfo[0] : null; credentials = userInfo.length > 1 ? userInfo[1] : null; } - } else if (scheme.equals("file")) { - } else if (scheme.equals("ipa")) { + } else if (scheme.equals(SCHEME_FILE)) { + } else if (scheme.equals(SCHEME_IPA)) { + } else if (scheme.equals(SCHEME_OS)) { } else throw new UserDirectoryException("Unsupported scheme " + scheme); Map> query = NamingUtils.queryToMap(u); @@ -159,14 +170,20 @@ public enum UserAdminConf { } } res.put(baseDn.name(), bDn); + if (SCHEME_OS.equals(scheme)) + res.put(readOnly.name(), "true"); if (principal != null) res.put(Context.SECURITY_PRINCIPAL, principal); if (credentials != null) res.put(Context.SECURITY_CREDENTIALS, credentials); if (scheme != null) {// relative URIs are dealt with externally - URI bareUri = new URI(scheme, null, u.getHost(), u.getPort(), - scheme.equals("file") ? u.getPath() : null, null, null); - res.put(uri.name(), bareUri.toString()); + if (SCHEME_OS.equals(scheme)) { + res.put(uri.name(), SCHEME_OS + ":///"); + } else { + URI bareUri = new URI(scheme, null, u.getHost(), u.getPort(), + scheme.equals(SCHEME_FILE) ? u.getPath() : null, null, null); + res.put(uri.name(), bareUri.toString()); + } } return res; } catch (Exception e) { @@ -196,7 +213,7 @@ public enum UserAdminConf { } } URI convertedUri = new URI( - "ldap://" + ldapHostsStr + "/" + IpaUtils.domainToUserDirectoryConfigPath(kerberosRealm)); + SCHEME_LDAP + "://" + ldapHostsStr + "/" + IpaUtils.domainToUserDirectoryConfigPath(kerberosRealm)); if (log.isDebugEnabled()) log.debug("Converted " + uri + " to " + convertedUri); return convertedUri; @@ -219,38 +236,22 @@ public enum UserAdminConf { } - // private static Map> splitQuery(String query) throws - // UnsupportedEncodingException { - // final Map> query_pairs = new LinkedHashMap>(); - // if (query == null) - // return query_pairs; - // final String[] pairs = query.split("&"); - // for (String pair : pairs) { - // final int idx = pair.indexOf("="); - // final String key = idx > 0 ? URLDecoder.decode(pair.substring(0, idx), - // "UTF-8") : pair; - // if (!query_pairs.containsKey(key)) { - // query_pairs.put(key, new LinkedList()); - // } - // final String value = idx > 0 && pair.length() > idx + 1 - // ? URLDecoder.decode(pair.substring(idx + 1), "UTF-8") : null; - // query_pairs.get(key).add(value); - // } - // return query_pairs; - // } - - public static void main(String[] args) { - Dictionary props = uriAsProperties("ldap://" + "uid=admin,ou=system:secret@localhost:10389" - + "/dc=example,dc=com" + "?readOnly=false&userObjectClass=person"); - System.out.println(props); - System.out.println(propertiesAsUri(props)); - - System.out.println(uriAsProperties("file://some/dir/dc=example,dc=com.ldif")); - - props = uriAsProperties( - "/dc=example,dc=com.ldif?readOnly=true" + "&userBase=ou=CoWorkers,ou=People&groupBase=ou=Roles"); - System.out.println(props); - System.out.println(propertiesAsUri(props)); + private static String getBaseDnFromHostname() { + String hostname; + try { + hostname = InetAddress.getLocalHost().getHostName(); + } catch (UnknownHostException e) { + log.warn("Using localhost as hostname", e); + hostname = "localhost.localdomain"; + } + int dotIdx = hostname.indexOf('.'); + if (dotIdx >= 0) { + String domain = hostname.substring(dotIdx + 1, hostname.length()); + String bDn = ("." + domain).replaceAll("\\.", ",dc="); + bDn = bDn.substring(1, bDn.length()); + return bDn; + } else { + return "dc=" + hostname; + } } }