First WebDav PROPFIND implementation server-side

[lgpl/argeo-commons.git] / org.argeo.cms / src / org / argeo / cms / dav / DavClient.java

diff --git a/org.argeo.cms/src/org/argeo/cms/dav/DavClient.java b/org.argeo.cms/src/org/argeo/cms/dav/DavClient.java
new file mode 100644 (file)
index 0000000..5788a32
--- /dev/null
+++ b/org.argeo.cms/src/org/argeo/cms/dav/DavClient.java
@@ -0,0 +1,160 @@
+package org.argeo.cms.dav;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.Authenticator;
+import java.net.PasswordAuthentication;
+import java.net.URI;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpRequest.BodyPublishers;
+import java.net.http.HttpResponse;
+import java.net.http.HttpResponse.BodyHandler;
+import java.net.http.HttpResponse.BodyHandlers;
+import java.util.Iterator;
+
+import javax.xml.namespace.QName;
+
+import org.argeo.util.http.HttpResponseStatus;
+
+public class DavClient {
+
+       private HttpClient httpClient;
+
+       public DavClient() {
+               httpClient = HttpClient.newBuilder() //
+//                             .sslContext(insecureContext()) //
+                               .version(HttpClient.Version.HTTP_1_1) //
+//                             .authenticator(new Authenticator() {
+//
+//                                     @Override
+//                                     protected PasswordAuthentication getPasswordAuthentication() {
+//                                             return new PasswordAuthentication("root", "demo".toCharArray());
+//                                     }
+//
+//                             }) //
+                               .build();
+       }
+
+       public void setProperty(String url, QName key, String value) {
+               try {
+                       String body = """
+                                       <?xml version="1.0" encoding="utf-8" ?>
+                                       <D:propertyupdate xmlns:D="DAV:"
+                                       """ //
+                                       + "xmlns:" + key.getPrefix() + "=\"" + key.getNamespaceURI() + "\">" + //
+                                       """
+                                                               <D:set>
+                                                                       <D:prop>
+                                                       """ //
+                                       + "<" + key.getPrefix() + ":" + key.getLocalPart() + ">" + value + "</" + key.getPrefix() + ":"
+                                       + key.getLocalPart() + ">" + //
+                                       """
+                                                                       </D:prop>
+                                                               </D:set>
+                                                       </D:propertyupdate>
+                                                       """;
+                       System.out.println(body);
+                       HttpRequest request = HttpRequest.newBuilder().uri(URI.create(url)) //
+                                       .header("Depth", "1") //
+                                       .method(DavMethod.PROPPATCH.name(), BodyPublishers.ofString(body)) //
+                                       .build();
+                       BodyHandler<String> bodyHandler = BodyHandlers.ofString();
+                       HttpResponse<String> response = httpClient.send(request, bodyHandler);
+                       System.out.println(response.body());
+               } catch (IOException | InterruptedException e) {
+                       // TODO Auto-generated catch block
+                       e.printStackTrace();
+               }
+       }
+
+       public Iterator<DavResponse> listChildren(URI uri) {
+               try {
+                       String body = """
+                                       <?xml version="1.0" encoding="utf-8" ?>
+                                       <D:propfind xmlns:D="DAV:">
+                                         <D:propname/>
+                                       </D:propfind>""";
+                       HttpRequest request = HttpRequest.newBuilder().uri(uri) //
+                                       .header(DavHeader.DEPTH.getHeaderName(), DavDepth.DEPTH_1.getValue()) //
+                                       .method(DavMethod.PROPFIND.name(), BodyPublishers.ofString(body)) //
+                                       .build();
+
+                       HttpResponse<String> responseStr = httpClient.send(request, BodyHandlers.ofString());
+                       System.out.println(responseStr.body());
+
+                       HttpResponse<InputStream> response = httpClient.send(request, BodyHandlers.ofInputStream());
+                       MultiStatusReader msReader = new MultiStatusReader(response.body(), uri.getPath());
+                       return msReader;
+               } catch (IOException | InterruptedException e) {
+                       throw new IllegalStateException("Cannot list children of " + uri, e);
+               }
+
+       }
+
+       public boolean exists(URI uri) {
+               try {
+                       HttpRequest request = HttpRequest.newBuilder().uri(uri) //
+                                       .header(DavHeader.DEPTH.getHeaderName(), DavDepth.DEPTH_0.getValue()) //
+                                       .method(DavMethod.HEAD.name(), BodyPublishers.noBody()) //
+                                       .build();
+                       BodyHandler<String> bodyHandler = BodyHandlers.ofString();
+                       HttpResponse<String> response = httpClient.send(request, bodyHandler);
+                       System.out.println(response.body());
+                       int responseStatusCode = response.statusCode();
+                       if (responseStatusCode == HttpResponseStatus.NOT_FOUND.getCode())
+                               return false;
+                       if (responseStatusCode >= 200 && responseStatusCode < 300)
+                               return true;
+                       throw new IllegalStateException(
+                                       "Cannot check whether " + uri + " exists: Unknown response status code " + responseStatusCode);
+               } catch (IOException | InterruptedException e) {
+                       throw new IllegalStateException("Cannot check whether " + uri + " exists", e);
+               }
+
+       }
+
+       public DavResponse get(URI uri) {
+               try {
+                       String body = """
+                                       <?xml version="1.0" encoding="utf-8" ?>
+                                       <D:propfind xmlns:D="DAV:">
+                                         <D:allprop/>
+                                       </D:propfind>""";
+                       HttpRequest request = HttpRequest.newBuilder().uri(uri) //
+                                       .header(DavHeader.DEPTH.getHeaderName(), DavDepth.DEPTH_0.getValue()) //
+                                       .method(DavMethod.PROPFIND.name(), BodyPublishers.ofString(body)) //
+                                       .build();
+
+//                     HttpResponse<String> responseStr = httpClient.send(request, BodyHandlers.ofString());
+//                     System.out.println(responseStr.body());
+
+                       HttpResponse<InputStream> response = httpClient.send(request, BodyHandlers.ofInputStream());
+                       MultiStatusReader msReader = new MultiStatusReader(response.body());
+                       if (!msReader.hasNext())
+                               throw new IllegalArgumentException(uri + " does not exist");
+                       return msReader.next();
+               } catch (IOException | InterruptedException e) {
+                       throw new IllegalStateException("Cannot list children of " + uri, e);
+               }
+
+       }
+
+       public static void main(String[] args) {
+               DavClient davClient = new DavClient();
+//             Iterator<DavResponse> responses = davClient
+//                             .listChildren(URI.create("http://localhost/unstable/a2/org.argeo.tp.sdk/"));
+               Iterator<DavResponse> responses = davClient
+                               .listChildren(URI.create("http://root:demo@localhost:7070/api/acr/srv/example"));
+               while (responses.hasNext()) {
+                       DavResponse response = responses.next();
+                       System.out.println(response.getHref() + (response.isCollection() ? " (collection)" : ""));
+                       System.out.println("  " + response.getPropertyNames());
+
+               }
+//             davClient.setProperty("http://localhost/unstable/a2/org.argeo.tp.sdk/org.opentest4j.1.2.jar",
+//                             CrName.uuid.qName(), UUID.randomUUID().toString());
+
+       }
+
+}