"""OWS Logic."""

from owsrequest import request

from src import config
from src.exceptions import InReviewQueueException
from src.exceptions import OwsRequestException
from src.log import log


def submit_products_by_id(product_id):
    """POST products to review queue."""
    result = request.process(
        config.APPLICATION_NAME,
        config.ENVIRONMENT,
        'POST',
        'ows-product-review',
        f'/review-queue/product/{product_id}',
        params={'queue_name': config.QUEUE_NAME}
    )
    log.debug(f'Submit response: status={result.status_code} content={result.text}')
    if result.status_code == 409:
        # product is already in review queue
        raise InReviewQueueException(result.json())
    if result.status_code != 201:
        raise OwsRequestException('submit', result.text)