# bzr.py - bzr support for the convert extension

#

#  Copyright 2008, 2009 Marek Kubica <marek@xivilization.net> and others

#

# This software may be used and distributed according to the terms of the

# GNU General Public License version 2 or any later version.

# This module is for handling Breezy imports or `brz`, but it's also compatible

# with Bazaar or `bzr`, that was formerly known as Bazaar-NG;

# it cannot access `bar` repositories, but they were never used very much.

from __future__ import absolute_import

import os

from mercurial.i18n import _

from mercurial import (

    demandimport,

    error,

    pycompat,

)

from . import common

# these do not work with demandimport, blacklist

demandimport.IGNORES.update(

    [

        b'breezy.transactions',

        b'breezy.urlutils',

        b'ElementPath',

    ]

)

try:

    # bazaar imports

    import breezy.bzr.bzrdir

    import breezy.errors

    import breezy.revision

    import breezy.revisionspec

    bzrdir = breezy.bzr.bzrdir

    errors = breezy.errors

    revision = breezy.revision

    revisionspec = breezy.revisionspec

    revisionspec.RevisionSpec

except ImportError:

    pass

supportedkinds = ('file', 'symlink')

class bzr_source(common.converter_source):

    """Reads Bazaar repositories by using the Bazaar Python libraries"""

    def __init__(self, ui, repotype, path, revs=None):

        super(bzr_source, self).__init__(ui, repotype, path, revs=revs)

        if not os.path.exists(os.path.join(path, b'.bzr')):

            raise common.NoRepo(

                _(b'%s does not look like a Bazaar repository') % path

            )

        try:

            # access breezy stuff

            bzrdir

        except NameError:

            raise common.NoRepo(_(b'Bazaar modules could not be loaded'))

        self._checkrepotype(path)

        try:

            bzr_dir = bzrdir.BzrDir.open(path.decode())

            self.sourcerepo = bzr_dir.open_repository()

        except errors.NoRepositoryPresent:

            raise common.NoRepo(

                _(b'%s does not look like a Bazaar repository') % path

            )

        self._parentids = {}

        self._saverev = ui.configbool(b'convert', b'bzr.saverev')

    def _checkrepotype(self, path):

        # Lightweight checkouts detection is informational but probably

        # fragile at API level. It should not terminate the conversion.

        try:

            dir = bzrdir.BzrDir.open_containing(path.decode())[0]

            try:

                tree = dir.open_workingtree(recommend_upgrade=False)

                branch = tree.branch

            except (errors.NoWorkingTree, errors.NotLocalUrl):

                tree = None

                branch = dir.open_branch()

            if (

                tree is not None

                and tree.controldir.root_transport.base

                != branch.controldir.root_transport.base

            ):

                self.ui.warn(

                    _(

                        b'warning: lightweight checkouts may cause '

                        b'conversion failures, try with a regular '

                        b'branch instead.\n'

                    )

                )

        except Exception:

            self.ui.note(_(b'bzr source type could not be determined\n'))

    def before(self):

        """Before the conversion begins, acquire a read lock

        for all the operations that might need it. Fortunately

        read locks don't block other reads or writes to the

        repository, so this shouldn't have any impact on the usage of

        the source repository.

        The alternative would be locking on every operation that

        needs locks (there are currently two: getting the file and

        getting the parent map) and releasing immediately after,

        but this approach can take even 40% longer."""

        self.sourcerepo.lock_read()

    def after(self):

        self.sourcerepo.unlock()

    def _bzrbranches(self):

        return self.sourcerepo.find_branches(using=True)

    def getheads(self):

        if not self.revs:

            # Set using=True to avoid nested repositories (see issue3254)

            heads = sorted([b.last_revision() for b in self._bzrbranches()])

        else:

            revid = None

            for branch in self._bzrbranches():

                try:

                    revspec = self.revs[0].decode()

                    r = revisionspec.RevisionSpec.from_string(revspec)

                    info = r.in_history(branch)

                except errors.BzrError:

                    pass

                revid = info.rev_id

            if revid is None:

                raise error.Abort(

                    _(b'%s is not a valid revision') % self.revs[0]

                )

            heads = [revid]

        # Empty repositories return 'null:', which cannot be retrieved

        heads = [h for h in heads if h != b'null:']

        return heads

    def getfile(self, name, rev):

        name = name.decode()

        revtree = self.sourcerepo.revision_tree(rev)

        try:

            kind = revtree.kind(name)

        except breezy.errors.NoSuchFile:

            return None, None

        if kind not in supportedkinds:

            # the file is not available anymore - was deleted

            return None, None

        mode = self._modecache[(name.encode(), rev)]

        if kind == 'symlink':

            target = revtree.get_symlink_target(name)

            if target is None:

                raise error.Abort(

                    _(b'%s.%s symlink has no target') % (name, rev)

                )

            return target.encode(), mode

        else:

            sio = revtree.get_file(name)

            return sio.read(), mode

    def getchanges(self, version, full):

        if full:

            raise error.Abort(_(b"convert from cvs does not support --full"))

        self._modecache = {}

        self._revtree = self.sourcerepo.revision_tree(version)

        # get the parentids from the cache

        parentids = self._parentids.pop(version)

        # only diff against first parent id

        prevtree = self.sourcerepo.revision_tree(parentids[0])

        files, changes = self._gettreechanges(self._revtree, prevtree)

        return files, changes, set()

    def getcommit(self, version):

        rev = self.sourcerepo.get_revision(version)

        # populate parent id cache

        if not rev.parent_ids:

            parents = []

            self._parentids[version] = (revision.NULL_REVISION,)

        else:

            parents = self._filterghosts(rev.parent_ids)

            self._parentids[version] = parents

        branch = rev.properties.get('branch-nick', 'default')

        if branch == 'trunk':

            branch = 'default'

        return common.commit(

            parents=parents,

            date=b'%d %d' % (rev.timestamp, -rev.timezone),

            author=self.recode(rev.committer),

            desc=self.recode(rev.message),

            branch=branch.encode('utf8'),

            rev=version,

            saverev=self._saverev,

        )

    def gettags(self):

        bytetags = {}

        for branch in self._bzrbranches():

            if not branch.supports_tags():

                return {}

            tagdict = branch.tags.get_tag_dict()

            for name, rev in pycompat.iteritems(tagdict):

                bytetags[self.recode(name)] = rev

        return bytetags

    def getchangedfiles(self, rev, i):

        self._modecache = {}

        curtree = self.sourcerepo.revision_tree(rev)

        if i is not None:

            parentid = self._parentids[rev][i]

        else:

            # no parent id, get the empty revision

            parentid = revision.NULL_REVISION

        prevtree = self.sourcerepo.revision_tree(parentid)

        changes = [e[0] for e in self._gettreechanges(curtree, prevtree)[0]]

        return changes

    def _gettreechanges(self, current, origin):

        revid = current._revision_id

        changes = []

        renames = {}

        seen = set()

        # Fall back to the deprecated attribute for legacy installations.

        try:

            inventory = origin.root_inventory

        except AttributeError:

            inventory = origin.inventory

        # Process the entries by reverse lexicographic name order to

        # handle nested renames correctly, most specific first.

        def key(c):

            return c.path[0] or c.path[1] or ""

        curchanges = sorted(

            current.iter_changes(origin),

            key=key,

            reverse=True,

        )

        for change in curchanges:

            paths = change.path

            kind = change.kind

            executable = change.executable

            if paths[0] == u'' or paths[1] == u'':

                # ignore changes to tree root

                continue

            # bazaar tracks directories, mercurial does not, so

            # we have to rename the directory contents

            if kind[1] == 'directory':

                if kind[0] not in (None, 'directory'):

                    # Replacing 'something' with a directory, record it

                    # so it can be removed.

                    changes.append((self.recode(paths[0]), revid))

                if kind[0] == 'directory' and None not in paths:

                    renaming = paths[0] != paths[1]

                    # neither an add nor an delete - a move

                    # rename all directory contents manually

                    subdir = inventory.path2id(paths[0])

                    # get all child-entries of the directory

                    for name, entry in inventory.iter_entries(subdir):

                        # hg does not track directory renames

                        if entry.kind == 'directory':

                            continue

                        frompath = self.recode(paths[0] + '/' + name)

                        if frompath in seen:

                            # Already handled by a more specific change entry

                            # This is important when you have:

                            # a => b

                            # a/c => a/c

                            # Here a/c must not be renamed into b/c

                            continue

                        seen.add(frompath)

                        if not renaming:

                            continue

                        topath = self.recode(paths[1] + '/' + name)

                        # register the files as changed

                        changes.append((frompath, revid))

                        changes.append((topath, revid))

                        # add to mode cache

                        mode = (

                            (entry.executable and b'x')

                            or (entry.kind == 'symlink' and b's')

                            or b''

                        )

                        self._modecache[(topath, revid)] = mode

                        # register the change as move

                        renames[topath] = frompath

                # no further changes, go to the next change

                continue

            # we got unicode paths, need to convert them

            path, topath = paths

            if path is not None:

                path = self.recode(path)

            if topath is not None:

                topath = self.recode(topath)

            seen.add(path or topath)

            if topath is None:

                # file deleted

                changes.append((path, revid))

                continue

            # renamed

            if path and path != topath:

                renames[topath] = path

                changes.append((path, revid))

            # populate the mode cache

            kind, executable = [e[1] for e in (kind, executable)]

            mode = (executable and b'x') or (kind == 'symlink' and b'l') or b''

            self._modecache[(topath, revid)] = mode

            changes.append((topath, revid))

        return changes, renames

    def _filterghosts(self, ids):

        """Filters out ghost revisions which hg does not support, see

        <http://bazaar-vcs.org/GhostRevision>

        """

        parentmap = self.sourcerepo.get_parent_map(ids)

        parents = tuple([parent for parent in ids if parent in parentmap])

        return parents