"""Configuration."""

import logging
import os

from secrets_manager.swf_ext import SWFSecretsManager
import sentry_sdk


APPLICATION_NAME = 'daemon-neo4j-sync-dlq'
APPLICATION_VERSION = '0.0.1'

AWS_REGION = os.environ.get('AWS_REGION', 'us-east-1')

ENVIRONMENT_PROD = 'prod'
ENVIRONMENT_DEV = 'dev'
ENVIRONMENT_QA = 'qa'
ENVIRONMENT_TEST = 'test'
ENVIRONMENT = os.environ.get('Environment', ENVIRONMENT_DEV)

secrets_manager_client = SWFSecretsManager(
    environment=ENVIRONMENT,
    service_name=APPLICATION_NAME,
    region_name=AWS_REGION)

KAFKA_BOOTSTRAP_SERVERS = os.environ.get(
    'KAFKA_BOOTSTRAP_SERVERS', '').split(',')
KAFKA_DLQ_TOPIC = os.environ.get('KAFKA_DLQ_TOPIC')
KAFKA_CONSUMER_GROUP = os.environ.get('KAFKA_CONSUMER_GROUP', APPLICATION_NAME)
KAFKA_POLL_TIMEOUT_MS = int(os.environ.get('KAFKA_POLL_TIMEOUT_MS', 1000))
KAFKA_POLL_NUM_RECORDS = int(os.environ.get('KAFKA_POLL_NUM_RECORDS', 50))
KAFKA_DLQ_HEADER_PREFIX = os.environ.get('KAFKA_DLQ_HEADER_PREFIX', '')

SENTRY_DSN = secrets_manager_client.get_cred('SENTRY_DSN')
sentry_sdk.init(dsn=SENTRY_DSN)

LOGGER_DSN = os.environ.get('LOGGER_DSN')
LOGGER_LEVEL = getattr(logging, os.environ.get('LOGGER_LEVEL', 'INFO'))

CACERTS_FILE = os.environ.get('CACERTS_FILE')
CACERTS_PASSWORD = os.environ.get('CACERTS_PASSWORD', 'changeit')