when ReplicationContentFilter actually gets trigerred
1. i want some properties and nodes get filtered out when i click replicate prgramatically.
2. my actual requirement is when i click quick publish, I want some properties with values /conf/.... not to get published.
Below is my actual code.
Filter for /bin/replicate
package com.macnicagwi.core.filters;
import org.apache.jackrabbit.api.security.user.Group;
import org.apache.jackrabbit.api.security.user.User;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.apache.sling.servlets.annotations.SlingServletFilter;
import org.apache.sling.servlets.annotations.SlingServletFilterScope;
import org.osgi.service.component.annotations.Component;
import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.day.cq.replication.ReplicationAction;
import com.day.cq.replication.ReplicationActionType;
import com.day.cq.replication.ReplicationContentFilter;
import com.day.cq.replication.ReplicationContentFilterFactory;
import com.day.cq.replication.ReplicationException;
import com.day.cq.replication.Replicator;
import javax.jcr.RepositoryException;
import javax.jcr.Session;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import java.io.IOException;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;
@8220494
@SlingServletFilter(
scope = {SlingServletFilterScope.REQUEST},
pattern = "/bin/replicate",
methods = {"POST"}
)
public class replicationFilter implements Filter {
private static final Logger logger = LoggerFactory.getLogger(replicationFilter.class);
@3214626
ResourceResolverFactory factory;
SlingHttpServletRequest slingRequest;
@3214626 Replicator replicator;
@9944223
public final void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException,
ServletException {
final SlingHttpServletResponse slingResponse = (SlingHttpServletResponse) response;
slingRequest = (SlingHttpServletRequest) request;
String servletPath = slingRequest.getRequestPathInfo().getResourcePath();
logger.info("reached the path: {}",servletPath);
try {
if(isquickPublish(request) && isPublisher()) {
String[] paths = slingRequest.getParameterValues("path");
Session session = slingRequest.getResourceResolver().adaptTo(Session.class);
ReplicationContentFilterFactory replicationFilterFacotry = new ReplicationContentFilterFactoryImpl();
for(String path : paths) {
ReplicationAction replicationAction = new ReplicationAction(ReplicationActionType.ACTIVATE, path);
ReplicationContentFilter filter = replicationFilterFacotry.createFilter(replicationAction);
replicator.replicate(session, ReplicationActionType.ACTIVATE, path);
}
}
} catch (RepositoryException | ReplicationException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
chain.doFilter(request, response);
}
private boolean isPublisher() throws RepositoryException {
// TODO Auto-generated method stub
// ResourceResolver resourceResolver = MacnicaCoreUtils.getResourceResolver(factory, "macnicagwi-wcm-system");
ResourceResolver resourceResolver = slingRequest.getResourceResolver();
String id = resourceResolver.getUserID();
User currentUser = resourceResolver.adaptTo(User.class);
logger.info("user name is: {}",currentUser.getID());
Iterator Group groupsIt = currentUser.declaredMemberOf();
while (groupsIt.hasNext()) {
Group group = groupsIt.next();
logger.info("group is: {}",group.toString());
String groupId = group.getID();
String groupName = group.getPrincipal().getName();
if(groupName.contains("approver")) {
logger.info("user is an approver");
return true;
}
logger.info("User belongs to this group {}", groupId);
}
return false;
}
private boolean isquickPublish(ServletRequest request) {
// TODO Auto-generated method stub
if(request.getParameter("model")==null && request.getParameter("absoluteTime")==null) {
return true;
}
return false;
}
}
ReolicationContentFilterImpl
package com.macnicagwi.core.filters;
import java.util.List;
import javax.jcr.Node;
import javax.jcr.Property;
import javax.jcr.RepositoryException;
import org.osgi.service.component.annotations.Component;
import com.day.cq.replication.ReplicationContentFilter;
@8220494(service = ReplicationContentFilter.class)
public class ReplicationContentFilterImpl implements ReplicationContentFilter {
@9944223
public boolean accepts(Node node) {
// TODO Auto-generated method stub
try {
return !node.getPath().startsWith("/conf");
} catch (RepositoryException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return true;
}
@9944223
public boolean accepts(Property property) {
// TODO Auto-generated method stub
try {
return !property.getValue().getString().startsWith("/conf");
} catch (IllegalStateException | RepositoryException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return true;
}
@9944223
public boolean allowsDescent(Node node) {
// TODO Auto-generated method stub
return accepts(node);
}
@9944223
public List<String> getFilteredPaths() {
// TODO Auto-generated method stub
return null;
}
}
ReplicationContentFilterFactoryImpl