Streaming body parsers foundation

src/StreamingBodyParser/Factory.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace React\Http\StreamingBodyParser;
+
+use React\Http\Request;
+
+class Factory
+{
+    /**
+     * @param Request $request
+     * @return ParserInterface
+     */
+    public static function create(Request $request)
+    {
+        return new RawBodyParser($request);
+    }
+}

src/StreamingBodyParser/ParserInterface.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace React\Http\StreamingBodyParser;
+
+use Evenement\EventEmitterInterface;
+use React\Http\Request;
+
+interface ParserInterface extends EventEmitterInterface
+{
+    public function __construct(Request $request);
+}

src/StreamingBodyParser/RawBodyParser.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace React\Http\StreamingBodyParser;
+
+use Evenement\EventEmitterTrait;
+use React\Http\Request;
+
+class RawBodyParser implements ParserInterface
+{
+    use EventEmitterTrait;
+
+    /**
+     * @param Request $request
+     */
+    public function __construct(Request $request)
+    {
+        $headers = $request->getHeaders();
+        $headers = array_change_key_case($headers, CASE_LOWER);
+
+        ContentLengthBufferedSink::createPromise(
+            $request,
+            $headers['content-length']
+        )->then([$this, 'finish']);
+    }
+
+    /**
+     * @param string $buffer
+     */
+    public function finish($buffer)
+    {
+        $this->emit('body', [$buffer]);
+        $this->emit('end');
+    }
+}

tests/StreamingBodyParser/FactoryTest.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace React\Tests\Http\StreamingBodyParser;
+
+use React\Http\StreamingBodyParser\Factory;
+use React\Http\Request;
+use React\Tests\Http\TestCase;
+
+class FactoryTest extends TestCase
+{
+    public function testNoContentType()
+    {
+        $request = new Request('POST', 'http://example.com/', [], 1.1, [
+            'content-length' => 123,
+        ]);
+        $parser = Factory::create($request);
+        $this->assertInstanceOf('React\Http\StreamingBodyParser\RawBodyParser', $parser);
+    }
+}

tests/StreamingBodyParser/RawBodyParserTest.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace React\Tests\Http\StreamingBodyParser;
+
+use React\Http\StreamingBodyParser\RawBodyParser;
+use React\Http\Request;
+use React\Tests\Http\TestCase;
+
+class RawBodyParserTest extends TestCase
+{
+    public function testNoContentLength()
+    {
+        $body = '';
+        $request = new Request('POST', 'http://example.com/', [], 1.1, [
+            'content-length' => 3,
+        ]);
+        $parser = new RawBodyParser($request);
+        $parser->on('body', function ($rawBody) use (&$body) {
+            $body = $rawBody;
+        });
+        $request->emit('data', ['abc']);
+        $this->assertSame('abc', $body);
+    }
+}