X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=plugins%2Forg.argeo.slc.client.ui.dist%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fclient%2Fui%2Fdist%2Fmodel%2FWorkspaceElem.java;h=c3088ebb22e8932382bd50f0b5b82a0c9e8cc367;hb=7ac8a536076af44569a23d9d67bb443cdc06018b;hp=41ba6efe32fa6dd51d3a3b14e7732381652b4c48;hpb=702f1e0c7d73edeb739dd62cd4248f489e1420b7;p=gpl%2Fargeo-slc.git diff --git a/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/model/WorkspaceElem.java b/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/model/WorkspaceElem.java index 41ba6efe3..c3088ebb2 100644 --- a/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/model/WorkspaceElem.java +++ b/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/model/WorkspaceElem.java @@ -44,12 +44,17 @@ public class WorkspaceElem extends DistParentElem { currSession = repoElem.repositoryLogin(getName()); } + /** Utility to create a new Session with correct credential in this context */ + public Session getNewSession() { + return repoElem.repositoryLogin(getName()); + } + public boolean hasChildren() { try { if (isConnected()) return currSession.getRootNode().hasNodes(); else - return false; + return true; } catch (RepositoryException re) { throw new ArgeoException( "Unexpected error while checking children node existence", @@ -65,45 +70,60 @@ public class WorkspaceElem extends DistParentElem { } else { // initialize current object try { + // Lazy connect the first time we retrieve children if (currSession == null) - return null; - else { - Query groupQuery = currSession.getWorkspace() - .getQueryManager() - // .createQuery( - // "select * from [" + SlcTypes.SLC_GROUP_BASE - // + "] as group order by group.[" - // + SlcNames.SLC_GROUP_BASE_ID + "]", - .createQuery( - "select * from [" - + SlcTypes.SLC_MODULAR_DISTRIBUTION - + "]", Query.JCR_SQL2); - NodeIterator distributions = groupQuery.execute() - .getNodes(); - distribs: while (distributions.hasNext()) { - Node currDist = distributions.nextNode(); - Node distBase = currDist.getParent().getParent(); - if (!distBase.isNodeType(SlcTypes.SLC_ARTIFACT_BASE)) - continue distribs; - String groupId = distBase.getProperty( - SlcNames.SLC_GROUP_ID).getString(); - String artifactId = distBase.getProperty( - SlcNames.SLC_ARTIFACT_ID).getString(); + login(); - String name; - String type; - if (ModularDistBaseElem.AETHER_BINARIES_TYPE - .equals(artifactId)) { - name = groupId; - type = ModularDistBaseElem.AETHER_BINARIES_TYPE; - } else { - name = artifactId; - type = ModularDistBaseElem.AETHER_DEP_TYPE; - } - if (getChildByName(name) == null) - addChild(new ModularDistBaseElem( - WorkspaceElem.this, name, distBase, type)); + // Retrieve already existing distribution + Query groupQuery = currSession + .getWorkspace() + .getQueryManager() + .createQuery( + "select * from [" + + SlcTypes.SLC_MODULAR_DISTRIBUTION + + "]", Query.JCR_SQL2); + NodeIterator distributions = groupQuery.execute().getNodes(); + distribs: while (distributions.hasNext()) { + Node currDist = distributions.nextNode(); + Node distBase = currDist.getParent().getParent(); + if (!distBase.isNodeType(SlcTypes.SLC_ARTIFACT_BASE)) + continue distribs; + String groupId = distBase + .getProperty(SlcNames.SLC_GROUP_ID).getString(); + String artifactId = distBase.getProperty( + SlcNames.SLC_ARTIFACT_ID).getString(); + + String name; + String type; + if (ModularDistBaseElem.AETHER_BINARIES_TYPE + .equals(artifactId)) { + name = groupId; + type = ModularDistBaseElem.AETHER_BINARIES_TYPE; + } else { + name = artifactId; + type = ModularDistBaseElem.AETHER_DEP_TYPE; } + if (getChildByName(name) == null) + addChild(new ModularDistBaseElem(WorkspaceElem.this, + name, distBase, type)); + } + // Add empty group base that have been marked as relevant + groupQuery = currSession + .getWorkspace() + .getQueryManager() + .createQuery( + "select * from [" + + SlcTypes.SLC_CATEGORY + "]", + Query.JCR_SQL2); + distributions = groupQuery.execute().getNodes(); + while (distributions.hasNext()) { + Node distBase = distributions.nextNode(); + String groupBaseId = distBase.getProperty( + SlcNames.SLC_GROUP_BASE_ID).getString(); + if (getChildByName(groupBaseId) == null) + addChild(new ModularDistBaseElem(WorkspaceElem.this, + groupBaseId, distBase, + ModularDistBaseElem.AETHER_CATEGORY_BASE)); } return super.getChildren(); } catch (RepositoryException e) {