bundles/org.eclipse.team.cvs.core/src/org/eclipse/team/internal/ccvs/core/client/Update.java - platform/eclipse.platform.team - Git at Google

 /*******************************************************************************
  * 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.core.client;


 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;

 import org.eclipse.core.resources.IResource;
 import org.eclipse.core.runtime.IProgressMonitor;
 import org.eclipse.core.runtime.IStatus;
 import org.eclipse.team.core.RepositoryProvider;
 import org.eclipse.team.internal.ccvs.core.CVSException;
 import org.eclipse.team.internal.ccvs.core.CVSProviderPlugin;
 import org.eclipse.team.internal.ccvs.core.CVSStatus;
 import org.eclipse.team.internal.ccvs.core.CVSTag;
 import org.eclipse.team.internal.ccvs.core.CVSTeamProvider;
 import org.eclipse.team.internal.ccvs.core.ICVSFolder;
 import org.eclipse.team.internal.ccvs.core.ICVSResource;
 import org.eclipse.team.internal.ccvs.core.Policy;
 import org.eclipse.team.internal.ccvs.core.client.listeners.ICommandOutputListener;
 import org.eclipse.team.internal.ccvs.core.client.listeners.UpdateListener;

 public class Update extends Command {
 	/*** Local options: specific to update ***/
 	public static final LocalOption CLEAR_STICKY = new LocalOption("-A"); //$NON-NLS-1$
 	public static final LocalOption IGNORE_LOCAL_CHANGES = new LocalOption("-C"); //$NON-NLS-1$
 	public static final LocalOption RETRIEVE_ABSENT_DIRECTORIES = new LocalOption("-d"); //$NON-NLS-1$
 	public static final LocalOption JOIN = new LocalOption("-j"); //$NON-NLS-1$

 	/*** Default command output listener ***/
 	private static final ICommandOutputListener DEFAULT_OUTPUT_LISTENER = new UpdateListener(null);

 	/*** File information status returned from update ***/
 	public static final int STATE_NONE = 0;							// no state information available
 	public static final int STATE_ADDED_LOCAL = 1; 			// new file locally that was added but not comitted to server yet
 	public static final int STATE_UNKOWN = 2; 						// new file locally but not added to server
 	public static final int STATE_REMOTE_CHANGES = 3; 		// remote changes to an unmodified local file
 	public static final int STATE_DELETED = 4; 						// removed locally but still exists on the server
 	public static final int STATE_MODIFIED = 5; 					// modified locally
 	public static final int STATE_CONFLICT = 6; 					// modified locally and on the server but cannot be auto-merged
 	public static final int STATE_MERGEABLE_CONFLICT = 7;  // modified locally and on the server but can be auto-merged

 	/**
 	 * Makes a -r or -D or -A option for a tag.
 	 * Valid for: checkout export history rdiff update
 	 */
 	public static LocalOption makeTagOption(CVSTag tag) {
 		int type = tag.getType();
 		switch (type) {
 			case CVSTag.HEAD:
 				return CLEAR_STICKY;
 			default:
 				return Command.makeTagOption(tag);
 		}
 	}

 	protected Update() { }
 	protected String getRequestId() {
 		return "update"; //$NON-NLS-1$
 	}

 	protected ICommandOutputListener getDefaultCommandOutputListener() {
 		return DEFAULT_OUTPUT_LISTENER;
 	}

 	protected ICVSResource[] sendLocalResourceState(Session session, GlobalOption[] globalOptions,
 		LocalOption[] localOptions, ICVSResource[] resources, IProgressMonitor monitor)
 		throws CVSException {

 		// Send all folders that are already managed to the server
 		// even folders that are empty
 		sendFileStructure(session, resources, true, monitor);
 		return resources;
 	}

 	/**
 	 * Convenience method that allows the creation of .# files to be disabled.
 	 * @param createBackups if true, creates .# files
 	 * @see Command.execute
 	 */
 	public final IStatus execute(Session session, GlobalOption[] globalOptions,
 		LocalOption[] localOptions, String[] arguments, ICommandOutputListener listener,
 		IProgressMonitor pm, boolean createBackups) throws CVSException {
 		session.setCreateBackups(createBackups);
 		try {
 			return super.execute(session, globalOptions, localOptions, arguments, listener, pm);
 		} finally {
 			session.setCreateBackups(true);
 		}
 	}

 	/**
 	 * On successful finish, prune empty directories if the -P or -D option was specified.
 	 */
 	protected IStatus commandFinished(Session session, GlobalOption[] globalOptions,
 		LocalOption[] localOptions, ICVSResource[] resources, IProgressMonitor monitor,
 		IStatus status) throws CVSException {
 		// If we didn't succeed, don't do any post processing
 		if (status.getCode() == CVSStatus.SERVER_ERROR) {
 			return status;
 		}

 		// If we are pruning (-P) or getting a sticky copy using -D, then prune empty directories
 		if (PRUNE_EMPTY_DIRECTORIES.isElementOf(localOptions) ||
 			findOption(localOptions, "-D") != null) { //$NON-NLS-1$
 			// Delete empty directories
 			new PruneFolderVisitor().visit(session, resources);

 		}
 		session.handleCaseCollisions();
 		return status;
 	}

 	protected LocalOption[] filterLocalOptions(Session session, GlobalOption[] globalOptions, LocalOption[] localOptions) {
 		List newOptions = new ArrayList(Arrays.asList(localOptions));

 		// Look for absent directories if enabled and the option is not already included
 		ICVSFolder sessionRoot = session.getLocalRoot();
 		IResource resource = null;
 		RepositoryProvider provider = null;
 		// If there is a provider, use the providers setting
 		try {
 			resource = session.getLocalRoot().getIResource();
 			if (resource != null) {
 				provider = RepositoryProvider.getProvider(resource.getProject(), CVSProviderPlugin.getTypeId());
 				if (provider != null) {
 					if (((CVSTeamProvider)provider).getFetchAbsentDirectories() && ! RETRIEVE_ABSENT_DIRECTORIES.isElementOf(localOptions)) {
 						newOptions.add(Update.RETRIEVE_ABSENT_DIRECTORIES);
 					}
 				}
 			}
 		} catch (CVSException e) {
 			CVSProviderPlugin.log(e);
 		}
 		// If there is no provider, use the global setting
 		if (provider == null) {
 			if (CVSProviderPlugin.getPlugin().getFetchAbsentDirectories() && ! RETRIEVE_ABSENT_DIRECTORIES.isElementOf(localOptions)) {
 				newOptions.add(Update.RETRIEVE_ABSENT_DIRECTORIES);
 			}
 		}

 		// Prune empty directories if pruning is enabled and the command in not being run in non-update mode
 		if (CVSProviderPlugin.getPlugin().getPruneEmptyDirectories() && ! PRUNE_EMPTY_DIRECTORIES.isElementOf(localOptions)) {
 			if (! DO_NOT_CHANGE.isElementOf(globalOptions)) {
 				newOptions.add(Update.PRUNE_EMPTY_DIRECTORIES);
 			}
 		}
 		localOptions = (LocalOption[]) newOptions.toArray(new LocalOption[newOptions.size()]);
 		return super.filterLocalOptions(session, globalOptions, localOptions);
 	}

 	/**
 	 * We allow unmanaged resources as long as there parents are managed.
 	 *
 	 * @see Command#checkResourcesManaged(ICVSResource[])
 	 */
 	protected void checkResourcesManaged(ICVSResource[] resources) throws CVSException {
 		for (int i = 0; i < resources.length; ++i) {
 			ICVSFolder folder;
 			if (resources[i].isFolder()) {
 				if (((ICVSFolder)resources[i]).isCVSFolder()) {
 					folder = (ICVSFolder)resources[i];
 				} else {
 					folder = resources[i].getParent();
 				}
 			}
 			else {
 				folder = resources[i].getParent();
 			}
 			if (folder==null || (!folder.isCVSFolder() && folder.exists())) {
 				throw new CVSException(Policy.bind("Command.argumentNotManaged", folder.getName()));//$NON-NLS-1$
 			}
 		}
 	}

 	/**
 	 * @see org.eclipse.team.internal.ccvs.core.client.Command#doExecute(org.eclipse.team.internal.ccvs.core.client.Session, org.eclipse.team.internal.ccvs.core.client.Command.GlobalOption, org.eclipse.team.internal.ccvs.core.client.Command.LocalOption, java.lang.String, org.eclipse.team.internal.ccvs.core.client.listeners.ICommandOutputListener, org.eclipse.core.runtime.IProgressMonitor)
 	 */
 	protected IStatus doExecute(
 			Session session,
 			GlobalOption[] globalOptions,
 			LocalOption[] localOptions,
 			String[] arguments,
 			ICommandOutputListener listener,
 			IProgressMonitor monitor)
 			throws CVSException {

 		session.setIgnoringLocalChanges(IGNORE_LOCAL_CHANGES.isElementOf(localOptions));
 		try {
 			return super.doExecute(
 				session,
 				globalOptions,
 				localOptions,
 				arguments,
 				listener,
 				monitor);
 		} finally {
 			session.setIgnoringLocalChanges(false);
 		}

 	}

 }
	/*******************************************************************************
	* 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.core.client;


	import java.util.ArrayList;
	import java.util.Arrays;
	import java.util.List;

	import org.eclipse.core.resources.IResource;
	import org.eclipse.core.runtime.IProgressMonitor;
	import org.eclipse.core.runtime.IStatus;
	import org.eclipse.team.core.RepositoryProvider;
	import org.eclipse.team.internal.ccvs.core.CVSException;
	import org.eclipse.team.internal.ccvs.core.CVSProviderPlugin;
	import org.eclipse.team.internal.ccvs.core.CVSStatus;
	import org.eclipse.team.internal.ccvs.core.CVSTag;
	import org.eclipse.team.internal.ccvs.core.CVSTeamProvider;
	import org.eclipse.team.internal.ccvs.core.ICVSFolder;
	import org.eclipse.team.internal.ccvs.core.ICVSResource;
	import org.eclipse.team.internal.ccvs.core.Policy;
	import org.eclipse.team.internal.ccvs.core.client.listeners.ICommandOutputListener;
	import org.eclipse.team.internal.ccvs.core.client.listeners.UpdateListener;

	public class Update extends Command {
	/* Local options: specific to update */
	public static final LocalOption CLEAR_STICKY = new LocalOption("-A"); //$NON-NLS-1$
	public static final LocalOption IGNORE_LOCAL_CHANGES = new LocalOption("-C"); //$NON-NLS-1$
	public static final LocalOption RETRIEVE_ABSENT_DIRECTORIES = new LocalOption("-d"); //$NON-NLS-1$
	public static final LocalOption JOIN = new LocalOption("-j"); //$NON-NLS-1$

	/* Default command output listener */
	private static final ICommandOutputListener DEFAULT_OUTPUT_LISTENER = new UpdateListener(null);

	/* File information status returned from update */
	public static final int STATE_NONE = 0; // no state information available
	public static final int STATE_ADDED_LOCAL = 1; // new file locally that was added but not comitted to server yet
	public static final int STATE_UNKOWN = 2; // new file locally but not added to server
	public static final int STATE_REMOTE_CHANGES = 3; // remote changes to an unmodified local file
	public static final int STATE_DELETED = 4; // removed locally but still exists on the server
	public static final int STATE_MODIFIED = 5; // modified locally
	public static final int STATE_CONFLICT = 6; // modified locally and on the server but cannot be auto-merged
	public static final int STATE_MERGEABLE_CONFLICT = 7; // modified locally and on the server but can be auto-merged

	/**
	* Makes a -r or -D or -A option for a tag.
	* Valid for: checkout export history rdiff update
	*/
	public static LocalOption makeTagOption(CVSTag tag) {
	int type = tag.getType();
	switch (type) {
	case CVSTag.HEAD:
	return CLEAR_STICKY;
	default:
	return Command.makeTagOption(tag);
	}
	}

	protected Update() { }
	protected String getRequestId() {
	return "update"; //$NON-NLS-1$
	}

	protected ICommandOutputListener getDefaultCommandOutputListener() {
	return DEFAULT_OUTPUT_LISTENER;
	}

	protected ICVSResource[] sendLocalResourceState(Session session, GlobalOption[] globalOptions,
	LocalOption[] localOptions, ICVSResource[] resources, IProgressMonitor monitor)
	throws CVSException {

	// Send all folders that are already managed to the server
	// even folders that are empty
	sendFileStructure(session, resources, true, monitor);
	return resources;
	}

	/**
	* Convenience method that allows the creation of .# files to be disabled.
	* @param createBackups if true, creates .# files
	* @see Command.execute
	*/
	public final IStatus execute(Session session, GlobalOption[] globalOptions,
	LocalOption[] localOptions, String[] arguments, ICommandOutputListener listener,
	IProgressMonitor pm, boolean createBackups) throws CVSException {
	session.setCreateBackups(createBackups);
	try {
	return super.execute(session, globalOptions, localOptions, arguments, listener, pm);
	} finally {
	session.setCreateBackups(true);
	}
	}

	/**
	* On successful finish, prune empty directories if the -P or -D option was specified.
	*/
	protected IStatus commandFinished(Session session, GlobalOption[] globalOptions,
	LocalOption[] localOptions, ICVSResource[] resources, IProgressMonitor monitor,
	IStatus status) throws CVSException {
	// If we didn't succeed, don't do any post processing
	if (status.getCode() == CVSStatus.SERVER_ERROR) {
	return status;
	}

	// If we are pruning (-P) or getting a sticky copy using -D, then prune empty directories
	if (PRUNE_EMPTY_DIRECTORIES.isElementOf(localOptions) \|\|
	findOption(localOptions, "-D") != null) { //$NON-NLS-1$
	// Delete empty directories
	new PruneFolderVisitor().visit(session, resources);

	}
	session.handleCaseCollisions();
	return status;
	}

	protected LocalOption[] filterLocalOptions(Session session, GlobalOption[] globalOptions, LocalOption[] localOptions) {
	List newOptions = new ArrayList(Arrays.asList(localOptions));

	// Look for absent directories if enabled and the option is not already included
	ICVSFolder sessionRoot = session.getLocalRoot();
	IResource resource = null;
	RepositoryProvider provider = null;
	// If there is a provider, use the providers setting
	try {
	resource = session.getLocalRoot().getIResource();
	if (resource != null) {
	provider = RepositoryProvider.getProvider(resource.getProject(), CVSProviderPlugin.getTypeId());
	if (provider != null) {
	if (((CVSTeamProvider)provider).getFetchAbsentDirectories() && ! RETRIEVE_ABSENT_DIRECTORIES.isElementOf(localOptions)) {
	newOptions.add(Update.RETRIEVE_ABSENT_DIRECTORIES);
	}
	}
	}
	} catch (CVSException e) {
	CVSProviderPlugin.log(e);
	}
	// If there is no provider, use the global setting
	if (provider == null) {
	if (CVSProviderPlugin.getPlugin().getFetchAbsentDirectories() && ! RETRIEVE_ABSENT_DIRECTORIES.isElementOf(localOptions)) {
	newOptions.add(Update.RETRIEVE_ABSENT_DIRECTORIES);
	}
	}

	// Prune empty directories if pruning is enabled and the command in not being run in non-update mode
	if (CVSProviderPlugin.getPlugin().getPruneEmptyDirectories() && ! PRUNE_EMPTY_DIRECTORIES.isElementOf(localOptions)) {
	if (! DO_NOT_CHANGE.isElementOf(globalOptions)) {
	newOptions.add(Update.PRUNE_EMPTY_DIRECTORIES);
	}
	}
	localOptions = (LocalOption[]) newOptions.toArray(new LocalOption[newOptions.size()]);
	return super.filterLocalOptions(session, globalOptions, localOptions);
	}

	/**
	* We allow unmanaged resources as long as there parents are managed.
	*
	* @see Command#checkResourcesManaged(ICVSResource[])
	*/
	protected void checkResourcesManaged(ICVSResource[] resources) throws CVSException {
	for (int i = 0; i < resources.length; ++i) {
	ICVSFolder folder;
	if (resources[i].isFolder()) {
	if (((ICVSFolder)resources[i]).isCVSFolder()) {
	folder = (ICVSFolder)resources[i];
	} else {
	folder = resources[i].getParent();
	}
	}
	else {
	folder = resources[i].getParent();
	}
	if (folder==null \|\| (!folder.isCVSFolder() && folder.exists())) {
	throw new CVSException(Policy.bind("Command.argumentNotManaged", folder.getName()));//$NON-NLS-1$
	}
	}
	}

	/**
	* @see org.eclipse.team.internal.ccvs.core.client.Command#doExecute(org.eclipse.team.internal.ccvs.core.client.Session, org.eclipse.team.internal.ccvs.core.client.Command.GlobalOption, org.eclipse.team.internal.ccvs.core.client.Command.LocalOption, java.lang.String, org.eclipse.team.internal.ccvs.core.client.listeners.ICommandOutputListener, org.eclipse.core.runtime.IProgressMonitor)
	*/
	protected IStatus doExecute(
	Session session,
	GlobalOption[] globalOptions,
	LocalOption[] localOptions,
	String[] arguments,
	ICommandOutputListener listener,
	IProgressMonitor monitor)
	throws CVSException {

	session.setIgnoringLocalChanges(IGNORE_LOCAL_CHANGES.isElementOf(localOptions));
	try {
	return super.doExecute(
	session,
	globalOptions,
	localOptions,
	arguments,
	listener,
	monitor);
	} finally {
	session.setIgnoringLocalChanges(false);
	}

	}

	}