<?php

declare(strict_types=1);

namespace Psl\Example\TCP;

use Psl\Async;
use Psl\IO;
use Psl\Str;
use Psl\TCP;

require __DIR__ . '/../../vendor/autoload.php';

Async\main(static function (): int {
    Async\concurrently([
        'server' => static function (): void {
            $server = TCP\Server::create('localhost', 91337);

            IO\write_error_line('< server is listening.');

            $connection = $server->nextConnection();

            IO\write_error_line('< connection received.');
            IO\write_error_line('< awaiting request.');

            $request = $connection->read();

            IO\write_error_line('< received request: "%s".', $request);
            IO\write_error_line('< sending response.');

            $connection->writeAll(Str\reverse($request));
            $connection->close();

            IO\write_error_line('< connection closed.');

            $server->close();

            IO\write_error_line('< server stopped.');
        },
        'client' => static function (): void {
            $client = TCP\connect('localhost', 91337);

            IO\write_error_line('> client connected');
            IO\write_error_line('> sending request');

            $client->writeAll('Hello, World!');

            IO\write_error_line('> awaiting response');

            $response = $client->readAll();

            IO\write_error_line('> received response: "%s".', $response);

            $client->close();

            IO\write_error_line('> client disconnected');
        },
    ]);

    return 0;
});