"""ows-product-review model."""

from oto import response, status
from owsrequest import request

from product_workflow.constants import error, services


def get_review_queue_eligibility(product_id):
    """Return whether a product should go into the review queue or the legacy queue."""
    url = f'/review-queue/product/{product_id}/eligibility-check'
    result = request.get(services.OWS_PRODUCT_REVIEW, url)
    if result.status_code != 200:
        return response.create_error_response(
            status=result.status_code,
            code=result.status_code,
            message=result.text)
    return response.Response(message=result.text)


def unsubmit_product(product_id):
    """Unsubmit product.

    Args:
        product_id (int): unique identifier for the product
    """
    ows_product_review_response = request.delete(
        services.OWS_PRODUCT_REVIEW,
        '/review-queue/product/{product_id}'.format(product_id=product_id))

    if ows_product_review_response.status_code == status.NOT_FOUND:
        return response.create_not_found_response(
            message=error.ERROR_MESSAGE_PRODUCT_APPROVAL_NOT_FOUND.format(
                product_id))

    if ows_product_review_response.status_code != status.NO_CONTENT:
        response_json = ows_product_review_response.json()
        response_code = response_json.get('code')
        response_message = response_json.get('message')

        return response.create_error_response(
            status=ows_product_review_response.status_code,
            code=response_code,
            message=response_message)

    return response.Response(
        message={'message': 'release approval deleted'},
        status=status.OK
    )