MoveRequest.java
4.09 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
/*
* Decompiled with CFR 0_118.
*
* Could not load the following classes:
* org.apache.sling.api.SlingHttpServletRequest
* org.apache.sling.api.resource.Resource
* org.apache.sling.api.resource.ResourceResolver
* org.apache.sling.api.resource.ResourceUtil
* org.apache.sling.api.resource.SyntheticResource
* org.apache.sling.servlets.post.Modification
* org.apache.sling.servlets.post.PostResponse
* org.slf4j.Logger
* org.slf4j.LoggerFactory
*/
package com.adobe.granite.rest.impl.servlet;
import com.adobe.granite.rest.RequestException;
import com.adobe.granite.rest.ResourceManager;
import com.adobe.granite.rest.impl.servlet.AbstractCopyMoveRequest;
import java.util.List;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceUtil;
import org.apache.sling.api.resource.SyntheticResource;
import org.apache.sling.servlets.post.Modification;
import org.apache.sling.servlets.post.PostResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MoveRequest
extends AbstractCopyMoveRequest {
private Logger logger;
public MoveRequest() {
this.logger = LoggerFactory.getLogger(this.getClass());
}
@Override
protected void doHandle(SlingHttpServletRequest request, PostResponse response, List<Modification> changes) throws UnsupportedOperationException, RequestException, Exception {
try {
Resource resource = request.getResource();
this.getDepth(request);
String overwrite = this.getOverwrite(request);
String dstUri = this.getDestination(request);
if (!dstUri.startsWith("/")) {
dstUri = ResourceUtil.getParent((String)resource.getPath()) + "/" + dstUri;
}
dstUri = ResourceUtil.normalize((String)dstUri);
Resource dstRes = this.getDestinationResource(request, dstUri);
if ("T".equals(overwrite) && dstRes != null) {
request.getResourceResolver().delete(dstRes);
}
if ("F".equals(overwrite) && dstRes != null) {
throw new RequestException(412, "Destination already exists");
}
if (resource instanceof SyntheticResource) {
throw new RequestException(404, "Missing source " + (Object)resource + " for COPY");
}
ResourceManager resourceMgr = (ResourceManager)request.adaptTo(ResourceManager.class);
if (resourceMgr != null) {
boolean created = resourceMgr.move(resource, dstUri);
changes.add(Modification.onMoved((String)resource.getPath(), (String)dstUri));
if (created) {
response.setStatus(201, "Content created " + dstUri);
response.setCreateRequest(true);
} else {
response.setStatus(204, "Content overwritten " + dstUri);
}
} else {
this.logger.warn("SlingHttpServletRequest is not adaptable to ResourceManager");
}
}
catch (UnsupportedOperationException e) {
throw new RequestException(403, "Source does not support copy");
}
}
protected int getDepth(SlingHttpServletRequest request) throws RequestException {
int depth = -1;
String depthHeader = request.getHeader("X-Depth");
if (depthHeader != null && !"infinity".equalsIgnoreCase(depthHeader)) {
throw new RequestException(412, "Request header 'X-Depth' must be 'inifity'");
}
return depth;
}
protected String getOverwrite(SlingHttpServletRequest request) throws RequestException {
String headerValue = request.getHeader("X-Overwrite");
if (headerValue != null) {
if ("FT".indexOf(headerValue.toUpperCase().trim()) > -1) {
return headerValue;
}
throw new RequestException(412, "Request header 'X-Overwrite' value '" + headerValue + "' unsupported");
}
return null;
}
}