X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Fintegration%2FJcrServlet.java;fp=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Fintegration%2FJcrServlet.java;h=a1170937e1c79e37776ceeb33e8e19e6a7269ab0;hb=5310ed9adea7fcf2cbcefc136e91674a412a1fa9;hp=0000000000000000000000000000000000000000;hpb=ce22d3eaabb4b9aa92f62f0302c235f951c26f3f;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/integration/JcrServlet.java b/org.argeo.cms/src/org/argeo/cms/integration/JcrServlet.java
new file mode 100644
index 000000000..a1170937e
--- /dev/null
+++ b/org.argeo.cms/src/org/argeo/cms/integration/JcrServlet.java
@@ -0,0 +1,197 @@
+package org.argeo.cms.integration;
+
+import java.io.IOException;
+import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
+
+import javax.jcr.Node;
+import javax.jcr.NodeIterator;
+import javax.jcr.Property;
+import javax.jcr.PropertyIterator;
+import javax.jcr.PropertyType;
+import javax.jcr.Repository;
+import javax.jcr.RepositoryException;
+import javax.jcr.Session;
+import javax.jcr.Value;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.jackrabbit.api.JackrabbitNode;
+import org.apache.jackrabbit.api.JackrabbitValue;
+import org.argeo.jcr.JcrUtils;
+
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.google.gson.stream.JsonWriter;
+
+/** Canonical access to a JCR repository via web services. */
+public class JcrServlet extends HttpServlet {
+	private static final long serialVersionUID = 6536175260540484539L;
+
+	private final static String PARAM_VERBOSE = "verbose";
+	private final static String PARAM_DEPTH = "depth";
+	private final static String PARAM_PRETTY = "pretty";
+
+	private final static Log log = LogFactory.getLog(JcrServlet.class);
+
+	private Repository repository;
+	private Integer maxDepth = 8;
+
+	private Gson gson = new GsonBuilder().setPrettyPrinting().create();
+
+	@Override
+	protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+		String path = req.getPathInfo();
+		if (log.isTraceEnabled())
+			log.trace("Data service: " + path);
+		path = URLDecoder.decode(path, StandardCharsets.UTF_8.name());
+		String[] pathTokens = path.split("/");
+		// TODO make it more robust
+
+		String domain = pathTokens[1];
+		String dataWorkspace = "vje_" + domain;
+		String jcrPath = path.substring(domain.length() + 1);
+
+		boolean verbose = req.getParameter(PARAM_VERBOSE) != null && !req.getParameter(PARAM_VERBOSE).equals("false");
+		int depth = 1;
+		if (req.getParameter(PARAM_DEPTH) != null) {
+			depth = Integer.parseInt(req.getParameter(PARAM_DEPTH));
+			if (depth > maxDepth)
+				throw new RuntimeException("Depth " + depth + " is higher than maximum " + maxDepth);
+		}
+		String urlBase = null;
+		if (req.getParameter("html") != null)
+			urlBase = req.getServletPath() + '/' + domain;
+		boolean pretty = req.getParameter(PARAM_PRETTY) != null;
+
+		resp.setContentType("application/json");
+		Session session = null;
+		try {
+			// authentication
+			session = openJcrSession(req, resp, repository, dataWorkspace);
+			if (!session.itemExists(jcrPath))
+				throw new RuntimeException("JCR node " + jcrPath + " does not exist");
+			Node node = session.getNode(jcrPath);
+
+			JsonWriter jsonWriter;
+			if (pretty)
+				jsonWriter = new GsonBuilder().setPrettyPrinting().create().newJsonWriter(resp.getWriter());
+			else
+				jsonWriter = gson.newJsonWriter(resp.getWriter());
+			jsonWriter.beginObject();
+			writeNodeProperties(node, jsonWriter, verbose, urlBase);
+			writeNodeChildren(node, jsonWriter, depth, verbose, urlBase);
+			jsonWriter.endObject();
+			jsonWriter.flush();
+		} catch (RepositoryException e) {
+			resp.setStatus(500);
+			throw new RuntimeException("Cannot process JCR node " + jcrPath, e);
+		} finally {
+			JcrUtils.logoutQuietly(session);
+		}
+	}
+
+	protected Session openJcrSession(HttpServletRequest req, HttpServletResponse resp, Repository repository,
+			String workspace) throws RepositoryException {
+		return repository.login();
+	}
+
+	protected void writeNodeProperties(Node node, JsonWriter jsonWriter, boolean verbose, String urlBase)
+			throws RepositoryException, IOException {
+		String jcrPath = node.getPath();
+		jsonWriter.name("jcr:name");
+		jsonWriter.value(node.getName());
+		jsonWriter.name("jcr:path");
+		jsonWriter.value(jcrPath);
+
+		PropertyIterator pit = node.getProperties();
+		properties: while (pit.hasNext()) {
+			Property property = pit.nextProperty();
+			if (!verbose) {
+				if (property.getName().equals("jcr:primaryType") || property.getName().equals("jcr:mixinTypes")
+						|| property.getName().equals("jcr:created") || property.getName().equals("jcr:createdBy")
+						|| property.getName().equals("jcr:lastModified")
+						|| property.getName().equals("jcr:lastModifiedBy")) {
+					continue properties;// skip
+				}
+			}
+
+			if (property.getType() == PropertyType.BINARY) {
+				if (!(node instanceof JackrabbitNode)) {
+					continue properties;// skip
+				}
+			}
+
+			if (!property.isMultiple()) {
+				jsonWriter.name(property.getName());
+				writePropertyValue(property.getType(), property.getValue(), jsonWriter);
+			} else {
+				jsonWriter.name(property.getName());
+				jsonWriter.beginArray();
+				Value[] values = property.getValues();
+				for (Value value : values) {
+					writePropertyValue(property.getType(), value, jsonWriter);
+				}
+				jsonWriter.endArray();
+			}
+		}
+
+		// meta data
+		if (verbose) {
+			jsonWriter.name("jcr:identifier");
+			jsonWriter.value(node.getIdentifier());
+		}
+		if (urlBase != null) {// TODO make it browsable
+			jsonWriter.name("url");
+			String url = urlBase + jcrPath;
+			jsonWriter.value("<a href='" + url + "?html=true'>" + url + "</a>");
+		}
+	}
+
+	protected void writePropertyValue(int type, Value value, JsonWriter jsonWriter)
+			throws RepositoryException, IOException {
+		if (type == PropertyType.DOUBLE)
+			jsonWriter.value(value.getDouble());
+		else if (type == PropertyType.LONG)
+			jsonWriter.value(value.getLong());
+		else if (type == PropertyType.BINARY) {
+			if (value instanceof JackrabbitValue) {
+				String contentIdentity = ((JackrabbitValue) value).getContentIdentity();
+				jsonWriter.value("SHA256:" + contentIdentity);
+			}
+		} else
+			jsonWriter.value(value.getString());
+	}
+
+	protected void writeNodeChildren(Node node, JsonWriter jsonWriter, int depth, boolean verbose, String urlBase)
+			throws RepositoryException, IOException {
+		if (!node.hasNodes())
+			return;
+		if (depth <= 0)
+			return;
+		NodeIterator nit = node.getNodes();
+		jsonWriter.name("jcr:nodes");
+		jsonWriter.beginArray();
+		while (nit.hasNext()) {
+			Node child = nit.nextNode();
+			jsonWriter.beginObject();
+			writeNodeProperties(child, jsonWriter, verbose, urlBase);
+			writeNodeChildren(child, jsonWriter, depth - 1, verbose, urlBase);
+			jsonWriter.endObject();
+		}
+		jsonWriter.endArray();
+	}
+
+	public void setRepository(Repository repository) {
+		this.repository = repository;
+	}
+
+	public void setMaxDepth(Integer maxDepth) {
+		this.maxDepth = maxDepth;
+	}
+
+}