X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=plugins%2Forg.argeo.slc.client.ui.dist%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fclient%2Fui%2Fdist%2Fcommands%2FCopyWorkspace.java;h=72b5a75035045945845ae62190976de00954ef65;hb=5d3d00fff63d9744f0de1a5e4a3735fcb093d3be;hp=adf339e9e1c56bb86cb8735ce9b1a34dc41f91e4;hpb=651d33e13bfa9a7b46464be412023ee747e612e8;p=gpl%2Fargeo-slc.git diff --git a/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/commands/CopyWorkspace.java b/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/commands/CopyWorkspace.java index adf339e9e..72b5a7503 100644 --- a/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/commands/CopyWorkspace.java +++ b/plugins/org.argeo.slc.client.ui.dist/src/main/java/org/argeo/slc/client/ui/dist/commands/CopyWorkspace.java @@ -1,180 +1,114 @@ +/* + * 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.client.ui.dist.commands; +import javax.jcr.Credentials; import javax.jcr.Node; -import javax.jcr.NodeIterator; -import javax.jcr.Property; -import javax.jcr.PropertyIterator; import javax.jcr.Repository; import javax.jcr.RepositoryException; +import javax.jcr.RepositoryFactory; import javax.jcr.Session; -import javax.jcr.nodetype.NodeType; +import javax.jcr.security.Privilege; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; import org.argeo.ArgeoException; import org.argeo.jcr.JcrUtils; import org.argeo.slc.client.ui.dist.DistPlugin; import org.argeo.slc.client.ui.dist.utils.CommandHelpers; -import org.argeo.slc.jcr.SlcTypes; +import org.argeo.slc.repo.RepoUtils; +import org.argeo.util.security.Keyring; import org.eclipse.core.commands.AbstractHandler; import org.eclipse.core.commands.ExecutionEvent; import org.eclipse.core.commands.ExecutionException; import org.eclipse.jface.dialogs.InputDialog; -import org.eclipse.ui.IWorkbenchWindow; +import org.eclipse.ui.handlers.HandlerUtil; /** * Create a copy of the chosen workspace in the current repository. */ public class CopyWorkspace extends AbstractHandler { - private static final Log log = LogFactory.getLog(CopyWorkspace.class); + // private static final Log log = LogFactory.getLog(CopyWorkspace.class); public final static String ID = DistPlugin.ID + ".copyWorkspace"; - public final static String PARAM_WORKSPACE_NAME = DistPlugin.ID - + ".workspaceName"; public final static String DEFAULT_LABEL = "Duplicate"; + public final static String PARAM_SOURCE_WORKSPACE_NAME = "srcWkspName"; + public final static String PARAM_TARGET_REPO_PATH = "targetRepoPath"; public final static String DEFAULT_ICON_PATH = "icons/addItem.gif"; - /* DEPENDENCY INJECTION */ - private Repository repository; + // DEPENDENCY INJECTION + private RepositoryFactory repositoryFactory; + private Keyring keyring; + private Repository nodeRepository; - public Object execute(ExecutionEvent event) throws ExecutionException { - String srcWorkspaceName = event.getParameter(PARAM_WORKSPACE_NAME); + private String slcRole = "ROLE_SLC"; - if (log.isTraceEnabled()) - log.debug("WORKSPACE " + srcWorkspaceName + " About to be copied"); + public Object execute(ExecutionEvent event) throws ExecutionException { - // MessageDialog.openWarning(DistPlugin.getDefault() - // .getWorkbench().getDisplay().getActiveShell(), - // "WARNING", "Not yet implemented"); - // return null; + String targetRepoPath = event.getParameter(PARAM_TARGET_REPO_PATH); + String wkspName = event.getParameter(PARAM_SOURCE_WORKSPACE_NAME); - IWorkbenchWindow iww = DistPlugin.getDefault().getWorkbench() - .getActiveWorkbenchWindow(); - InputDialog inputDialog = new InputDialog(iww.getShell(), - "New copy of the current workspace", - "Choose a name for the workspace to create", "", null); - inputDialog.open(); - String newWorkspaceName = inputDialog.getValue(); + Session nodeSession = null; Session srcSession = null; Session newSession = null; try { - srcSession = repository.login(srcWorkspaceName); + nodeSession = nodeRepository.login(); + Node repoNode = nodeSession.getNode(targetRepoPath); + Repository repository = RepoUtils.getRepository(repositoryFactory, + keyring, repoNode); + Credentials credentials = RepoUtils.getRepositoryCredentials( + keyring, repoNode); + + InputDialog inputDialog = new InputDialog(HandlerUtil + .getActiveWorkbenchWindow(event).getShell(), + "New copy of workspace " + wkspName, + "Choose a name for the workspace to create", "", null); + inputDialog.open(); + String newWorkspaceName = inputDialog.getValue(); + srcSession = repository.login(credentials, wkspName); // Create the workspace srcSession.getWorkspace().createWorkspace(newWorkspaceName); Node srcRootNode = srcSession.getRootNode(); // log in the newly created workspace - newSession = repository.login(newWorkspaceName); - //newSession.save(); + newSession = repository.login(credentials, newWorkspaceName); Node newRootNode = newSession.getRootNode(); - copy(srcRootNode, newRootNode); + RepoUtils.copy(srcRootNode, newRootNode); newSession.save(); - + JcrUtils.addPrivilege(newSession, "/", slcRole, Privilege.JCR_ALL); CommandHelpers.callCommand(RefreshDistributionsView.ID); } catch (RepositoryException re) { throw new ArgeoException( "Unexpected error while creating the new workspace.", re); } finally { - if (srcSession != null) - srcSession.logout(); - if (newSession != null) - newSession.logout(); + JcrUtils.logoutQuietly(newSession); + JcrUtils.logoutQuietly(srcSession); + JcrUtils.logoutQuietly(nodeSession); } return null; } - // FIXME : commons is frozen, cannot fix the problem directly there. - // test and report corresponding patch - private void copy(Node fromNode, Node toNode) { - try { - if (log.isDebugEnabled()) - log.debug("copy node :" + fromNode.getPath()); - - // FIXME : small hack to enable specific workspace copy - if (fromNode.isNodeType("rep:ACL") - || fromNode.isNodeType("rep:system")) { - if (log.isTraceEnabled()) - log.trace("node skipped"); - return; - } - - // add mixins - for (NodeType mixinType : fromNode.getMixinNodeTypes()) { - toNode.addMixin(mixinType.getName()); - } - - // Double check - for (NodeType mixinType : toNode.getMixinNodeTypes()) { - if (log.isDebugEnabled()) - log.debug(mixinType.getName()); - } - - // process properties - PropertyIterator pit = fromNode.getProperties(); - properties: while (pit.hasNext()) { - Property fromProperty = pit.nextProperty(); - String propName = fromProperty.getName(); - try { - String propertyName = fromProperty.getName(); - if (toNode.hasProperty(propertyName) - && toNode.getProperty(propertyName).getDefinition() - .isProtected()) - continue properties; - - if (fromProperty.getDefinition().isProtected()) - continue properties; - - if (propertyName.equals("jcr:created") - || propertyName.equals("jcr:createdBy") - || propertyName.equals("jcr:lastModified") - || propertyName.equals("jcr:lastModifiedBy")) - continue properties; - - if (fromProperty.isMultiple()) { - toNode.setProperty(propertyName, - fromProperty.getValues()); - } else { - toNode.setProperty(propertyName, - fromProperty.getValue()); - } - } catch (RepositoryException e) { - throw new ArgeoException("Cannot property " + propName, e); - } - } - - // recursively process children nodes - NodeIterator nit = fromNode.getNodes(); - while (nit.hasNext()) { - Node fromChild = nit.nextNode(); - Integer index = fromChild.getIndex(); - String nodeRelPath = fromChild.getName() + "[" + index + "]"; - Node toChild; - if (toNode.hasNode(nodeRelPath)) - toChild = toNode.getNode(nodeRelPath); - else - toChild = toNode.addNode(fromChild.getName(), fromChild - .getPrimaryNodeType().getName()); - copy(fromChild, toChild); - } - - // update jcr:lastModified and jcr:lastModifiedBy in toNode in case - // they existed - if (!toNode.getDefinition().isProtected() - && toNode.isNodeType(NodeType.MIX_LAST_MODIFIED)) - JcrUtils.updateLastModified(toNode); - - // Workaround to reduce session size: artifact is a saveable unity - if (toNode.isNodeType(SlcTypes.SLC_ARTIFACT)) - toNode.getSession().save(); + /* DEPENDENCY INJECTION */ + public void setNodeRepository(Repository nodeRepository) { + this.nodeRepository = nodeRepository; + } - } catch (RepositoryException e) { - throw new ArgeoException("Cannot copy " + fromNode + " to " - + toNode, e); - } + public void setRepositoryFactory(RepositoryFactory repositoryFactory) { + this.repositoryFactory = repositoryFactory; } - /* DEPENDENCY INJECTION */ - public void setRepository(Repository repository) { - this.repository = repository; + public void setKeyring(Keyring keyring) { + this.keyring = keyring; } -} +} \ No newline at end of file