-/*
- * Copyright (C) 2007-2012 Argeo GmbH
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
package org.argeo.slc.repo;
import java.io.InputStream;
import org.apache.commons.io.IOUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.argeo.ArgeoMonitor;
+import org.argeo.jcr.JcrMonitor;
import org.argeo.jcr.JcrUtils;
-import org.argeo.node.NodeUtils;
+import org.argeo.api.NodeUtils;
import org.argeo.slc.SlcException;
import org.xml.sax.SAXException;
private final static Log log = LogFactory.getLog(RepoSync.class);
// Centralizes definition of workspaces that must be ignored by the sync.
- private final static List<String> IGNORED_WKSP_LIST = Arrays.asList(
- "security", "localrepo");
+ private final static List<String> IGNORED_WKSP_LIST = Arrays.asList("security", "localrepo");
private final Calendar zero;
private Session sourceDefaultSession = null;
private RepositoryFactory repositoryFactory;
- private ArgeoMonitor monitor;
+ private JcrMonitor monitor;
private Map<String, String> workspaceMap;
// TODO fix monitor
* @param targetRepository
* @param targetCredentials
*/
- public RepoSync(Repository sourceRepository, Credentials sourceCredentials,
- Repository targetRepository, Credentials targetCredentials) {
+ public RepoSync(Repository sourceRepository, Credentials sourceCredentials, Repository targetRepository,
+ Credentials targetCredentials) {
this();
this.sourceRepository = sourceRepository;
this.sourceCredentials = sourceCredentials;
// Setup
if (sourceRepository == null)
- sourceRepository = NodeUtils.getRepositoryByUri(
- repositoryFactory, sourceRepoUri);
+ sourceRepository = NodeUtils.getRepositoryByUri(repositoryFactory, sourceRepoUri);
if (sourceCredentials == null && sourceUsername != null)
- sourceCredentials = new SimpleCredentials(sourceUsername,
- sourcePassword);
- sourceDefaultSession = sourceRepository.login(sourceCredentials);
+ sourceCredentials = new SimpleCredentials(sourceUsername, sourcePassword);
+ // FIXME make it more generic
+ sourceDefaultSession = sourceRepository.login(sourceCredentials, RepoConstants.DEFAULT_DEFAULT_WORKSPACE);
if (targetRepository == null)
- targetRepository = NodeUtils.getRepositoryByUri(
- repositoryFactory, targetRepoUri);
+ targetRepository = NodeUtils.getRepositoryByUri(repositoryFactory, targetRepoUri);
if (targetCredentials == null && targetUsername != null)
- targetCredentials = new SimpleCredentials(targetUsername,
- targetPassword);
+ targetCredentials = new SimpleCredentials(targetUsername, targetPassword);
targetDefaultSession = targetRepository.login(targetCredentials);
Map<String, Exception> errors = new HashMap<String, Exception>();
- for (String sourceWorkspaceName : sourceDefaultSession
- .getWorkspace().getAccessibleWorkspaceNames()) {
+ for (String sourceWorkspaceName : sourceDefaultSession.getWorkspace().getAccessibleWorkspaceNames()) {
if (monitor != null && monitor.isCanceled())
break;
- if (workspaceMap != null
- && !workspaceMap.containsKey(sourceWorkspaceName))
+ if (workspaceMap != null && !workspaceMap.containsKey(sourceWorkspaceName))
continue;
if (IGNORED_WKSP_LIST.contains(sourceWorkspaceName))
continue;
Session sourceSession = null;
Session targetSession = null;
- String targetWorkspaceName = workspaceMap
- .get(sourceWorkspaceName);
+ String targetWorkspaceName = workspaceMap.get(sourceWorkspaceName);
try {
try {
- targetSession = targetRepository.login(
- targetCredentials, targetWorkspaceName);
+ targetSession = targetRepository.login(targetCredentials, targetWorkspaceName);
} catch (NoSuchWorkspaceException e) {
- targetDefaultSession.getWorkspace().createWorkspace(
- targetWorkspaceName);
- targetSession = targetRepository.login(
- targetCredentials, targetWorkspaceName);
+ targetDefaultSession.getWorkspace().createWorkspace(targetWorkspaceName);
+ targetSession = targetRepository.login(targetCredentials, targetWorkspaceName);
}
- sourceSession = sourceRepository.login(sourceCredentials,
- sourceWorkspaceName);
+ sourceSession = sourceRepository.login(sourceCredentials, sourceWorkspaceName);
syncWorkspace(sourceSession, targetSession);
} catch (Exception e) {
- errors.put("Could not sync workspace "
- + sourceWorkspaceName, e);
+ errors.put("Could not sync workspace " + sourceWorkspaceName, e);
if (log.isErrorEnabled())
e.printStackTrace();
log.info("Sync has been canceled by user");
long duration = (System.currentTimeMillis() - begin) / 1000;// s
- log.info("Sync " + sourceRepoUri + " to " + targetRepoUri + " in "
- + (duration / 60)
+ log.info("Sync " + sourceRepoUri + " to " + targetRepoUri + " in " + (duration / 60)
+ "min " + (duration % 60) + "s");
throw new SlcException("Sync failed " + errors);
}
} catch (RepositoryException e) {
- throw new SlcException("Cannot sync " + sourceRepoUri + " to "
- + targetRepoUri, e);
+ throw new SlcException("Cannot sync " + sourceRepoUri + " to " + targetRepoUri, e);
} finally {
JcrUtils.logoutQuietly(sourceDefaultSession);
JcrUtils.logoutQuietly(targetDefaultSession);
if (IGNORED_WKSP_LIST.contains(session.getWorkspace().getName()))
return 0l;
try {
- Query countQuery = session
- .getWorkspace()
- .getQueryManager()
- .createQuery(
- "select file from ["
- + (true ? NodeType.NT_FILE
- : NodeType.NT_BASE) + "] as file",
- Query.JCR_SQL2);
+ Query countQuery = session.getWorkspace().getQueryManager().createQuery(
+ "select file from [" + (true ? NodeType.NT_FILE : NodeType.NT_BASE) + "] as file", Query.JCR_SQL2);
QueryResult result = countQuery.execute();
Long expectedCount = result.getNodes().getSize();
return expectedCount;
} catch (RepositoryException e) {
- throw new SlcException("Unexpected error while computing "
- + "the size of the fetch for workspace "
+ throw new SlcException("Unexpected error while computing " + "the size of the fetch for workspace "
+ session.getWorkspace().getName(), e);
}
}
}
try {
- String msg = "Synchronizing workspace: "
- + sourceSession.getWorkspace().getName();
+ String msg = "Synchronizing workspace: " + sourceSession.getWorkspace().getName();
if (monitor != null)
monitor.setTaskName(msg);
if (log.isDebugEnabled())
log.debug(msg);
- if (filesOnly) {
- JcrUtils.copyFiles(sourceSession.getRootNode(),
- targetSession.getRootNode(), true, monitor);
- } else {
- for (NodeIterator it = sourceSession.getRootNode().getNodes(); it
- .hasNext();) {
- Node node = it.nextNode();
- if (node.getName().equals("jcr:system"))
- continue;
- syncNode(node, targetSession);
- }
+ for (NodeIterator it = sourceSession.getRootNode().getNodes(); it.hasNext();) {
+ Node node = it.nextNode();
+ if (node.getName().contains(":"))
+ continue;
+ if (node.getName().equals("download"))
+ continue;
+ if (!node.isNodeType(NodeType.NT_HIERARCHY_NODE))
+ continue;
+ syncNode(node, targetSession);
}
+ // if (filesOnly) {
+ // JcrUtils.copyFiles(sourceSession.getRootNode(), targetSession.getRootNode(),
+ // true, monitor);
+ // } else {
+ // for (NodeIterator it = sourceSession.getRootNode().getNodes(); it.hasNext();)
+ // {
+ // Node node = it.nextNode();
+ // if (node.getName().equals("jcr:system"))
+ // continue;
+ // syncNode(node, targetSession);
+ // }
+ // }
if (log.isDebugEnabled())
log.debug("Synced " + sourceSession.getWorkspace().getName());
} catch (Exception e) {
e.printStackTrace();
- throw new SlcException("Cannot sync "
- + sourceSession.getWorkspace().getName() + " to "
+ throw new SlcException("Cannot sync " + sourceSession.getWorkspace().getName() + " to "
+ targetSession.getWorkspace().getName(), e);
}
}
updateMonitor(msg, false);
}
- protected void syncNode(Node sourceNode, Session targetSession)
- throws RepositoryException, SAXException {
+ protected void syncNode(Node sourceNode, Session targetSession) throws RepositoryException, SAXException {
+ if (filesOnly) {
+ Node targetNode;
+ if (targetSession.itemExists(sourceNode.getPath()))
+ targetNode = targetSession.getNode(sourceNode.getPath());
+ else
+ targetNode = JcrUtils.mkdirs(targetSession, sourceNode.getPath(), NodeType.NT_FOLDER);
+ JcrUtils.copyFiles(sourceNode, targetNode, true, monitor, true);
+ return;
+ }
// Boolean singleLevel = singleLevel(sourceNode);
try {
if (monitor != null && monitor.isCanceled()) {
- updateMonitor("Fetched has been canceled, "
- + "process is terminating");
+ updateMonitor("Fetched has been canceled, " + "process is terminating");
return;
}
- Node targetParentNode = targetSession.getNode(sourceNode
- .getParent().getPath());
+ Node targetParentNode = targetSession.getNode(sourceNode.getParent().getPath());
Node targetNode;
- if (monitor != null
- && sourceNode.isNodeType(NodeType.NT_HIERARCHY_NODE))
+ if (monitor != null && sourceNode.isNodeType(NodeType.NT_HIERARCHY_NODE))
monitor.subTask("Process " + sourceNode.getPath());
final Boolean isNew;
if (!targetSession.itemExists(sourceNode.getPath())) {
isNew = true;
- targetNode = targetParentNode.addNode(sourceNode.getName(),
- sourceNode.getPrimaryNodeType().getName());
+ targetNode = targetParentNode.addNode(sourceNode.getName(), sourceNode.getPrimaryNodeType().getName());
} else {
isNew = false;
targetNode = targetSession.getNode(sourceNode.getPath());
- if (!targetNode.getPrimaryNodeType().getName()
- .equals(sourceNode.getPrimaryNodeType().getName()))
- targetNode.setPrimaryType(sourceNode.getPrimaryNodeType()
- .getName());
+ if (!targetNode.getPrimaryNodeType().getName().equals(sourceNode.getPrimaryNodeType().getName()))
+ targetNode.setPrimaryType(sourceNode.getPrimaryNodeType().getName());
}
// export
// mixin and properties
for (NodeType nt : sourceNode.getMixinNodeTypes()) {
- if (!targetNode.isNodeType(nt.getName())
- && targetNode.canAddMixin(nt.getName()))
+ if (!targetNode.isNodeType(nt.getName()) && targetNode.canAddMixin(nt.getName()))
targetNode.addMixin(nt.getName());
}
copyProperties(sourceNode, targetNode);
if (sourceNode.isNodeType(NodeType.NT_HIERARCHY_NODE)) {
if (targetSession.hasPendingChanges()) {
if (sourceNode.isNodeType(NodeType.NT_FILE))
- updateMonitor((isNew ? "Added " : "Updated ")
- + targetNode.getPath(), true);
+ updateMonitor((isNew ? "Added " : "Updated ") + targetNode.getPath(), true);
// if (doSave)
targetSession.save();
} else {
}
}
- private void copyTimestamps(Node sourceNode, Node targetNode)
- throws RepositoryException {
+ private void copyTimestamps(Node sourceNode, Node targetNode) throws RepositoryException {
if (sourceNode.getDefinition().isProtected())
return;
if (targetNode.getDefinition().isProtected())
copyTimestamp(sourceNode, targetNode, Property.JCR_LAST_MODIFIED_BY);
}
- private void copyTimestamp(Node sourceNode, Node targetNode, String property)
- throws RepositoryException {
+ private void copyTimestamp(Node sourceNode, Node targetNode, String property) throws RepositoryException {
if (sourceNode.hasProperty(property)) {
Property p = sourceNode.getProperty(property);
if (p.getDefinition().isProtected())
return;
if (targetNode.hasProperty(property)
- && targetNode
- .getProperty(property)
- .getValue()
- .equals(sourceNode.getProperty(property).getValue()))
+ && targetNode.getProperty(property).getValue().equals(sourceNode.getProperty(property).getValue()))
return;
- targetNode.setProperty(property, sourceNode.getProperty(property)
- .getValue());
+ targetNode.setProperty(property, sourceNode.getProperty(property).getValue());
}
}
- private void copyProperties(Node sourceNode, Node targetNode)
- throws RepositoryException {
- properties: for (PropertyIterator pi = sourceNode.getProperties(); pi
- .hasNext();) {
+ private void copyProperties(Node sourceNode, Node targetNode) throws RepositoryException {
+ properties: for (PropertyIterator pi = sourceNode.getProperties(); pi.hasNext();) {
Property p = pi.nextProperty();
if (p.getDefinition().isProtected())
continue properties;
- if (p.getName().equals(Property.JCR_CREATED)
- || p.getName().equals(Property.JCR_CREATED_BY)
+ if (p.getName().equals(Property.JCR_CREATED) || p.getName().equals(Property.JCR_CREATED_BY)
|| p.getName().equals(Property.JCR_LAST_MODIFIED)
|| p.getName().equals(Property.JCR_LAST_MODIFIED_BY))
continue properties;
if (p.isMultiple()) {
if (!targetNode.hasProperty(p.getName())
- || !Arrays.equals(
- targetNode.getProperty(p.getName())
- .getValues(), p.getValues()))
+ || !Arrays.equals(targetNode.getProperty(p.getName()).getValues(), p.getValues()))
targetNode.setProperty(p.getName(), p.getValues());
} else {
if (!targetNode.hasProperty(p.getName())
- || !targetNode.getProperty(p.getName()).getValue()
- .equals(p.getValue()))
+ || !targetNode.getProperty(p.getName()).getValue().equals(p.getValue()))
targetNode.setProperty(p.getName(), p.getValue());
}
}
}
}
- private static void copyBinary(Property p, Node targetNode)
- throws RepositoryException {
+ private static void copyBinary(Property p, Node targetNode) throws RepositoryException {
InputStream in = null;
Binary sourceBinary = null;
Binary targetBinary = null;
}
in = sourceBinary.getStream();
- targetBinary = targetNode.getSession().getValueFactory()
- .createBinary(in);
+ targetBinary = targetNode.getSession().getValueFactory().createBinary(in);
targetNode.setProperty(p.getName(), targetBinary);
} catch (Exception e) {
throw new SlcException("Could not transfer " + p, e);
// throws RepositoryException, SAXException {
//
// // enable cancelation of the current fetch process
- // // FIXME insure the repository stays in a stable state
+ // // fxme insure the repository stays in a stable state
// if (monitor != null && monitor.isCanceled()) {
// updateMonitor("Fetched has been canceled, "
// + "process is terminating");
}
/**
- * Synchronises only one workspace, retrieved by name without changing its
- * name.
+ * Synchronises only one workspace, retrieved by name without changing its name.
*/
public void setSourceWksp(String sourceWksp) {
if (sourceWksp != null && !sourceWksp.trim().equals("")) {
/**
* Synchronises a map of workspaces that will be retrieved by name. If the
- * target name is not defined (eg null or an empty string) for a given
- * source workspace, we use the source name as target name.
+ * target name is not defined (eg null or an empty string) for a given source
+ * workspace, we use the source name as target name.
*/
public void setWkspMap(Map<String, String> workspaceMap) {
// clean the list to ease later use
this.workspaceMap = null;
}
- public void setMonitor(ArgeoMonitor monitor) {
+ public void setMonitor(JcrMonitor monitor) {
this.monitor = monitor;
}
projects / gpl / argeo-slc.git / blobdiff