# rebase.py - rebasing feature for mercurial

#

# Copyright 2008 Stefano Tortarolo <stefano.tortarolo at gmail dot com>

#

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

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

'''command to move sets of revisions to a different ancestor

This extension lets you rebase changesets in an existing Mercurial

repository.

For more information:

https://mercurial-scm.org/wiki/RebaseExtension

'''

from __future__ import absolute_import

import errno

import os

from mercurial.i18n import _

from mercurial.node import (

    hex,

    nullid,

    nullrev,

    short,

)

from mercurial import (

    bookmarks,

    cmdutil,

    commands,

    copies,

    destutil,

    error,

    extensions,

    hg,

    lock,

    merge,

    obsolete,

    patch,

    phases,

    registrar,

    repair,

    repoview,

    revset,

    scmutil,

    util,

)

release = lock.release

templateopts = commands.templateopts

# The following constants are used throughout the rebase module. The ordering of

# their values must be maintained.

# Indicates that a revision needs to be rebased

revtodo = -1

nullmerge = -2

revignored = -3

# successor in rebase destination

revprecursor = -4

# plain prune (no successor)

revpruned = -5

revskipped = (revignored, revprecursor, revpruned)

cmdtable = {}

command = cmdutil.command(cmdtable)

# Note for extension authors: ONLY specify testedwith = 'internal' for

# extensions which SHIP WITH MERCURIAL. Non-mainline extensions should

# be specifying the version(s) of Mercurial they are tested with, or

# leave the attribute unspecified.

testedwith = 'internal'

def _nothingtorebase():

    return 1

def _savegraft(ctx, extra):

    s = ctx.extra().get('source', None)

    if s is not None:

        extra['source'] = s

    s = ctx.extra().get('intermediate-source', None)

    if s is not None:

        extra['intermediate-source'] = s

def _savebranch(ctx, extra):

    extra['branch'] = ctx.branch()

def _makeextrafn(copiers):

    """make an extrafn out of the given copy-functions.

    A copy function takes a context and an extra dict, and mutates the

    extra dict as needed based on the given context.

    """

    def extrafn(ctx, extra):

        for c in copiers:

            c(ctx, extra)

    return extrafn

def _destrebase(repo, sourceset, destspace=None):

    """small wrapper around destmerge to pass the right extra args

    Please wrap destutil.destmerge instead."""

    return destutil.destmerge(repo, action='rebase', sourceset=sourceset,

                              onheadcheck=False, destspace=destspace)

revsetpredicate = registrar.revsetpredicate()

@revsetpredicate('_destrebase')

def _revsetdestrebase(repo, subset, x):

    # ``_rebasedefaultdest()``

    # default destination for rebase.

    # # XXX: Currently private because I expect the signature to change.

    # # XXX: - bailing out in case of ambiguity vs returning all data.

    # i18n: "_rebasedefaultdest" is a keyword

    sourceset = None

    if x is not None:

        sourceset = revset.getset(repo, revset.fullreposet(repo), x)

    return subset & revset.baseset([_destrebase(repo, sourceset)])

@command('rebase',

    [('s', 'source', '',

     _('rebase the specified changeset and descendants'), _('REV')),

    ('b', 'base', '',

     _('rebase everything from branching point of specified changeset'),

     _('REV')),

    ('r', 'rev', [],

     _('rebase these revisions'),

     _('REV')),

    ('d', 'dest', '',

     _('rebase onto the specified changeset'), _('REV')),

    ('', 'collapse', False, _('collapse the rebased changesets')),

    ('m', 'message', '',

     _('use text as collapse commit message'), _('TEXT')),

    ('e', 'edit', False, _('invoke editor on commit messages')),

    ('l', 'logfile', '',

     _('read collapse commit message from file'), _('FILE')),

    ('k', 'keep', False, _('keep original changesets')),

    ('', 'keepbranches', False, _('keep original branch names')),

    ('D', 'detach', False, _('(DEPRECATED)')),

    ('i', 'interactive', False, _('(DEPRECATED)')),

    ('t', 'tool', '', _('specify merge tool')),

    ('c', 'continue', False, _('continue an interrupted rebase')),

    ('a', 'abort', False, _('abort an interrupted rebase'))] +

     templateopts,

    _('[-s REV | -b REV] [-d REV] [OPTION]'))

def rebase(ui, repo, **opts):

    """move changeset (and descendants) to a different branch

    Rebase uses repeated merging to graft changesets from one part of

    history (the source) onto another (the destination). This can be

    useful for linearizing *local* changes relative to a master

    development tree.

    Published commits cannot be rebased (see :hg:`help phases`).

    To copy commits, see :hg:`help graft`.

    If you don't specify a destination changeset (``-d/--dest``), rebase

    will use the same logic as :hg:`merge` to pick a destination.  if

    the current branch contains exactly one other head, the other head

    is merged with by default.  Otherwise, an explicit revision with

    which to merge with must be provided.  (destination changeset is not

    modified by rebasing, but new changesets are added as its

    descendants.)

    Here are the ways to select changesets:

      1. Explicitly select them using ``--rev``.

      2. Use ``--source`` to select a root changeset and include all of its

         descendants.

      3. Use ``--base`` to select a changeset; rebase will find ancestors

         and their descendants which are not also ancestors of the destination.

      4. If you do not specify any of ``--rev``, ``source``, or ``--base``,

         rebase will use ``--base .`` as above.

    Rebase will destroy original changesets unless you use ``--keep``.

    It will also move your bookmarks (even if you do).

    Some changesets may be dropped if they do not contribute changes

    (e.g. merges from the destination branch).

    Unlike ``merge``, rebase will do nothing if you are at the branch tip of

    a named branch with two heads. You will need to explicitly specify source

    and/or destination.

    If you need to use a tool to automate merge/conflict decisions, you

    can specify one with ``--tool``, see :hg:`help merge-tools`.

    As a caveat: the tool will not be used to mediate when a file was

    deleted, there is no hook presently available for this.

    If a rebase is interrupted to manually resolve a conflict, it can be

    continued with --continue/-c or aborted with --abort/-a.

    .. container:: verbose

      Examples:

      - move "local changes" (current commit back to branching point)

        to the current branch tip after a pull::

          hg rebase

      - move a single changeset to the stable branch::

          hg rebase -r 5f493448 -d stable

      - splice a commit and all its descendants onto another part of history::

          hg rebase --source c0c3 --dest 4cf9

      - rebase everything on a branch marked by a bookmark onto the

        default branch::

          hg rebase --base myfeature --dest default

      - collapse a sequence of changes into a single commit::

          hg rebase --collapse -r 1520:1525 -d .

      - move a named branch while preserving its name::

          hg rebase -r "branch(featureX)" -d 1.3 --keepbranches

    Returns 0 on success, 1 if nothing to rebase or there are

    unresolved conflicts.

    """

    skipped = set()

    targetancestors = set()

    lock = wlock = None

    try:

        wlock = repo.wlock()

        lock = repo.lock()

        # Validate input and define rebasing points

        destf = opts.get('dest', None)

        srcf = opts.get('source', None)

        basef = opts.get('base', None)

        revf = opts.get('rev', [])

        # search default destination in this space

        # used in the 'hg pull --rebase' case, see issue 5214.

        destspace = opts.get('_destspace')

        contf = opts.get('continue')

        abortf = opts.get('abort')

        collapsef = opts.get('collapse', False)

        collapsemsg = cmdutil.logmessage(ui, opts)

        date = opts.get('date', None)

        e = opts.get('extrafn') # internal, used by e.g. hgsubversion

        extrafns = [_savegraft]

        if e:

            extrafns = [e]

        keepf = opts.get('keep', False)

        keepbranchesf = opts.get('keepbranches', False)

        # keepopen is not meant for use on the command line, but by

        # other extensions

        keepopen = opts.get('keepopen', False)

        if opts.get('interactive'):

            try:

                if extensions.find('histedit'):

                    enablehistedit = ''

            except KeyError:

                enablehistedit = " --config extensions.histedit="

            help = "hg%s help -e histedit" % enablehistedit

            msg = _("interactive history editing is supported by the "

                    "'histedit' extension (see \"%s\")") % help

            raise error.Abort(msg)

        if collapsemsg and not collapsef:

            raise error.Abort(

                _('message can only be specified with collapse'))

        if contf or abortf:

            if contf and abortf:

                raise error.Abort(_('cannot use both abort and continue'))

            if collapsef:

                raise error.Abort(

                    _('cannot use collapse with continue or abort'))

            if srcf or basef or destf:

                raise error.Abort(

                    _('abort and continue do not allow specifying revisions'))

            if abortf and opts.get('tool', False):

                ui.warn(_('tool option will be ignored\n'))

            try:

                collapsemsg = restorecollapsemsg(repo)

            except error.RepoLookupError:

                if abortf:

                    clearstatus(repo)

                    clearcollapsemsg(repo)

                    repo.ui.warn(_('rebase aborted (no revision is removed,'

                                   ' only broken state is cleared)\n'))

                    return 0

                else:

                    msg = _('cannot continue inconsistent rebase')

                    hint = _('use "hg rebase --abort" to clear broken state')

                    raise error.Abort(msg, hint=hint)

            if abortf:

            obsoletenotrebased = {}

            if ui.configbool('experimental', 'rebaseskipobsolete',

                             default=True):

                obsoletenotrebased = _computeobsoletenotrebased(repo,

                rebaseobsskipped = set(obsoletenotrebased)

                _checkobsrebase(repo, ui, rebaseobsrevs, rebasesetrevs,

                                rebaseobsskipped)

        else:

            dest, rebaseset = _definesets(ui, repo, destf, srcf, basef, revf,

                                          destspace=destspace)

            if dest is None:

                return _nothingtorebase()

            allowunstable = obsolete.isenabled(repo, obsolete.allowunstableopt)

            if (not (keepf or allowunstable)

                  and repo.revs('first(children(%ld) - %ld)',

                                rebaseset, rebaseset)):

                raise error.Abort(

                    _("can't remove original changesets with"

                      " unrebased descendants"),

                    hint=_('use --keep to keep original changesets'))

            obsoletenotrebased = {}

            if ui.configbool('experimental', 'rebaseskipobsolete',

                             default=True):

                rebasesetrevs = set(rebaseset)

                rebaseobsrevs = _filterobsoleterevs(repo, rebasesetrevs)

                obsoletenotrebased = _computeobsoletenotrebased(repo,

                                                                rebaseobsrevs,

                                                                dest)

                rebaseobsskipped = set(obsoletenotrebased)

                _checkobsrebase(repo, ui, rebaseobsrevs,

                                              rebasesetrevs,

                                              rebaseobsskipped)

            result = buildstate(repo, dest, rebaseset, collapsef,

                                obsoletenotrebased)

            if not result:

                # Empty state built, nothing to rebase

                ui.status(_('nothing to rebase\n'))

                return _nothingtorebase()

            root = min(rebaseset)

            if not keepf and not repo[root].mutable():

                raise error.Abort(_("can't rebase public changeset %s")

                                 % repo[root],

                                 hint=_('see "hg help phases" for details'))

            if collapsef:

                targetancestors = repo.changelog.ancestors([target],

                                                           inclusive=True)

            if dest.closesbranch() and not keepbranchesf:

                ui.status(_('reopening closed branch head %s\n') % dest)

        if keepbranchesf:

            # insert _savebranch at the start of extrafns so if

            # there's a user-provided extrafn it can clobber branch if

            # desired

            extrafns.insert(0, _savebranch)

            if collapsef:

                branches = set()

                    branches.add(repo[rev].branch())