();
private final int BATCH_SIZE = 10;
private Processor(Replicator replicator, ResourceResolver resolver, PrintWriter out, SlingScriptHelper sling, I18n i18n) {
this.replicator = replicator;
this.resolver = resolver;
this.out = out;
this.session = resolver.adaptTo(Session.class);
this.sling = sling;
this.i18n = i18n;
this.xssAPI = sling.getService(XSSAPI.class);
}
public void setOnlyModified(boolean onlyModified) {
this.onlyModified = onlyModified;
}
public void setReactivate(boolean reactivate) {
this.reactivate = reactivate;
}
public void setIgnoreDeactivated(boolean ignoreDeactivated) {
this.ignoreDeactivated = ignoreDeactivated;
}
public void setDryRun(boolean dryRun) {
this.dryRun = dryRun;
}
public void process(String path) {
if (path == null || path.length() == 0) {
out.printf("" + i18n.get("No start path specified.") + "
");
return;
}
// snip off all trailing slashes
while (path.endsWith("/")) {
path = path.substring(0, path.length() - 1);
}
// reject root and 1 level paths
if (path.lastIndexOf('/') <= 0) {
if (path.length() == 0) {
path = "/";
}
out.printf("" + xssAPI.encodeForHTML(i18n.get("Refusing to tree-activate '{0}'", null, path)) + "
");
return;
}
Resource res = resolver.getResource(path);
if (res == null) {
out.printf("" + xssAPI.encodeForHTML(i18n.get("The resource at '{0}' does not exist.", null, path)) + "
");
return;
}
out.printf("%n%n");
if(dryRun){
if(onlyModified && !reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are modified", null, path)) + "
");
else if(!onlyModified && reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are activated", null, path)) + "
");
else if(!onlyModified && !reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are not deactivated", null, path)) + "
");
else if(onlyModified && !reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are modified and not deactivated", null, path)) + "
");
else if(onlyModified && reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are modified and activated", null, path)) + "
");
else if(!onlyModified && reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are activated and not deactivated", null, path)) + "
");
else if(onlyModified && reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages that are modified and activated and not deactivated", null, path)) + "
");
else
out.printf("" + xssAPI.encodeForHTML(i18n.get("Simulating tree nice-activation below path '{0}' of all pages", null, path)) + "
");
}
else{
if(onlyModified && !reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are modified", null, path)) + "
");
else if(!onlyModified && reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are activated", null, path)) + "
");
else if(!onlyModified && !reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are not deactivated", null, path)) + "
");
else if(onlyModified && !reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are modified and not deactivated", null, path)) + "
");
else if(onlyModified && reactivate && !ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are modified and activated", null, path)) + "
");
else if(!onlyModified && reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are activated and not deactivated", null, path)) + "
");
else if(onlyModified && reactivate && ignoreDeactivated)
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages that are modified and activated and not deactivated", null, path)) + "
");
else
out.printf("" + xssAPI.encodeForHTML(i18n.get("Starting tree nice-activation below path '{0}' of all pages", null, path)) + "
");
}
out.printf("
%n");
long startTime = System.currentTimeMillis();
tCount = aCount = 0;
try {
process(res);
replicate(session, null);
long endTime = System.currentTimeMillis();
out.printf("
" + xssAPI.encodeForHTML(i18n.get("Activated {0} of {1} resources in {2} seconds.", null, aCount, tCount, (endTime-startTime)/1000)) + "
");
} catch (Exception e) {
out.printf("" + xssAPI.encodeForHTML(i18n.get("Error during processing: {0}", null, e.toString())) + "
");
log.error("Error during tree activation of " + path, e);
}
out.printf("%n%n");
out.flush();
}
private boolean process(Resource res)
throws RepositoryException, ReplicationException {
// we can only tree-activate hierarchy nodes
Node node = res.adaptTo(Node.class);
if (node==null || !node.isNodeType("nt:hierarchyNode")) {
return false;
}
Page page = res.adaptTo(Page.class);
Asset asset = res.adaptTo(Asset.class);
long lastModified;
if (page != null) {
lastModified = page.getLastModified() == null
? -1
: page.getLastModified().getTimeInMillis();
} else if (asset != null) {
lastModified = asset.getLastModified() == 0
? -1
: asset.getLastModified();
}else {
ResourceMetadata data = res.getResourceMetadata();
lastModified = data.getModificationTime();
}
String title = Text.getName(res.getPath());
LabeledResource lr = res.adaptTo(LabeledResource.class);
if (lr != null && lr.getTitle() != null) {
title = lr.getTitle();
}
ReplicationStatus rs = res.adaptTo(ReplicationStatus.class);
long lastPublished = 0;
boolean isDeactivated = false;
boolean isActivated = false;
if (rs != null && rs.getLastPublished() != null) {
lastPublished = rs.getLastPublished().getTimeInMillis();
isDeactivated = rs.isDeactivated();
isActivated = rs.isActivated();
}
boolean isModified = lastModified > lastPublished;
boolean doActivate = false;
String action;
if (!isModified && onlyModified) {
doActivate = false;
action = i18n.get("Ignore (not modified)");
} else if (!isActivated && reactivate) {
action = i18n.get("Ignore (not activated)");
} else if (isDeactivated && ignoreDeactivated) {
action = i18n.get("Ignore (deactivated)");
} else {
try {
replicator.checkPermission(this.session, ReplicationActionType.ACTIVATE, res.getPath());
action = i18n.get("Activate");
doActivate = true;
} catch (ReplicationException e) {
action = i18n.get("No replication permission");
}
}
tCount++;
if (doActivate) {
if (!dryRun) {
replicate(session, res);
}
aCount++;
}
// get classifier
String cf = "";
String delim = "(";
if (isModified) {
cf+= delim + i18n.get("modified");
delim = ", ";
}
if (isActivated) {
cf+= delim + i18n.get("activated");
delim = ", ";
}
if (isDeactivated) {
cf+= delim + i18n.get("deactivated");
}
if (cf.length() > 0) {
cf = "" + cf + ")";
}
// print
out.printf("%s
", doActivate ? "activate" : "ignore", action);
out.printf("%s
", xssAPI.encodeForHTML(title));
out.printf("%s %s [%d]
", xssAPI.encodeForHTML(res.getPath()), cf, tCount);
out.flush();
long now = System.currentTimeMillis();
if (now - lastUpdate > 1000L) {
lastUpdate = now;
out.printf("%n");
out.flush();
}
Iterator iter = resolver.listChildren(res);
while (iter.hasNext()) {
process(iter.next());
}
// flush
return true;
}
private void replicate(Session session, Resource res) throws RepositoryException {
try {
boolean doReplicate = false;
if (res != null) {
replicatedPaths.add(res.getPath());
doReplicate = replicatedPaths.size() >= BATCH_SIZE;
} else {
doReplicate = replicatedPaths.size() > 0;
}
if (doReplicate) {
if (session.hasPendingChanges()) {
session.refresh(true);
}
String[] array = replicatedPaths.toArray(new String[replicatedPaths.size()]);
replicator.replicate(session, ReplicationActionType.ACTIVATE, array, null);
out.printf("Flush
");
out.printf("%d resources activated
", array.length);
out.printf("");
out.flush();
replicatedPaths.clear();
}
} catch (ReplicationException e) {
out.printf("" + xssAPI.encodeForHTML(i18n.get("Error during processing: {0}", null, e.toString())) + "
");
log.error("Error during tree activation of " + res.getPath(), e);
if (e.getCause() instanceof RepositoryException) {
session.refresh(false);
}
}
}
}
%>