X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fkernel%2FNodeDeployConfig.java;fp=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Finternal%2Fkernel%2FNodeDeployConfig.java;h=85906b092162c31af6bbc2bf2c2f6c50160546c1;hb=3400a80f88b418c598bf30f27b13ce1360902376;hp=0000000000000000000000000000000000000000;hpb=ee5aea67d92a71fc4cbb0ed1c11fe5f2c0280196;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeDeployConfig.java b/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeDeployConfig.java
new file mode 100644
index 000000000..85906b092
--- /dev/null
+++ b/org.argeo.cms/src/org/argeo/cms/internal/kernel/NodeDeployConfig.java
@@ -0,0 +1,100 @@
+package org.argeo.cms.internal.kernel;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Writer;
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.Dictionary;
+import java.util.Hashtable;
+import java.util.SortedMap;
+import java.util.function.Function;
+
+import javax.naming.InvalidNameException;
+import javax.naming.directory.Attributes;
+import javax.naming.ldap.LdapName;
+
+import org.argeo.cms.CmsException;
+import org.argeo.node.NodeConstants;
+import org.argeo.node.RepoConf;
+import org.argeo.util.naming.AttributesDictionary;
+import org.argeo.util.naming.LdifParser;
+import org.argeo.util.naming.LdifWriter;
+
+class NodeDeployConfig {
+	private final String BASE = "ou=deploy,ou=node";
+	private final Path path;
+	private final Function<String, String> getter;
+
+	private final SortedMap<LdapName, Attributes> configurations;
+
+	public NodeDeployConfig(Function<String, String> getter) {
+		String osgiConfigurationArea = getter.apply(KernelUtils.OSGI_CONFIGURATION_AREA);
+		try {
+			this.path = Paths.get(new URI(osgiConfigurationArea));
+		} catch (URISyntaxException e) {
+			throw new IllegalArgumentException("Cannot parse " + getter.apply(KernelUtils.OSGI_CONFIGURATION_AREA), e);
+		}
+		this.getter = getter;
+
+		if (!Files.exists(path))
+			try (Writer writer = Files.newBufferedWriter(path)) {
+				Files.createFile(path);
+				LdifWriter ldifWriter = new LdifWriter(writer);
+			} catch (IOException e) {
+				throw new CmsException("Cannot create " + path, e);
+			}
+		
+		try (InputStream in = Files.newInputStream(path)) {
+			configurations = new LdifParser().read(in);
+		} catch (IOException e) {
+			throw new CmsException("Cannot read " + path, e);
+		}
+	}
+
+	public Dictionary<String, Object> getConfiguration(String servicePid) {
+		LdapName dn;
+		try {
+			dn = new LdapName("ou=" + servicePid + "," + BASE);
+		} catch (InvalidNameException e) {
+			throw new IllegalArgumentException("Cannot parse DN", e);
+		}
+		if (configurations.containsKey(dn))
+			return new AttributesDictionary(configurations.get(dn));
+		else
+			return null;
+	}
+	
+	static Dictionary<String, Object> getStatePropertiesFromEnvironment(Function<String, String> getter) {
+		Hashtable<String, Object> props = new Hashtable<>();
+		// i18n
+		copyFrameworkProp(getter, NodeConstants.I18N_DEFAULT_LOCALE, props);
+		copyFrameworkProp(getter, NodeConstants.I18N_LOCALES, props);
+		// user admin
+		copyFrameworkProp(getter, NodeConstants.ROLES_URI, props);
+		copyFrameworkProp(getter, NodeConstants.USERADMIN_URIS, props);
+		// data
+		for (RepoConf repoConf : RepoConf.values())
+			copyFrameworkProp(getter, NodeConstants.NODE_REPO_PROP_PREFIX + repoConf.name(), props);
+		// TODO add other environment sources
+		return props;
+	}
+
+	static Dictionary<String, Object> getUserAdminPropertiesFromEnvironment(Function<String, String> getter) {
+		Hashtable<String, Object> props = new Hashtable<>();
+		copyFrameworkProp(getter, NodeConstants.ROLES_URI, props);
+		copyFrameworkProp(getter, NodeConstants.USERADMIN_URIS, props);
+		return props;
+	}
+
+	private static void copyFrameworkProp(Function<String, String> getter, String key,
+			Dictionary<String, Object> props) {
+		String value = getter.apply(key);
+		if (value != null)
+			props.put(key, value);
+	}
+
+}