X-Git-Url: http://git.argeo.org/?p=gpl%2Fargeo-suite.git;a=blobdiff_plain;f=org.argeo.suite.core%2Fsrc%2Forg%2Fargeo%2Fsuite%2Fcore%2FSuiteTermsManager.java;fp=org.argeo.suite.core%2Fsrc%2Forg%2Fargeo%2Fsuite%2Fcore%2FSuiteTermsManager.java;h=3c5a59fa42c5425820340017bc0ece5b2ccab93d;hp=0000000000000000000000000000000000000000;hb=678186f16393cdafbd5430adbad98359179c96bd;hpb=9dd16d64cc4ea274c33a4c1acaa289c46bf5251f

diff --git a/org.argeo.suite.core/src/org/argeo/suite/core/SuiteTermsManager.java b/org.argeo.suite.core/src/org/argeo/suite/core/SuiteTermsManager.java
new file mode 100644
index 0000000..3c5a59f
--- /dev/null
+++ b/org.argeo.suite.core/src/org/argeo/suite/core/SuiteTermsManager.java
@@ -0,0 +1,94 @@
+package org.argeo.suite.core;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.jcr.Node;
+import javax.jcr.Repository;
+import javax.jcr.RepositoryException;
+import javax.jcr.Session;
+
+import org.argeo.api.NodeConstants;
+import org.argeo.api.NodeUtils;
+import org.argeo.entity.EntityNames;
+import org.argeo.entity.EntityType;
+import org.argeo.entity.TermsManager;
+import org.argeo.jcr.Jcr;
+import org.argeo.jcr.JcrException;
+
+/** Argeo Suite implementation of terms manager. */
+public class SuiteTermsManager implements TermsManager {
+	private final Map<String, SuiteTerm> terms = new HashMap<>();
+	private final Map<String, SuiteTypology> typologies = new HashMap<>();
+
+	// JCR
+	private Repository repository;
+	private Session adminSession;
+
+	public void init() {
+		adminSession = NodeUtils.openDataAdminSession(repository, NodeConstants.SYS_WORKSPACE);
+	}
+
+	@Override
+	public List<String> listAllTerms(String typology) {
+		List<String> res = new ArrayList<>();
+		SuiteTypology t = getTypology(typology);
+		for (SuiteTerm term : t.getAllTerms()) {
+			res.add(term.getId());
+		}
+		return res;
+	}
+
+	SuiteTypology getTypology(String typology) {
+		SuiteTypology t = typologies.get(typology);
+		if (t == null) {
+			Node termsNode = Jcr.getNode(adminSession, "SELECT * FROM [{0}] WHERE NAME()=\"{1}\"",
+					EntityType.terms.get(), typology);
+			t = loadTypology(termsNode);
+		}
+		return t;
+	}
+
+	SuiteTypology loadTypology(Node termsNode) {
+		try {
+			SuiteTypology typology = new SuiteTypology(termsNode);
+			for (Node termNode : Jcr.iterate(termsNode.getNodes())) {
+				if (termNode.isNodeType(EntityType.term.get())) {
+					SuiteTerm term = loadTerm(typology, termNode, null);
+					if (!term.getSubTerms().isEmpty())
+						typology.markNotFlat();
+					typology.getSubTerms().add(term);
+				}
+			}
+			typologies.put(typology.getName(), typology);
+			return typology;
+		} catch (RepositoryException e) {
+			throw new JcrException("Cannot load typology from " + termsNode, e);
+		}
+	}
+
+	SuiteTerm loadTerm(SuiteTypology typology, Node termNode, SuiteTerm parentTerm) throws RepositoryException {
+		String name = termNode.getProperty(EntityNames.NAME).getString();
+		String relativePath = parentTerm == null ? name : parentTerm.getRelativePath() + '/' + name;
+		SuiteTerm term = new SuiteTerm(typology, relativePath, parentTerm);
+		terms.put(term.getId(), term);
+		for (Node subTermNode : Jcr.iterate(termNode.getNodes())) {
+			if (termNode.isNodeType(EntityType.term.get())) {
+				SuiteTerm subTerm = loadTerm(typology, subTermNode, term);
+				term.getSubTerms().add(subTerm);
+			}
+		}
+		return term;
+	}
+
+	public void destroy() {
+		Jcr.logout(adminSession);
+	}
+
+	public void setRepository(Repository repository) {
+		this.repository = repository;
+	}
+
+}