symplely/coroutine

<?php

/**
 * This also an simpler version of
 * "HOWTO: PHP TCP Server/Client with SSL Encryption using Streams"
 *
 * @see http://blog.leenix.co.uk/2011/05/howto-php-tcp-serverclient-with-ssl.html
 */
include 'vendor/autoload.php';

use function Async\Path\{file_open, file_contents, file_close};
use function Async\socket\{
    messenger_for,
    net_accept,
    net_read,
    net_write,
    net_close,
    net_peer,
    net_server,
    net_response
};

\error_reporting(-1);
\ini_set("display_errors", 1);
echo "CO-ROUTINE EXAMPLE. WEBSERVER" . EOL;

\chdir(__DIR__);

echo "LIBS LOADED" . EOL;

function server($port)
{
    global $i;
    echo "SERVER LISTENING ON: $port" . EOL . EOL;;

    //$socket = \net_server($port, true);
    $socket = yield net_server($port);
    $i = 1;
    while (true) {
        $connectedSocket = yield net_accept($socket);
        yield \away('handleClient', $connectedSocket);
    }
}

function loadFile($template, $vars, $fd)
{
    yield file_close($fd);

    \extract($vars, \EXTR_OVERWRITE);
    $output = '';

    \ob_start();
    require $template;
    $output = \ob_get_contents();
    \ob_end_clean();

    return $output;
}


function handleClient($socket)
{
    global $i;
    $data = yield net_read($socket);

    $ip = net_peer($socket);
    print "New connection from " . $ip . "\n";

    $output = "Received following request:\n\n$data";

    switch ($data) {
            #exit command will cause this script to quit out
        case 'exit';
            print "exit command received \n";
            exit(0);
            #hi command
        case 'hi';
            #write back to the client a response.
            yield net_write($socket, "Hello {$ip}. This is our $i command run!");
            $i++;
            print "hi command received \n";
            break;
        default:
            $input = \explode(" ", $data);
            if (empty($input[1])) {
                $input[1] = "index.html";
            }
            $input = $input[1];
            $fileinfo = \pathinfo($input);
            $mime = "text/html";

            if (!empty($fileinfo['extension'])) {
                switch ($fileinfo['extension']) {
                    case "png";
                        $mime = "image/png";
                        break;
                    case "jpg";
                        $mime = "image/jpeg";
                        break;
                    case "ico";
                        $mime = "image/x-icon";
                        break;
                    default:
                        $mime = "text/html";
                }
            }

            if ($input == "/") {
                $input = "/index.html";
            }

            if ($input == "/test") {
                $input = "/test.php";
            }

            $input = '.' . $input;

            $responser = messenger_for(\RESPONSE);
            $fd = yield file_open($input);
            if (\is_resource($fd)) {
                print "Serving $input\n";

                if (\strstr($input, '.php')) {
                    $contents = yield \loadFile($input, [], $fd);
                } else {
                    $contents = yield file_contents($fd);
                    yield file_close($fd);
                }

                $output = net_response($responser, $contents, 200, $mime);
            } else {
                $output = net_response($responser, "The file you requested does not exist. Sorry!", 404);
            }

            yield net_write($socket, $output);
    }

    yield net_close($socket);
}

\coroutine_run(\server(5000));