Streaming request body parsing

README.md

@@ -31,3 +31,25 @@ This is an HTTP server which responds with `Hello World` to every request.
     $socket->listen(1337);
     $loop->run();
 ```
+
+## StreamingBodyParser\Factory and StreamingBodyParser\BufferedSink Usage
+
+The `StreamingBodyParser\FormParserFactory` parses a request and determines which body parser to use (multipart, formurlencoded, raw body, or no body). Those body parsers emit events on `post` fields, `file` on files, and raw body emits `body` when it received the whole body. `StreamingBodyParser\BufferedSink` listens for those events and returns them through a promise when done.
+
+```php
+    $loop = React\EventLoop\Factory::create();
+    $socket = new React\Socket\Server($loop);
+
+    $http = new React\Http\Server($socket);
+    $http->on('request', function ($request, $response) {
+        $parser = React\Http\StreamingBodyParser\Factory::create($request);
+        React\Http\StreamingBodyParser\BufferedSink::createPromise($parser)->then(function ($result) use ($response) {
+            var_export($result);
+            $response->writeHead(200, array('Content-Type' => 'text/plain'));
+            $response->end("Hello World!\n");
+        });
+    });
+
+    $socket->listen(1337);
+    $loop->run();
+```

composer.json

@@ -8,11 +8,15 @@
         "guzzlehttp/psr7": "^1.0",
         "react/socket": "^0.4",
         "react/stream": "^0.4",
-        "evenement/evenement": "^2.0"
+        "evenement/evenement": "^2.0",
+        "react/promise": "^2.0 || ^1.1"
     },
     "autoload": {
         "psr-4": {
             "React\\Http\\": "src"
         }
+    },
+    "require-dev": {
+        "clue/block-react": "^1.1"
     }
 }

src/File.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace React\Http;
+
+use React\Stream\ReadableStreamInterface;
+
+class File implements FileInterface
+{
+    /**
+     * @var string
+     */
+    protected $filename;
+
+    /**
+     * @var string
+     */
+    protected $contentType;
+
+    /**
+     * @var ReadableStreamInterface
+     */
+    protected $stream;
+
+    /**
+     * @param string $filename
+     * @param string $contentType
+     * @param ReadableStreamInterface $stream
+     */
+    public function __construct($filename, $contentType, ReadableStreamInterface $stream)
+    {
+        $this->filename = $filename;
+        $this->contentType = $contentType;
+        $this->stream = $stream;
+    }
+
+    /**
+     * @return string
+     */
+    public function getFilename()
+    {
+        return $this->filename;
+    }
+
+    /**
+     * @return string
+     */
+    public function getContentType()
+    {
+        return $this->contentType;
+    }
+
+    /**
+     * @return ReadableStreamInterface
+     */
+    public function getStream()
+    {
+        return $this->stream;
+    }
+}

src/FileInterface.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace React\Http;
+
+use React\Stream\ReadableStreamInterface;
+
+interface FileInterface
+{
+    /**
+     * @return string
+     */
+    public function getFilename();
+
+    /**
+     * @return string
+     */
+    public function getContentType();
+
+    /**
+     * @return ReadableStreamInterface
+     */
+    public function getStream();
+}

src/Request.php

@@ -15,21 +15,17 @@ class Request extends EventEmitter implements ReadableStreamInterface
     private $query;
     private $httpVersion;
     private $headers;
-    private $body;
-    private $post = [];
-    private $files = [];
 
     // metadata, implicitly added externally
     public $remoteAddress;
 
-    public function __construct($method, $url, $query = array(), $httpVersion = '1.1', $headers = array(), $body = '')
+    public function __construct($method, $url, $query = array(), $httpVersion = '1.1', $headers = array())
     {
         $this->method = $method;
         $this->url = $url;
         $this->query = $query;
         $this->httpVersion = $httpVersion;
         $this->headers = $headers;
-        $this->body = $body;
     }
 
     public function getMethod()
@@ -62,36 +58,6 @@ public function getHeaders()
         return $this->headers;
     }
 
-    public function getBody()
-    {
-        return $this->body;
-    }
-
-    public function setBody($body)
-    {
-        $this->body = $body;
-    }
-
-    public function getFiles()
-    {
-        return $this->files;
-    }
-
-    public function setFiles($files)
-    {
-        $this->files = $files;
-    }
-
-    public function getPost()
-    {
-        return $this->post;
-    }
-
-    public function setPost($post)
-    {
-        $this->post = $post;
-    }
-
     public function getRemoteAddress()
     {
         return $this->remoteAddress;