# Copyright 2010-2011 Fog Creek Software

#

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

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

'''largefile store working over Mercurial's wire protocol'''

from __future__ import absolute_import

from . import (

    lfutil,

    remotestore,

)

class wirestore(remotestore.remotestore):

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

        cap = remote.capable(b'largefiles')

        if not cap:

            raise lfutil.storeprotonotcapable([])

        storetypes = cap.split(b',')

        if b'serve' not in storetypes:

            raise lfutil.storeprotonotcapable(storetypes)

        self.remote = remote

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

    def _put(self, hash, fd):

        return self.remote.putlfile(hash, fd)

    def _get(self, hash):

        return self.remote.getlfile(hash)

    def _stat(self, hashes):

        """For each hash, return 0 if it is available, other values if not.

        It is usually 2 if the largefile is missing, but might be 1 the server

        has a corrupted copy."""

        with self.remote.commandexecutor() as e:

            fs = []

            for hash in hashes:

                fs.append(

                    (

                        hash,

                        e.callcommand(

                            b'statlfile',

                            {

                                b'sha': hash,

                            },

                        ),

                    )

                )

            return {hash: f.result() for hash, f in fs}