"""Ows-podcast related model tier."""

from owsrequest import request
from owsrequest.flask_request import get_ows_headers
from owsresponse import response
from participant.constants import error as error_consts
from participant.utils.convert import format_response

OWS_PODCAST = 'ows-podcast'


def current_user_owns_network_id(network_id):
    """Make request to ows-podcast in order to check network ownership.

    Args:
        network_id (int): Network id
    Returns:
        response.Response: Response with newly updated network participant.
            Or error response.

    """
    podcast_response = request.get(
        OWS_PODCAST,
        '/check-ownership',
        params={'object_type': 'network', 'object_id': network_id},
        headers=get_ows_headers(),
    )
    response_body = podcast_response.json()
    if not response_body.get('authorized'):
        return response.create_error_response(
            code=error_consts.ERROR_CODE_ACCESS_FORBIDDEN,
            message=error_consts.ERROR_MESSAGE_ACCESS_FORBIDDEN,
            status=response.status.FORBIDDEN,
        )
    return response.Response(format_response(response_body))