#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#

import abc
from typing import Any, Callable, Union

import airbyte_api_client
import click
from airbyte_api_client.api import (
    destination_definition_api,
    destination_definition_specification_api,
    source_definition_api,
    source_definition_specification_api,
)
from airbyte_api_client.exceptions import ApiException
from airbyte_api_client.model.destination_definition_id_request_body import DestinationDefinitionIdRequestBody
from airbyte_api_client.model.destination_definition_id_with_workspace_id import DestinationDefinitionIdWithWorkspaceId
from airbyte_api_client.model.source_definition_id_request_body import SourceDefinitionIdRequestBody
from airbyte_api_client.model.source_definition_id_with_workspace_id import SourceDefinitionIdWithWorkspaceId


class DefinitionNotFoundError(click.ClickException):
    pass


class BaseDefinition(abc.ABC):
    COMMON_GET_FUNCTION_KWARGS = {"_check_return_type": False}

    specification = None

    @property
    @abc.abstractmethod
    def api(
        self,
    ):  # pragma: no cover
        pass

    @property
    @abc.abstractmethod
    def type(
        self,
    ):  # pragma: no cover
        pass

    @property
    @abc.abstractmethod
    def get_function_name(
        self,
    ):  # pragma: no cover
        pass

    @property
    def _get_fn(self) -> Callable:
        return getattr(self.api, self.get_function_name)

    @property
    def _get_fn_kwargs(self) -> dict:
        return {}

    def __init__(self, api_client: airbyte_api_client.ApiClient, id: str) -> None:
        self.id = id
        self.api_instance = self.api(api_client)
        self._api_data = self._read()

    def _read(self) -> dict:
        try:
            return self._get_fn(self.api_instance, **self._get_fn_kwargs, **self.COMMON_GET_FUNCTION_KWARGS)
        except ApiException as e:
            if e.status in [422, 404]:
                raise DefinitionNotFoundError(f"Definition {self.id} does not exists on your Airbyte instance.")
            raise e

    def __getattr__(self, name: str) -> Any:
        """Map attribute of the API response to the BaseDefinition object.

        Args:
            name (str): Attribute name

        Raises:
            AttributeError: Raised if the attributed was not found in the API response payload.

        Returns:
            [Any]: Attribute value
        """
        if name in self._api_data:
            return self._api_data.get(name)
        raise AttributeError(f"{self.__class__.__name__}.{name} is invalid.")


class ConnectionDefinition(BaseDefinition):
    type = "connection"


class SourceDefinition(BaseDefinition):
    api = source_definition_api.SourceDefinitionApi
    type = "source"
    get_function_name = "get_source_definition"

    @property
    def _get_fn_kwargs(self) -> dict:
        return {"source_definition_id_request_body": SourceDefinitionIdRequestBody(self.id)}


class DestinationDefinition(BaseDefinition):
    api = destination_definition_api.DestinationDefinitionApi
    type = "destination"
    get_function_name = "get_destination_definition"

    @property
    def _get_fn_kwargs(self) -> dict:
        return {"destination_definition_id_request_body": DestinationDefinitionIdRequestBody(self.id)}


class DefinitionSpecification(BaseDefinition):
    def __init__(self, api_client: airbyte_api_client.ApiClient, workspace_id: str, id: str) -> None:
        self.workspace_id = workspace_id
        super().__init__(api_client, id)


class SourceDefinitionSpecification(DefinitionSpecification):
    api = source_definition_specification_api.SourceDefinitionSpecificationApi
    type = "source"
    get_function_name = "get_source_definition_specification"

    @property
    def _get_fn_kwargs(self) -> dict:
        return {"source_definition_id_with_workspace_id": SourceDefinitionIdWithWorkspaceId(self.id, self.workspace_id)}


class DestinationDefinitionSpecification(DefinitionSpecification):
    api = destination_definition_specification_api.DestinationDefinitionSpecificationApi
    type = "destination"
    get_function_name = "get_destination_definition_specification"

    @property
    def _get_fn_kwargs(self) -> dict:
        return {"destination_definition_id_with_workspace_id": DestinationDefinitionIdWithWorkspaceId(self.id, self.workspace_id)}


def factory(
    definition_type: str, api_client: airbyte_api_client.ApiClient, workspace_id: str, definition_id: str
) -> Union[SourceDefinition, DestinationDefinition]:
    if definition_type == "source":
        definition = SourceDefinition(api_client, definition_id)
        specification = SourceDefinitionSpecification(api_client, workspace_id, definition_id)
    elif definition_type == "destination":
        definition = DestinationDefinition(api_client, definition_id)
        specification = DestinationDefinitionSpecification(api_client, workspace_id, definition_id)
    else:
        raise ValueError(f"{definition_type} does not exist")
    definition.specification = specification
    return definition
