"""OpenSearch connector."""

from content_utils.connectors.opensearch import LambdaOpensearchConnector

from src import config

os_opts = {}

if config.OPENSEARCH_PORT:
    os_opts.update(port=int(config.OPENSEARCH_PORT))

if config.OPENSEARCH_INDEX_ALIAS:
    os_opts.update(alias_name=config.OPENSEARCH_INDEX_ALIAS)

os_connector = LambdaOpensearchConnector(
    config.OPENSEARCH_ENDPOINT,
    config.app_logger,
    **os_opts
)