# wrapper.py - methods wrapping core mercurial logic

#

# Copyright 2017 Facebook, Inc.

#

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

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

import hashlib

from mercurial.i18n import _

from mercurial.node import bin, hex, short

from mercurial.pycompat import (

    getattr,

    setattr,

)

from mercurial import (

    bundle2,

    changegroup,

    cmdutil,

    context,

    error,

    exchange,

    exthelper,

    localrepo,

    revlog,

    scmutil,

    util,

    vfs as vfsmod,

    wireprotov1server,

)

from mercurial.upgrade_utils import (

    actions as upgrade_actions,

    engine as upgrade_engine,

)

from mercurial.interfaces import repository

from mercurial.utils import (

    storageutil,

    stringutil,

)

from ..largefiles import lfutil

from . import (

    blobstore,

    pointer,

)

eh = exthelper.exthelper()

@eh.wrapfunction(localrepo, b'makefilestorage')

def localrepomakefilestorage(orig, requirements, features, **kwargs):

    if b'lfs' in requirements:

        features.add(repository.REPO_FEATURE_LFS)

    return orig(requirements=requirements, features=features, **kwargs)

@eh.wrapfunction(changegroup, b'allsupportedversions')

def allsupportedversions(orig, ui):

    versions = orig(ui)

    versions.add(b'03')

    return versions

@eh.wrapfunction(wireprotov1server, b'_capabilities')

def _capabilities(orig, repo, proto):

    '''Wrap server command to announce lfs server capability'''

    caps = orig(repo, proto)

    if util.safehasattr(repo.svfs, b'lfslocalblobstore'):

        # Advertise a slightly different capability when lfs is *required*, so

        # that the client knows it MUST load the extension.  If lfs is not

        # required on the server, there's no reason to autoload the extension

        # on the client.

        if b'lfs' in repo.requirements:

            caps.append(b'lfs-serve')

        caps.append(b'lfs')

    return caps

def bypasscheckhash(self, text):

    return False

def readfromstore(self, text):

    """Read filelog content from local blobstore transform for flagprocessor.

    Default tranform for flagprocessor, returning contents from blobstore.

    Returns a 2-typle (text, validatehash) where validatehash is True as the

    contents of the blobstore should be checked using checkhash.

    """

    p = pointer.deserialize(text)

    oid = p.oid()

    store = self.opener.lfslocalblobstore

    if not store.has(oid):

        p.filename = self.filename

        self.opener.lfsremoteblobstore.readbatch([p], store)

    # The caller will validate the content

    text = store.read(oid, verify=False)

    # pack hg filelog metadata

    hgmeta = {}

    for k in p.keys():

        if k.startswith(b'x-hg-'):

            name = k[len(b'x-hg-') :]

            hgmeta[name] = p[k]

    if hgmeta or text.startswith(b'\1\n'):

        text = storageutil.packmeta(hgmeta, text)

    return (text, True)

def writetostore(self, text):

    # hg filelog metadata (includes rename, etc)

    hgmeta, offset = storageutil.parsemeta(text)

    if offset and offset > 0:

        # lfs blob does not contain hg filelog metadata

        text = text[offset:]

    # git-lfs only supports sha256

    oid = hex(hashlib.sha256(text).digest())

    self.opener.lfslocalblobstore.write(oid, text)

    # replace contents with metadata

    longoid = b'sha256:%s' % oid

    metadata = pointer.gitlfspointer(oid=longoid, size=b'%d' % len(text))

    # by default, we expect the content to be binary. however, LFS could also

    # be used for non-binary content. add a special entry for non-binary data.

    # this will be used by filectx.isbinary().

    if not stringutil.binary(text):

        # not hg filelog metadata (affecting commit hash), no "x-hg-" prefix

        metadata[b'x-is-binary'] = b'0'

    # translate hg filelog metadata to lfs metadata with "x-hg-" prefix

    if hgmeta is not None:

        for k, v in hgmeta.items():

            metadata[b'x-hg-%s' % k] = v

    rawtext = metadata.serialize()

    return (rawtext, False)

def _islfs(rlog, node=None, rev=None):

    if rev is None:

        if node is None:

            # both None - likely working copy content where node is not ready

            return False

        rev = rlog.rev(node)

    else:

        node = rlog.node(rev)

    if node == rlog.nullid:

        return False

    flags = rlog.flags(rev)

    return bool(flags & revlog.REVIDX_EXTSTORED)

# Wrapping may also be applied by remotefilelog

def filelogaddrevision(

    orig,

    self,

    text,

    transaction,

    link,

    p1,

    p2,

    cachedelta=None,

    node=None,

    flags=revlog.REVIDX_DEFAULT_FLAGS,

    **kwds

):

    # The matcher isn't available if reposetup() wasn't called.

    lfstrack = self._revlog.opener.options.get(b'lfstrack')

    if lfstrack:

        textlen = len(text)

        # exclude hg rename meta from file size

        meta, offset = storageutil.parsemeta(text)

        if offset:

            textlen -= offset

        if lfstrack(self._revlog.filename, textlen):

            flags |= revlog.REVIDX_EXTSTORED

    return orig(

        self,

        text,

        transaction,

        link,

        p1,

        p2,

        cachedelta=cachedelta,

        node=node,

        flags=flags,

        **kwds

    )

# Wrapping may also be applied by remotefilelog

def filelogrenamed(orig, self, node):

    if _islfs(self._revlog, node):

        rawtext = self._revlog.rawdata(node)

        if not rawtext:

            return False

        metadata = pointer.deserialize(rawtext)

        if b'x-hg-copy' in metadata and b'x-hg-copyrev' in metadata:

            return metadata[b'x-hg-copy'], bin(metadata[b'x-hg-copyrev'])

        else:

            return False

    return orig(self, node)

# Wrapping may also be applied by remotefilelog

def filelogsize(orig, self, rev):

    if _islfs(self._revlog, rev=rev):

        # fast path: use lfs metadata to answer size

        rawtext = self._revlog.rawdata(rev)

        metadata = pointer.deserialize(rawtext)

        return int(metadata[b'size'])

    return orig(self, rev)

@eh.wrapfunction(revlog, b'_verify_revision')

def _verify_revision(orig, rl, skipflags, state, node):

    if _islfs(rl, node=node):

        rawtext = rl.rawdata(node)

        metadata = pointer.deserialize(rawtext)

        # Don't skip blobs that are stored locally, as local verification is

        # relatively cheap and there's no other way to verify the raw data in

        # the revlog.

        if rl.opener.lfslocalblobstore.has(metadata.oid()):

            skipflags &= ~revlog.REVIDX_EXTSTORED

        elif skipflags & revlog.REVIDX_EXTSTORED:

            # The wrapped method will set `skipread`, but there's enough local

            # info to check renames.

            state[b'safe_renamed'].add(node)

    orig(rl, skipflags, state, node)

@eh.wrapfunction(context.basefilectx, b'cmp')

def filectxcmp(orig, self, fctx):

    """returns True if text is different than fctx"""

    # some fctx (ex. hg-git) is not based on basefilectx and do not have islfs

    if self.islfs() and getattr(fctx, 'islfs', lambda: False)():

        # fast path: check LFS oid

        p1 = pointer.deserialize(self.rawdata())

        p2 = pointer.deserialize(fctx.rawdata())

        return p1.oid() != p2.oid()

    return orig(self, fctx)

@eh.wrapfunction(context.basefilectx, b'isbinary')

def filectxisbinary(orig, self):

    if self.islfs():

        # fast path: use lfs metadata to answer isbinary

        metadata = pointer.deserialize(self.rawdata())

        # if lfs metadata says nothing, assume it's binary by default

        return bool(int(metadata.get(b'x-is-binary', 1)))

    return orig(self)

def filectxislfs(self):

    return _islfs(self.filelog()._revlog, self.filenode())

@eh.wrapfunction(cmdutil, b'_updatecatformatter')

def _updatecatformatter(orig, fm, ctx, matcher, path, decode):

    orig(fm, ctx, matcher, path, decode)

    fm.data(rawdata=ctx[path].rawdata())

@eh.wrapfunction(scmutil, b'wrapconvertsink')

def convertsink(orig, sink):

    sink = orig(sink)

    if sink.repotype == b'hg':

        class lfssink(sink.__class__):

            def putcommit(

                self,

                files,

                copies,

                parents,

                commit,

                source,

                revmap,

                full,

                cleanp2,

            ):

                pc = super(lfssink, self).putcommit

                node = pc(

                    files,

                    copies,

                    parents,

                    commit,

                    source,

                    revmap,

                    full,

                    cleanp2,

                )

                if b'lfs' not in self.repo.requirements:

                    ctx = self.repo[node]

                    # The file list may contain removed files, so check for

                    # membership before assuming it is in the context.

                    if any(f in ctx and ctx[f].islfs() for f, n in files):

                        self.repo.requirements.add(b'lfs')

                        scmutil.writereporequirements(self.repo)

                return node

        sink.__class__ = lfssink

    return sink

# bundlerepo uses "vfsmod.readonlyvfs(othervfs)", we need to make sure lfs

# options and blob stores are passed from othervfs to the new readonlyvfs.

@eh.wrapfunction(vfsmod.readonlyvfs, b'__init__')

def vfsinit(orig, self, othervfs):

    orig(self, othervfs)

    # copy lfs related options

    for k, v in othervfs.options.items():

        if k.startswith(b'lfs'):

            self.options[k] = v

    # also copy lfs blobstores. note: this can run before reposetup, so lfs

    # blobstore attributes are not always ready at this time.

    for name in [b'lfslocalblobstore', b'lfsremoteblobstore']:

        if util.safehasattr(othervfs, name):

            setattr(self, name, getattr(othervfs, name))

def _prefetchfiles(repo, revmatches):

    """Ensure that required LFS blobs are present, fetching them as a group if

    needed."""

    if not util.safehasattr(repo.svfs, b'lfslocalblobstore'):

        return

    pointers = []

    oids = set()

    localstore = repo.svfs.lfslocalblobstore

    for rev, match in revmatches:

        ctx = repo[rev]

        for f in ctx.walk(match):

            p = pointerfromctx(ctx, f)

            if p and p.oid() not in oids and not localstore.has(p.oid()):

                p.filename = f

                pointers.append(p)

                oids.add(p.oid())

    if pointers:

        # Recalculating the repo store here allows 'paths.default' that is set

        # on the repo by a clone command to be used for the update.

        blobstore.remote(repo).readbatch(pointers, localstore)

def _canskipupload(repo):

    # Skip if this hasn't been passed to reposetup()

    if not util.safehasattr(repo.svfs, b'lfsremoteblobstore'):

        return True

    # if remotestore is a null store, upload is a no-op and can be skipped

    return isinstance(repo.svfs.lfsremoteblobstore, blobstore._nullremote)

def candownload(repo):

    # Skip if this hasn't been passed to reposetup()

    if not util.safehasattr(repo.svfs, b'lfsremoteblobstore'):

        return False

    # if remotestore is a null store, downloads will lead to nothing

    return not isinstance(repo.svfs.lfsremoteblobstore, blobstore._nullremote)

def uploadblobsfromrevs(repo, revs):

    """upload lfs blobs introduced by revs

    Note: also used by other extensions e. g. infinitepush. avoid renaming.

    """

    if _canskipupload(repo):