Continue framework clean up.

[lgpl/argeo-commons.git] / org.argeo.cms / src / org / argeo / cms / internal / kernel / NodeDeployConfig.java

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 (file)
index 0000000..85906b0
--- /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);
+       }
+
+}