"""Config file for lambda function."""
import logging
import os

from secrets_manager.lambda_ext import LambdaSecretsManager

APPLICATION_NAME = 'lambda-gda-sks-unqualified-leads'

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

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

BOOTSTRAP_SERVERS = os.environ.get('BOOTSTRAP_SERVERS')
KAFKA_TOPIC = os.environ.get('KAFKA_TOPIC', 'event.gdaUnqualifiedLeads')
KAFKA_OFFSET_TOPIC = os.environ.get(
    'KAFKA_OFFSET_TOPIC', 'event.gdaUnqualifiedLeads.offsets')
GROUP_ID = os.environ.get(
    'GROUP_ID', f'{ENVIRONMENT}-salesforce-unqualified-leads-poller')
SALESFORCE_VERSION = os.environ.get('SALESFORCE_VERSION', '47.0')
# default use QA salesforce
SALESFORCE_QA_DOMAIN = 'test'
SALESFORCE_DOMAIN = os.environ.get('SALESFORCE_DOMAIN', SALESFORCE_QA_DOMAIN)
OFFSETS_POLL_WAIT_TIME = int(os.environ.get('OFFSETS_POLL_WAIT_TIME', 5))
OFFSET_TOPIC_PARTITIONS = int(os.environ.get('OFFSET_TOPIC_PARTITIONS', 1))
OFFSET_TOPIC_REPLICAS = int(os.environ.get('OFFSET_TOPIC_REPLICAS', 3))
RETRY_COUNT = int(os.environ.get('RETRY_COUNT', 5))
RETRY_MAX_WAIT = int(os.environ.get('RETRY_MAX_WAIT', 10))

LOG_LEVEL = os.environ.get('LOG_LEVEL', logging.INFO)


logger = logging.getLogger(__name__)
handler = logging.StreamHandler()
handler.setLevel(logging.getLevelName(LOG_LEVEL))
logger.setLevel(logging.getLevelName(LOG_LEVEL))
formatter = logging.Formatter(logging.BASIC_FORMAT)
logger.addHandler(handler)
secrets_manager_client = LambdaSecretsManager(
    environment=ENVIRONMENT, service_name=APPLICATION_NAME)