Editing jcr:data/binary/rendition in AEM

Sharing a code snippet to update a Binary file stored in AEM. Here, we are updating a binary file stored as jcr:data in the original rendition.

	package com.techrevel.dam.core.workflows;

	import java.io.BufferedReader;
	import java.io.ByteArrayInputStream;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.InputStreamReader;

	import javax.jcr.Binary;
	import javax.jcr.Node;
	import javax.jcr.RepositoryException;
	import javax.jcr.Session;

	import org.apache.sling.api.resource.Resource;
	import org.apache.sling.api.resource.ResourceResolver;
	import org.apache.sling.api.resource.ResourceResolverFactory;
	import org.osgi.service.component.annotations.Component;
	import org.osgi.service.component.annotations.Reference;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	import com.adobe.granite.workflow.WorkflowException;
	import com.adobe.granite.workflow.WorkflowSession;
	import com.adobe.granite.workflow.exec.WorkItem;
	import com.adobe.granite.workflow.exec.WorkflowProcess;
	import com.adobe.granite.workflow.metadata.MetaDataMap;
	import com.day.cq.commons.jcr.JcrConstants;

	@Component(service = WorkflowProcess.class, property = { "process.label=Update jcr:data binary" })
	public class UpdateBinaryWorkflowProcess implements WorkflowProcess {

	private static final Logger LOG = LoggerFactory.getLogger(UpdateBinaryWorkflowProcess.class);

	@Reference
	private ResourceResolverFactory resolverFactory;

	@Override
	public void execute(WorkItem workItem, WorkflowSession workflowSession, MetaDataMap metaDataMap)
	throws WorkflowException {
	String path = getPath(workItem);
	ResourceResolver resolver = null;
	try {
	resolver = getResolver(workflowSession);
	if (null != resolver) {
	Resource fileResource = resolver.getResource(path);
	if (null != fileResource) {
	Node fileNode = fileResource.adaptTo(Node.class);

	Session session = resolver.adaptTo(Session.class);
	if (null != session && null != fileNode && fileNode.hasProperty(JcrConstants.JCR_DATA)) {
	// Fetching XML from jcr:data property
	InputStream xmlContent = fileNode.getProperty(JcrConstants.JCR_DATA).getBinary().getStream();
	String xmlString = readXml(xmlContent);

	String updatedXml = xmlString.replaceAll("a", "b"); //Updated XML to be persisted
	InputStream targetStream = new ByteArrayInputStream(updatedXml.getBytes());
	Binary contentValue = session.getValueFactory().createBinary(targetStream);
	fileNode.setProperty(JcrConstants.JCR_DATA, contentValue);
	session.save();
	contentValue.dispose();
	LOG.debug("Successfully updated original rendition");

	}
	}
	}
	} catch (

	RepositoryException e) {
	LOG.error("Exception while updating xml:lang attribute : {}", e.getMessage());
	}
	}

	ResourceResolver getResolver(WorkflowSession workflowSession) {
	ResourceResolver rr = workflowSession.adaptTo(ResourceResolver.class);
	return rr;
	}

	String getPath(WorkItem workItem) {
	String path = workItem.getWorkflowData().getPayload().toString() + "/" + JcrConstants.JCR_CONTENT;
	return path;
	}

	public String readXml(InputStream content) {
	String readLine;
	BufferedReader br = new BufferedReader(new InputStreamReader(content));
	StringBuilder strBuilder = new StringBuilder();

	try {
	while (((readLine = br.readLine()) != null)) {
	strBuilder.append(readLine);
	}
	} catch (IOException e) {
	LOG.error("IOException while reading InputStream into String : {}", e.getMessage());
	}
	return strBuilder.toString();
	}
	}

view raw UpdateBinaryWorkflowProcess.java hosted with ❤ by GitHub

Share this:

Like this:

Leave a Reply Cancel reply