X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;ds=sidebyside;f=org.argeo.cms%2Fsrc%2Forg%2Fargeo%2Fcms%2Facr%2Fxml%2FDomContentProvider.java;h=8caac1ad29a2629e11e09b7c72dc2857ead361f2;hb=584b2b87593892c6ded7b645425b603a4f554026;hp=4db49343386902e40bdd2e15f7a61bf2996b823a;hpb=85015a7cbfe5343c88477d828fa2f8fb754a65cd;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms/src/org/argeo/cms/acr/xml/DomContentProvider.java b/org.argeo.cms/src/org/argeo/cms/acr/xml/DomContentProvider.java
index 4db493433..8caac1ad2 100644
--- a/org.argeo.cms/src/org/argeo/cms/acr/xml/DomContentProvider.java
+++ b/org.argeo.cms/src/org/argeo/cms/acr/xml/DomContentProvider.java
@@ -1,5 +1,7 @@
 package org.argeo.cms.acr.xml;
 
+import java.io.IOException;
+import java.io.OutputStream;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Iterator;
@@ -16,18 +18,22 @@ import org.argeo.api.acr.ContentNotFoundException;
 import org.argeo.api.acr.NamespaceUtils;
 import org.argeo.api.acr.spi.ContentProvider;
 import org.argeo.api.acr.spi.ProvidedSession;
+import org.argeo.cms.acr.CmsContentRepository;
 import org.w3c.dom.Document;
 import org.w3c.dom.Element;
 import org.w3c.dom.NodeList;
 
 public class DomContentProvider implements ContentProvider, NamespaceContext {
-	private Document document;
+	private final Document document;
 
 	// XPath
 	// TODO centralise in some executor?
 	private final ThreadLocal<XPath> xPath;
 
-	public DomContentProvider(Document document) {
+	private String mountPath;
+
+	public DomContentProvider(String mountPath, Document document) {
+		this.mountPath = mountPath;
 		this.document = document;
 		this.document.normalizeDocument();
 		XPathFactory xPathFactory = XPathFactory.newInstance();
@@ -77,6 +83,23 @@ public class DomContentProvider implements ContentProvider, NamespaceContext {
 		}
 	}
 
+	public void persist(ProvidedSession session) {
+		if (mountPath != null) {
+			Content mountPoint = session.getMountPoint(mountPath);
+			try (OutputStream out = mountPoint.open(OutputStream.class)) {
+				CmsContentRepository contentRepository = (CmsContentRepository) session.getRepository();
+				contentRepository.writeDom(document, out);
+			} catch (IOException e) {
+				throw new IllegalStateException("Cannot persist " + mountPath, e);
+			}
+		}
+	}
+
+	@Override
+	public String getMountPath() {
+		return mountPath;
+	}
+
 	/*
 	 * NAMESPACE CONTEXT
 	 */