# Copyright 2009-2010 Gregory P. Ward

# Copyright 2009-2010 Intelerad Medical Systems Incorporated

# Copyright 2010-2011 Fog Creek Software

# Copyright 2010-2011 Unity Technologies

#

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

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

'''store class for local filesystem'''

from mercurial.i18n import _

import lfutil

import basestore

class localstore(basestore.basestore):

    '''localstore first attempts to grab files out of the store in the remote

    Mercurial repository.  Failing that, it attempts to grab the files from

    the user cache.'''

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

        self.remote = remote.local()

        super(localstore, self).__init__(ui, repo, self.remote.url())

    def put(self, source, hash):

        if lfutil.instore(self.remote, hash):

            return

        lfutil.link(lfutil.storepath(self.repo, hash),

                lfutil.storepath(self.remote, hash))

    def exists(self, hashes):

        retval = {}

        for hash in hashes:

            retval[hash] = lfutil.instore(self.remote, hash)

        return retval

    def _getfile(self, tmpfile, filename, hash):

        path = lfutil.findfile(self.remote, hash)

        if not path:

            raise basestore.StoreError(filename, hash, self.url,

                _("can't get file locally"))

        fd = open(path, 'rb')

        try:

            return lfutil.copyandhash(fd, tmpfile)

        finally:

            fd.close()

    def _verifyfile(self, cctx, cset, contents, standin, verified):

        filename = lfutil.splitstandin(standin)

        if not filename:

            return False

        fctx = cctx[standin]

        key = (filename, fctx.filenode())

        if key in verified:

            return False

        expecthash = fctx.data()[0:40]

        storepath = lfutil.storepath(self.remote, expecthash)

        verified.add(key)

        if not lfutil.instore(self.remote, expecthash):

            self.ui.warn(

                _('changeset %s: %s references missing %s\n')

                % (cset, filename, storepath))

            return True                 # failed

        if contents:

            actualhash = lfutil.hashfile(storepath)

            if actualhash != expecthash:

                self.ui.warn(

                    _('changeset %s: %s references corrupted %s\n')

                    % (cset, filename, storepath))

                return True             # failed

        return False