"""GraphQL Logic."""

from content_utils.connectors.graphql import LambdaGraphQLConnector

from src import config

with open('src/logic/reviewQueue.graphql') as f:
    REVIEW_QUEUE_QUERY = f.read()

graphql_connector = LambdaGraphQLConnector(
    graphql_service_name=config.GRAPHQL_SERVICE_NAME,
    application_name=config.APPLICATION_NAME,
    logger=config.app_logger,
    environment=config.ENVIRONMENT,
    raise_on_error=True
)


def get_review_queue_products():
    """Get review queue products."""
    review_queue_products_response = graphql_connector.execute(
        REVIEW_QUEUE_QUERY,
        None
    )
    config.app_logger.debug(review_queue_products_response)
    return review_queue_products_response.get('data').get('reviewQueueItems')