# Patch transplanting extension for Mercurial

#

# Copyright 2006, 2007 Brendan Cully <brendan@kublai.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 transplant changesets from another branch

This extension allows you to transplant changes to another parent revision,

possibly in another repository. The transplant is done using 'diff' patches.

Transplanted patches are recorded in .hg/transplant/transplants, as a

map from a changeset hash to its hash in the source repository.

'''

from __future__ import absolute_import

import os

from mercurial.i18n import _

from mercurial.pycompat import open

from mercurial.node import (

    bin,

    hex,

    nullid,

    short,

)

from mercurial import (

    bundlerepo,

    cmdutil,

    error,

    exchange,

    hg,

    logcmdutil,

    match,

    merge,

    patch,

    pycompat,

    registrar,

    revset,

    scmutil,

    smartset,

    state as statemod,

    util,

    vfs as vfsmod,

)

from mercurial.utils import (

    procutil,

    stringutil,

    urlutil,

)

class TransplantError(error.Abort):

    pass

cmdtable = {}

command = registrar.command(cmdtable)

# Note for extension authors: ONLY specify testedwith = 'ships-with-hg-core' 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 = b'ships-with-hg-core'

configtable = {}

configitem = registrar.configitem(configtable)

configitem(

    b'transplant',

    b'filter',

    default=None,

)

configitem(

    b'transplant',

    b'log',

    default=None,

)

class transplantentry(object):

    def __init__(self, lnode, rnode):

        self.lnode = lnode

        self.rnode = rnode

class transplants(object):

    def __init__(self, path=None, transplantfile=None, opener=None):

        self.path = path

        self.transplantfile = transplantfile

        self.opener = opener

        if not opener:

            self.opener = vfsmod.vfs(self.path)

        self.transplants = {}

        self.dirty = False

        self.read()

    def read(self):

        abspath = os.path.join(self.path, self.transplantfile)

        if self.transplantfile and os.path.exists(abspath):

            for line in self.opener.read(self.transplantfile).splitlines():

                lnode, rnode = map(bin, line.split(b':'))

                list = self.transplants.setdefault(rnode, [])

                list.append(transplantentry(lnode, rnode))

    def write(self):

        if self.dirty and self.transplantfile:

            if not os.path.isdir(self.path):

                os.mkdir(self.path)

            fp = self.opener(self.transplantfile, b'w')

            for list in pycompat.itervalues(self.transplants):

                for t in list:

                    l, r = map(hex, (t.lnode, t.rnode))

                    fp.write(l + b':' + r + b'\n')

            fp.close()

        self.dirty = False

    def get(self, rnode):

        return self.transplants.get(rnode) or []

    def set(self, lnode, rnode):

        list = self.transplants.setdefault(rnode, [])

        list.append(transplantentry(lnode, rnode))

        self.dirty = True

    def remove(self, transplant):

        list = self.transplants.get(transplant.rnode)

        if list:

            del list[list.index(transplant)]

            self.dirty = True

class transplanter(object):

    def __init__(self, ui, repo, opts):

        self.ui = ui

        self.path = repo.vfs.join(b'transplant')

        self.opener = vfsmod.vfs(self.path)

        self.transplants = transplants(

            self.path, b'transplants', opener=self.opener

        )

        def getcommiteditor():

            editform = cmdutil.mergeeditform(repo[None], b'transplant')

            return cmdutil.getcommiteditor(

                editform=editform, **pycompat.strkwargs(opts)

            )

        self.getcommiteditor = getcommiteditor

    def applied(self, repo, node, parent):

        """returns True if a node is already an ancestor of parent

        or is parent or has already been transplanted"""

        if hasnode(repo, parent):

            parentrev = repo.changelog.rev(parent)

        if hasnode(repo, node):

            rev = repo.changelog.rev(node)

            reachable = repo.changelog.ancestors(

                [parentrev], rev, inclusive=True

            )

            if rev in reachable:

                return True

        for t in self.transplants.get(node):

            # it might have been stripped

            if not hasnode(repo, t.lnode):

                self.transplants.remove(t)

                return False

            lnoderev = repo.changelog.rev(t.lnode)

            if lnoderev in repo.changelog.ancestors(

                [parentrev], lnoderev, inclusive=True

            ):

                return True

        return False

    def apply(self, repo, source, revmap, merges, opts=None):

        '''apply the revisions in revmap one by one in revision order'''

        if opts is None:

            opts = {}

        revs = sorted(revmap)

        p1 = repo.dirstate.p1()

        pulls = []

        diffopts = patch.difffeatureopts(self.ui, opts)

        diffopts.git = True

        lock = tr = None

        try:

            lock = repo.lock()

            tr = repo.transaction(b'transplant')

            for rev in revs:

                node = revmap[rev]

                revstr = b'%d:%s' % (rev, short(node))

                if self.applied(repo, node, p1):

                    self.ui.warn(

                        _(b'skipping already applied revision %s\n') % revstr

                    )

                    continue

                parents = source.changelog.parents(node)

                if not (opts.get(b'filter') or opts.get(b'log')):

                    # If the changeset parent is the same as the

                    # wdir's parent, just pull it.

                    if parents[0] == p1:

                        pulls.append(node)

                        p1 = node

                        continue

                    if pulls:

                        if source != repo:

                            exchange.pull(repo, source.peer(), heads=pulls)

                        merge.update(repo[pulls[-1]])

                        p1 = repo.dirstate.p1()

                        pulls = []

                domerge = False

                if node in merges:

                    # pulling all the merge revs at once would mean we

                    # couldn't transplant after the latest even if

                    # transplants before them fail.

                    domerge = True

                    if not hasnode(repo, node):

                        exchange.pull(repo, source.peer(), heads=[node])

                skipmerge = False

                if parents[1] != nullid:

                    if not opts.get(b'parent'):

                        self.ui.note(

                            _(b'skipping merge changeset %d:%s\n')

                            % (rev, short(node))

                        )

                        skipmerge = True

                    else:

                        parent = source.lookup(opts[b'parent'])

                        if parent not in parents:

                            raise error.Abort(

                                _(b'%s is not a parent of %s')

                                % (short(parent), short(node))

                            )

                else:

                    parent = parents[0]

                if skipmerge:

                    patchfile = None

                else:

                    fd, patchfile = pycompat.mkstemp(prefix=b'hg-transplant-')

                    fp = os.fdopen(fd, 'wb')

                    gen = patch.diff(source, parent, node, opts=diffopts)

                    for chunk in gen:

                        fp.write(chunk)

                    fp.close()

                del revmap[rev]

                if patchfile or domerge:

                    try:

                        try:

                            n = self.applyone(

                                repo,

                                node,

                                source.changelog.read(node),

                                patchfile,

                                merge=domerge,

                                log=opts.get(b'log'),

                                filter=opts.get(b'filter'),

                            )

                        except TransplantError:

                            # Do not rollback, it is up to the user to

                            # fix the merge or cancel everything

                            tr.close()

                            raise

                        if n and domerge:

                            self.ui.status(

                                _(b'%s merged at %s\n') % (revstr, short(n))

                            )

                        elif n:

                            self.ui.status(

                                _(b'%s transplanted to %s\n')

                                % (short(node), short(n))

                            )

                    finally:

                        if patchfile:

                            os.unlink(patchfile)

            tr.close()

            if pulls:

                exchange.pull(repo, source.peer(), heads=pulls)

                merge.update(repo[pulls[-1]])

        finally:

            self.saveseries(revmap, merges)

            self.transplants.write()

            if tr:

                tr.release()

            if lock:

                lock.release()

    def filter(self, filter, node, changelog, patchfile):

        '''arbitrarily rewrite changeset before applying it'''

        self.ui.status(_(b'filtering %s\n') % patchfile)

        user, date, msg = (changelog[1], changelog[2], changelog[4])

        fd, headerfile = pycompat.mkstemp(prefix=b'hg-transplant-')

        fp = os.fdopen(fd, 'wb')

        fp.write(b"# HG changeset patch\n")

        fp.write(b"# User %s\n" % user)

        fp.write(b"# Date %d %d\n" % date)

        fp.write(msg + b'\n')

        fp.close()

        try:

            self.ui.system(

                b'%s %s %s'

                % (

                    filter,

                    procutil.shellquote(headerfile),

                    procutil.shellquote(patchfile),

                ),

                environ={

                    b'HGUSER': changelog[1],

                    b'HGREVISION': hex(node),

                },

                onerr=error.Abort,

                errprefix=_(b'filter failed'),

                blockedtag=b'transplant_filter',

            )

            user, date, msg = self.parselog(open(headerfile, b'rb'))[1:4]

        finally:

            os.unlink(headerfile)

        return (user, date, msg)

    def applyone(

        self, repo, node, cl, patchfile, merge=False, log=False, filter=None

    ):

        '''apply the patch in patchfile to the repository as a transplant'''

        (manifest, user, (time, timezone), files, message) = cl[:5]

        date = b"%d %d" % (time, timezone)

        extra = {b'transplant_source': node}

        if filter:

            (user, date, message) = self.filter(filter, node, cl, patchfile)

        if log:

            # we don't translate messages inserted into commits

            message += b'\n(transplanted from %s)' % hex(node)

        self.ui.status(_(b'applying %s\n') % short(node))

        self.ui.note(b'%s %s\n%s\n' % (user, date, message))

        if not patchfile and not merge:

            raise error.Abort(_(b'can only omit patchfile if merging'))

        if patchfile:

            try:

                files = set()

                patch.patch(self.ui, repo, patchfile, files=files, eolmode=None)

                files = list(files)

            except Exception as inst:

                seriespath = os.path.join(self.path, b'series')

                if os.path.exists(seriespath):

                    os.unlink(seriespath)

                p1 = repo.dirstate.p1()

                p2 = node

                self.log(user, date, message, p1, p2, merge=merge)

                self.ui.write(stringutil.forcebytestr(inst) + b'\n')

                raise TransplantError(

                    _(

                        b'fix up the working directory and run '

                        b'hg transplant --continue'

                    )

                )

        else:

            files = None

        if merge: