from typing import AsyncIterable, Iterable, Any, List
from os import scandir, DirEntry, stat_result

from .wrap import to_thread


class EntryWrapper:
    __slots__ = "entry",

    def __init__(self, entry: DirEntry):
        self.entry = entry

    def __getattr__(self, attr: str) -> Any:
        return getattr(self.entry, attr)

    def __repr__(self) -> str:
        name = type(self).__name__
        return f"{name}<{self.entry}>"

    async def inode(self) -> int:
        return await to_thread(self.entry.inode)

    async def is_dir(self, *, follow_symlinks: bool = True) -> bool:
        return await to_thread(self.entry.is_dir, follow_symlinks=follow_symlinks)

    async def is_file(self, *, follow_symlinks: bool = True) -> bool:
        return await to_thread(self.entry.is_file, follow_symlinks=follow_symlinks)

    async def is_symlink(self) -> bool:
        return await to_thread(self.entry.is_symlink)

    async def stat(self, *, follow_symlinks: bool = True) -> stat_result:
        return await to_thread(self.entry.stat, follow_symlinks=follow_symlinks)


def wrapped_scandir(*args, **kwargs) -> Iterable[EntryWrapper]:
    entries = scandir(*args, **kwargs)
    yield from map(EntryWrapper, entries)


def _scandir_results(*args, **kwargs) -> List[EntryWrapper]:
    return list(wrapped_scandir(*args, **kwargs))


async def scandir_async(*args, **kwargs) -> AsyncIterable[EntryWrapper]:
    results = await to_thread(_scandir_results, *args, **kwargs)

    for result in results:
        yield result
from typing import AsyncIterable, Iterable, Any, List
from os import scandir, DirEntry, stat_result

from .wrap import to_thread


class EntryWrapper:
    __slots__ = "entry",

    def __init__(self, entry: DirEntry):
        self.entry = entry

    def __getattr__(self, attr: str) -> Any:
        return getattr(self.entry, attr)

    def __repr__(self) -> str:
        name = type(self).__name__
        return f"{name}<{self.entry}>"

    async def inode(self) -> int:
        return await to_thread(self.entry.inode)

    async def is_dir(self, *, follow_symlinks: bool = True) -> bool:
        return await to_thread(self.entry.is_dir, follow_symlinks=follow_symlinks)

    async def is_file(self, *, follow_symlinks: bool = True) -> bool:
        return await to_thread(self.entry.is_file, follow_symlinks=follow_symlinks)

    async def is_symlink(self) -> bool:
        return await to_thread(self.entry.is_symlink)

    async def stat(self, *, follow_symlinks: bool = True) -> stat_result:
        return await to_thread(self.entry.stat, follow_symlinks=follow_symlinks)


def wrapped_scandir(*args, **kwargs) -> Iterable[EntryWrapper]:
    entries = scandir(*args, **kwargs)
    yield from map(EntryWrapper, entries)


def _scandir_results(*args, **kwargs) -> List[EntryWrapper]:
    return list(wrapped_scandir(*args, **kwargs))


async def scandir_async(*args, **kwargs) -> AsyncIterable[EntryWrapper]:
    results = await to_thread(_scandir_results, *args, **kwargs)

    for result in results:
        yield result