<?php

namespace Amp\ByteStream\Test;

use Amp\ByteStream\ResourceInputStream;
use Amp\PHPUnit\AsyncTestCase;

class ResourceInputStreamTest extends AsyncTestCase
{
    public function testGetResource(): void
    {
        $stream = new ResourceInputStream(\STDIN);

        self::assertSame(\STDIN, $stream->getResource());
    }

    public function testNonStream(): void
    {
        $this->expectException(\Error::class);
        $this->expectExceptionMessage("Expected a valid stream");

        new ResourceInputStream(42);
    }

    public function testNotReadable(): void
    {
        $this->expectException(\Error::class);
        $this->expectExceptionMessage("Expected a readable stream");

        new ResourceInputStream(\STDOUT);
    }

    public function testClosedRemoteSocketWithFork(): ?\Generator
    {
        $server = \stream_socket_server("tcp://127.0.0.1:0");
        $address = \stream_socket_get_name($server, false);

        $a = \stream_socket_client("tcp://" . $address);
        $b = \stream_socket_accept($server);

        // Creates a fork without having to deal with it…
        // The fork inherits the FDs of the current process.
        $proc = \proc_open("sleep 3", [
            ['pipe', 'r'],
            ['pipe', 'w'],
            ['pipe', 'w'],
        ], $pipes);

        $stream = new ResourceInputStream($a);
        \stream_socket_shutdown($b, \STREAM_SHUT_RDWR);
        \fclose($b);

        try {
            // Read must succeed before the sub-process exits
            $start = \microtime(true);
            self::assertNull(yield $stream->read());
            self::assertLessThanOrEqual(1, \microtime(true) - $start);
        } finally {
            \proc_terminate($proc);
            \proc_close($proc);
        }
    }
}