React Chatroulette

composer.json

{
    "require": {
        "react/socket": "0.2.*"
    }
}

server.php

<?php

// nc localhost 4000

require 'vendor/autoload.php';

function getConnectionId($conn)
{
    // ugh!
    static $i = 0;

    if (!isset($conn->id)) {
        $conn->id = $i++;
    }

    return $conn->id;
}

$loop = React\EventLoop\Factory::create();
$socket = new React\Socket\Server($loop);

$waiting = null;

$socket->on('connection', function ($conn) use (&$waiting) {
    printf("New connection %s\n", getConnectionId($conn));
    $conn->write(sprintf("Hello %s!\n", getConnectionId($conn)));

    if (null === $waiting || !$waiting->isReadable()) {
        $waiting = $conn;
        $conn->write("Please wait until a partner connects.\n");
        return;
    }

    printf("Pairing up connection %s with waiting connection %s.\n",
        getConnectionId($conn), getConnectionId($waiting));

    $message = "You are now talking to %s.\n";
    $conn->write(sprintf($message, getConnectionId($waiting)));
    $waiting->write(sprintf($message, getConnectionId($conn)));

    $conn->pipe($waiting)->pipe($conn);

    $waiting = null;
});

$socket->listen(4000);
$loop->run();