Merge pull request #18 from mekras/stream_factories

Add StreamFactory and Discovery

Author: sagikazarmark

spec/StreamFactory/DiactorosStreamFactorySpec.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace spec\Http\Discovery\StreamFactory;
+
+use PhpSpec\Exception\Example\SkippingException;
+use PhpSpec\ObjectBehavior;
+use Zend\Diactoros\Stream;
+
+class DiactorosStreamFactorySpec extends ObjectBehavior
+{
+    function let()
+    {
+        if (!class_exists('Zend\Diactoros\Stream')) {
+            throw new SkippingException('Diactoros is not available');
+        }
+    }
+
+    function it_is_initializable()
+    {
+        $this->shouldHaveType('Http\Discovery\StreamFactory\DiactorosStreamFactory');
+    }
+
+    function it_is_a_stream_factory()
+    {
+        $this->shouldImplement('Http\Message\StreamFactory');
+    }
+
+    function it_creates_a_stream_from_string()
+    {
+        $this->createStream('foo')->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    function it_creates_a_stream_from_resource()
+    {
+        $this->createStream(fopen('php://memory', 'rw'))
+            ->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    function it_creates_a_stream_from_stream()
+    {
+        $this->createStream(new Stream('php://memory'))
+            ->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    function it_creates_a_stream_from_null()
+    {
+        $this->createStream(null)->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+}

spec/StreamFactory/GuzzleStreamFactorySpec.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace spec\Http\Discovery\StreamFactory;
+
+use GuzzleHttp\Psr7\Stream;
+use PhpSpec\Exception\Example\SkippingException;
+use PhpSpec\ObjectBehavior;
+
+class GuzzleStreamFactorySpec extends ObjectBehavior
+{
+    public function let()
+    {
+        if (!class_exists('GuzzleHttp\Psr7\Stream')) {
+            throw new SkippingException('GuzzleHttp is not available');
+        }
+    }
+
+    public function it_is_initializable()
+    {
+        $this->shouldHaveType('Http\Discovery\StreamFactory\GuzzleStreamFactory');
+    }
+
+    public function it_is_a_stream_factory()
+    {
+        $this->shouldImplement('Http\Message\StreamFactory');
+    }
+
+    public function it_creates_a_stream_from_string()
+    {
+        $this->createStream('foo')->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    public function it_creates_a_stream_from_resource()
+    {
+        $this->createStream(fopen('php://memory', 'rw'))
+            ->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    public function it_creates_a_stream_from_stream()
+    {
+        $this->createStream(new Stream(fopen('php://memory', 'rw')))
+            ->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+
+    public function it_creates_a_stream_from_null()
+    {
+        $this->createStream(null)->shouldHaveType('Psr\Http\Message\StreamInterface');
+    }
+}

spec/StreamFactoryDiscoverySpec.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace spec\Http\Discovery;
+
+use PhpSpec\ObjectBehavior;
+
+class StreamFactoryDiscoverySpec extends ObjectBehavior
+{
+    function it_is_initializable()
+    {
+        $this->shouldHaveType('Http\Discovery\StreamFactoryDiscovery');
+    }
+
+    function it_is_a_class_discovery()
+    {
+        $this->shouldHaveType('Http\Discovery\ClassDiscovery');
+    }
+
+    function it_finds_an_http_stream_factory()
+    {
+        $this->find()->shouldHaveType('Http\Message\StreamFactory');
+    }
+}

src/StreamFactory/DiactorosStreamFactory.php

@@ -0,0 +1,55 @@
+<?php
+
+/*
+ * This file is part of the Http Discovery package.
+ *
+ * (c) PHP HTTP Team <[email protected]>
+ *
+ * For the full copyright and license information, please read the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Http\Discovery\StreamFactory;
+
+use Http\Message\StreamFactory;
+use Psr\Http\Message\StreamInterface;
+use Zend\Diactoros\Request;
+use Zend\Diactoros\Response;
+use Zend\Diactoros\Stream;
+
+/**
+ * @author Михаил Красильников <[email protected]>
+ */
+class DiactorosStreamFactory implements StreamFactory
+{
+    /**
+     * Creates a stream
+     *
+     * @param string|resource|StreamInterface|null $body
+     *
+     * @return StreamInterface
+     *
+     * @throws \InvalidArgumentException If the stream body is invalid
+     * @throws \RuntimeException If cannot write into stream
+     */
+    public function createStream($body = null)
+    {
+        if (!$body instanceof StreamInterface) {
+            if (is_resource($body)) {
+                $body = new Stream($body);
+            } else {
+                $stream = new Stream('php://memory', 'rw');
+
+                if (null !== $body) {
+                    $stream->write((string) $body);
+                }
+
+                $body = $stream;
+            }
+        }
+
+        $body->rewind();
+
+        return $body;
+    }
+}

src/StreamFactory/GuzzleStreamFactory.php

@@ -0,0 +1,35 @@
+<?php
+
+/*
+ * This file is part of the Http Discovery package.
+ *
+ * (c) PHP HTTP Team <[email protected]>
+ *
+ * For the full copyright and license information, please read the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Http\Discovery\StreamFactory;
+
+use Http\Message\StreamFactory;
+use Psr\Http\Message\StreamInterface;
+
+/**
+ * @author Михаил Красильников <[email protected]>
+ */
+class GuzzleStreamFactory implements StreamFactory
+{
+    /**
+     * Creates a stream
+     *
+     * @param string|resource|StreamInterface|null $body
+     *
+     * @return StreamInterface
+     *
+     * @throws \InvalidArgumentException if the $body arg is not valid.
+     */
+    public function createStream($body = null)
+    {
+        return \GuzzleHttp\Psr7\stream_for($body);
+    }
+}

src/StreamFactoryDiscovery.php

@@ -0,0 +1,54 @@
+<?php
+
+/*
+ * This file is part of the Http Discovery package.
+ *
+ * (c) PHP HTTP Team <[email protected]>
+ *
+ * For the full copyright and license information, please read the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Http\Discovery;
+
+use Http\Message\StreamFactory;
+
+/**
+ * Finds a Stream Factory
+ *
+ * @author Михаил Красильников <[email protected]>
+ */
+class StreamFactoryDiscovery extends ClassDiscovery
+{
+    /**
+     * @var StreamFactory
+     */
+    protected static $cache;
+
+    /**
+     * @var array
+     */
+    protected static $classes = [
+        'guzzle' => [
+            'class'     => 'Http\Discovery\StreamFactory\GuzzleStreamFactory',
+            'condition' => 'GuzzleHttp\Psr7\Stream',
+        ],
+        'diactoros' => [
+            'class'     => 'Http\Discovery\StreamFactory\DiactorosStreamFactory',
+            'condition' => 'Zend\Diactoros\Stream',
+        ],
+    ];
+
+    /**
+     * Finds a Stream Factory
+     *
+     * @return StreamFactory
+     *
+     * @throws NotFoundException
+     */
+    public static function find()
+    {
+        // Override only used for return type declaration
+        return parent::find();
+    }
+}