import io
import os.path as op
import time
import typing as t
from datetime import datetime
from datetime import timedelta

try:
    from azure.core.exceptions import ResourceExistsError
    from azure.storage.blob import BlobProperties
    from azure.storage.blob import BlobServiceClient
    from azure.storage.blob import ContainerClient
except ImportError as e:
    raise Exception(
        "Could not import `azure.storage.blob`. "
        "Enable `azure-blob-storage` integration "
        "by installing `flask-admin[azure-blob-storage]`"
    ) from e

import flask

from . import BaseFileAdmin
from . import BaseFileStorage


class AzureStorage(BaseFileStorage):
    """
    Storage object representing files on an Azure Storage container.

    Usage::

        from flask_admin.contrib.fileadmin import BaseFileAdmin
        from flask_admin.contrib.fileadmin.azure import AzureStorage

        class MyAzureAdmin(BaseFileAdmin):
            # Configure your class however you like
            pass

        fileadmin_view = MyAzureAdmin(storage=AzureStorage(...))

    """

    _fakedir = ".dir"
    _copy_poll_interval_seconds = 1
    _send_file_lookback = timedelta(minutes=15)
    _send_file_validity = timedelta(hours=1)
    separator = "/"

    def __init__(
        self,
        blob_service_client: BlobServiceClient,
        container_name: str,
        on_windows=False,
    ):
        """
        Constructor

        :param blob_service_client:
            BlobServiceClient for the Azure Blob Storage account

        :param container_name:
            Name of the container that the files are on.

        :param on_windows:
            True for Windows storage, this parameter is needed only if your
            azure storage on Windows while your host is Linux and vice
            versa.
        """
        self._client = blob_service_client
        self._container_name = container_name
        self.on_windows = on_windows
        try:
            self._client.create_container(self._container_name)
        except ResourceExistsError:
            pass

    @property
    def _container_client(self) -> ContainerClient:
        return self._client.get_container_client(self._container_name)

    @classmethod
    def _get_blob_last_modified(cls, blob: BlobProperties) -> float:
        last_modified = blob.last_modified
        tzinfo = last_modified.tzinfo
        epoch = last_modified - datetime(1970, 1, 1, tzinfo=tzinfo)
        return epoch.total_seconds()

    @classmethod
    def _ensure_blob_path(cls, path: str | None) -> str | None:
        if path is None:
            return None

        path_parts = path.split(op.sep)
        return cls.separator.join(path_parts).lstrip(cls.separator)

    def get_files(
        self, path: str, directory: str | None
    ) -> list[tuple[str, str, bool, int, float]]:
        if directory and path != directory:
            path = op.join(path, directory)

        path = self._ensure_blob_path(path)  # type: ignore[assignment]
        directory = self._ensure_blob_path(directory)

        path_parts = path.split(self.separator) if path else []
        num_path_parts = len(path_parts)

        folders = set()
        files = []

        container_client = self._client.get_container_client(self._container_name)

        for blob in container_client.list_blobs(path):
            blob_path_parts = blob.name.split(self.separator)
            name = blob_path_parts.pop()

            blob_is_file_at_current_level = blob_path_parts == path_parts
            blob_is_directory_file = name == self._fakedir

            if blob_is_file_at_current_level and not blob_is_directory_file:
                rel_path = blob.name
                is_dir = False
                size = blob.size
                last_modified = self._get_blob_last_modified(blob)
                files.append((name, rel_path, is_dir, size, last_modified))
            else:
                next_level_folder = blob_path_parts[: num_path_parts + 1]
                folder = self.separator.join(next_level_folder)
                folders.add(folder)

        folders.discard(directory)  # type: ignore[arg-type]
        for folder in folders:
            name = folder.split(self.separator)[-1]
            rel_path = folder
            is_dir = True
            size = 0
            last_modified = 0
            files.append((name, rel_path, is_dir, size, last_modified))

        return files

    def is_dir(self, path: str | None) -> bool:
        path = self._ensure_blob_path(path)

        blobs = self._container_client.list_blobs(name_starts_with=path)
        for blob in blobs:
            if blob.name != path:
                return True
        return False

    def path_exists(self, path: str | None) -> bool:
        path = self._ensure_blob_path(path)

        if path == self.get_base_path():
            return True

        if path is None:
            return False

        # Return true if it exists as either a directory or a file
        for _ in self._container_client.list_blobs(name_starts_with=path):
            return True
        return False

    def get_base_path(self) -> str:
        return ""

    def get_breadcrumbs(self, path: str | None) -> list[tuple[str, str]]:
        path = self._ensure_blob_path(path)

        accumulator = []
        breadcrumbs = []
        if path is not None:
            for folder in path.split(self.separator):
                accumulator.append(folder)
                breadcrumbs.append((folder, self.separator.join(accumulator)))
        return breadcrumbs

    def send_file(self, file_path: str) -> flask.Response:
        path = self._ensure_blob_path(file_path)
        if path is None:
            raise ValueError("No path provided")
        blob = self._container_client.get_blob_client(path).download_blob()
        if not blob.properties or not blob.properties.has_key("content_settings"):
            raise ValueError("Blob has no properties")
        mime_type = blob.properties["content_settings"]["content_type"]
        blob_file = io.BytesIO()
        blob.readinto(blob_file)
        blob_file.seek(0)
        return flask.send_file(
            blob_file,
            mimetype=mime_type,
            as_attachment=True,
            download_name=path,
        )

    def read_file(self, path: str | None) -> bytes:
        path = self._ensure_blob_path(path)
        if path is None:
            raise ValueError("No path provided")
        blob = self._container_client.get_blob_client(path).download_blob()
        return blob.readall()

    def write_file(self, path: str | None, content: t.Any) -> None:
        path = self._ensure_blob_path(path)
        if path is None:
            raise ValueError("No path provided")
        self._container_client.upload_blob(path, content, overwrite=True)

    def save_file(self, path: str | None, file_data: t.Any) -> None:
        path = self._ensure_blob_path(path)
        if path is None:
            raise ValueError("No path provided")
        self._container_client.upload_blob(path, file_data.stream)

    def delete_tree(self, directory: str | None) -> None:
        directory = self._ensure_blob_path(directory)

        for blob in self._container_client.list_blobs(directory):
            self._container_client.delete_blob(blob.name)

    def delete_file(self, file_path: str | None) -> None:
        file_path = self._ensure_blob_path(file_path)
        if file_path is None:
            raise ValueError("No path provided")
        self._container_client.delete_blob(file_path)

    def make_dir(self, path: str | None, directory: str | None) -> None:
        path = self._ensure_blob_path(path)
        directory = self._ensure_blob_path(directory)
        if path is None or directory is None:
            raise ValueError("No path provided")
        blob = self.separator.join([path, directory, self._fakedir])
        blob = blob.lstrip(self.separator)
        self._container_client.upload_blob(blob, b"")

    def _copy_blob(self, src: str, dst: str) -> None:
        src_blob_client = self._container_client.get_blob_client(src)
        dst_blob_client = self._container_client.get_blob_client(dst)
        copy_result = dst_blob_client.start_copy_from_url(src_blob_client.url)
        if copy_result.get("copy_status") == "success":
            return

        for _ in range(10):
            props = dst_blob_client.get_blob_properties()
            status = props.copy.status
            if status == "success":
                return
            time.sleep(1)

        if status != "success":
            props = dst_blob_client.get_blob_properties()
            copy_id = props.copy.id
            if copy_id is not None:
                dst_blob_client.abort_copy(copy_id)
            raise Exception(f"Copy operation failed: {status}")

    def _rename_file(self, src: str, dst: str) -> None:
        self._copy_blob(src, dst)
        self.delete_file(src)

    def _rename_directory(self, src: str, dst: str) -> None:
        for blob in self._container_client.list_blobs(src):
            self._rename_file(blob.name, blob.name.replace(src, dst, 1))

    def rename_path(
        self,
        src: str,
        dst: str,
    ) -> None:
        src = t.cast(str, self._ensure_blob_path(src))
        dst = t.cast(str, self._ensure_blob_path(dst))

        if self.is_dir(src):
            self._rename_directory(src, dst)
        else:
            self._rename_file(src, dst)


class AzureFileAdmin(BaseFileAdmin):
    """
    Simple Azure Blob Storage file-management interface.

        :param container_name:
            Name of the container that the files are on.

        :param connection_string:
            Azure Blob Storage Connection String

    Sample usage::
        from azure.storage.blob import BlobServiceClient
        from flask_admin import Admin
        from flask_admin.contrib.fileadmin.azure import AzureFileAdmin

        admin = Admin()
        client = BlobServiceClient.from_connection_string("my-connection-string")
        admin.add_view(AzureFileAdmin(client, 'files_container')
    """

    def __init__(
        self,
        blob_service_client: BlobServiceClient,
        container_name: str,
        on_windows: bool | None = False,
        *args: t.Any,
        **kwargs: t.Any,
    ) -> None:
        storage = AzureStorage(
            blob_service_client, container_name, on_windows=on_windows
        )
        super().__init__(*args, storage=storage, **kwargs)  # type: ignore[misc]
