"""
Factory functions for SQL queries used in the producer lambda.
"""

# flake8: noqa: E501
from common.src.typings import SqlString


# noinspection SqlNoDataSourceInspection
def labels_period_ids() -> SqlString:
    """Query to get all Label IDs and their available period IDs for reporting."""
    return SqlString(
        f"""
        SELECT
          S.ACCOUNT_ID AS LABEL_ID,
          ARRAY_AGG(DISTINCT S.PERIOD_ID) AS AVAILABLE_PERIODS
        FROM ROYALTY_ACCOUNTING.PROD.VW_ABACUS_FACT_SALES_PUBLISHING S
        GROUP BY 1
        """
    )