import json
import logging
import random
import re
import string

from app.api.agents import (
    add_tool as api_add_agent_tool,
)
from app.api.tools import (
    create as api_create_tool,
)
from app.api.tools import (
    delete as api_delete_tool,
)
from app.api.tools import (
    update as api_update_tool,
)
from app.api.workflow_configs.api.base import (
    BaseApiAgentManager,
    BaseApiDatasourceManager,
)
from app.models.request import (
    AgentTool as AgentToolRequest,
)
from app.models.request import (
    Tool as ToolRequest,
)
from app.models.request import (
    ToolUpdate as ToolUpdateRequest,
)
from prisma.enums import ToolType
from services.superrag import SuperRagService

logger = logging.getLogger(__name__)


def random_id(k: int):
    alphabet = string.ascii_lowercase + string.digits
    return "".join(random.choices(alphabet, k=k))


class ApiDatasourceSuperRagManager(BaseApiDatasourceManager):
    """
    Class for managing datasources in SuperRag.
    """

    def __init__(self, api_user, agent_manager: BaseApiAgentManager):
        self.api_user = api_user
        self.agent_manager = agent_manager

        self.superrag_service = SuperRagService()

    async def _create_tool(self, assistant: dict, data: dict):
        try:
            res = await api_create_tool(
                body=ToolRequest.parse_obj(data),
                api_user=self.api_user,
            )

            new_tool = res.get("data", {})

            logger.info(f"Created tool: ${new_tool.name} - ${assistant.get('name')}")
            return new_tool
        except Exception as err:
            logger.error(f"Error creating tool: {data} - Error: {err}")

    async def _add_tool(self, assistant: dict, data: dict):
        new_tool = await self._create_tool(assistant, data)
        assistant = await self.agent_manager.get_assistant(assistant)

        try:
            await api_add_agent_tool(
                agent_id=assistant.id,
                body=AgentToolRequest(
                    toolId=new_tool.id,
                ),
                api_user=self.api_user,
            )
            logger.info(f"Added tool: {new_tool.name} - {assistant.name}")
        except Exception as err:
            logger.error(f"Error adding tool: {new_tool} - {assistant} - Error: {err}")

    async def _update_tool(self, assistant: dict, data: dict):
        tool = await self.agent_manager.get_tool(assistant, data)

        try:
            await api_update_tool(
                tool_id=tool.id,
                body=ToolUpdateRequest.parse_obj(data),
                api_user=self.api_user,
            )
            logger.info(f"Updated tool: {tool.name} - {assistant.get('name')}")
        except Exception as err:
            logger.error(
                f"Error updating tool: {tool} - {data} - {assistant} - Error: {err}"
            )

    async def _add_superrag_tool(self, assistant: dict, data: dict):
        new_tool = {
            **data,
            "type": ToolType.SUPERRAG.value,
            "metadata": {
                **data.get("metadata", {}),
                "index_name": data.get("index_name"),
                "vector_database": {
                    "type": data.get("vector_database", {}).get("type"),
                },
                "encoder": data.get("document_processor", {}).get("encoder"),
            },
        }

        await self._add_tool(assistant, new_tool)

    async def _delete_tool(self, assistant: dict, tool: dict):
        tool = await self.agent_manager.get_tool(assistant, tool)

        try:
            await api_delete_tool(
                tool_id=tool.id,
                api_user=self.api_user,
            )
            logger.info(f"Deleted tool: {tool.name} - {assistant.get('name')}")
        except Exception as err:
            logger.error(f"Error deleting tool: {tool} - {assistant} - Error: {err}")

    async def _get_unique_index_name(self, datasource: dict, assistant: dict):
        datasource_name = datasource.get("name")
        unique_name = f"{datasource_name}{random_id(8)}"
        unique_name = re.sub(r"[^a-zA-Z0-9-]", "", unique_name)

        return unique_name

    async def update_datasource(self, assistant: dict, data: dict):
        """
        This method only updates the superrag tool, not the datasource in SuperRag.
        To achive that, first delete the datasource and then add it again.
        """
        await self._update_tool(assistant, data)

    async def add_datasource(self, assistant: dict, data: dict):
        data["index_name"] = await self._get_unique_index_name(data, assistant)

        await self._add_superrag_tool(assistant, data)
        await self.superrag_service.aingest(data=data)

    async def delete_datasource(self, assistant: dict, datasource: dict):
        tool = await self.agent_manager.get_tool(
            assistant,
            {
                "name": datasource.get("name"),
            },
        )
        if tool and tool.metadata:
            tool_metadata = json.loads(tool.metadata)

            await self._delete_tool(assistant, datasource)
            await self.superrag_service.adelete(
                {
                    **datasource,
                    "index_name": tool_metadata.get("index_name"),
                }
            )
