# hgweb/request.py - An http request from either CGI or the standalone server.

#

# Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>

# 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

import socket

import wsgiref.headers as wsgiheaders

#import wsgiref.validate

from .common import (

    ErrorResponse,

    statusmessage,

)

from ..thirdparty import (

    attr,

)

from .. import (

    error,

    pycompat,

    util,

)

class multidict(object):

    """A dict like object that can store multiple values for a key.

    Used to store parsed request parameters.

    This is inspired by WebOb's class of the same name.

    """

    def __init__(self):

        # Stores (key, value) 2-tuples. This isn't the most efficient. But we

        # don't rely on parameters that much, so it shouldn't be a perf issue.

        # we can always add dict for fast lookups.

        self._items = []

    def __getitem__(self, key):

        """Returns the last set value for a key."""

        for k, v in reversed(self._items):

            if k == key:

                return v

        raise KeyError(key)

    def __setitem__(self, key, value):

        """Replace a values for a key with a new value."""

        try:

            del self[key]

        except KeyError:

            pass

        self._items.append((key, value))

    def __delitem__(self, key):

        """Delete all values for a key."""

        oldlen = len(self._items)

        self._items[:] = [(k, v) for k, v in self._items if k != key]

        if oldlen == len(self._items):

            raise KeyError(key)

    def __contains__(self, key):

        return any(k == key for k, v in self._items)

    def __len__(self):

        return len(self._items)

    def get(self, key, default=None):

        try:

            return self.__getitem__(key)

        except KeyError:

            return default

    def add(self, key, value):

        """Add a new value for a key. Does not replace existing values."""

        self._items.append((key, value))

    def getall(self, key):

        """Obtains all values for a key."""

        return [v for k, v in self._items if k == key]

    def getone(self, key):

        """Obtain a single value for a key.

        Raises KeyError if key not defined or it has multiple values set.

        """

        vals = self.getall(key)

        if not vals:

            raise KeyError(key)

        if len(vals) > 1:

            raise KeyError('multiple values for %r' % key)

        return vals[0]

    def asdictoflists(self):

        d = {}

        for k, v in self._items:

            if k in d:

                d[k].append(v)

            else:

                d[k] = [v]

        return d

@attr.s(frozen=True)

class parsedrequest(object):

    """Represents a parsed WSGI request.

    Contains both parsed parameters as well as a handle on the input stream.

    """

    # Request method.

    method = attr.ib()

    # Full URL for this request.

    url = attr.ib()

    # URL without any path components. Just <proto>://<host><port>.

    baseurl = attr.ib()

    # Advertised URL. Like ``url`` and ``baseurl`` but uses SERVER_NAME instead

    # of HTTP: Host header for hostname. This is likely what clients used.

    advertisedurl = attr.ib()

    advertisedbaseurl = attr.ib()

    # URL scheme (part before ``://``). e.g. ``http`` or ``https``.

    urlscheme = attr.ib()

    # Value of REMOTE_USER, if set, or None.

    remoteuser = attr.ib()

    # Value of REMOTE_HOST, if set, or None.

    remotehost = attr.ib()

    # Relative WSGI application path. If defined, will begin with a

    # ``/``.

    apppath = attr.ib()

    # List of path parts to be used for dispatch.

    dispatchparts = attr.ib()

    # URL path component (no query string) used for dispatch. Can be

    # ``None`` to signal no path component given to the request, an

    # empty string to signal a request to the application's root URL,

    # or a string not beginning with ``/`` containing the requested

    # path under the application.

    dispatchpath = attr.ib()

    # The name of the repository being accessed.

    reponame = attr.ib()

    # Raw query string (part after "?" in URL).

    querystring = attr.ib()

    # multidict of query string parameters.

    qsparams = attr.ib()

    # wsgiref.headers.Headers instance. Operates like a dict with case

    # insensitive keys.

    headers = attr.ib()

    # Request body input stream.

    bodyfh = attr.ib()

    """Parse URL components from environment variables.

    WSGI defines request attributes via environment variables. This function

    parses the environment variables into a data structure.

    If ``reponame`` is defined, the leading path components matching that

    string are effectively shifted from ``PATH_INFO`` to ``SCRIPT_NAME``.

    This simulates the world view of a WSGI application that processes

    requests from the base URL of a repo.

    """

    # We first validate that the incoming object conforms with the WSGI spec.

    # We only want to be dealing with spec-conforming WSGI implementations.

    # TODO enable this once we fix internal violations.

    #wsgiref.validate.check_environ(env)

    # PEP-0333 states that environment keys and values are native strings

    # (bytes on Python 2 and str on Python 3). The code points for the Unicode

    # strings on Python 3 must be between \00000-\000FF. We deal with bytes

    # in Mercurial, so mass convert string keys and values to bytes.

    if pycompat.ispy3:

        env = {k.encode('latin-1'): v for k, v in env.iteritems()}

        env = {k: v.encode('latin-1') if isinstance(v, str) else v

               for k, v in env.iteritems()}

    # https://www.python.org/dev/peps/pep-0333/#environ-variables defines

    # the environment variables.

    # https://www.python.org/dev/peps/pep-0333/#url-reconstruction defines

    # how URLs are reconstructed.

    fullurl = env['wsgi.url_scheme'] + '://'

        else:

        return s

    if env.get('HTTP_HOST'):

        fullurl += env['HTTP_HOST']

    else:

        fullurl += env['SERVER_NAME']

    baseurl = fullurl

    advertisedbaseurl = advertisedfullurl

    fullurl += util.urlreq.quote(env.get('SCRIPT_NAME', ''))

    fullurl += util.urlreq.quote(env.get('PATH_INFO', ''))

    advertisedfullurl += util.urlreq.quote(env.get('PATH_INFO', ''))

    if env.get('QUERY_STRING'):

        fullurl += '?' + env['QUERY_STRING']

        advertisedfullurl += '?' + env['QUERY_STRING']

    # If ``reponame`` is defined, that must be a prefix on PATH_INFO

    # that represents the repository being dispatched to. When computing

    # the dispatch info, we ignore these leading path components.

    if reponame:

        repoprefix = '/' + reponame.strip('/')

        if not env.get('PATH_INFO'):

            raise error.ProgrammingError('reponame requires PATH_INFO')

        if not env['PATH_INFO'].startswith(repoprefix):

            raise error.ProgrammingError('PATH_INFO does not begin with repo '

                                         'name: %s (%s)' % (env['PATH_INFO'],

                                                            reponame))

        dispatchpath = env['PATH_INFO'][len(repoprefix):]

        if dispatchpath and not dispatchpath.startswith('/'):

            raise error.ProgrammingError('reponame prefix of PATH_INFO does '

                                         'not end at path delimiter: %s (%s)' %

                                         (env['PATH_INFO'], reponame))

        apppath = apppath.rstrip('/') + repoprefix

        dispatchparts = dispatchpath.strip('/').split('/')

        dispatchpath = '/'.join(dispatchparts)

    elif 'PATH_INFO' in env:

        if env['PATH_INFO'].strip('/'):

            dispatchparts = env['PATH_INFO'].strip('/').split('/')

            dispatchpath = '/'.join(dispatchparts)

        else:

            dispatchparts = []

            dispatchpath = ''

    else:

        dispatchparts = []

        dispatchpath = None

    querystring = env.get('QUERY_STRING', '')

    # We store as a list so we have ordering information. We also store as

    # a dict to facilitate fast lookup.

    qsparams = multidict()

    for k, v in util.urlreq.parseqsl(querystring, keep_blank_values=True):

        qsparams.add(k, v)

    # HTTP_* keys contain HTTP request headers. The Headers structure should

    # perform case normalization for us. We just rewrite underscore to dash

    # so keys match what likely went over the wire.

    headers = []

    for k, v in env.iteritems():

        if k.startswith('HTTP_'):

            headers.append((k[len('HTTP_'):].replace('_', '-'), v))

    headers = wsgiheaders.Headers(headers)

    # This is kind of a lie because the HTTP header wasn't explicitly

    # sent. But for all intents and purposes it should be OK to lie about

    # this, since a consumer will either either value to determine how many

    # bytes are available to read.

    if 'CONTENT_LENGTH' in env and 'HTTP_CONTENT_LENGTH' not in env:

        headers['Content-Length'] = env['CONTENT_LENGTH']

    # TODO do this once we remove wsgirequest.inp, otherwise we could have

    # multiple readers from the underlying input stream.

    #bodyfh = env['wsgi.input']

    #if 'Content-Length' in headers:

    #    bodyfh = util.cappedreader(bodyfh, int(headers['Content-Length']))

    return parsedrequest(method=env['REQUEST_METHOD'],

                         url=fullurl, baseurl=baseurl,

                         advertisedurl=advertisedfullurl,

                         advertisedbaseurl=advertisedbaseurl,

                         urlscheme=env['wsgi.url_scheme'],

                         remoteuser=env.get('REMOTE_USER'),

                         remotehost=env.get('REMOTE_HOST'),

                         apppath=apppath,

                         dispatchparts=dispatchparts, dispatchpath=dispatchpath,

                         reponame=reponame,

                         querystring=querystring,

                         qsparams=qsparams,

                         headers=headers,

                         bodyfh=bodyfh)

class offsettrackingwriter(object):

    """A file object like object that is append only and tracks write count.

    Instances are bound to a callable. This callable is called with data

    whenever a ``write()`` is attempted.

    Instances track the amount of written data so they can answer ``tell()``

    requests.

    The intent of this class is to wrap the ``write()`` function returned by

    a WSGI ``start_response()`` function. Since ``write()`` is a callable and

    not a file object, it doesn't implement other file object methods.

    """

    def __init__(self, writefn):

        self._write = writefn

        self._offset = 0

    def write(self, s):

        res = self._write(s)

        # Some Python objects don't report the number of bytes written.

        if res is None:

            self._offset += len(s)

        else:

            self._offset += res

    def flush(self):

        pass

    def tell(self):

        return self._offset

class wsgiresponse(object):

    """Represents a response to a WSGI request.

    A response consists of a status line, headers, and a body.

    Consumers must populate the ``status`` and ``headers`` fields and

    make a call to a ``setbody*()`` method before the response can be

    issued.

    When it is time to start sending the response over the wire,

    ``sendresponse()`` is called. It handles emitting the header portion

    of the response message. It then yields chunks of body data to be

    written to the peer. Typically, the WSGI application itself calls

    and returns the value from ``sendresponse()``.

    """