# Copyright (C) 2017  The Software Heritage developers
# See the AUTHORS file at the top-level directory of this distribution
# License: GNU General Public License version 3, or any later version
# See top-level LICENSE file for more information

import json

from rest_framework.response import Response

from swh.storage.exc import StorageDBError, StorageAPIError

from swh.web.common.exc import NotFoundExc, ForbiddenExc
from swh.web.common.utils import shorten_path
from swh.web.api import utils


def compute_link_header(rv, options):
    """Add Link header in returned value results.

    Args:
        rv (dict): dictionary with keys:

            - headers: potential headers with 'link-next' and 'link-prev'
              keys
            - results: containing the result to return

        options (dict): the initial dict to update with result if any

    Returns:
        dict: dictionary with optional keys 'link-next' and 'link-prev'

    """
    link_headers = []

    if 'headers' not in rv:
        return {}

    rv_headers = rv['headers']

    if 'link-next' in rv_headers:
        link_headers.append('<%s>; rel="next"' % (
            rv_headers['link-next']))
    if 'link-prev' in rv_headers:
        link_headers.append('<%s>; rel="previous"' % (
            rv_headers['link-prev']))

    if link_headers:
        link_header_str = ','.join(link_headers)
        headers = options.get('headers', {})
        headers.update({
            'Link': link_header_str
        })
        return headers

    return {}


def filter_by_fields(request, data):
    """Extract a request parameter 'fields' if it exists to permit the filtering on
    he data dict's keys.

    If such field is not provided, returns the data as is.

    """
    fields = utils.get_query_params(request).get('fields')
    if fields:
        fields = set(fields.split(','))
        data = utils.filter_field_keys(data, fields)

    return data


def transform(rv):
    """Transform an eventual returned value with multiple layer of
    information with only what's necessary.

    If the returned value rv contains the 'results' key, this is the
    associated value which is returned.

    Otherwise, return the initial dict without the potential 'headers'
    key.

    """
    if 'results' in rv:
        return rv['results']

    if 'headers' in rv:
        rv.pop('headers')

    return rv


def make_api_response(request, data, doc_data={}, options={}):
    """Generates an API response based on the requested mimetype.

    Args:
        request: a DRF Request object
        data: raw data to return in the API response
        doc_data: documentation data for HTML response
        options: optionnal data that can be used to generate the response

    Returns:
        a DRF Response a object

    """
    if data:
        options['headers'] = compute_link_header(data, options)
        data = transform(data)
        data = filter_by_fields(request, data)
    doc_env = doc_data
    headers = {}
    if 'headers' in options:
        doc_env['headers_data'] = options['headers']
        headers = options['headers']

    # get request status code
    doc_env['status_code'] = options.get('status', 200)

    response_args = {'status': doc_env['status_code'],
                     'headers': headers,
                     'content_type': request.accepted_media_type}

    # when requesting HTML, typically when browsing the API through its
    # documented views, we need to enrich the input data with documentation
    # related ones and inform DRF that we request HTML template rendering
    if request.accepted_media_type == 'text/html':

        if data:
            data = json.dumps(data, sort_keys=True,
                              indent=4,
                              separators=(',', ': '))
        doc_env['response_data'] = data
        doc_env['request'] = request
        doc_env['heading'] = shorten_path(str(request.path))

        response_args['data'] = doc_env
        response_args['template_name'] = 'apidoc.html'

    # otherwise simply return the raw data and let DRF picks
    # the correct renderer (JSON or YAML)
    else:
        response_args['data'] = data

    return Response(**response_args)


def error_response(request, error, doc_data):
    """Private function to create a custom error response.

    Args:
        request: a DRF Request object
        error: the exception that caused the error
        doc_data: documentation data for HTML response

    """
    error_code = 400
    if isinstance(error, NotFoundExc):
        error_code = 404
    elif isinstance(error, ForbiddenExc):
        error_code = 403
    elif isinstance(error, StorageDBError):
        error_code = 503
    elif isinstance(error, StorageAPIError):
        error_code = 503

    error_opts = {'status': error_code}
    error_data = {
        'exception': error.__class__.__name__,
        'reason': str(error),
    }

    return make_api_response(request, error_data, doc_data,
                             options=error_opts)