#!/usr/bin/env php
<?php

declare(strict_types=1);

function info(string $info): void
{
    echo "\033[7m" . $info . "\033[0m";
}

try {
    $host = null;
    $port = null;
    $file = null;
    $secure = false;

    // Read options and parameters
    for ($i = 1; $i < $argc; $i++) {
        $arg = $argv[$i];

        switch ($argv[$i]) {
            case '--host':
            case '-h':
                $host = $argv[++$i] ?? null;
                if (null === $host) {
                    throw new Exception("no host provided");
                }
                if (gethostbyname($host) === $host && !inet_pton($host)) {
                    throw new Exception("host not found");
                }
                break;

            case '--port':
            case '-p':
                $port = $argv[++$i] ?? null;
                if (null === $host) {
                    throw new Exception("no port provided");
                }
                if (!ctype_digit($port)) {
                    throw new Exception("port not numeric");
                }
                $port = (int)$port;
                break;

            case '--secure':
            case '-s':
                $secure = true;
                break;

            default:
                if (preg_match('/^-/', $arg)) {
                    throw new Exception("unknown option '{$arg}'");
                }
                if (null !== $file) {
                    throw new Exception("unknown parameter '{$arg}'");
                }
                if (!file_exists($arg)) {
                    throw new Exception("file '$arg' not found");
                }
                if (!is_readable($arg)) {
                    throw new Exception("file '$arg' not readable");
                }
                if (!is_file($arg)) {
                    throw new Exception("file '$arg' is not a regular file");
                }
                $file = $arg;
        }
    }

    if (!isset($host, $port, $file)) {
        throw new Exception("missing parameters");
    }

    // Disable SSL certificates checks
    $context = stream_context_create([
        'ssl' => [
            'verify_peer' => false,
            'verify_peer_name' => false
        ]
    ]);

    // Connect to server
    $sock = @stream_socket_client('tcp://' . $host . ':' . $port, $error_code, $error_message, 0.5, STREAM_CLIENT_CONNECT, $context);
    if ($secure && !@stream_socket_enable_crypto($sock, true, STREAM_CRYPTO_METHOD_TLS_CLIENT)) {
        throw new Exception('Unable to turn encryption on');
    }

    if ($sock === false) {
        throw new Exception($error_message, $error_code);
    }
    @socket_set_blocking($sock, false);

    // Read request from file
    $request = '';
    info("REQUEST:\n");
    foreach (file($file) as $i => $data) {
        $CRLFLine = str_replace("\n", "\r\n", str_replace("\r", "", $data));
        info(++$i . ': ');
        echo $data;
        $request .= $CRLFLine;
    }

    // Send request
    if (@fwrite($sock, $request) !== strlen($request)) {
        throw new Exception('request not sent');
    }

    @fflush($sock);

    info("\n--------------------------------------------------------------------------------\n");
    info("RESPONSE:\n");

    // Non-blocking reading loop
    $connected = true;
    do {
        $read = [$sock];
        $write = null;
        $except = null;
        $modified = @stream_select($read, $write, $except, 1);

        if ($modified === false) {
            $connected = false;
            info("connection error\n");
        }
        if (stream_get_meta_data($sock)['eof'] ?? true) {
            $connected = false;
        }
        if ($modified === 1) {
            $data = @fread($sock, 1024);
            if ($data !== false) {
                echo $data;
            } else {
                $connected = false;
            }
        } else {
            info("waiting...\n");
        }
    } while ($connected);

    // Close connection
    @fclose($sock);
    info("connection closed\n");
} catch (Exception $exception) {
    fprintf(STDERR, "USAGE:\n" . basename($argv[0]) . " --host|-h host --port|-p port [--secure|-s] file\n");
    fprintf(STDERR, "\033[31mERROR: {$exception->getMessage()}\033[0m\n");
}