# upgrade.py - functions for in place upgrade of Mercurial repository

#

# Copyright (c) 2016-present, Gregory Szorc

#

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

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

from __future__ import absolute_import

from .i18n import _

from . import (

    error,

    hg,

    localrepo,

    pycompat,

)

from .upgrade_utils import (

    actions as upgrade_actions,

    engine as upgrade_engine,

)

allformatvariant = upgrade_actions.allformatvariant

def upgraderepo(

    ui,

    repo,

    run=False,

    optimize=None,

    backup=True,

    manifest=None,

    changelog=None,

    filelogs=None,

):

    """Upgrade a repository in place."""

    if optimize is None:

        optimize = {}

    repo = repo.unfiltered()

    revlogs = set(upgrade_engine.UPGRADE_ALL_REVLOGS)

    specentries = (

        (upgrade_engine.UPGRADE_CHANGELOG, changelog),

        (upgrade_engine.UPGRADE_MANIFEST, manifest),

        (upgrade_engine.UPGRADE_FILELOGS, filelogs),

    )

    specified = [(y, x) for (y, x) in specentries if x is not None]

    if specified:

        # we have some limitation on revlogs to be recloned

        if any(x for y, x in specified):

            revlogs = set()

            for upgrade, enabled in specified:

                if enabled:

                    revlogs.add(upgrade)

        else:

            # none are enabled

            for upgrade, __ in specified:

                revlogs.discard(upgrade)

    # Ensure the repository can be upgraded.

    upgrade_actions.check_source_requirements(repo)

    default_options = localrepo.defaultcreateopts(repo.ui)

    newreqs = localrepo.newreporequirements(repo.ui, default_options)

    newreqs.update(upgrade_actions.preservedrequirements(repo))

    upgrade_actions.check_requirements_changes(repo, newreqs)

    # Find and validate all improvements that can be made.

    alloptimizations = upgrade_actions.findoptimizations(repo)

    # Apply and Validate arguments.

    optimizations = []

    for o in alloptimizations:

        if o.name in optimize:

            optimizations.append(o)

            optimize.discard(o.name)

    if optimize:  # anything left is unknown

        raise error.Abort(

            _(b'unknown optimization action requested: %s')

            % b', '.join(sorted(optimize)),

            hint=_(b'run without arguments to see valid optimizations'),

        )

    format_upgrades = upgrade_actions.find_format_upgrades(repo)

    up_actions = upgrade_actions.determine_upgrade_actions(

        repo, format_upgrades, optimizations, repo.requirements, newreqs

    )

    removed_actions = upgrade_actions.find_format_downgrades(repo)

    removedreqs = repo.requirements - newreqs

    addedreqs = newreqs - repo.requirements

    if revlogs != upgrade_engine.UPGRADE_ALL_REVLOGS:

        incompatible = upgrade_actions.RECLONES_REQUIREMENTS & (

            removedreqs | addedreqs

        )

        if incompatible:

            msg = _(

                b'ignoring revlogs selection flags, format requirements '

                b'change: %s\n'

            )

            ui.warn(msg % b', '.join(sorted(incompatible)))

            revlogs = upgrade_engine.UPGRADE_ALL_REVLOGS

    upgrade_op = upgrade_actions.UpgradeOperation(

        ui,

        newreqs,

        repo.requirements,

        up_actions,

        removed_actions,

        revlogs,

    )

    if not run:

        fromconfig = []

        onlydefault = []

        for d in format_upgrades:

            if d.fromconfig(repo):

                fromconfig.append(d)

            elif d.default:

                onlydefault.append(d)

        if fromconfig or onlydefault:

            if fromconfig:

                ui.status(

                    _(

                        b'repository lacks features recommended by '

                        b'current config options:\n\n'

                    )

                )

                for i in fromconfig:

                    ui.status(b'%s\n   %s\n\n' % (i.name, i.description))

            if onlydefault:

                ui.status(

                    _(

                        b'repository lacks features used by the default '

                        b'config options:\n\n'

                    )

                )

                for i in onlydefault:

                    ui.status(b'%s\n   %s\n\n' % (i.name, i.description))

            ui.status(b'\n')

        else:

            ui.status(_(b'(no format upgrades found in existing repository)\n'))

        ui.status(

            _(

                b'performing an upgrade with "--run" will make the following '

                b'changes:\n\n'

            )

        )

        upgrade_op.print_requirements()

        upgrade_op.print_optimisations()

        upgrade_op.print_upgrade_actions()

        upgrade_op.print_affected_revlogs()

        if upgrade_op.unused_optimizations:

            ui.status(

                _(

                    b'additional optimizations are available by specifying '

                    b'"--optimize <name>":\n\n'

                )

            )

            upgrade_op.print_unused_optimizations()

        return

    # Else we're in the run=true case.

    ui.write(_(b'upgrade will perform the following actions:\n\n'))

    upgrade_op.print_requirements()

    upgrade_op.print_optimisations()

    upgrade_op.print_upgrade_actions()

    upgrade_op.print_affected_revlogs()

    ui.status(_(b'beginning upgrade...\n'))

    with repo.wlock(), repo.lock():

        ui.status(_(b'repository locked and read-only\n'))

        # Our strategy for upgrading the repository is to create a new,

        # temporary repository, write data to it, then do a swap of the

        # data. There are less heavyweight ways to do this, but it is easier

        # to create a new repo object than to instantiate all the components

        # (like the store) separately.

        tmppath = pycompat.mkdtemp(prefix=b'upgrade.', dir=repo.path)

        backuppath = None

        try:

            ui.status(

                _(

                    b'creating temporary repository to stage migrated '

                    b'data: %s\n'

                )

                % tmppath

            )

            # clone ui without using ui.copy because repo.ui is protected

            repoui = repo.ui.__class__(repo.ui)

            dstrepo = hg.repository(repoui, path=tmppath, create=True)

            with dstrepo.wlock(), dstrepo.lock():

                backuppath = upgrade_engine.upgrade(

                    ui, repo, dstrepo, upgrade_op

                )

                ui.status(

                    _(b'removing old repository content %s\n') % backuppath

                )

                repo.vfs.rmtree(backuppath, forcibly=True)

                backuppath = None

        finally:

            ui.status(_(b'removing temporary repository %s\n') % tmppath)

            repo.vfs.rmtree(tmppath, forcibly=True)

            if backuppath and not ui.quiet:

                ui.warn(

                    _(b'copy of old repository backed up at %s\n') % backuppath

                )

                ui.warn(

                    _(

                        b'the old repository will not be deleted; remove '

                        b'it to free up disk space once the upgraded '

                        b'repository is verified\n'

                    )

                )

            upgrade_op.print_post_op_messages()