fixed large content receiving bugs

Author: mkusher

bin/behat

@@ -0,0 +1 @@
+../vendor/behat/behat/bin/behat

bin/indexer.php

@@ -10,7 +10,7 @@
 /** @var $command \Command\CommandInterface */
 
 $arguments = [];
-$router = new Router;
+$router = new \Router;
 
 $command = $router->getCommand($argv[1]);
 

bin/peridot

@@ -0,0 +1 @@
+../vendor/peridot-php/peridot/bin/peridot

bin/server.php

@@ -0,0 +1,37 @@
+#!/usr/bin/env php
+<?php
+
+require "app/config/bin.php";
+require "vendor/autoload.php";
+$app = new App;
+$handler = function ($request, $response) use ($app){
+    $start = microtime(1);
+    printf("%s %s\n", $request->getMethod(), $request->getPath());
+    $headers = $request->getHeaders();
+    $body = new \stdClass;
+    $body->data = "";
+    $body->receivedLength = 0;
+    $body->dataLength = $headers['Content-Length'];
+    $request->on("data", function($data) use (
+        $request, $response, $app, $body, $start
+    ){
+        $body->data .= $data;
+        $body->receivedLength += strlen($data);
+        if($body->receivedLength >= $body->dataLength){
+            $response->end($app->handle($request, $response, $body->data));
+            printf("Response time: %s\n", microtime(1) - $start);
+        }
+    });
+};
+
+$loop = React\EventLoop\Factory::create();
+$socket = new React\Socket\Server($loop);
+$http = new React\Http\Server($socket);
+
+$http->on('request', $handler);
+
+$socket->listen($port);
+
+echo "Started http server on {$port}\n";
+
+$loop->run();

bin/start.php

@@ -16,5 +16,10 @@
         "mnapoli/php-di": "~4.4",
         "sami/sami": "~3.0",
         "react/react": "0.4.*"
+    },
+    "require-dev": {
+        "behat/behat": "~3.0",
+        "peridot-php/peridot": "~1.15",
+        "peridot-php/leo": "~1.4"
     }
 }