Version 1

[yaffs-website] / vendor / alchemy / zippy / src / Resource / Reader / Guzzle / GuzzleReader.php

diff --git a/vendor/alchemy/zippy/src/Resource/Reader/Guzzle/GuzzleReader.php b/vendor/alchemy/zippy/src/Resource/Reader/Guzzle/GuzzleReader.php
new file mode 100644 (file)
index 0000000..46785cd
--- /dev/null
+++ b/vendor/alchemy/zippy/src/Resource/Reader/Guzzle/GuzzleReader.php
@@ -0,0 +1,59 @@
+<?php
+
+namespace Alchemy\Zippy\Resource\Reader\Guzzle;
+
+use Alchemy\Zippy\Resource\Resource as ZippyResource;
+use Alchemy\Zippy\Resource\ResourceReader;
+use GuzzleHttp\ClientInterface;
+
+class GuzzleReader implements ResourceReader
+{
+    /**
+     * @var ClientInterface
+     */
+    private $client;
+
+    /**
+     * @var \Alchemy\Zippy\Resource\Resource
+     */
+    private $resource;
+
+    /**
+     * @param ZippyResource   $resource
+     * @param ClientInterface $client
+     */
+    public function __construct(ZippyResource $resource, ClientInterface $client = null)
+    {
+        $this->resource = $resource;
+        $this->client = $client;
+    }
+
+    /**
+     * @return string
+     */
+    public function getContents()
+    {
+        return $this->buildRequest()->getBody()->getContents();
+    }
+
+    /**
+     * @return resource
+     */
+    public function getContentsAsStream()
+    {
+        $response = $this->buildRequest()->getBody()->getContents();
+        $stream = fopen('php://temp', 'r+');
+
+        if ($response != '') {
+            fwrite($stream, $response);
+            fseek($stream, 0);
+        }
+
+        return $stream;
+    }
+
+    private function buildRequest()
+    {
+        return $this->client->request('GET', $this->resource->getOriginal());
+    }
+}