"""Add product to queue logic."""


from content_utils.connectors.graphql import LambdaGraphQLConnector

from src import config


def add_product_to_queue(product_id, correlation_id, identity_id=None, submission_datetime=None):
    """Add a product id to the review queue."""
    gql_conn = LambdaGraphQLConnector(
        config.GRAPHQL_GATEWAY_URL,
        config.APPLICATION_NAME,
        config.app_logger,
        correlation_id=correlation_id
    )
    response = gql_conn.execute_add_to_queue_mutation(product_id, identity_id, submission_datetime)
    return response.get('createReviewQueueItem').get('reviewQueueId')