/brz/remove-bazaar

# along with this program; if not, write to the Free Software

# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 

from dulwich.objects import (

    Commit,

    Tag,

from dulwich.object_store import (

    tree_lookup_path,

    )

import stat

 

from bzrlib import (

    urlutils,

    )

from bzrlib.errors import (

    NoSuchId,

    )

from bzrlib.inventory import (

    Inventory,

    InventoryDirectory,

    InventoryFile,

    InventoryLink,

    )

from bzrlib.lru_cache import (

    LRUCache,

    inventory_to_tree_and_blobs,

    mode_is_executable,

    squash_revision,

    warn_unusual_mode,

    )

from bzrlib.plugins.git.object_store import (

    RemoteGitRepository,

    )

from bzrlib.plugins.git.repository import (

    GitRepositoryFormat,

    LocalGitRepository,

    )

 

 

    revision_id, parent_invs, shagitmap, lookup_object, executable, symlink):

    """Import a git blob object into a bzr repository.

 

    ie = cls(file_id, urlutils.basename(path).decode("utf-8"), parent_id)

    ie.executable = executable

    # See if this has changed at all

        base_sha = None

    else:

        try:

        shamap = [(hexsha, "blob", (ie.file_id, ie.revision))]

    else:

        shamap = []

        old_path = base_inv.id2path(file_id)

    else:

        old_path = None

    return (invdelta, shamap)

 

 

    ret = []

    while deletable:

        if ie.kind == "directory":

    return ret

 

 

    revision_id, parent_invs, shagitmap, lookup_object):

    """Import a git tree object into a bzr repository.

 

    invdelta = []

    file_id = mapping.generate_file_id(path)

    # We just have to hope this is indeed utf-8:

        parent_id)

        # Newly appeared here

        ie.revision = revision_id

        invdelta.append((None, path, file_id, ie))

    else:

        # See if this has changed at all

                return [], {}, []

        if base_ie.kind != "directory":

            ie.revision = revision_id

            invdelta.append((base_inv.id2path(ie.file_id), path, ie.file_id, ie))

    # Remember for next time

    existing_children = set()

    child_modes = {}

        child_path = osutils.pathjoin(path, name)

        if stat.S_ISDIR(mode):

            subinvdelta, grandchildmodes, subshamap = import_git_tree(

            invdelta.extend(subinvdelta)

            child_modes.update(grandchildmodes)

            shamap.extend(subshamap)

        elif S_ISGITLINK(mode): # submodule

            subinvdelta, grandchildmodes, subshamap = import_git_submodule(

                    file_id, revision_id, parent_invs, shagitmap, lookup_object)

            invdelta.extend(subinvdelta)

            child_modes.update(grandchildmodes)

            shamap.extend(subshamap)

        else:

                    mode_is_executable(mode), stat.S_ISLNK(mode))

            invdelta.extend(subinvdelta)

            shamap.extend(subshamap)

                        stat.S_IFLNK, DEFAULT_FILE_MODE|0111):

            child_modes[child_path] = mode

    # Remove any children that have disappeared

    shamap.append((hexsha, "tree", (file_id, revision_id)))

    return invdelta, child_modes, shamap

 

 

        heads, pb=None):

    """Import a set of git objects into a bzr repository.

 

        try:

            o = lookup_object(head)

        except KeyError:

            continue

        if isinstance(o, Commit):

            rev = mapping.import_commit(o)

            root_trees[rev.revision_id] = o.tree

            revisions[rev.revision_id] = rev

            graph.append((rev.revision_id, rev.parent_ids))

                    (rev.revision_id, o.tree))

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

        elif isinstance(o, Tag):

        if pb is not None:

            pb.update("fetching revisions", i, len(graph))

        rev = revisions[revid]

        # path; this may involve adding them more than once.

        parent_invs = []

        for parent_id in rev.parent_ids:

                parent_invs_cache[parent_id] = parent_inv

        if parent_invs == []:

            base_inv = Inventory(root_id=None)

        else:

            base_inv = parent_invs[0]

                parent_invs, target_git_object_retriever._idmap, lookup_object)

        target_git_object_retriever._idmap.add_entries(shamap)

        if unusual_modes != {}:

            basis_id = rev.parent_ids[0]

        except IndexError:

            basis_id = NULL_REVISION

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

        parent_invs_cache[rev.revision_id] = inv

        repo.add_revision(rev.revision_id, rev)

        if "verify" in debug.debug_flags:

 

 

class InterGitNonGitRepository(InterGitRepository):

    repository."""

 

              mapping=None, fetch_spec=None):

        if mapping is None:

            mapping = self.source.get_mapping()

            else:

                ret = [mapping.revision_id_bzr_to_foreign(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(mapping.revision_id_foreign_to_bzr(rev))]

        return self._refs

 

 

class InterRemoteGitNonGitRepository(InterGitNonGitRepository):

    repository."""

 

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

        def progress(text):

        store = BazaarObjectStore(self.target, mapping)

        self.target.lock_write()

        try:

            graph_walker = store.get_graph_walker(

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

            recorded_wants = []

                wants = determine_wants(heads)

                recorded_wants.extend(wants)

                return wants

            create_pb = None

            if pb is None:

                create_pb = pb = ui.ui_factory.nested_progress_bar()

                self.target.start_write_group()

                try:

                    objects_iter = self.source.fetch_objects(

                                store.get_raw, progress)

                            store, recorded_wants, pb)

                finally:

            finally:

                if create_pb:

                    create_pb.finished()

    def is_compatible(source, target):

        """Be compatible with GitRepository."""

        # FIXME: Also check target uses VersionedFile

                target.supports_rich_root() and

                not isinstance(target, GitRepository))

 

 

class InterLocalGitNonGitRepository(InterGitNonGitRepository):

    repository."""

 

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

            try:

                self.target.start_write_group()

                try:

                            target_git_object_retriever, wants, pb)

                finally:

            finally:

                self.target.unlock()

        finally:

    def is_compatible(source, target):

        """Be compatible with GitRepository."""

        # FIXME: Also check target uses VersionedFile

                target.supports_rich_root() and

                not isinstance(target, GitRepository))

 

class InterGitGitRepository(InterGitRepository):

    """InterRepository that copies between Git repositories."""

 

              mapping=None, fetch_spec=None, branches=None):

        if mapping is None:

            mapping = self.source.get_mapping()

        r = self.target._git

        if revision_id is not None:

            args = [mapping.revision_id_bzr_to_foreign(revision_id)[0]]

            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):

        """Be compatible with GitRepository."""

                isinstance(target, GitRepository))