Set<String> processed = new HashSet<String>();
bundles: for (Bundle bundle : bc.getBundles()) {
BundleWiring wiring = bundle.adapt(BundleWiring.class);
- if (wiring == null) {
- if (log.isTraceEnabled())
- log.error("No wiring for " + bundle.getSymbolicName());
+ if (wiring == null)
continue bundles;
- }
processWiring(adminSession, wiring, processed);
}
} finally {
private void registerCnd(Session adminSession, BundleCapability capability, Set<String> processed) {
Map<String, Object> attrs = capability.getAttributes();
- String name = attrs.get(DataModelNamespace.CAPABILITY_NAME_ATTRIBUTE).toString();
+ String name = (String) attrs.get(DataModelNamespace.CAPABILITY_NAME_ATTRIBUTE);
if (processed.contains(name)) {
if (log.isTraceEnabled())
log.trace("Data model " + name + " has already been processed");
return;
}
- String path = attrs.get(DataModelNamespace.CAPABILITY_CND_ATTRIBUTE).toString();
+ String path = (String) attrs.get(DataModelNamespace.CAPABILITY_CND_ATTRIBUTE);
URL url = capability.getRevision().getBundle().getResource(path);
try (Reader reader = new InputStreamReader(url.openStream())) {
CndImporter.registerNodeTypes(reader, adminSession, true);
throw new CmsException("Cannot import CND " + url, e);
}
- Hashtable<String, Object> properties = new Hashtable<>();
- properties.put(ArgeoJcrConstants.JCR_REPOSITORY_ALIAS, name);
- properties.put(NodeConstants.CN, name);
- if (name.equals(ArgeoJcrConstants.ALIAS_NODE))
- properties.put(Constants.SERVICE_RANKING, Integer.MAX_VALUE);
- bc.registerService(Repository.class, adminSession.getRepository(), properties);
- if (log.isDebugEnabled())
- log.debug("Published data model " + name);
+ if (!asBoolean((String) attrs.get(DataModelNamespace.CAPABILITY_ABSTRACT_ATTRIBUTE))) {
+ Hashtable<String, Object> properties = new Hashtable<>();
+ properties.put(ArgeoJcrConstants.JCR_REPOSITORY_ALIAS, name);
+ properties.put(NodeConstants.CN, name);
+ if (name.equals(ArgeoJcrConstants.ALIAS_NODE))
+ properties.put(Constants.SERVICE_RANKING, Integer.MAX_VALUE);
+ LocalRepository localRepository = new LocalRepository(adminSession.getRepository(), capability);
+ bc.registerService(Repository.class, localRepository, properties);
+ if (log.isDebugEnabled())
+ log.debug("Published data model " + name);
+ }
+ }
+
+ private boolean asBoolean(String value) {
+ if (value == null)
+ return false;
+ switch (value) {
+ case "true":
+ return true;
+ case "false":
+ return false;
+ default:
+ throw new CmsException("Unsupported value for attribute " + DataModelNamespace.CAPABILITY_ABSTRACT_ATTRIBUTE
+ + ": " + value);
+ }
}
@Override
* Make sure each user has a home directory available in the default workspace.
*/
class HomeRepository extends JcrRepositoryWrapper implements KernelConstants, ArgeoJcrConstants {
- // private final Kernel kernel;
-
/** The home base path. */
private String homeBasePath = "/home";
private String peopleBasePath = ArgeoJcrConstants.PEOPLE_BASE_PATH;
private Set<String> checkedUsers = new HashSet<String>();
public HomeRepository(Repository repository) {
- // this.kernel = kernel;
setRepository(repository);
LoginContext lc;
try {
--- /dev/null
+package org.argeo.cms.internal.kernel;
+
+import java.util.Map;
+
+import javax.jcr.Repository;
+
+import org.argeo.jcr.JcrRepositoryWrapper;
+import org.argeo.node.DataModelNamespace;
+import org.osgi.framework.wiring.BundleCapability;
+
+class LocalRepository extends JcrRepositoryWrapper {
+ private final String cn;
+
+ public LocalRepository(Repository repository, BundleCapability dataModelCapability) {
+ Map<String, Object> attrs = dataModelCapability.getAttributes();
+ cn = (String) attrs.get(DataModelNamespace.CAPABILITY_NAME_ATTRIBUTE);
+ setRepository(repository);
+ }
+
+ String getCn() {
+ return cn;
+ }
+
+}
public static final String CMS_DATA_MODEL_NAMESPACE = "cms.datamodel";
public static final String CAPABILITY_NAME_ATTRIBUTE = "name";
public static final String CAPABILITY_CND_ATTRIBUTE = "cnd";
+ /** If 'true', indicates that no repository should be published */
+ public static final String CAPABILITY_ABSTRACT_ATTRIBUTE = "abstract";
+ /**
+ * If 'true', indicates that code using this data model should be prepared
+ * to have it stored in a different JCR repository than the node
+ */
+ public static final String CAPABILITY_STANDALONE_ATTRIBUTE = "standalone";
private DataModelNamespace() {
// empty