X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms.jcr%2Fsrc%2Forg%2Fargeo%2Fcms%2Fjcr%2Finternal%2Fservlet%2FJcrWriteServlet.java;fp=org.argeo.cms.jcr%2Fsrc%2Forg%2Fargeo%2Fcms%2Fjcr%2Finternal%2Fservlet%2FJcrWriteServlet.java;h=459a1e493c55ca75e75eacfbf7a3f967febbb4d4;hb=bce03099b0d2f1758e7a3d74fba339d0200924d5;hp=0000000000000000000000000000000000000000;hpb=0ea2992e5f3803cd98b5981f27274faa922bc199;p=gpl%2Fargeo-jcr.git

diff --git a/org.argeo.cms.jcr/src/org/argeo/cms/jcr/internal/servlet/JcrWriteServlet.java b/org.argeo.cms.jcr/src/org/argeo/cms/jcr/internal/servlet/JcrWriteServlet.java
new file mode 100644
index 0000000..459a1e4
--- /dev/null
+++ b/org.argeo.cms.jcr/src/org/argeo/cms/jcr/internal/servlet/JcrWriteServlet.java
@@ -0,0 +1,92 @@
+package org.argeo.cms.jcr.internal.servlet;
+
+import java.io.IOException;
+
+import javax.jcr.ImportUUIDBehavior;
+import javax.jcr.Node;
+import javax.jcr.Session;
+import javax.jcr.nodetype.NodeType;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.commons.io.FilenameUtils;
+import org.apache.commons.io.IOUtils;
+import org.argeo.api.cms.CmsLog;
+import org.argeo.cms.integration.CmsExceptionsChain;
+import org.argeo.jcr.JcrUtils;
+
+/** Access a JCR repository via web services. */
+public class JcrWriteServlet extends JcrReadServlet {
+	private static final long serialVersionUID = 17272653843085492L;
+	private final static CmsLog log = CmsLog.getLog(JcrWriteServlet.class);
+
+	@Override
+	protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+		if (log.isDebugEnabled())
+			log.debug("Data service POST: " + req.getPathInfo());
+
+		String dataWorkspace = getWorkspace(req);
+		String jcrPath = getJcrPath(req);
+
+		Session session = null;
+		try {
+			// authentication
+			session = openJcrSession(req, resp, getRepository(), dataWorkspace);
+
+			if (req.getContentType() != null && req.getContentType().equals(XML_CONTENT_TYPE)) {
+//				resp.setContentType(XML_CONTENT_TYPE);
+				session.getWorkspace().importXML(jcrPath, req.getInputStream(),
+						ImportUUIDBehavior.IMPORT_UUID_COLLISION_REMOVE_EXISTING);
+				return;
+			}
+
+			if (!session.itemExists(jcrPath)) {
+				String parentPath = FilenameUtils.getFullPathNoEndSeparator(jcrPath);
+				String fileName = FilenameUtils.getName(jcrPath);
+				Node folderNode = JcrUtils.mkfolders(session, parentPath);
+				byte[] bytes = IOUtils.toByteArray(req.getInputStream());
+				JcrUtils.copyBytesAsFile(folderNode, fileName, bytes);
+			} else {
+				Node node = session.getNode(jcrPath);
+				if (!node.isNodeType(NodeType.NT_FILE))
+					throw new IllegalArgumentException("Node " + jcrPath + " exists but is not a file");
+				byte[] bytes = IOUtils.toByteArray(req.getInputStream());
+				JcrUtils.copyBytesAsFile(node.getParent(), node.getName(), bytes);
+			}
+			session.save();
+		} catch (Exception e) {
+			new CmsExceptionsChain(e).writeAsJson(getObjectMapper(), resp);
+		} finally {
+			JcrUtils.logoutQuietly(session);
+		}
+	}
+
+	@Override
+	protected void doDelete(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
+		if (log.isDebugEnabled())
+			log.debug("Data service DELETE: " + req.getPathInfo());
+
+		String dataWorkspace = getWorkspace(req);
+		String jcrPath = getJcrPath(req);
+
+		Session session = null;
+		try {
+			// authentication
+			session = openJcrSession(req, resp, getRepository(), dataWorkspace);
+			if (!session.itemExists(jcrPath)) {
+				// ignore
+				return;
+			} else {
+				Node node = session.getNode(jcrPath);
+				node.remove();
+			}
+			session.save();
+		} catch (Exception e) {
+			new CmsExceptionsChain(e).writeAsJson(getObjectMapper(), resp);
+		} finally {
+			JcrUtils.logoutQuietly(session);
+		}
+	}
+
+}