"""Test XDISPLOC, rfc-1096_."""

# std imports
import asyncio

# local
import telnetlib3
import telnetlib3.stream_writer
from telnetlib3.telopt import DO, IS, SB, SE, IAC, WILL, XDISPLOC
from telnetlib3.tests.accessories import create_server, open_connection, asyncio_connection


async def test_telnet_server_on_xdisploc(bind_host, unused_tcp_port):
    """Test Server's callback method on_xdisploc()."""
    _waiter = asyncio.Future()
    given_xdisploc = "alpha:0"

    class ServerTestXdisploc(telnetlib3.TelnetServer):
        def on_xdisploc(self, xdisploc):
            super().on_xdisploc(xdisploc)
            _waiter.set_result(self)

    async with create_server(
        protocol_factory=ServerTestXdisploc, host=bind_host, port=unused_tcp_port
    ):
        async with asyncio_connection(bind_host, unused_tcp_port) as (reader, writer):
            writer.write(IAC + WILL + XDISPLOC)
            writer.write(IAC + SB + XDISPLOC + IS + given_xdisploc.encode("ascii") + IAC + SE)

            srv_instance = await asyncio.wait_for(_waiter, 0.5)
            assert srv_instance.get_extra_info("xdisploc") == "alpha:0"


async def test_telnet_client_send_xdisploc(bind_host, unused_tcp_port):
    """Test Client's callback method send_xdisploc()."""
    _waiter = asyncio.Future()
    given_xdisploc = "alpha"

    class ServerTestXdisploc(telnetlib3.TelnetServer):
        def on_xdisploc(self, xdisploc):
            super().on_xdisploc(xdisploc)
            _waiter.set_result(xdisploc)

        def begin_advanced_negotiation(self):
            super().begin_advanced_negotiation()
            self.writer.iac(DO, XDISPLOC)

    async with create_server(
        protocol_factory=ServerTestXdisploc, host=bind_host, port=unused_tcp_port
    ):
        async with open_connection(
            host=bind_host, port=unused_tcp_port, xdisploc=given_xdisploc
        ) as (reader, writer):
            recv_xdisploc = await asyncio.wait_for(_waiter, 0.5)
            assert recv_xdisploc == given_xdisploc