/brz/remove-bazaar

# Copyright (C) 2010 Canonical Ltd

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

# the Free Software Foundation; either version 2 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

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

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

from io import BytesIO

import re

from .lazy_import import lazy_import

lazy_import(globals(), """

from fnmatch import fnmatch

from breezy._termcolor import color_string, FG

from breezy import (

    diff,

    )

""")

from . import (

    controldir,

    errors,

    osutils,

    revision as _mod_revision,

    trace,

    )

from .revisionspec import (

    RevisionSpec,

    RevisionSpec_revid,

    RevisionSpec_revno,

    )

_user_encoding = osutils.get_user_encoding()

class _RevisionNotLinear(Exception):

    """Raised when a revision is not on left-hand history."""

class GrepOptions(object):

    """Container to pass around grep options.

    This class is used as a container to pass around user option and

    some other params (like outf) to processing functions. This makes

    it easier to add more options as grep evolves.

    """

    verbose = False

    ignore_case = False

    no_recursive = False

    from_root = False

    null = False

    levels = None

    line_number = False

    path_list = None

    revision = None

    pattern = None

    include = None

    exclude = None

    fixed_string = False

    files_with_matches = False

    files_without_match = False

    color = None

    diff = False

    # derived options

    recursive = None

    eol_marker = None

    patternc = None

    sub_patternc = None

    print_revno = None

    fixed_string = None

    outf = None

    show_color = False

def _rev_on_mainline(rev_tuple):

    """returns True is rev tuple is on mainline"""

    if len(rev_tuple) == 1:

        return True

    return rev_tuple[1] == 0 and rev_tuple[2] == 0

# NOTE: _linear_view_revisions is basided on

# breezy.log._linear_view_revisions.

# This should probably be a common public API

def _linear_view_revisions(branch, start_rev_id, end_rev_id):

    # requires that start is older than end

    repo = branch.repository

    graph = repo.get_graph()

    for revision_id in graph.iter_lefthand_ancestry(

            end_rev_id, (_mod_revision.NULL_REVISION, )):

        revno = branch.revision_id_to_dotted_revno(revision_id)

        revno_str = '.'.join(str(n) for n in revno)

        if revision_id == start_rev_id:

            yield revision_id, revno_str, 0

            break

        yield revision_id, revno_str, 0

# NOTE: _graph_view_revisions is copied from

# breezy.log._graph_view_revisions.

# This should probably be a common public API

def _graph_view_revisions(branch, start_rev_id, end_rev_id,

                          rebase_initial_depths=True):

    """Calculate revisions to view including merges, newest to oldest.

    :param branch: the branch

    :param start_rev_id: the lower revision-id

    :param end_rev_id: the upper revision-id

    :param rebase_initial_depth: should depths be rebased until a mainline

      revision is found?

    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.

    """

    # requires that start is older than end

    view_revisions = branch.iter_merge_sorted_revisions(

        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,

        stop_rule="with-merges")

    if not rebase_initial_depths:

        for (rev_id, merge_depth, revno, end_of_merge

             ) in view_revisions:

            yield rev_id, '.'.join(map(str, revno)), merge_depth

    else:

        # We're following a development line starting at a merged revision.

        # We need to adjust depths down by the initial depth until we find

        # a depth less than it. Then we use that depth as the adjustment.

        # If and when we reach the mainline, depth adjustment ends.

        depth_adjustment = None

        for (rev_id, merge_depth, revno, end_of_merge

             ) in view_revisions:

            if depth_adjustment is None:

                depth_adjustment = merge_depth

            if depth_adjustment:

                if merge_depth < depth_adjustment:

                    # From now on we reduce the depth adjustement, this can be

                    # surprising for users. The alternative requires two passes

                    # which breaks the fast display of the first revision

                    # though.

                    depth_adjustment = merge_depth

                merge_depth -= depth_adjustment

            yield rev_id, '.'.join(map(str, revno)), merge_depth

def compile_pattern(pattern, flags=0):

    try:

        return re.compile(pattern, flags)

    except re.error as e:

        raise errors.BzrError("Invalid pattern: '%s'" % pattern)

    return None

def is_fixed_string(s):

    if re.match("^([A-Za-z0-9_]|\\s)*$", s):

        return True

    return False

class _GrepDiffOutputter(object):

    """Precalculate formatting based on options given for diff grep.

    """

    def __init__(self, opts):

        self.opts = opts

        self.outf = opts.outf

        if opts.show_color:

            if opts.fixed_string:

                self._old = opts.pattern

                self._new = color_string(opts.pattern, FG.BOLD_RED)

                self.get_writer = self._get_writer_fixed_highlighted

            else:

                flags = opts.patternc.flags

                self._sub = re.compile(

                    opts.pattern.join(("((?:", ")+)")), flags).sub

                self._highlight = color_string("\\1", FG.BOLD_RED)

                self.get_writer = self._get_writer_regexp_highlighted

        else:

            self.get_writer = self._get_writer_plain

    def get_file_header_writer(self):

        """Get function for writing file headers"""

        write = self.outf.write

        eol_marker = self.opts.eol_marker

        def _line_writer(line):

            write(line + eol_marker)

        def _line_writer_color(line):

            write(FG.BOLD_MAGENTA + line + FG.NONE + eol_marker)

        if self.opts.show_color:

            return _line_writer_color

        else:

            return _line_writer

        return _line_writer

    def get_revision_header_writer(self):

        """Get function for writing revno lines"""

        write = self.outf.write

        eol_marker = self.opts.eol_marker

        def _line_writer(line):

            write(line + eol_marker)

        def _line_writer_color(line):

            write(FG.BOLD_BLUE + line + FG.NONE + eol_marker)

        if self.opts.show_color:

            return _line_writer_color

        else:

            return _line_writer

        return _line_writer

    def _get_writer_plain(self):

        """Get function for writing uncoloured output"""

        write = self.outf.write

        eol_marker = self.opts.eol_marker

        def _line_writer(line):

            write(line + eol_marker)

        return _line_writer

    def _get_writer_regexp_highlighted(self):

        """Get function for writing output with regexp match highlighted"""

        _line_writer = self._get_writer_plain()

        sub, highlight = self._sub, self._highlight

        def _line_writer_regexp_highlighted(line):

            """Write formatted line with matched pattern highlighted"""

            return _line_writer(line=sub(highlight, line))

        return _line_writer_regexp_highlighted

    def _get_writer_fixed_highlighted(self):

        """Get function for writing output with search string highlighted"""

        _line_writer = self._get_writer_plain()

        old, new = self._old, self._new

        def _line_writer_fixed_highlighted(line):

            """Write formatted line with string searched for highlighted"""

            return _line_writer(line=line.replace(old, new))

        return _line_writer_fixed_highlighted

def grep_diff(opts):

    wt, branch, relpath = \

        controldir.ControlDir.open_containing_tree_or_branch('.')

    with branch.lock_read():

        if opts.revision:

            start_rev = opts.revision[0]

        else:

            # if no revision is sepcified for diff grep we grep all changesets.

            opts.revision = [RevisionSpec.from_string('revno:1'),

                             RevisionSpec.from_string('last:1')]

            start_rev = opts.revision[0]

        start_revid = start_rev.as_revision_id(branch)

        if start_revid == b'null:':

            return

        srevno_tuple = branch.revision_id_to_dotted_revno(start_revid)

        if len(opts.revision) == 2:

            end_rev = opts.revision[1]

            end_revid = end_rev.as_revision_id(branch)

            if end_revid is None:

                end_revno, end_revid = branch.last_revision_info()

            erevno_tuple = branch.revision_id_to_dotted_revno(end_revid)

            grep_mainline = (_rev_on_mainline(srevno_tuple)

                             and _rev_on_mainline(erevno_tuple))

            # ensure that we go in reverse order

            if srevno_tuple > erevno_tuple:

                srevno_tuple, erevno_tuple = erevno_tuple, srevno_tuple

                start_revid, end_revid = end_revid, start_revid

            # Optimization: Traversing the mainline in reverse order is much

            # faster when we don't want to look at merged revs. We try this

            # with _linear_view_revisions. If all revs are to be grepped we

            # use the slower _graph_view_revisions

            if opts.levels == 1 and grep_mainline:

                given_revs = _linear_view_revisions(

                    branch, start_revid, end_revid)

            else:

                given_revs = _graph_view_revisions(

                    branch, start_revid, end_revid)

        else:

            # We do an optimization below. For grepping a specific revison

            # We don't need to call _graph_view_revisions which is slow.

            # We create the start_rev_tuple for only that specific revision.

            # _graph_view_revisions is used only for revision range.

            start_revno = '.'.join(map(str, srevno_tuple))

            start_rev_tuple = (start_revid, start_revno, 0)

            given_revs = [start_rev_tuple]

        repo = branch.repository

        diff_pattern = re.compile(

            b"^[+\\-].*(" + opts.pattern.encode(_user_encoding) + b")")

        file_pattern = re.compile(b"=== (modified|added|removed) file '.*'")

        outputter = _GrepDiffOutputter(opts)

        writeline = outputter.get_writer()

        writerevno = outputter.get_revision_header_writer()

        writefileheader = outputter.get_file_header_writer()

        file_encoding = _user_encoding

        for revid, revno, merge_depth in given_revs:

            if opts.levels == 1 and merge_depth != 0:

                # with level=1 show only top level

                continue

            rev_spec = RevisionSpec_revid.from_string(

                "revid:" + revid.decode('utf-8'))

            new_rev = repo.get_revision(revid)

            new_tree = rev_spec.as_tree(branch)

            if len(new_rev.parent_ids) == 0:

                ancestor_id = _mod_revision.NULL_REVISION

            else:

                ancestor_id = new_rev.parent_ids[0]

            old_tree = repo.revision_tree(ancestor_id)

            s = BytesIO()

            diff.show_diff_trees(old_tree, new_tree, s,

                                 old_label='', new_label='')

            display_revno = True

            display_file = False

            file_header = None

            text = s.getvalue()

            for line in text.splitlines():

                if file_pattern.search(line):

                    file_header = line

                    display_file = True

                elif diff_pattern.search(line):

                    if display_revno:

                        writerevno("=== revno:%s ===" % (revno,))

                        display_revno = False

                    if display_file:

                        writefileheader(

                            "  %s" % (file_header.decode(file_encoding, 'replace'),))

                        display_file = False

                    line = line.decode(file_encoding, 'replace')

                    writeline("    %s" % (line,))

def versioned_grep(opts):

    wt, branch, relpath = \

        controldir.ControlDir.open_containing_tree_or_branch('.')

    with branch.lock_read():

        start_rev = opts.revision[0]

        start_revid = start_rev.as_revision_id(branch)

        if start_revid is None:

            start_rev = RevisionSpec_revno.from_string("revno:1")

            start_revid = start_rev.as_revision_id(branch)

        srevno_tuple = branch.revision_id_to_dotted_revno(start_revid)

        if len(opts.revision) == 2:

            end_rev = opts.revision[1]

            end_revid = end_rev.as_revision_id(branch)

            if end_revid is None:

                end_revno, end_revid = branch.last_revision_info()

            erevno_tuple = branch.revision_id_to_dotted_revno(end_revid)

            grep_mainline = (_rev_on_mainline(srevno_tuple)

                             and _rev_on_mainline(erevno_tuple))

            # ensure that we go in reverse order

            if srevno_tuple > erevno_tuple:

                srevno_tuple, erevno_tuple = erevno_tuple, srevno_tuple

                start_revid, end_revid = end_revid, start_revid

            # Optimization: Traversing the mainline in reverse order is much

            # faster when we don't want to look at merged revs. We try this

            # with _linear_view_revisions. If all revs are to be grepped we

            # use the slower _graph_view_revisions

            if opts.levels == 1 and grep_mainline:

                given_revs = _linear_view_revisions(

                    branch, start_revid, end_revid)

            else:

                given_revs = _graph_view_revisions(

                    branch, start_revid, end_revid)

        else:

            # We do an optimization below. For grepping a specific revison

            # We don't need to call _graph_view_revisions which is slow.

            # We create the start_rev_tuple for only that specific revision.

            # _graph_view_revisions is used only for revision range.

            start_revno = '.'.join(map(str, srevno_tuple))

            start_rev_tuple = (start_revid, start_revno, 0)

            given_revs = [start_rev_tuple]

        # GZ 2010-06-02: Shouldn't be smuggling this on opts, but easy for now

        opts.outputter = _Outputter(opts, use_cache=True)

        for revid, revno, merge_depth in given_revs:

            if opts.levels == 1 and merge_depth != 0:

                # with level=1 show only top level

                continue

            rev = RevisionSpec_revid.from_string(

                "revid:" + revid.decode('utf-8'))

            tree = rev.as_tree(branch)

            for path in opts.path_list:

                tree_path = osutils.pathjoin(relpath, path)

                if not tree.has_filename(tree_path):

                    trace.warning("Skipped unknown file '%s'.", path)

                    continue

                if osutils.isdir(path):

                    path_prefix = path

                    dir_grep(tree, path, relpath, opts, revno, path_prefix)

                else:

                    versioned_file_grep(

                        tree, tree_path, '.', path, opts, revno)

def workingtree_grep(opts):

    revno = opts.print_revno = None  # for working tree set revno to None

    tree, branch, relpath = \

        controldir.ControlDir.open_containing_tree_or_branch('.')

    if not tree:

        msg = ('Cannot search working tree. Working tree not found.\n'

               'To search for specific revision in history use the -r option.')

        raise errors.CommandError(msg)

    # GZ 2010-06-02: Shouldn't be smuggling this on opts, but easy for now

    opts.outputter = _Outputter(opts)

    with tree.lock_read():

        for path in opts.path_list:

            if osutils.isdir(path):

                path_prefix = path

                dir_grep(tree, path, relpath, opts, revno, path_prefix)

            else:

                with open(path, 'rb') as f:

                    _file_grep(f.read(), path, opts, revno)

def _skip_file(include, exclude, path):

    if include and not _path_in_glob_list(path, include):

        return True

    if exclude and _path_in_glob_list(path, exclude):

        return True

    return False

def dir_grep(tree, path, relpath, opts, revno, path_prefix):

    # setup relpath to open files relative to cwd

    rpath = relpath

    if relpath:

        rpath = osutils.pathjoin('..', relpath)

    from_dir = osutils.pathjoin(relpath, path)

    if opts.from_root:

        # start searching recursively from root

        from_dir = None

        recursive = True

    to_grep = []

    to_grep_append = to_grep.append

    # GZ 2010-06-05: The cache dict used to be recycled every call to dir_grep

    #                and hits manually refilled. Could do this again if it was

    #                for a good reason, otherwise cache might want purging.

    outputter = opts.outputter

    for fp, fc, fkind, entry in tree.list_files(

            include_root=False, from_dir=from_dir, recursive=opts.recursive):

        if _skip_file(opts.include, opts.exclude, fp):

            continue

        if fc == 'V' and fkind == 'file':

            tree_path = osutils.pathjoin(from_dir if from_dir else '', fp)

            if revno is not None:

                # If old result is valid, print results immediately.

                # Otherwise, add file info to to_grep so that the

                # loop later will get chunks and grep them

                cache_id = tree.get_file_revision(tree_path)

                if cache_id in outputter.cache:

                    # GZ 2010-06-05: Not really sure caching and re-outputting

                    #                the old path is really the right thing,

                    #                but it's what the old code seemed to do

                    outputter.write_cached_lines(cache_id, revno)

                else:

                    to_grep_append((tree_path, (fp, tree_path)))

            else:

                # we are grepping working tree.

                if from_dir is None:

                    from_dir = '.'

                path_for_file = osutils.pathjoin(tree.basedir, from_dir, fp)

                if opts.files_with_matches or opts.files_without_match:

                    # Optimize for wtree list-only as we don't need to read the

                    # entire file

                    with open(path_for_file, 'rb', buffering=4096) as file:

                        _file_grep_list_only_wtree(file, fp, opts, path_prefix)

                else:

                    with open(path_for_file, 'rb') as f:

                        _file_grep(f.read(), fp, opts, revno, path_prefix)

    if revno is not None:  # grep versioned files

        for (path, tree_path), chunks in tree.iter_files_bytes(to_grep):

            path = _make_display_path(relpath, path)

            _file_grep(b''.join(chunks), path, opts, revno, path_prefix,

                       tree.get_file_revision(tree_path))

def _make_display_path(relpath, path):

    """Return path string relative to user cwd.

    Take tree's 'relpath' and user supplied 'path', and return path

    that can be displayed to the user.

    """

    if relpath:

        # update path so to display it w.r.t cwd

        # handle windows slash separator

        path = osutils.normpath(osutils.pathjoin(relpath, path))

        path = path.replace('\\', '/')

        path = path.replace(relpath + '/', '', 1)

    return path

def versioned_file_grep(tree, tree_path, relpath, path, opts, revno, path_prefix=None):

    """Create a file object for the specified id and pass it on to _file_grep.

    """

    path = _make_display_path(relpath, path)

    file_text = tree.get_file_text(tree_path)

    _file_grep(file_text, path, opts, revno, path_prefix)

def _path_in_glob_list(path, glob_list):

    for glob in glob_list:

        if fnmatch(path, glob):

            return True

    return False

def _file_grep_list_only_wtree(file, path, opts, path_prefix=None):

    # test and skip binary files

    if b'\x00' in file.read(1024):

        if opts.verbose:

            trace.warning("Binary file '%s' skipped.", path)

        return

    file.seek(0)  # search from beginning

    found = False

    if opts.fixed_string:

        pattern = opts.pattern.encode(_user_encoding, 'replace')

        for line in file:

            if pattern in line:

                found = True

                break

    else:  # not fixed_string

        for line in file:

            if opts.patternc.search(line):

                found = True

                break

    if (opts.files_with_matches and found) or \

            (opts.files_without_match and not found):

        if path_prefix and path_prefix != '.':

            # user has passed a dir arg, show that as result prefix

            path = osutils.pathjoin(path_prefix, path)

        opts.outputter.get_writer(path, None, None)()

class _Outputter(object):

    """Precalculate formatting based on options given

    The idea here is to do this work only once per run, and finally return a

    function that will do the minimum amount possible for each match.

    """

    def __init__(self, opts, use_cache=False):

        self.outf = opts.outf

        if use_cache:

            # self.cache is used to cache results for dir grep based on fid.

            # If the fid is does not change between results, it means that

            # the result will be the same apart from revno. In such a case

            # we avoid getting file chunks from repo and grepping. The result

            # is just printed by replacing old revno with new one.

            self.cache = {}

        else:

            self.cache = None

        no_line = opts.files_with_matches or opts.files_without_match

        if opts.show_color:

            if no_line:

                self.get_writer = self._get_writer_plain

            elif opts.fixed_string:

                self._old = opts.pattern

                self._new = color_string(opts.pattern, FG.BOLD_RED)

                self.get_writer = self._get_writer_fixed_highlighted

            else:

                flags = opts.patternc.flags

                self._sub = re.compile(

                    opts.pattern.join(("((?:", ")+)")), flags).sub

                self._highlight = color_string("\\1", FG.BOLD_RED)

                self.get_writer = self._get_writer_regexp_highlighted

            path_start = FG.MAGENTA

            path_end = FG.NONE

            sep = color_string(':', FG.BOLD_CYAN)

            rev_sep = color_string('~', FG.BOLD_YELLOW)

        else:

            self.get_writer = self._get_writer_plain

            path_start = path_end = ""

            sep = ":"

            rev_sep = "~"

        parts = [path_start, "%(path)s"]

        if opts.print_revno:

            parts.extend([rev_sep, "%(revno)s"])

        self._format_initial = "".join(parts)

        parts = []

        if no_line:

            if not opts.print_revno:

                parts.append(path_end)

        else:

            if opts.line_number:

                parts.extend([sep, "%(lineno)s"])

            parts.extend([sep, "%(line)s"])

        parts.append(opts.eol_marker)