/*******************************************************************************
* Copyright (c) 2000, 2003 IBM Corporation and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Common Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/cpl-v10.html
*
* Contributors:
* IBM Corporation - initial API and implementation
*******************************************************************************/
package org.eclipse.team.internal.ccvs.ui.subscriber;
import java.util.ArrayList;
import java.util.List;
import org.eclipse.core.resources.IContainer;
import org.eclipse.core.resources.IFile;
import org.eclipse.core.resources.IResource;
import org.eclipse.core.runtime.CoreException;
import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.team.core.TeamException;
import org.eclipse.team.core.subscribers.SyncInfo;
import org.eclipse.team.core.subscribers.TeamSubscriber;
import org.eclipse.team.core.sync.IRemoteResource;
import org.eclipse.team.internal.ccvs.core.CVSException;
import org.eclipse.team.internal.ccvs.core.CVSMergeSubscriber;
import org.eclipse.team.internal.ccvs.core.CVSSyncInfo;
import org.eclipse.team.internal.ccvs.core.CVSTag;
import org.eclipse.team.internal.ccvs.core.ICVSFolder;
import org.eclipse.team.internal.ccvs.core.client.Command;
import org.eclipse.team.internal.ccvs.core.client.Update;
import org.eclipse.team.internal.ccvs.core.resources.CVSWorkspaceRoot;
import org.eclipse.team.internal.ccvs.ui.Policy;
import org.eclipse.team.ui.sync.OrSyncInfoFilter;
import org.eclipse.team.ui.sync.SyncInfoDirectionFilter;
import org.eclipse.team.ui.sync.SyncInfoFilter;
import org.eclipse.team.ui.sync.SyncInfoSet;
/**
* This action performs a "cvs update -j start -j end ..." to merge changes
* into the local workspace.
*/
public class MergeUpdateAction extends SafeUpdateAction {
/* (non-Javadoc)
* @see org.eclipse.team.ui.sync.SubscriberAction#getSyncInfoFilter()
*/
protected SyncInfoFilter getSyncInfoFilter() {
// Update works for all incoming and conflicting nodes
// TODO: there should be an instance variable for the filter
return new OrSyncInfoFilter(new SyncInfoFilter[] {
new SyncInfoDirectionFilter(SyncInfo.INCOMING),
new SyncInfoDirectionFilter(SyncInfo.CONFLICTING)
});
}
protected void updated(IResource[] resources) throws CVSException {
// Mark all succesfully updated resources as merged
((CVSMergeSubscriber)getSubscriber()).merged(resources);
}
/* (non-Javadoc)
* @see org.eclipse.team.internal.ccvs.ui.subscriber.SafeUpdateAction#runUpdateDeletions(org.eclipse.team.internal.ui.sync.views.SyncInfo[], org.eclipse.team.internal.ccvs.ui.repo.RepositoryManager, org.eclipse.core.runtime.IProgressMonitor)
*/
protected void runUpdateDeletions(SyncInfo[] nodes, IProgressMonitor monitor) throws TeamException {
// When merging, update deletions become outgoing deletions so just delete
// the files locally without unmanaging (so the sync info is kept to
// indicate an outgoing deletion
try {
monitor.beginTask(null, 100 * nodes.length);
for (int i = 0; i < nodes.length; i++) {
IResource resource = nodes[i].getLocal();
if (resource.getType() == IResource.FILE) {
((IFile)resource).delete(false /* force */, true /* keep local history */, Policy.subMonitorFor(monitor, 100));
}
}
} catch (CoreException e) {
throw CVSException.wrapException(e);
} finally {
monitor.done();
}
}
/* (non-Javadoc)
* @see org.eclipse.team.internal.ccvs.ui.subscriber.SubscriberUpdateAction#runUpdateShallow(org.eclipse.team.internal.ui.sync.views.SyncInfo[], org.eclipse.team.internal.ccvs.ui.repo.RepositoryManager, org.eclipse.core.runtime.IProgressMonitor)
*/
protected void runSafeUpdate(SyncInfo[] nodes, IProgressMonitor monitor) throws TeamException {
TeamSubscriber subscriber = getSubscriber();
if (!(subscriber instanceof CVSMergeSubscriber)) {
throw new CVSException("Invalid subscriber: " + subscriber.getId());
}
CVSTag startTag = ((CVSMergeSubscriber)subscriber).getStartTag();
CVSTag endTag = ((CVSMergeSubscriber)subscriber).getEndTag();
// Incoming additions require different handling then incoming changes and deletions
List additions = new ArrayList();
List changes = new ArrayList();
for (int i = 0; i < nodes.length; i++) {
SyncInfo resource = nodes[i];
int kind = resource.getKind();
if ((kind & SyncInfo.ADDITION) != 0) {
additions.add(resource);
} else {
changes.add(resource);
}
}
monitor.beginTask(null, (additions.size() + changes.size()) * 100);
if (!additions.isEmpty()) {
safeUpdate(
getIResourcesFrom((SyncInfo[]) additions.toArray(new SyncInfo[additions.size()])),
new Command.LocalOption[] {
Command.DO_NOT_RECURSE,
Update.makeArgumentOption(Update.JOIN, endTag.getName())
},
Policy.subMonitorFor(monitor, additions.size() * 100));
}
if (!changes.isEmpty()) {
safeUpdate(
getIResourcesFrom((SyncInfo[]) changes.toArray(new SyncInfo[changes.size()])),
new Command.LocalOption[] {
Command.DO_NOT_RECURSE,
Update.makeArgumentOption(Update.JOIN, startTag.getName()),
Update.makeArgumentOption(Update.JOIN, endTag.getName())
},
Policy.subMonitorFor(monitor, changes.size() * 100));
}
monitor.done();
}
/*
* @see UpdateSyncAction#runUpdateDeep(IProgressMonitor, List, RepositoryManager)
* incoming-change
* incoming-deletion
*/
protected void overwriteUpdate(SyncInfoSet set, IProgressMonitor monitor) throws TeamException {
SyncInfo[] nodes = set.getSyncInfos();
monitor.beginTask(null, 1000 * nodes.length);
try {
for (int i = 0; i < nodes.length; i++) {
makeRemoteLocal(nodes[i], Policy.subMonitorFor(monitor, 1000));
}
} finally {
monitor.done();
}
}
/*
* If called on a new folder, the folder will become an outgoing addition.
*/
private void makeRemoteLocal(SyncInfo info, IProgressMonitor monitor) throws TeamException {
IRemoteResource remote = info.getRemote();
IResource local = info.getLocal();
try {
if(remote==null) {
local.delete(false, monitor);
} else {
if(remote.isContainer()) {
ensureContainerExists(info);
} else {
monitor.beginTask(null, 200);
try {
IFile localFile = (IFile)local;
if(local.exists()) {
localFile.setContents(remote.getContents(Policy.subMonitorFor(monitor, 100)), false /*don't force*/, true /*keep history*/, Policy.subMonitorFor(monitor, 100));
} else {
ensureContainerExists(getParent(info));
localFile.create(remote.getContents(Policy.subMonitorFor(monitor, 100)), false /*don't force*/, Policy.subMonitorFor(monitor, 100));
}
} finally {
monitor.done();
}
}
}
} catch(CoreException e) {
throw new CVSException(Policy.bind("UpdateMergeActionProblems_merging_remote_resources_into_workspace_1"), e); //$NON-NLS-1$
}
}
private void ensureContainerExists(SyncInfo info) throws TeamException {
IResource local = info.getLocal();
// make sure that the parent exists
if (!local.exists()) {
ensureContainerExists(getParent(info));
}
// make sure that the folder sync info is set;
if (info instanceof CVSSyncInfo) {
CVSSyncInfo cvsInfo = (CVSSyncInfo)info;
cvsInfo.makeInSync();
}
// create the folder if it doesn't exist
ICVSFolder cvsFolder = CVSWorkspaceRoot.getCVSFolderFor((IContainer)local);
if (!cvsFolder.exists()) {
cvsFolder.mkdir();
}
}
}
