Fixed fetch/push/pull implementation. Next up is to integrate the consolidation changes from master to make clone use the same facilities

Author: Byron

git/db/cmd/base.py

@@ -18,11 +18,15 @@
 							isfile,
 							join_path,
 							join,
-							Actor
+							Actor,
+							IterableList
 					)
 from git.db.interface import FetchInfo as GitdbFetchInfo
 from git.db.interface import PushInfo as GitdbPushInfo
-from git.db.interface import HighLevelRepository
+from git.db.interface import (
+							HighLevelRepository,
+							TransportDB
+							)
 from git.cmd import Git
 from git.refs import (
 						Reference,
@@ -332,7 +336,7 @@ def partial_to_complete_sha_hex(self, partial_hexsha):
 	#} END odb interface
 
 
-class CmdTransportMixin(object):
+class CmdTransportMixin(TransportDB):
 	"""A mixin requiring the .git property as well as repository paths
 	
 	It will create objects only in the loose object database.
@@ -399,13 +403,13 @@ def _get_fetch_info_from_stderr(self, proc, progress):
 		# END for each line
 
 		# read head information 
-		fp = open(join(self.root_path(), 'FETCH_HEAD'),'r')
+		fp = open(join(self.git_dir, 'FETCH_HEAD'),'r')
 		fetch_head_info = fp.readlines()
 		fp.close()
 
 		assert len(fetch_info_lines) == len(fetch_head_info)
 
-		output.extend(FetchInfo._from_line(self.repo, err_line, fetch_line) 
+		output.extend(FetchInfo._from_line(self, err_line, fetch_line) 
 						for err_line,fetch_line in zip(fetch_info_lines, fetch_head_info))
 
 		self._finalize_proc(proc)
@@ -450,15 +454,15 @@ def pull(self, url, refspecs=None, progress=None, **kwargs):
 		:param url: may be a remote name or a url
 		:param refspecs: see push()
 		:param progress: see push()"""
-		proc = self._git.pull(url, refspec, with_extended_output=True, as_process=True, v=True, **kwargs)
+		proc = self._git.pull(url, refspecs, with_extended_output=True, as_process=True, v=True, **kwargs)
 		return self._get_fetch_info_from_stderr(proc, progress or RemoteProgress())
 
 	def fetch(self, url, refspecs=None, progress=None, **kwargs):
 		"""Fetch the latest changes
 		:param url: may be a remote name or a url
 		:param refspecs: see push()
 		:param progress: see push()"""
-		proc = self._git.fetch(url, refspec, with_extended_output=True, as_process=True, v=True, **kwargs)
+		proc = self._git.fetch(url, refspecs, with_extended_output=True, as_process=True, v=True, **kwargs)
 		return self._get_fetch_info_from_stderr(proc, progress or RemoteProgress())
 
 	#} end transport db interface

git/remote.py

@@ -16,7 +16,7 @@
 						IterableList,
 						RemoteProgress
 						)
-
+from git.db.interface import TransportDB
 from refs import RemoteReference
 
 import os
@@ -53,6 +53,16 @@ def __init__(self, repo, name):
 		
 		:param repo: The repository we are a remote of
 		:param name: the name of the remote, i.e. 'origin'"""
+		if not hasattr(repo, 'git'):
+			# note: at some point we could just create a git command instance ourselves
+			# but lets just be lazy for now
+			raise AssertionError("Require repository to provide a git command instance currently")
+		#END assert git cmd
+		
+		if not isinstance(repo, TransportDB):
+			raise AssertionError("Require TransportDB interface implementation")
+		#END verify interface
+		
 		self.repo = repo
 		self.name = name
 
@@ -228,8 +238,7 @@ def fetch(self, refspec=None, progress=None, **kwargs):
 		:note:
 			As fetch does not provide progress information to non-ttys, we cannot make 
 			it available here unfortunately as in the 'push' method."""
-		proc = self.repo.git.fetch(self, refspec, with_extended_output=True, as_process=True, v=True, **kwargs)
-		return self._get_fetch_info_from_stderr(proc, progress or RemoteProgress())
+		return self.repo.fetch(self.name, refspec, progress, **kwargs)
 
 	def pull(self, refspec=None, progress=None, **kwargs):
 		"""Pull changes from the given branch, being the same as a fetch followed 
@@ -239,8 +248,7 @@ def pull(self, refspec=None, progress=None, **kwargs):
 		:param progress: see 'push' method
 		:param kwargs: Additional arguments to be passed to git-pull
 		:return: Please see 'fetch' method """
-		proc = self.repo.git.pull(self, refspec, with_extended_output=True, as_process=True, v=True, **kwargs)
-		return self._get_fetch_info_from_stderr(proc, progress or RemoteProgress())
+		return self.repo.pull(self.name, refspec, progress, **kwargs)
 
 	def push(self, refspec=None, progress=None, **kwargs):
 		"""Push changes from source branch in refspec to target branch in refspec.
@@ -260,8 +268,7 @@ def push(self, refspec=None, progress=None, **kwargs):
 			in their flags.
 			If the operation fails completely, the length of the returned IterableList will
 			be null."""
-		proc = self.repo.git.push(self, refspec, porcelain=True, as_process=True, **kwargs)
-		return self._get_push_info(proc, progress or RemoteProgress())
+		return self.repo.push(self.name, refspec, progress, **Kwargs)
 
 	@property
 	def config_reader(self):