"""Module for representing a JVC Projector network connection."""

from __future__ import annotations

import asyncio


class Connection:
    """Class for representing a JVC Projector network connection."""

    def __init__(self, ip: str, port: int, timeout: float):
        """Initialize instance of class."""
        self._ip = ip
        self._port = port
        self._timeout = timeout
        self._reader: asyncio.StreamReader | None = None
        self._writer: asyncio.StreamWriter | None = None

    @property
    def ip(self) -> str:
        """Return ip address."""
        return self._ip

    @property
    def port(self) -> int:
        """Return port."""
        return self._port

    def is_connected(self) -> bool:
        """Return if connected to the projector."""
        return self._reader is not None and self._writer is not None

    async def connect(self) -> None:
        """Connect to the projector."""
        assert self._reader is None and self._writer is None
        conn = asyncio.open_connection(self._ip, self._port)
        self._reader, self._writer = await asyncio.wait_for(conn, timeout=self._timeout)

    async def read(self, n: int) -> bytes:
        """Read n bytes from the projector."""
        assert self._reader
        return await asyncio.wait_for(self._reader.read(n), timeout=self._timeout)

    async def readline(self, timeout: float | None = None) -> bytes:
        """Read all bytes up to a newline from the projector."""
        assert self._reader
        return await asyncio.wait_for(
            self._reader.readline(), timeout=timeout or self._timeout
        )

    async def write(self, data: bytes) -> None:
        """Write data to the projector."""
        assert self._writer
        self._writer.write(data)
        await self._writer.drain()

    async def disconnect(self) -> None:
        """Disconnect from the projector."""
        if self._writer:
            self._writer.close()
        self._writer = None
        self._reader = None