"""Config file for lambda function."""

import os

from secrets_manager.python_ext import PythonSecretsManager

LAMBDA_NAME = 'lambda-smf-fan-response'

# AWS region configuration
DEFAULT_AWS_REGION = 'us-east-1'
AWS_REGION = os.environ.get('AWS_REGION', DEFAULT_AWS_REGION)

# Environment setup
DEV_ENVIRONMENT = 'dev'
QA_ENVIRONMENT = 'qa'
PROD_ENVIRONMENT = 'prod'
ENVIRONMENT = os.environ.get('ENVIRONMENT', DEV_ENVIRONMENT)

SENTRY_DSN = os.environ.get('SENTRY_DSN')

# Kafka Config
KAFKA_BOOTSTRAP_SERVERS = os.environ.get('KAFKA_BOOTSTRAP_SERVERS')
KAFKA_SECURITY_PROTOCOL = os.environ.get('KAFKA_SECURITY_PROTOCOL', 'SSL')
KAFKA_MESSAGE_HEADER_KEY = os.environ.get('KAFKA_MESSAGE_HEADER_KEY', 'email.hash')
DLQ_TOPIC = os.environ.get('DLQ_TOPIC', 'dlq.lambda.fanresponse')

VENDOR_TOPICS = {
    'smf': os.environ.get('KAFKA_SMF_TOPIC', 'event.smf.fanresponse'),
    'tunespeak': os.environ.get('KAFKA_TUNESPEAK_TOPIC', 'event.tunespeak.fanresponse'),
    'wyng': os.environ.get('KAFKA_WYNG_TOPIC', 'event.wyng.fanresponse'),
    'mtl': os.environ.get('KAFKA_MTL_TOPIC', 'event.mtl.fanresponse'),
}

if ENVIRONMENT in (QA_ENVIRONMENT, PROD_ENVIRONMENT):
    secrets_manager = PythonSecretsManager(
        environment=ENVIRONMENT, service_name=LAMBDA_NAME)
    email_hash_secret_raw = secrets_manager.get_cred('EMAIL_HASH_SECRET')
    EMAIL_HASH_SECRET = email_hash_secret_raw.encode()
else:
    EMAIL_HASH_SECRET = b'dummy-key'