"""Logic for ows-assets."""

from owsrequest import request

from src import config
from src import service


def apply_corrections(product_id):
    """Apply validations ."""
    response = request.process(
        config.APPLICATION_NAME,
        config.ENVIRONMENT,
        'PUT',
        service.OWS_ASSETS,
        path='/v2/asset/product/{}/corrections/apply'.format(product_id),
        headers={'Content-Type': 'application/json'},
    )
    if (
        response.status_code == 404
        and response.text == 'No rows updated.'
    ):
        return None
    if response.status_code != 200:
        error_msg = (
            f'apply_corrections failed for product id {product_id}\n'
            f'Status code: {response.status_code}\n'
            f'Error: {response.text}\n'
        )
        raise Exception(error_msg)
    return response.json()