import sys
import time

import pytest

from easyprocess import EasyProcess

python = sys.executable


def test_timeout():
    p = EasyProcess("sleep 1").start()
    p.wait(0.2)
    assert p.is_alive()
    p.wait(0.2)
    assert p.is_alive()
    p.wait(2)
    assert not p.is_alive()

    assert EasyProcess("sleep 0.3").call().return_code == 0
    assert EasyProcess("sleep 0.3").call(timeout=0.1).return_code != 0
    assert EasyProcess("sleep 0.3").call(timeout=1).return_code == 0

    assert EasyProcess("sleep 0.3").call().timeout_happened is False
    assert EasyProcess("sleep 0.3").call(timeout=0.1).timeout_happened
    assert EasyProcess("sleep 0.3").call(timeout=1).timeout_happened is False


@pytest.mark.timeout(10)
def test_time_cli1():
    hdr = "import logging;logging.basicConfig(level=logging.DEBUG);from easyprocess import EasyProcess;"
    p = EasyProcess(
        [
            python,
            "-c",
            hdr + "EasyProcess('sleep 15').start()",
        ]
    )
    p.call()
    assert p.return_code == 0


@pytest.mark.timeout(10)
def test_time_cli2():
    hdr = "import logging;logging.basicConfig(level=logging.DEBUG);from easyprocess import EasyProcess;"
    p = EasyProcess(
        [
            python,
            "-c",
            hdr + "EasyProcess('sleep 15').call(timeout=0.5)",
        ]
    )
    p.call()
    assert p.return_code == 0


@pytest.mark.timeout(10)
def test_time2():
    p = EasyProcess("sleep 15").call(timeout=1)
    assert p.is_alive() is False
    assert p.timeout_happened
    assert p.return_code != 0
    assert p.stdout == ""


@pytest.mark.timeout(10)
def test_timeout_out():
    p = EasyProcess(
        [python, "-c", "import time;print( 'start');time.sleep(15);print( 'end')"]
    ).call(timeout=1)
    assert p.is_alive() is False
    assert p.timeout_happened
    assert p.return_code != 0
    assert p.stdout == ""


@pytest.mark.timeout(3)
def test_time3():
    EasyProcess("sleep 15").start()


ignore_term = """
import signal;
import time;
signal.signal(signal.SIGTERM, lambda *args: None);
while True:
    time.sleep(0.5);
"""


# @pytest.mark.timeout(10)
# def test_force_timeout():
#     proc = EasyProcess([python, "-c", ignore_term]).start()
#     # Calling stop() right away actually stops python before it
#     # has a change to actually compile and run the input code,
#     # meaning the signal handlers aren't registered yet. Give it
#     # a moment to setup
#     time.sleep(1)
#     proc.stop(kill_after=1)
#     assert proc.is_alive() is False
#     assert proc.return_code != 0


@pytest.mark.timeout(30)
def test_kill():
    proc = EasyProcess([python, "-c", ignore_term]).start()
    # Calling stop() right away actually stops python before it
    # has a change to actually compile and run the input code,
    # meaning the signal handlers aren't registered yet. Give it
    # a moment to setup
    time.sleep(3)
    proc.stop()
    assert proc.is_alive() is False
    assert proc.return_code != 0


# @pytest.mark.timeout(10)
# def test_force_0_timeout():
#     proc = EasyProcess([python, "-c", ignore_term]).start()
#     time.sleep(1)
#     proc.stop(kill_after=0)
#     assert proc.is_alive() is False
#     assert proc.return_code != 0


@pytest.mark.timeout(10)
def test_force_timeout2():
    proc = EasyProcess([python, "-c", ignore_term]).call(timeout=1)
    assert proc.is_alive() is False
    assert proc.return_code != 0


# @pytest.mark.timeout(10)
# def test_stop_wait():
#     proc = EasyProcess([python, "-c", ignore_term]).start()
#     time.sleep(1)
#     proc.sendstop().wait(timeout=1)
#     # On windows, Popen.terminate actually behaves like kill,
#     # so don't check that our hanging process code is actually hanging.
#     # The end result is still what we want. On other platforms, leave
#     # this assertion to make sure we are correctly testing the ability
#     # to stop a hung process
#     if not sys.platform.startswith("win"):
#         assert proc.is_alive() is True
#     proc.stop(kill_after=1)
#     assert proc.is_alive() is False
#     assert proc.return_code != 0


@pytest.mark.timeout(30)
def test_stop_wait():
    proc = EasyProcess([python, "-c", ignore_term]).start()
    time.sleep(3)
    proc.sendstop().wait(timeout=3)
    assert proc.is_alive() is False
    assert proc.return_code != 0