import json

from tests_python.debugger_unittest import ReaderThread, IS_JYTHON
import pytest
import socket
from _pydev_bundle import pydev_localhost
from _pydevd_bundle.pydevd_comm import start_client

ABORT_CONNECTION = 'ABORT_CONNECTION'

pytestmark = pytest.mark.skipif(IS_JYTHON, reason='Getting the actual port does not work when the port is == 0.')


class _DummySocket(object):

    def __init__(self):
        self._sock_for_reader_thread = None
        self._sock_for_fixture_test = None
        self._socket_server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self._localhost = host = pydev_localhost.get_localhost()
        self._socket_server.bind((host, 0))
        self._socket_server.listen(1)

    def recv(self, *args, **kwargs):
        if self._sock_for_reader_thread is None:
            sock, _addr = self._socket_server.accept()
            self._sock_for_reader_thread = sock
        return self._sock_for_reader_thread.recv(*args, **kwargs)

    def put(self, msg):
        if not isinstance(msg, bytes):
            msg = msg.encode('utf-8')

        if self._sock_for_fixture_test is None:
            self._sock_for_fixture_test = start_client(*self._socket_server.getsockname())

        self._sock_for_fixture_test.sendall(msg)

    def close(self):
        self._socket_server.close()

        if self._sock_for_fixture_test is not None:
            self._sock_for_fixture_test.close()

        if self._sock_for_reader_thread is not None:
            self._sock_for_reader_thread.close()


@pytest.yield_fixture
def _dummy_socket():
    sock = _DummySocket()
    yield sock
    sock.close()


def test_fixture_reader_thread1(_dummy_socket):
    sock = _dummy_socket

    reader_thread = ReaderThread(sock)
    reader_thread.start()

    json_part = json.dumps({'key': 'val'})
    json_part = json_part.replace(':', ':\n')
    msg = json_part

    msg = ('Content-Length: %s\r\n\r\n%s' % (len(msg), msg)).encode('utf-8')
    # Check that receiving 2 messages at a time we're able to properly deal
    # with each one.
    sock.put(msg + msg)

    assert reader_thread.get_next_message('check 1') == json_part
    assert reader_thread.get_next_message('check 2') == json_part


def test_fixture_reader_thread2(_dummy_socket):
    sock = _DummySocket()

    reader_thread = ReaderThread(sock)
    reader_thread.start()

    json_part = json.dumps({'key': 'val'})
    json_part = json_part.replace(':', ':\n')
    msg = json_part

    http = ('Content-Length: %s\r\n\r\n%s' % (len(msg), msg))
    sock.put('msg1\nmsg2\nmsg3\n' + http + http)

    assert reader_thread.get_next_message('check 1') == 'msg1'
    assert reader_thread.get_next_message('check 2') == 'msg2'
    assert reader_thread.get_next_message('check 3') == 'msg3'
    assert reader_thread.get_next_message('check 4') == json_part
    assert reader_thread.get_next_message('check 5') == json_part


def test_fixture_reader_thread3(_dummy_socket):
    sock = _DummySocket()

    reader_thread = ReaderThread(sock)
    reader_thread.start()

    msg = 'aaaaaaabbbbbbbccccccc'
    http = ('Content-Length: %s\r\n\r\n%s' % (len(msg), msg))
    http *= 2
    initial = http
    for i in range(1, len(http)):
        while http:
            sock.put(http[:i])
            http = http[i:]

        assert reader_thread.get_next_message('check 1: %s' % i) == msg
        assert reader_thread.get_next_message('check 2: %s' % i) == msg
        http = initial