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

use React\MySQL\Factory;
use React\MySQL\QueryResult;

use Clue\React\Block;

$loop = React\EventLoop\Factory::create();
$factory = new Factory($loop);

$loop->addPeriodicTimer(3.0, function() use ($loop, $factory) {

    echo "trying to run a query...\n";

    $uri = DB_USER . ':' . rawurlencode(DB_PASS) . "@" . DB_HOST . "/" . DB_NAME;
    $connection = $factory->createLazyConnection($uri);

    $promise = $connection->query('SELECT * FROM table ORDER BY ts desc limit 1');

    try {

        $ret = Block\await($promise, $loop);
        echo "done with " . count($ret->resultRows) . " rows\n";
        $connection->quit();

    } catch (Exception $e) {
        // promise rejected with $exception
        echo 'ERROR: ' . $e->getMessage();
    }

});

$loop->run();