/brz/remove-bazaar

import urllib

 

    trace,

    osutils,

from bzrlib.bzrdir import CreateRepository

from bzrlib.transport import do_catching_redirections

from bzrlib.controldir import (

    ControlDir,

    ControlDirFormat,

    format_registry,

    def __init__(self):

        self.lock_name = "git lock"

 

        raise NotImplementedError(self.break_lock)

 

    def dont_leave_in_place(self):

        raise NotImplementedError(self.dont_leave_in_place)

 

    def leave_in_place(self):

        raise NotImplementedError(self.leave_in_place)

class GitControlDirFormat(ControlDirFormat):

 

    _lock_class = lockable_files.TransportLock

 

    colocated_branches = True

    fixed_components = True

 

    def __eq__(self, other):

        return type(self) == type(other)

 

    def is_supported(self):

        return True

 

    def network_name(self):

        return "git"

 

 

    def checkout_metadir(self, stacked=False):

        return format_registry.make_bzrdir("default")

    def _get_selected_ref(self, branch):

        if branch is None and getattr(self, "_get_selected_branch", False):

            branch = self._get_selected_branch()

        if branch is not None:

            from bzrlib.plugins.git.refs import branch_name_to_ref

            return branch_name_to_ref(branch, None)

        segment_parameters = getattr(

            self.user_transport, "get_segment_parameters", lambda: {})()

        ref = segment_parameters.get("ref")

        if ref is not None:

            ref = urlutils.unescape(ref)

        return ref

    def _available_backup_name(self, base):

        return osutils.available_backup_name(base, self.root_transport.has)

 

    def sprout(self, url, revision_id=None, force_new_repo=False,

               recurse='down', possible_transports=None,

               accelerator_tree=None, hardlink=False, stacked=False,

               source_branch=None, create_tree_if_local=True):

        from bzrlib.repository import InterRepository

        from bzrlib.transport.local import LocalTransport

        from bzrlib.transport import get_transport

        target_transport = get_transport(url, possible_transports)

        target_transport.ensure_base()

        cloning_format = self.cloning_metadir()

        # Create/update the result branch

        result = cloning_format.initialize_on_transport(target_transport)

        source_branch = self.open_branch()

        source_repository = self.find_repository()

        try:

            result_repo = result.find_repository()

        except bzr_errors.NoRepositoryPresent:

            result_repo = result.create_repository()

            target_is_empty = True

        else:

            target_is_empty = None # Unknown

        if stacked:

            raise bzr_errors.IncompatibleRepositories(source_repository, result_repo)

        interrepo = InterRepository.get(source_repository, result_repo)

 

        if revision_id is not None:

            determine_wants = interrepo.get_determine_wants_revids(

                [revision_id], include_tags=True)

        else:

            determine_wants = interrepo.determine_wants_all

        interrepo.fetch_objects(determine_wants=determine_wants,

            mapping=source_branch.mapping)

        result_branch = source_branch.sprout(result,

            revision_id=revision_id, repository=result_repo)

        if (create_tree_if_local and isinstance(target_transport, LocalTransport)

            and (result_repo is None or result_repo.make_working_trees())):

            wt = result.create_workingtree(accelerator_tree=accelerator_tree,

                hardlink=hardlink, from_branch=result_branch)

            wt.lock_write()

            try:

                if wt.path2id('') is None:

                    try:

                        wt.set_root_id(self.open_workingtree.get_root_id())

                    except bzr_errors.NoWorkingTree:

                        pass

            finally:

                wt.unlock()

        return result

 

    def clone_on_transport(self, transport, revision_id=None,

        force_new_repo=False, preserve_stacking=False, stacked_on=None,

        create_prefix=False, use_existing_dir=True, no_tree=False):

        """See ControlDir.clone_on_transport."""

        from bzrlib.repository import InterRepository

        from bzrlib.plugins.git.mapping import default_mapping

        if no_tree:

            format = BareLocalGitControlDirFormat()

        else:

            format = LocalGitControlDirFormat()

        (target_repo, target_controldir, stacking, repo_policy) = format.initialize_on_transport_ex(transport, use_existing_dir=use_existing_dir, create_prefix=create_prefix, force_new_repo=force_new_repo)

        target_git_repo = target_repo._git

        source_repo = self.open_repository()

        source_git_repo = source_repo._git

        interrepo = InterRepository.get(source_repo, target_repo)

        if revision_id is not None:

            determine_wants = interrepo.get_determine_wants_revids([revision_id], include_tags=True)

        else:

            determine_wants = interrepo.determine_wants_all

        (pack_hint, _, refs) = interrepo.fetch_objects(determine_wants,

            mapping=default_mapping)

        for name, val in refs.iteritems():

            target_git_repo.refs[name] = val

        lockfiles = GitLockableFiles(transport, GitLock())

        return self.__class__(transport, lockfiles, target_git_repo, format)

 

    def find_repository(self):

        """Find the repository that should be used.

 

        This does not require a branch as we use it to find the repo for

        new branches as well as to hook existing branches up to their

        repository.

        """

        return self.open_repository()

 

 

class LocalGitControlDirFormat(GitControlDirFormat):

    """The .git directory control format."""

 

    bare = False

 

    @classmethod

    def _known_formats(self):

        return set([LocalGitControlDirFormat()])

 

    @property

    def repository_format(self):

        from bzrlib.plugins.git.repository import GitRepositoryFormat

        return GitRepositoryFormat()

 

    def get_branch_format(self):

        from bzrlib.plugins.git.branch import GitBranchFormat

        return GitBranchFormat()

 

    def open(self, transport, _found=None):

        """Open this directory.

 

        """

        from bzrlib.plugins.git.transportgit import TransportRepo

        gitrepo = TransportRepo(transport)

        lockfiles = GitLockableFiles(transport, GitLock())

        return LocalGitDir(transport, lockfiles, gitrepo, self)

 

    def get_format_description(self):

        return "Local Git Repository"

 

    def initialize_on_transport(self, transport):

        from bzrlib.plugins.git.transportgit import TransportRepo

        TransportRepo.init(transport, bare=self.bare)

        return self.open(transport)

 

    def initialize_on_transport_ex(self, transport, use_existing_dir=False,

        create_prefix=False, force_new_repo=False, stacked_on=None,

        stack_on_pwd=None, repo_format_name=None, make_working_trees=None,

        shared_repo=False, vfs_only=False):

        def make_directory(transport):

            transport.mkdir('.')

            return transport

        def redirected(transport, e, redirection_notice):

            trace.note(redirection_notice)

            return transport._redirected_to(e.source, e.target)

        try:

            transport = do_catching_redirections(make_directory, transport,

                redirected)

        except bzr_errors.FileExists:

            if not use_existing_dir:

                raise

        except bzr_errors.NoSuchFile:

            if not create_prefix:

                raise

            transport.create_prefix()

        controldir = self.initialize_on_transport(transport)

        repository = controldir.open_repository()

        repository.lock_write()

        return (repository, controldir, False, CreateRepository(controldir))

 

    def is_supported(self):

        return True

 

 

class BareLocalGitControlDirFormat(LocalGitControlDirFormat):

 

    bare = True

    supports_workingtrees = False

 

    def get_format_description(self):

        return "Local Git Repository (bare)"

 

    def __repr__(self):

        return "<%s at %r>" % (

            self.__class__.__name__, self.root_transport.base)

 

        return (filename == '.git' or filename.startswith('.git/'))

 

    def _get_symref(self, ref):

        from dulwich.repo import SYMREF

        refcontents = self._git.refs.read_ref(ref)

        if refcontents is None: # no such ref

            return None

        if refcontents.startswith(SYMREF):

            return refcontents[len(SYMREF):].rstrip("\n")

        return None

 

    def set_branch_reference(self, name, target):

        ref = self._get_selected_ref(name)

        if ref is None:

            ref = "HEAD"

        if not getattr(target, "ref", None):

            raise bzr_errors.BzrError("Can only set symrefs to Git refs")

        self._git.refs.set_symbolic_ref(ref, target.ref)

 

    def get_branch_reference(self, name=None):

        ref = self._get_selected_ref(name)

        if ref is None:

            ref = "HEAD"

        target_ref = self._get_symref(ref)

        if target_ref is not None:

            return ",ref=%s" % urllib.quote(target_ref)

        return None

 

    def find_branch_format(self, name=None):

        from bzrlib.plugins.git.branch import (

            GitBranchFormat,

            GitSymrefBranchFormat,

            )

        ref = self._get_selected_ref(name)

        if ref is None:

            ref = "HEAD"

        if self._get_symref(ref) is not None:

            return GitSymrefBranchFormat()

        else:

            return GitBranchFormat()

    def open_branch(self, name=None, unsupported=False, ignore_fallbacks=None):

        ref = self._get_selected_ref(name)

        if ref is None:

            ref = "HEAD"

        ref, sha = self._git.refs._follow(ref)

        if not ref in self._git.refs:

            raise bzr_errors.NotBranchError(self.root_transport.base,

                    bzrdir=self)

        return LocalGitBranch(self, repo, ref, self._lockfiles)

        refname = self._get_selected_ref(name)

        for name in self._git.refs.keys():

    def open_repository(self):

        from bzrlib.plugins.git.repository import GitRepositoryFormat

        if shared:

            raise bzr_errors.IncompatibleFormat(GitRepositoryFormat(), self._format)

    def create_branch(self, name=None, repository=None):

        refname = self._get_selected_ref(name)

        # FIXME: This is a bit awkward. Perhaps we should have a

        # a separate method for changing the default branch?

        if refname is None:

            refname = "refs/heads/master"

            self._git.refs.set_symbolic_ref("HEAD", refname)

        self._git.refs[refname] = ZERO_SHA

            raise bzr_errors.UnsupportedOperation(self.create_workingtree, self)

    def _find_or_create_repository(self, force_new_repo=None):

        return self.create_repository(shared=False)

        except bzr_errors.TransportNotPossible: