310
309
self.mapping.revision_id_bzr_to_foreign(old_revid)
311
310
except InvalidRevisionId:
311
refname = self.mapping.revid_as_refname(old_revid)
312
self.target_refs[refname] = git_sha
313
313
revidmap[old_revid] = (git_sha, new_revid)
314
314
self.target_store.add_objects(object_generator)
372
372
self._warn_slow()
373
373
with self.source_store.lock_read():
374
result = self.target.send_pack(
374
new_refs = self.target.send_pack(
375
375
git_update_refs, self.source_store.generate_lossy_pack_data)
376
if result is not None and not isinstance(result, dict):
377
for ref, error in result.ref_status.items():
379
raise RemoteGitError(
380
'unable to update ref %r: %s' % (ref, error))
381
new_refs = result.refs
382
else: # dulwich < 0.20.3
384
376
# FIXME: revidmap?
385
377
return revidmap, self.old_refs, new_refs
788
780
"""Be compatible with GitRepository."""
789
781
return (isinstance(source, RemoteGitRepository) and
790
782
isinstance(target, LocalGitRepository))
794
class InterLocalGitRemoteGitRepository(InterToGitRepository):
796
def fetch_refs(self, update_refs, lossy=False, overwrite=False):
797
"""Import the gist of the ancestry of a particular revision."""
799
raise LossyPushToSameVCS(self.source, self.target)
801
def git_update_refs(old_refs):
804
k: (v, None) for (k, v) in viewitems(old_refs)}
805
new_refs = update_refs(self.old_refs)
806
for name, (gitid, revid) in viewitems(new_refs):
808
gitid = self.source_store._lookup_revision_sha1(revid)
810
if remote_divergence(
811
old_refs.get(name), gitid, self.source_store):
812
raise DivergedBranches(self.source, self.target)
815
new_refs = self.target.send_pack(
817
self.source._git.generate_pack_data)
818
return None, self.old_refs, new_refs
821
def is_compatible(source, target):
822
return (isinstance(source, LocalGitRepository) and
823
isinstance(target, RemoteGitRepository))