Below is the code that worked for me. I've highlighted couple of changes that I did in DecryptAssetsFilter shared in that link:
- Used slingRequest.getParts() to iterate rather than the custom request attribute
- changed the method getSubmittedFileName() to getName()
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
throws IOException, ServletException {
if (!(request instanceof SlingHttpServletRequest) || !(response instanceof SlingHttpServletResponse)) {
chain.doFilter(request, response);
return;
}
final SlingHttpServletRequest slingRequest = (SlingHttpServletRequest) request;
if (!StringUtils.equals("POST", slingRequest.getMethod()) || !isCreateAssetRequest(slingRequest)) {
chain.doFilter(request, response);
return;
}
log.info("Decoding create asset request - " + slingRequest.getRequestURI());
List parts = (ArrayList) slingRequest.getParts();
if ((parts == null) || parts.size() == 0) {
chain.doFilter(request, response);
return;
}
List<Part> otherParts = new ArrayList<Part>();
Part part = null;
for (int i = 0; i < parts.size() - 1; i++) {
part = (Part) parts.get(i);
otherParts.add(new EAEMDecryptRequestPart(part));
}
chain.doFilter(request, response);
}
private boolean isCreateAssetRequest(SlingHttpServletRequest slingRequest) {
String[] selectors = slingRequest.getRequestPathInfo().getSelectors();
if (ArrayUtils.isEmpty(selectors) || (selectors.length > 1)) {
return false;
}
return selectors[0].equals("createasset");
}
public void destroy() {
}
private static class EAEMDecryptRequestPart implements Part {
private final Part part;
private final InputStream inputStream;
private static final String TEMP_PREFIX = "eaem_decrypt_";
public EAEMDecryptRequestPart(Part part) throws IOException {
this.part = part;
if (!isFilePart(part)) {
this.inputStream = new ByteArrayInputStream(IOUtils.toByteArray(part.getInputStream()));
} else {
this.inputStream = this.getDecodedStream(part);
}
}
private InputStream getDecodedStream(Part part) throws IOException {
File tmpFile = File.createTempFile(TEMP_PREFIX, ".tmp");
// byte[] decoded =
// Base64.getDecoder().decode(IOUtils.toByteArray(part.getInputStream())); //use decode, if the input file is encoded
byte[] decoded = IOUtils.toByteArray(part.getInputStream());
FileOutputStream decodedStream = new FileOutputStream(tmpFile);
decodedStream.write(decoded);
decodedStream.close();
return new FileInputStream(tmpFile);
}
private boolean isFilePart(Part part) {
return StringUtils.isNotEmpty(part.getName());
}
public InputStream getInputStream() throws IOException {
return inputStream;
}
public String getContentType() {
return part.getContentType();
}
public String getName() {
return part.getName();
}
public long getSize() {
return 0;
}
public void write(String s) throws IOException {
throw new UnsupportedOperationException(
"Writing parts directly to disk is not supported by this implementation, use getInputStream instead");
}
public void delete() throws IOException {
}
public String getHeader(String headerName) {
return part.getHeader(headerName);
}
public Collection<String> getHeaders(String headerName) {
return part.getHeaders(headerName);
}
public Collection<String> getHeaderNames() {
return part.getHeaderNames();
}
public String getSubmittedFileName() {
return part.getName();
}
private <T> Collection<T> toCollection(Iterator<T> i) {
if (i == null) {
return Collections.emptyList();
} else {
List<T> c = new ArrayList<T>();
while (i.hasNext()) {
c.add(i.next());
}
return c;
}
}
}
}
