"""Examples using create_subprocess_exec() and create_subprocess_shell()."""

import trollius as asyncio
from trollius import From
import signal
from trollius.subprocess import PIPE
from trollius.py33_exceptions import ProcessLookupError

@asyncio.coroutine
def cat(loop):
    proc = yield From(asyncio.create_subprocess_shell("cat",
                                                      stdin=PIPE,
                                                      stdout=PIPE))
    print("pid: %s" % proc.pid)

    message = "Hello World!"
    print("cat write: %r" % message)

    stdout, stderr = yield From(proc.communicate(message.encode('ascii')))
    print("cat read: %r" % stdout.decode('ascii'))

    exitcode = yield From(proc.wait())
    print("(exit code %s)" % exitcode)

@asyncio.coroutine
def ls(loop):
    proc = yield From(asyncio.create_subprocess_exec("ls",
                                                     stdout=PIPE))
    while True:
        line = yield From(proc.stdout.readline())
        if not line:
            break
        print("ls>>", line.decode('ascii').rstrip())
    try:
        proc.send_signal(signal.SIGINT)
    except ProcessLookupError:
        pass

@asyncio.coroutine
def test_call(*args, **kw):
    timeout = kw.pop('timeout', None)
    try:
        proc = yield From(asyncio.create_subprocess_exec(*args))
        exitcode = yield From(asyncio.wait_for(proc.wait(), timeout))
        print("%s: exit code %s" % (' '.join(args), exitcode))
    except asyncio.TimeoutError:
        print("timeout! (%.1f sec)" % timeout)

loop = asyncio.get_event_loop()
loop.run_until_complete(cat(loop))
loop.run_until_complete(ls(loop))
loop.run_until_complete(test_call("bash", "-c", "sleep 3", timeout=1.0))
loop.close()