Rename packages in order to make future stable documentation clearer.
[lgpl/argeo-commons.git] / org.argeo.cms / src / org / argeo / cms / internal / kernel / NodeRepositoryFactory.java
index 2e3e78f0da5b49380d55f453978f3f6ae78bbd48..47e8b5cd5e538d01497dd4fa682366daee997c2d 100644 (file)
@@ -28,13 +28,13 @@ import javax.jcr.RepositoryFactory;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.jackrabbit.jcr2dav.Jcr2davRepositoryFactory;
+import org.argeo.api.NodeConstants;
+import org.argeo.cms.internal.jcr.RepoConf;
 import org.argeo.jcr.ArgeoJcrException;
-import org.argeo.node.NodeConstants;
 import org.osgi.framework.BundleContext;
 import org.osgi.framework.FrameworkUtil;
 import org.osgi.framework.InvalidSyntaxException;
 import org.osgi.framework.ServiceReference;
-import org.springframework.core.io.Resource;
 
 /**
  * OSGi-aware Jackrabbit repository factory which can retrieve/publish
@@ -84,15 +84,16 @@ class NodeRepositoryFactory implements RepositoryFactory {
                // check if remote
                Repository repository;
                String uri = null;
-               if (parameters.containsKey(NodeConstants.LABELED_URI))
+               if (parameters.containsKey(RepoConf.labeledUri.name()))
                        uri = parameters.get(NodeConstants.LABELED_URI).toString();
                else if (parameters.containsKey(KernelConstants.JACKRABBIT_REPOSITORY_URI))
                        uri = parameters.get(KernelConstants.JACKRABBIT_REPOSITORY_URI).toString();
 
                if (uri != null) {
-                       if (uri.startsWith("http"))// http, https
-                               repository = createRemoteRepository(uri);
-                       else if (uri.startsWith("file"))// http, https
+                       if (uri.startsWith("http")) {// http, https
+                               Object defaultWorkspace = parameters.get(RepoConf.defaultWorkspace.name());
+                               repository = createRemoteRepository(uri, defaultWorkspace != null ? defaultWorkspace.toString() : null);
+                       } else if (uri.startsWith("file"))// http, https
                                repository = createFileRepository(uri, parameters);
                        else if (uri.startsWith("vm")) {
                                // log.warn("URI " + uri + " should have been managed by generic
@@ -120,9 +121,11 @@ class NodeRepositoryFactory implements RepositoryFactory {
                return repository;
        }
 
-       protected Repository createRemoteRepository(String uri) throws RepositoryException {
+       protected Repository createRemoteRepository(String uri, String defaultWorkspace) throws RepositoryException {
                Map<String, String> params = new HashMap<String, String>();
                params.put(KernelConstants.JACKRABBIT_REPOSITORY_URI, uri);
+               if (defaultWorkspace != null)
+                       params.put(KernelConstants.JACKRABBIT_REMOTE_DEFAULT_WORKSPACE, defaultWorkspace);
                Repository repository = new Jcr2davRepositoryFactory().getRepository(params);
                if (repository == null)
                        throw new ArgeoJcrException("Remote Davex repository " + uri + " not found");
@@ -190,16 +193,10 @@ class NodeRepositoryFactory implements RepositoryFactory {
        }
 
        /**
-        * Called after the repository has been initialised. Does nothing by
-        * default.
+        * Called after the repository has been initialised. Does nothing by default.
         */
        @SuppressWarnings("rawtypes")
        protected void postInitialization(Repository repository, Map parameters) {
 
        }
-
-       public void setFileRepositoryConfiguration(Resource fileRepositoryConfiguration) {
-//             this.fileRepositoryConfiguration = fileRepositoryConfiguration;
-       }
-
 }