First ACR search experiments

[lgpl/argeo-commons.git] / org.argeo.cms / src / org / argeo / cms / acr / MountManager.java

diff --git a/org.argeo.cms/src/org/argeo/cms/acr/MountManager.java b/org.argeo.cms/src/org/argeo/cms/acr/MountManager.java
index 3995dc30fcc84c1f32a55f435d94f6cbb0dd280f..75ca427c7e25bdee4d96e7bbd768c65c959b3e90 100644 (file)
--- a/org.argeo.cms/src/org/argeo/cms/acr/MountManager.java
+++ b/org.argeo.cms/src/org/argeo/cms/acr/MountManager.java
@@ -31,7 +31,7 @@ class MountManager {
                String[] parentPath = ContentUtils.getParentPath(mountPath);
                Content parent = systemSession.get(parentPath[0]);
                Content mount = parent.add(parentPath[1]);
-               mount.put(CrName.MOUNT.get(), "true");
+               mount.put(CrName.mount.qName(), "true");
 
        }
 
@@ -47,13 +47,36 @@ class MountManager {
                return partitions.get(mountPath);
        }
 
+       /** The content provider for this path. */
        synchronized ContentProvider findContentProvider(String path) {
+//             if (ContentUtils.EMPTY.equals(path))
+//                     return partitions.firstEntry().getValue();
                Map.Entry<String, ContentProvider> entry = partitions.floorEntry(path);
                if (entry == null)
-                       throw new IllegalArgumentException("No entry provider found for " + path);
+                       throw new IllegalArgumentException("No entry provider found for path '" + path + "'");
                String mountPath = entry.getKey();
+               if (!path.startsWith(mountPath)) {
+                       // FIXME make it more robust and find when there is no content provider
+                       String[] parent = ContentUtils.getParentPath(path);
+                       return findContentProvider(parent[0]);
+                       // throw new IllegalArgumentException("Path " + path + " doesn't have a content
+                       // provider");
+               }
                ContentProvider contentProvider = entry.getValue();
                assert mountPath.equals(contentProvider.getMountPath());
                return contentProvider;
        }
+
+       /** All content provider under this path. */
+       synchronized NavigableMap<String, ContentProvider> findContentProviders(String path) {
+               NavigableMap<String, ContentProvider> res = new TreeMap<>();
+               tail: for (Map.Entry<String, ContentProvider> provider : partitions.tailMap(path).entrySet()) {
+                       if (!provider.getKey().startsWith(path))
+                               break tail;
+                       res.put(provider.getKey(), provider.getValue());
+               }
+               return res;
+
+       }
+
 }