"""Used for mapping a GRPS vendor/subgenre to an email address."""
import config
from constants.sql_queries import (SELECT_EMAIL_ADDRESSES_FOR_SUBACCOUNT,
                                   SELECT_EMAIL_ADDRESSES_FOR_VENDOR)
from ddex_ingester_common.helpers.rds import run_rds_query


def get_email_addresses_for_major_label(
        logger, vendor_id, subaccount_id) -> list:
    """Lookup email addresses for error reporting for the vendor."""
    logger.info('Reading emails addresses from RDS given vendor.')

    if subaccount_id:
        query_args = (vendor_id, subaccount_id)
        query_text = SELECT_EMAIL_ADDRESSES_FOR_SUBACCOUNT
    else:
        query_args = (vendor_id)
        query_text = SELECT_EMAIL_ADDRESSES_FOR_VENDOR

    return run_rds_query(
        logger,
        config.RDS_HOST,
        config.RDS_DB_NAME,
        config.RDS_RW_USER,
        config.secrets_manager_client.get_cred('rds_read_write_password'),
        query_text,
        query_args,
    )