[WIP] Parser: urlencoded

src/StreamingBodyParser/FormUrlencodedParser.php

@@ -0,0 +1,57 @@
+<?php
+
+namespace React\Http\StreamingBodyParser;
+
+use Evenement\EventEmitterTrait;
+use React\Http\Request;
+use React\Promise\CancellablePromiseInterface;
+
+class FormUrlencodedParser implements ParserInterface
+{
+    use EventEmitterTrait;
+
+    /**
+     * @var CancellablePromiseInterface
+     */
+    private $promise;
+
+    /**
+     * @param Request $request
+     * @return ParserInterface
+     */
+    public static function create(Request $request)
+    {
+        return new static($request);
+    }
+
+    /**
+     * @param Request $request
+     */
+    private function __construct(Request $request)
+    {
+        $headers = $request->getHeaders();
+        $headers = array_change_key_case($headers, CASE_LOWER);
+
+        $this->promise = ContentLengthBufferedSink::createPromise(
+            $request,
+            $headers['content-length']
+        )->then([$this, 'finish']);
+    }
+
+    /**
+     * @param string $buffer
+     */
+    public function finish($buffer)
+    {
+        parse_str(trim($buffer), $result);
+        foreach ($result as $key => $value) {
+            $this->emit('post', [$key, $value]);
+        }
+        $this->emit('end');
+    }
+
+    public function cancel()
+    {
+        $this->promise->cancel();
+    }
+}

tests/StreamingBodyParser/FormUrlencodedParserTest.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace React\Tests\Http\StreamingBodyParser;
+
+use React\Http\StreamingBodyParser\FormUrlencodedParser;
+use React\Http\Request;
+use React\Tests\Http\TestCase;
+
+class FormUrlencodedParserTest extends TestCase
+{
+    public function testParse()
+    {
+        $post = [];
+        $request = new Request('POST', 'http://example.com/', [], '1.1', [
+            'Content-Length' => 79,
+        ]);
+        $parser = new FormUrlencodedParser($request);
+        $parser->on('post', function ($key, $value) use (&$post) {
+            $post[] = [$key, $value];
+        });
+        $request->emit('data', ['user=single&user2=second&us']);
+        $request->emit('data', ['ers%5B%5D=first+in+array&users%5B%5D=second+in+array']);
+        $this->assertEquals(
+            [
+                ['user', 'single'],
+                ['user2', 'second'],
+                ['users', ['first in array', 'second in array']],
+            ],
+            $post
+        );
+    }
+}