1 files changed, 124 insertions, 0 deletions
diff --git a/org.eclipse.egit.core.test/src/org/eclipse/egit/core/op/T0001_ConnectProviderOperationTest.java b/org.eclipse.egit.core.test/src/org/eclipse/egit/core/op/T0001_ConnectProviderOperationTest.java
new file mode 100644
index 0000000000..dc3969f43a
--- /dev/null
+++ b/org.eclipse.egit.core.test/src/org/eclipse/egit/core/op/T0001_ConnectProviderOperationTest.java
@@ -0,0 +1,124 @@
+/*******************************************************************************
+ * Copyright (C) 2007, Robin Rosenberg <robin.rosenberg@dewire.com>
+ * Copyright (C) 2008, Shawn O. Pearce <spearce@spearce.org>
+ *
+ * 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
+ *******************************************************************************/
+package org.eclipse.egit.core.op;
+
+import java.io.ByteArrayInputStream;
+import java.io.File;
+import java.io.IOException;
+import java.util.Date;
+import java.util.TimeZone;
+
+import org.eclipse.core.resources.IFile;
+import org.eclipse.core.runtime.CoreException;
+import org.eclipse.core.runtime.IProgressMonitor;
+import org.eclipse.core.runtime.IStatus;
+import org.eclipse.core.runtime.jobs.Job;
+import org.eclipse.egit.core.op.ConnectProviderOperation;
+import org.eclipse.egit.core.test.GitTestCase;
+import org.eclipse.team.core.RepositoryProvider;
+import org.eclipse.jgit.lib.Commit;
+import org.eclipse.jgit.lib.FileTreeEntry;
+import org.eclipse.jgit.lib.ObjectId;
+import org.eclipse.jgit.lib.ObjectWriter;
+import org.eclipse.jgit.lib.PersonIdent;
+import org.eclipse.jgit.lib.RefUpdate;
+import org.eclipse.jgit.lib.Repository;
+import org.eclipse.jgit.lib.Tree;
+
+public class T0001_ConnectProviderOperationTest extends GitTestCase {
+
+	public void testNoRepository() throws CoreException {
+
+		ConnectProviderOperation operation = new ConnectProviderOperation(
+				project.getProject());
+		operation.run(null);
+
+		// We are shared because we declared as shared
+		assertTrue(RepositoryProvider.isShared(project.getProject()));
+		assertTrue(!gitDir.exists());
+	}
+
+	public void testNewRepository() throws CoreException, IOException {
+
+		File gitDir = new File(project.getProject().getWorkspace().getRoot()
+				.getRawLocation().toFile(), ".git");
+		Repository repository = new Repository(gitDir);
+		repository.create();
+		repository.close();
+		ConnectProviderOperation operation = new ConnectProviderOperation(
+				project.getProject());
+		operation.run(null);
+
+		assertTrue(RepositoryProvider.isShared(project.getProject()));
+
+		assertTrue(gitDir.exists());
+	}
+
+	public void testNewUnsharedFile() throws CoreException, IOException,
+			InterruptedException {
+
+		project.createSourceFolder();
+		IFile fileA = project.getProject().getFolder("src").getFile("A.java");
+		String srcA = "class A {\n" + "}\n";
+		fileA.create(new ByteArrayInputStream(srcA.getBytes()), false, null);
+
+		File gitDir = new File(project.getProject().getWorkspace().getRoot()
+				.getRawLocation().toFile(), ".git");
+		Repository thisGit = new Repository(gitDir);
+		thisGit.create();
+		Tree rootTree = new Tree(thisGit);
+		Tree prjTree = rootTree.addTree(project.getProject().getName());
+		Tree srcTree = prjTree.addTree("src");
+		FileTreeEntry entryA = srcTree.addFile("A.java");
+		ObjectWriter writer = new ObjectWriter(thisGit);
+		entryA.setId(writer.writeBlob(fileA.getRawLocation().toFile()));
+		srcTree.setId(writer.writeTree(srcTree));
+		prjTree.setId(writer.writeTree(prjTree));
+		rootTree.setId(writer.writeTree(rootTree));
+		Commit commit = new Commit(thisGit);
+		commit.setTree(rootTree);
+		commit.setAuthor(new PersonIdent("J. Git", "j.git@egit.org", new Date(
+				60876075600000L), TimeZone.getTimeZone("GMT+1")));
+		commit.setCommitter(commit.getAuthor());
+		commit.setMessage("testNewUnsharedFile\n\nJunit tests\n");
+		ObjectId id = writer.writeCommit(commit);
+		RefUpdate lck = thisGit.updateRef("refs/heads/master");
+		assertNotNull("obtained lock", lck);
+		lck.setNewObjectId(id);
+		assertEquals(RefUpdate.Result.NEW, lck.forceUpdate());
+
+		ConnectProviderOperation operation = new ConnectProviderOperation(
+				project.getProject());
+		operation.run(null);
+
+		final boolean f[] = new boolean[1];
+		new Job("wait") {
+			protected IStatus run(IProgressMonitor monitor) {
+
+				System.out.println("MyJob");
+				f[0] = true;
+				return null;
+			}
+
+			{
+				setRule(project.getProject());
+				schedule();
+			}
+		};
+		while (!f[0]) {
+			System.out.println("Waiting");
+			Thread.sleep(1000);
+		}
+		System.out.println("DONE");
+
+		assertNotNull(RepositoryProvider.getProvider(project.getProject()));
+
+	}
+}