X-Git-Url: https://git.argeo.org/?p=gpl%2Fargeo-suite.git;a=blobdiff_plain;f=org.argeo.app.core%2Fsrc%2Forg%2Fargeo%2Fapp%2Fcore%2FSuiteTermsManager.java;fp=org.argeo.app.core%2Fsrc%2Forg%2Fargeo%2Fapp%2Fcore%2FSuiteTermsManager.java;h=c14f871a272b89cb511d35365f9491e0c9ee96fe;hp=0000000000000000000000000000000000000000;hb=6e56ffa34cb02ab04d028423aea342e3dfed4358;hpb=c285180bece610b2c2921d44fe14b6dde2123efa

diff --git a/org.argeo.app.core/src/org/argeo/app/core/SuiteTermsManager.java b/org.argeo.app.core/src/org/argeo/app/core/SuiteTermsManager.java
new file mode 100644
index 0000000..c14f871
--- /dev/null
+++ b/org.argeo.app.core/src/org/argeo/app/core/SuiteTermsManager.java
@@ -0,0 +1,103 @@
+package org.argeo.app.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.cms.CmsConstants;
+import org.argeo.app.api.EntityNames;
+import org.argeo.app.api.EntityType;
+import org.argeo.app.api.Term;
+import org.argeo.app.api.TermsManager;
+import org.argeo.cms.jcr.CmsJcrUtils;
+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 = CmsJcrUtils.openDataAdminSession(repository, CmsConstants.SYS_WORKSPACE);
+	}
+
+	@Override
+	public List<Term> listAllTerms(String typology) {
+		List<Term> res = new ArrayList<>();
+		SuiteTypology t = getTypology(typology);
+		for (SuiteTerm term : t.getAllTerms()) {
+			res.add(term);
+		}
+		return res;
+	}
+
+	@Override
+	public SuiteTerm getTerm(String termId) {
+		return terms.get(termId);
+	}
+
+	@Override
+	public 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);
+			if (termsNode == null)
+				throw new IllegalArgumentException("Typology " + typology + " not found.");
+			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;
+	}
+
+}