/brz/remove-bazaar

from bzrlib.revisiontree import (

    RevisionTree,

    )

from bzrlib.tsort import (

    topo_sort,

    )

    else:

        cls = InventoryFile

    ie = cls(file_id, name.decode("utf-8"), parent_id)

    if base_hexsha == hexsha and mode_kind(base_mode) == mode_kind(mode):

        base_ie = base_inv[base_inv.path2id(path)]

        ie.text_size = base_ie.text_size

        ie.text_sha1 = base_ie.text_sha1

        if ie.executable == base_ie.executable:

            ie.revision = base_ie.revision

        else:

        if ie.kind == "symlink":

            ie.revision = None

            ie.symlink_target = blob.data

        else:

            ie.text_size = sum(imap(len, blob.chunked))

            ie.text_sha1 = osutils.sha_strings(blob.chunked)

def import_git_commit(repo, mapping, head, lookup_object,

                      target_git_object_retriever, trees_cache):

    o = lookup_object(head)

            lambda x: target_git_object_retriever.lookup_git_sha(x)[1][0])

    # We have to do this here, since we have to walk the tree and

    # we need to make sure to import the blobs / trees with the right

        base_tree = lookup_object(o.parents[0]).tree

        base_mode = stat.S_IFDIR

    store_updater = target_git_object_retriever._get_updater(rev)

    fileid_map = mapping.get_fileid_map(lookup_object, o.tree)

    inv_delta, unusual_modes = import_git_tree(repo.texts,

            mapping, "", "", (base_tree, o.tree), base_inv,

            lookup_object, (base_mode, stat.S_IFDIR), store_updater,

            fileid_map.lookup_file_id,

            allow_submodules=getattr(repo._format, "supports_tree_reference", False))

    if unusual_modes != {}:

        for path, mode in unusual_modes.iteritems():

            warn_unusual_mode(rev.foreign_revid, path, mode)

        base_inv = None

    rev.inventory_sha1, inv = repo.add_inventory_by_delta(basis_id,

              inv_delta, rev.revision_id, rev.parent_ids, base_inv)

    ret_tree = RevisionTree(repo, inv, rev.revision_id)

    trees_cache.add(ret_tree)

    repo.add_revision(rev.revision_id, rev)

        except KeyError:

            continue

        if isinstance(o, Commit):

                continue

            graph.append((o.id, o.parents))

            heads.extend([p for p in o.parents if p not in checked])

    """Base InterRepository that copies revisions from a Git into a non-Git

    repository."""

 

    def fetch(self, revision_id=None, pb=None, find_ghosts=False,

              mapping=None, fetch_spec=None):

        if mapping is None:

            interesting_heads = fetch_spec.heads

        else:

            interesting_heads = None

        def determine_wants(refs):

            if interesting_heads is None:

                ret = [sha for (ref, sha) in refs.iteritems() if not ref.endswith("^{}")]

            else:

                ret = [self.source.lookup_bzr_revision_id(revid)[0] for revid in interesting_heads if revid not in (None, NULL_REVISION)]

            return [rev for rev in ret if not self.target.has_revision(self.source.lookup_foreign_revision_id(rev))]

        if pack_hint is not None and self.target._format.pack_compresses:

            self.target.pack(hint=pack_hint)

 

 

_GIT_PROGRESS_RE = re.compile(r"(.*?): +(\d+)% \((\d+)/(\d+)\)")

        pb.update(text, 0, 0)

 

 

class InterRemoteGitNonGitRepository(InterGitNonGitRepository):

    """InterRepository that copies revisions from a remote Git into a non-Git

    repository."""

        return set(all_revs) - all_parents

 

    def fetch_objects(self, determine_wants, mapping, pb=None, limit=None):

        def progress(text):

            report_git_progress(pb, text)

        store = BazaarObjectStore(self.target, mapping)

            heads = self.get_target_heads()

            graph_walker = store.get_graph_walker(

                    [store._lookup_revision_sha1(head) for head in heads])

 

            create_pb = None

            if pb is None:

                create_pb = pb = ui.ui_factory.nested_progress_bar()

            try:

            finally:

                if create_pb:

                    create_pb.finished()

    repository."""

 

    def fetch_objects(self, determine_wants, mapping, pb=None, limit=None):

        create_pb = None

        if pb is None:

            create_pb = pb = ui.ui_factory.nested_progress_bar()

        try:

            self.target.lock_write()

            try:

                    self.source._git.object_store,

                    target_git_object_retriever, wants, pb, limit)

            finally:

                self.target.unlock()

        finally:

        graphwalker = self.target._git.get_graph_walker()

        if (isinstance(self.source, LocalGitRepository) and

            isinstance(self.target, LocalGitRepository)):

                progress)

        elif (isinstance(self.source, LocalGitRepository) and

              isinstance(self.target, RemoteGitRepository)):

            raise NotImplementedError

              isinstance(self.target, LocalGitRepository)):

            f, commit = self.target._git.object_store.add_thin_pack()

            try:

                commit()

            except:

                f.close()

                raise

            determine_wants = r.object_store.determine_wants_all

        else:

            determine_wants = lambda x: [y for y in args if not y in r.object_store]

 

    @staticmethod

    def is_compatible(source, target):