1 files changed, 124 insertions, 0 deletions
diff --git a/org.eclipse.egit.core/src/org/eclipse/egit/core/synchronize/GitResourceVariantTreeSubscriber.java b/org.eclipse.egit.core/src/org/eclipse/egit/core/synchronize/GitResourceVariantTreeSubscriber.java
new file mode 100644
index 0000000000..780f45b186
--- /dev/null
+++ b/org.eclipse.egit.core/src/org/eclipse/egit/core/synchronize/GitResourceVariantTreeSubscriber.java
@@ -0,0 +1,124 @@
+/*******************************************************************************
+ * Copyright (c) 2010 IBM Corporation and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     IBM Corporation - initial API and implementation
+ *     Dariusz Luksza <dariusz@luksza.org>
+ *******************************************************************************/
+package org.eclipse.egit.core.synchronize;
+
+import org.eclipse.core.resources.IResource;
+import org.eclipse.egit.core.CoreText;
+import org.eclipse.egit.core.synchronize.dto.GitSynchronizeDataSet;
+import org.eclipse.team.core.TeamException;
+import org.eclipse.team.core.synchronize.SyncInfo;
+import org.eclipse.team.core.variants.IResourceVariant;
+import org.eclipse.team.core.variants.IResourceVariantComparator;
+import org.eclipse.team.core.variants.IResourceVariantTree;
+import org.eclipse.team.core.variants.ResourceVariantByteStore;
+import org.eclipse.team.core.variants.ResourceVariantTreeSubscriber;
+
+/**
+ *
+ */
+public class GitResourceVariantTreeSubscriber extends
+		ResourceVariantTreeSubscriber {
+
+	private final ResourceVariantByteStore store;
+
+	/**
+	 * A resource variant tree of the remote branch(es).
+	 */
+	private IResourceVariantTree remoteTree;
+
+	/**
+	 * A resource variant tree against HEAD.
+	 */
+	private IResourceVariantTree baseTree;
+
+	private GitSynchronizeDataSet gitSynchronizeDataSet;
+
+	/**
+	 * @param data
+	 * @param store
+	 */
+	public GitResourceVariantTreeSubscriber(GitSynchronizeDataSet data,
+			ResourceVariantByteStore store) {
+		this.store = store;
+		this.gitSynchronizeDataSet = data;
+	}
+
+	private IResource[] roots;
+
+	@Override
+	public boolean isSupervised(IResource resource) throws TeamException {
+		return true; //gitSynchronizeDataSet.contains(resource.getProject());
+	}
+
+	@Override
+	public IResource[] roots() {
+		if (roots != null) {
+			return roots;
+		}
+
+		roots = gitSynchronizeDataSet.getAllResources();
+		return roots;
+	}
+
+	/**
+	 * @param data
+	 */
+	public void reset(GitSynchronizeDataSet data) {
+		gitSynchronizeDataSet = data;
+		store.dispose();
+
+		roots = null;
+		baseTree = null;
+		remoteTree = null;
+	}
+
+	@Override
+	public IResource[] members(IResource resource) throws TeamException {
+		return getBaseTree().members(resource);
+	}
+
+	@Override
+	public String getName() {
+		return CoreText.GitBranchResourceVariantTreeSubscriber_gitRepository;
+	}
+
+	@Override
+	public IResourceVariantComparator getResourceComparator() {
+		return new GitResourceVariantComparator(gitSynchronizeDataSet, store);
+	}
+
+	@Override
+	protected IResourceVariantTree getBaseTree() {
+		if (baseTree == null) {
+			baseTree = new GitBaseResourceVariantTree(gitSynchronizeDataSet, store);
+		}
+		return baseTree;
+	}
+
+	@Override
+	protected IResourceVariantTree getRemoteTree() {
+		if (remoteTree == null) {
+			remoteTree = new GitRemoteResourceVariantTree(gitSynchronizeDataSet, store);
+		}
+		return remoteTree;
+	}
+
+	@Override
+	protected SyncInfo getSyncInfo(IResource local, IResourceVariant base,
+			IResourceVariant remote) throws TeamException {
+		GitSyncInfo info = new GitSyncInfo(local, base, remote,
+				getResourceComparator());
+		info.init();
+		return info;
+	}
+
+}
+\ No newline at end of file