from owsclient import AsyncM2MTokenManager, AsyncOwsClient

from delivery_metadata import config


class OwsConnector(AsyncOwsClient):
    def __init__(self) -> None:
        super().__init__(
            environment=config.ENVIRONMENT,
            service_name=config.SERVICE_NAME,
            m2m_token_manager=(
                AsyncM2MTokenManager(
                    secrets_manager=config.secrets_manager_client,
                    environment=config.TOKEN_MANAGER_ENVIRONMENT,
                    service_name=config.SERVICE_NAME,
                )
            ),
            timeout=config.DEFAULT_OWS_CLIENT_TIMEOUT,
        )