from src import connection

UPDATE_STATEMENT = """
UPDATE encoding_queue_detail eqd
INNER JOIN encoding_queue eq ON eq.encoding_queue_id = eqd.encoding_queue_id
SET eqd.status = 'system_cancelled', error_log = %(error_log)s
WHERE eqd.dms_master_master_id = %(store_id)s
AND eqd.status IN ('new', 'ready_to_encode', 'encoding', 'ready_to_deliver', 'delivering', 'encoded', 'queued_for_delivery')
AND eq.encoder_id = %(encoder_id)s
"""


def update_encoding_queue(store_id, encoder_id, error_log):
    db_connection = connection.dd_db_connection()
    db_connection.cursor().execute(
        UPDATE_STATEMENT,
        {"store_id": store_id, "encoder_id": encoder_id, "error_log": error_log},
    )
    db_connection.commit()
    db_connection.close()