X-Git-Url: https://git.argeo.org/?p=gpl%2Fargeo-suite.git;a=blobdiff_plain;f=knowledge%2Forg.argeo.support.odk%2Fsrc%2Forg%2Fargeo%2Fsupport%2Fodk%2FOdkUtils.java;fp=knowledge%2Forg.argeo.support.odk%2Fsrc%2Forg%2Fargeo%2Fsupport%2Fodk%2FOdkUtils.java;h=4c106a29b2a7dfd007ce2cb6cead390a34a09ce4;hp=0000000000000000000000000000000000000000;hb=65030067b0125a4399f58b897b78debded2984d3;hpb=fe67dd9853e3cd8a5056d211e3086a832aba36d1

diff --git a/knowledge/org.argeo.support.odk/src/org/argeo/support/odk/OdkUtils.java b/knowledge/org.argeo.support.odk/src/org/argeo/support/odk/OdkUtils.java
new file mode 100644
index 0000000..4c106a2
--- /dev/null
+++ b/knowledge/org.argeo.support.odk/src/org/argeo/support/odk/OdkUtils.java
@@ -0,0 +1,78 @@
+package org.argeo.support.odk;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+
+import javax.jcr.ImportUUIDBehavior;
+import javax.jcr.Node;
+import javax.jcr.RepositoryException;
+import javax.jcr.Session;
+import javax.jcr.nodetype.NodeType;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.argeo.entity.EntityType;
+import org.argeo.jcr.JcrUtils;
+import org.argeo.jcr.JcrxApi;
+import org.argeo.util.DigestUtils;
+
+/** Utilities around ODK. */
+public class OdkUtils {
+	private final static Log log = LogFactory.getLog(OdkUtils.class);
+
+	public static void loadOdkForm(Node formBase, String name, InputStream in) throws RepositoryException, IOException {
+		if (!formBase.isNodeType(EntityType.formSet.get()))
+			throw new IllegalArgumentException(
+					"Parent path " + formBase + " must be of type " + EntityType.formSet.get());
+		Node form = JcrUtils.getOrAdd(formBase, name, OrxListType.xform.get(), NodeType.MIX_SIMPLE_VERSIONABLE);
+
+		String previousCsum = JcrxApi.getChecksum(form, JcrxApi.MD5);
+
+		Session s = formBase.getSession();
+//		String res = "/odk/apafSession.odk.xml";
+//		try (InputStream in = getClass().getClassLoader().getResourceAsStream(res)) {
+		s.importXML(form.getPath(), in, ImportUUIDBehavior.IMPORT_UUID_COLLISION_REPLACE_EXISTING);
+//		}
+
+		if (previousCsum == null)// save before checksuming
+			s.save();
+		String newCsum;
+		try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
+			s.exportDocumentView(form.getPath() + "/" + OdkNames.H_HTML, out, true, false);
+			newCsum = DigestUtils.digest(DigestUtils.MD5, out.toByteArray());
+		}
+		if (previousCsum == null) {
+			JcrxApi.addChecksum(form, newCsum);
+			JcrUtils.updateLastModified(form);
+			s.save();
+			s.getWorkspace().getVersionManager().checkpoint(form.getPath());
+			if (log.isDebugEnabled())
+				log.debug("New form " + form);
+		} else {
+			if (newCsum.equals(previousCsum)) {
+				// discard
+				s.refresh(false);
+				if (log.isDebugEnabled())
+					log.debug("Unmodified form " + form);
+				return;
+			} else {
+				JcrxApi.addChecksum(form, newCsum);
+				JcrUtils.updateLastModified(form);
+				s.save();
+				s.getWorkspace().getVersionManager().checkpoint(form.getPath());
+				if (log.isDebugEnabled()) {
+					log.debug("Updated form " + form);
+					log.debug("Previous csum " + previousCsum);
+					log.debug("New csum " + newCsum);
+				}
+			}
+		}
+	}
+
+	/** Singleton. */
+	private OdkUtils() {
+
+	}
+
+}