"""Snowflake queries module."""
CREATE_VENDOR_DELETIONS_EXPORT = """
CREATE OR REPLACE TRANSIENT TABLE {db}.{schema}.VENDOR_DELETIONS_EXPORT AS
SELECT
    REQUEST_ID,
    EMAIL,
    PLATFORMS
FROM {db}.{schema}.FAN_DELETION_REQUESTS_LOG
WHERE STATUS = 'COMPLETED'
AND CSV_EXPORTED = FALSE
AND PROCESSED_AT >= DATEADD(DAY, -8, CURRENT_TIMESTAMP())
AND ARRAYS_OVERLAP(PLATFORMS, PARSE_JSON(%(platforms)s))
ORDER BY PROCESSED_AT;
"""

GET_VENDOR_DELETIONS = """
SELECT DISTINCT
    EMAIL,
    PLATFORMS
FROM {db}.{schema}.VENDOR_DELETIONS_EXPORT
"""

MARK_VENDOR_DELETIONS_AS_EXPORTED = """
UPDATE {db}.{schema}.FAN_DELETION_REQUESTS_LOG
SET CSV_EXPORTED = TRUE,
    CSV_EXPORTED_AT = CONVERT_TIMEZONE('UTC', CURRENT_TIMESTAMP()),
    TASK_CSV_EXPORTED_ID = %(task_run_id)s
FROM {db}.{schema}.VENDOR_DELETIONS_EXPORT
WHERE {db}.{schema}.FAN_DELETION_REQUESTS_LOG.REQUEST_ID = {db}.{schema}.VENDOR_DELETIONS_EXPORT.REQUEST_ID;
"""

CLEANUP_VENDOR_DELETIONS_EXPORT = """
DROP TABLE IF EXISTS {db}.{schema}.VENDOR_DELETIONS_EXPORT;
"""