Smartphone

Goal

Replicate Assets from 60 author to 61 author using workflows (ideally any author-author)

Demo | Package Install (Includes Replication Agent and Workflow)

Solution

1) Create a Replication Agent on 60 author connecting to 61 author. Assuming the source author 60 is running on http://localhost:4502/ and destination author 61 running on http://localhost:5502/....

           a. Access http://localhost:4502/miscadmin#/etc/replication/agents.author

           b. Click New, select Replication Agent

                         Title: Replicate to 61 Author
                         Name: 61_author (this name is used in AgentFilter of ReplicationStep, added in next steps)



         
c. Agent as xml - /etc/replication/agents.author/61_author

<?xml version="1.0" encoding="UTF-8"?>
<jcr:root    
 jcr_primaryType="cq:Page">
 <jcr:content
 cq_lastModified="{Date}2015-08-13T11:51:39.314-05:00"
 cq_lastModifiedBy="admin"
 cq_template="/libs/cq/replication/templates/agent"
 jcr_lastModified="{Date}2015-08-13T11:51:39.286-05:00"
 jcr_lastModifiedBy="admin"
 jcr_primaryType="nt:unstructured"
 jcr_title="Replicate to 61 Author"
 sling_resourceType="cq/replication/components/agent"
 enabled="true"
 protocolHTTPMethod="POST"
 serializationType="durbo"
 ssl="default"
 transportPassword="{2878481d659c461d12b8db7a89ee0c422749e5f2958a757d00a79819da0f0187}"
 transportUri="http://localhost:5502/bin/receive?sling:authRequestLogin=1"
 transportUser="admin"
 triggerSpecific="true"/>
</jcr:root>

2) Create a Process Step apps.experienceaem.replication.ReplicationStep used for replicating the asset, with following code

package apps.experienceaem.replication;

import com.day.cq.dam.api.Asset;
import com.day.cq.dam.commons.process.AbstractAssetWorkflowProcess;
import com.day.cq.replication.*;
import com.day.cq.workflow.WorkflowException;
import com.day.cq.workflow.WorkflowSession;
import com.day.cq.workflow.exec.WorkItem;
import com.day.cq.workflow.metadata.MetaDataMap;
import org.apache.felix.scr.annotations.*;
import org.apache.sling.api.resource.LoginException;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.jcr.Session;
import java.util.ArrayList;
import java.util.List;

@Component
@Service
@Properties({@Property(name = "process.label", value = "Replicate Assets to 61 Author")})
public class ReplicationStep extends AbstractAssetWorkflowProcess {
 private static final Logger log = LoggerFactory.getLogger(ReplicationStep.class);

 // the agent used for replication
 private static final String REP_AGENT_61 = "61_author";

 @Reference
 Replicator replicator;

 @Reference
 private AgentManager agentMgr = null;

 @Reference
 ResourceResolverFactory resourceResolverFactory;

 @Override
 public void execute(WorkItem workItem, WorkflowSession workflowSession, MetaDataMap args)
 throws WorkflowException {
 try{
 if(!agentExists()){
 log.info("NO Replication agent " + REP_AGENT_61 + ", skipping replicating to 61");
 return;
 }

 Session session = workflowSession.getSession();
 Asset asset = getAssetFromPayload(workItem, session);

 List<String> paths = new ArrayList<String>();

 //add the file path to replication queue
 paths.add(asset.getPath());

 doReplicate(paths, session);
 }catch(Exception e){
 throw new WorkflowException("Error replicating to 61 Author", e);
 }
 }

 private boolean agentExists(){
 return agentMgr.getAgents().containsKey(REP_AGENT_61);
 }

 private void doReplicate(List<String> paths, Session session) throws Exception{
 ReplicationOptions opts = new ReplicationOptions();

 //use the 61 replication agent
 opts.setFilter(new AgentFilter() {
 public boolean isIncluded(com.day.cq.replication.Agent agent) {
 return agent.getId().equalsIgnoreCase(REP_AGENT_61);
 }
 });

 for(String path : paths){
 replicator.replicate(session, ReplicationActionType.ACTIVATE, path, opts);
 }
 }

 public ResourceResolver getResourceResolver(final Session session) {
 ResourceResolver resourceResolver = null;

 try {
 resourceResolver = resourceResolverFactory.getAdministrativeResourceResolver(null);
 } catch (LoginException e) {
 log.error("Error obtaining the resourceresolver",e);
 }

 return resourceResolver;
 }
}

3)  Create a workflow Replicate to 61 Author - /etc/workflow/models/replicate-to-61-author




4) Select an asset and start workflow Replicate to 61 Author