# transaction.py - simple journaling scheme for mercurial

#

# This transaction scheme is intended to gracefully handle program

# errors and interruptions. More serious failures like system crashes

# can be recovered with an fsck-like tool. As the whole repository is

# effectively log-structured, this should amount to simply truncating

# anything that isn't referenced in the changelog.

#

# Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>

#

# 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

import errno

from .i18n import _

from . import (

    error,

    pycompat,

    util,

)

from .utils import stringutil

version = 2

# These are the file generators that should only be executed after the

# finalizers are done, since they rely on the output of the finalizers (like

# the changelog having been written).

postfinalizegenerators = {b'bookmarks', b'dirstate'}

gengroupall = b'all'

gengroupprefinalize = b'prefinalize'

gengrouppostfinalize = b'postfinalize'

def active(func):

    def _active(self, *args, **kwds):

        if self._count == 0:

            raise error.Abort(

                _(

                    b'cannot use transaction when it is already committed/aborted'

                )

            )

        return func(self, *args, **kwds)

    return _active

def _playback(

    journal,

    report,

    opener,

    vfsmap,

    entries,

    backupentries,

    unlink=True,

    checkambigfiles=None,

):

    for f, o, _ignore in entries:

        if o or not unlink:

            checkambig = checkambigfiles and (f, b'') in checkambigfiles

            try:

                fp = opener(f, b'a', checkambig=checkambig)

                if fp.tell() < o:

                    raise error.Abort(

                        _(

                            b"attempted to truncate %s to %d bytes, but it was "

                            b"already %d bytes\n"

                        )

                        % (f, o, fp.tell())

                    )

                fp.truncate(o)

                fp.close()

            except IOError:

                report(_(b"failed to truncate %s\n") % f)

                raise

        else:

            try:

                opener.unlink(f)

            except (IOError, OSError) as inst:

                if inst.errno != errno.ENOENT:

                    raise

    backupfiles = []

    for l, f, b, c in backupentries:

        if l not in vfsmap and c:

            report(b"couldn't handle %s: unknown cache location %s\n" % (b, l))

        vfs = vfsmap[l]

        try:

            if f and b:

                filepath = vfs.join(f)

                backuppath = vfs.join(b)

                checkambig = checkambigfiles and (f, l) in checkambigfiles

                try:

                    util.copyfile(backuppath, filepath, checkambig=checkambig)

                    backupfiles.append(b)

                except IOError:

                    report(_(b"failed to recover %s\n") % f)

            else:

                target = f or b

                try:

                    vfs.unlink(target)

                except (IOError, OSError) as inst:

                    if inst.errno != errno.ENOENT:

                        raise

        except (IOError, OSError, error.Abort):

            if not c:

                raise

    backuppath = b"%s.backupfiles" % journal

    if opener.exists(backuppath):

        opener.unlink(backuppath)

    opener.unlink(journal)

    try:

        for f in backupfiles:

            if opener.exists(f):

                opener.unlink(f)

    except (IOError, OSError, error.Abort):

        # only pure backup file remains, it is sage to ignore any error

        pass

class transaction(util.transactional):

    def __init__(

        self,

        report,

        opener,

        vfsmap,

        journalname,

        undoname=None,

        after=None,

        createmode=None,

        validator=None,

        releasefn=None,

        checkambigfiles=None,

        name='<unnamed>',

    ):

        """Begin a new transaction

        Begins a new transaction that allows rolling back writes in the event of

        an exception.

        * `after`: called after the transaction has been committed

        * `createmode`: the mode of the journal file that will be created

        * `releasefn`: called after releasing (with transaction and result)

        `checkambigfiles` is a set of (path, vfs-location) tuples,

        which determine whether file stat ambiguity should be avoided

        for corresponded files.

        """

        self._count = 1

        self._usages = 1

        self._report = report

        # a vfs to the store content

        self._opener = opener

        # a map to access file in various {location -> vfs}

        vfsmap = vfsmap.copy()

        vfsmap[b''] = opener  # set default value

        self._vfsmap = vfsmap

        self._after = after

        self._entries = []

        self._map = {}

        self._journal = journalname

        self._undoname = undoname

        self._queue = []

        # A callback to validate transaction content before closing it.

        # should raise exception is anything is wrong.

        # target user is repository hooks.

        if validator is None:

            validator = lambda tr: None

        self._validator = validator

        # A callback to do something just after releasing transaction.

        if releasefn is None:

            releasefn = lambda tr, success: None

        self._releasefn = releasefn

        self._checkambigfiles = set()

        if checkambigfiles:

            self._checkambigfiles.update(checkambigfiles)

        self._names = [name]

        # A dict dedicated to precisely tracking the changes introduced in the

        # transaction.

        self.changes = {}

        # a dict of arguments to be passed to hooks

        self.hookargs = {}

        self._file = opener.open(self._journal, b"w")

        # a list of ('location', 'path', 'backuppath', cache) entries.

        # - if 'backuppath' is empty, no file existed at backup time

        # - if 'path' is empty, this is a temporary transaction file

        # - if 'location' is not empty, the path is outside main opener reach.

        #   use 'location' value as a key in a vfsmap to find the right 'vfs'

        # (cache is currently unused)

        self._backupentries = []

        self._backupmap = {}

        self._backupjournal = b"%s.backupfiles" % self._journal

        self._backupsfile = opener.open(self._backupjournal, b'w')

        self._backupsfile.write(b'%d\n' % version)

        if createmode is not None:

            opener.chmod(self._journal, createmode & 0o666)

            opener.chmod(self._backupjournal, createmode & 0o666)

        # hold file generations to be performed on commit

        self._filegenerators = {}

        # hold callback to write pending data for hooks

        self._pendingcallback = {}

        # True is any pending data have been written ever

        self._anypending = False

        # holds callback to call when writing the transaction

        self._finalizecallback = {}

        # hold callback for post transaction close

        self._postclosecallback = {}

        # holds callbacks to call during abort

        self._abortcallback = {}

    def __repr__(self):

        name = '/'.join(self._names)

        return '<transaction name=%s, count=%d, usages=%d>' % (

            name,

            self._count,

            self._usages,

        )

    def __del__(self):

        if self._journal:

            self._abort()

    @active

    def startgroup(self):

        """delay registration of file entry

        This is used by strip to delay vision of strip offset. The transaction

        sees either none or all of the strip actions to be done."""

        self._queue.append([])

    @active

    def endgroup(self):

        """apply delayed registration of file entry.

        This is used by strip to delay vision of strip offset. The transaction

        sees either none or all of the strip actions to be done."""

        q = self._queue.pop()

        for f, o, data in q:

            self._addentry(f, o, data)

    @active

    def add(self, file, offset, data=None):

        """record the state of an append-only file before update"""

        if file in self._map or file in self._backupmap:

            return

        if self._queue:

            self._queue[-1].append((file, offset, data))

            return

        self._addentry(file, offset, data)

    def _addentry(self, file, offset, data):

        """add a append-only entry to memory and on-disk state"""

        if file in self._map or file in self._backupmap:

            return

        self._entries.append((file, offset, data))

        self._map[file] = len(self._entries) - 1

        # add enough data to the journal to do the truncate

        self._file.write(b"%s\0%d\n" % (file, offset))

        self._file.flush()

    @active

    def addbackup(self, file, hardlink=True, location=b''):

        """Adds a backup of the file to the transaction

        Calling addbackup() creates a hardlink backup of the specified file

        that is used to recover the file in the event of the transaction

        aborting.

        * `file`: the file path, relative to .hg/store

        * `hardlink`: use a hardlink to quickly create the backup

        """

        if self._queue:

            msg = b'cannot use transaction.addbackup inside "group"'

            raise error.ProgrammingError(msg)

        if file in self._map or file in self._backupmap:

            return

        vfs = self._vfsmap[location]

        dirname, filename = vfs.split(file)

        backupfilename = b"%s.backup.%s" % (self._journal, filename)

        backupfile = vfs.reljoin(dirname, backupfilename)

        if vfs.exists(file):

            filepath = vfs.join(file)

            backuppath = vfs.join(backupfile)

            util.copyfile(filepath, backuppath, hardlink=hardlink)

        else:

            backupfile = b''

        self._addbackupentry((location, file, backupfile, False))

    def _addbackupentry(self, entry):

        """register a new backup entry and write it to disk"""

        self._backupentries.append(entry)

        self._backupmap[entry[1]] = len(self._backupentries) - 1

        self._backupsfile.write(b"%s\0%s\0%s\0%d\n" % entry)

        self._backupsfile.flush()

    @active

    def registertmp(self, tmpfile, location=b''):

        """register a temporary transaction file

        Such files will be deleted when the transaction exits (on both

        failure and success).

        """

        self._addbackupentry((location, b'', tmpfile, False))

    @active

    def addfilegenerator(

        self, genid, filenames, genfunc, order=0, location=b''

    ):

        """add a function to generates some files at transaction commit

        The `genfunc` argument is a function capable of generating proper

        content of each entry in the `filename` tuple.

        At transaction close time, `genfunc` will be called with one file

        object argument per entries in `filenames`.

        The transaction itself is responsible for the backup, creation and

        final write of such file.

        The `genid` argument is used to ensure the same set of file is only

        generated once. Call to `addfilegenerator` for a `genid` already

        present will overwrite the old entry.

        The `order` argument may be used to control the order in which multiple

        generator will be executed.

        The `location` arguments may be used to indicate the files are located

        outside of the the standard directory for transaction. It should match

        one of the key of the `transaction.vfsmap` dictionary.

        """

        # For now, we are unable to do proper backup and restore of custom vfs

        # but for bookmarks that are handled outside this mechanism.

        self._filegenerators[genid] = (order, filenames, genfunc, location)

    @active

    def removefilegenerator(self, genid):

        """reverse of addfilegenerator, remove a file generator function"""

        if genid in self._filegenerators:

            del self._filegenerators[genid]

    def _generatefiles(self, suffix=b'', group=gengroupall):

        # write files registered for generation

        any = False

        for id, entry in sorted(pycompat.iteritems(self._filegenerators)):

            any = True

            order, filenames, genfunc, location = entry

            # for generation at closing, check if it's before or after finalize

            postfinalize = group == gengrouppostfinalize

            if (

                group != gengroupall

                and (id in postfinalizegenerators) != postfinalize

            ):

                continue

            vfs = self._vfsmap[location]

            files = []

            try:

                for name in filenames:

                    name += suffix

                    if suffix:

                        self.registertmp(name, location=location)

                        checkambig = False

                    else:

                        self.addbackup(name, location=location)

                        checkambig = (name, location) in self._checkambigfiles

                    files.append(

                        vfs(name, b'w', atomictemp=True, checkambig=checkambig)

                    )

                genfunc(*files)

                for f in files:

                    f.close()