Fix stream wrapper (tweaked #193)

src/VCR/LibraryHooks/StreamWrapperHook.php

@@ -7,11 +7,12 @@
 use VCR\Util\Assertion;
 use VCR\Util\HttpUtil;
 use VCR\Util\StreamHelper;
+use ArrayAccess;
 
 /**
  * Library hook for streamWrapper functions using stream_wrapper_register().
  */
-class StreamWrapperHook implements LibraryHook
+class StreamWrapperHook implements LibraryHook, ArrayAccess
 {
     /**
      * @var \Closure Callback which will be executed when a request is intercepted.
@@ -154,6 +155,18 @@ public function stream_eof()
         return $this->position >= strlen($this->response->getBody());
     }
 
+    /**
+     * This method is called to set options on the stream.
+     *
+     * @link http://php.net/manual/en/streamwrapper.stream-set-option.php
+     * @return boolean Returns TRUE on success or FALSE on failure.
+     *                 If option is not implemented, FALSE should be returned.
+     */
+    public function stream_set_option($option, $arg1, $arg2)
+    {
+        return true;
+    }
+
     /**
      * Retrieve information about a file resource.
      *
@@ -231,4 +244,76 @@ public function stream_metadata($path, $option, $var)
     {
         return false;
     }
+
+    /**
+     * Emulate accessing headers inside the wrapper data.
+     *
+     * This allows libraries that consume the stream API to access headers.
+     *
+     * @link http://php.net/manual/en/context.http.php
+     * @param string $key The key to read. Only 'headers' is implemented.
+     *
+     * @return array|bool Either an array of headers or false
+     */
+    public function offsetGet($key)
+    {
+        if ($key === 'headers') {
+            $httpHeader = sprintf(
+                'HTTP/%s %s %s',
+                $this->response->getHttpVersion(),
+                $this->response->getStatusCode(),
+                $this->response->getStatusMessage()
+            );
+            $headers = array($httpHeader);
+            foreach ($this->response->getHeaders() as $header => $value) {
+                $headers[] = "{$header}: {$value}";
+            }
+            return $headers;
+        }
+        return false;
+    }
+
+    /**
+     * Part of the ArrayAccess Interface.
+     *
+     * Not implemented
+     *
+     * @param string $key The key to set.
+     * @param mixed $value The value to set
+     *
+     * @return bool Always false
+     */
+    public function offsetSet($key, $value)
+    {
+        return false;
+    }
+
+    /**
+     * Check if a metadata key exists.
+     *
+     * @param string $key The key to check.
+     *
+     * @return bool True if the key exists, false otherwise
+     */
+    public function offsetExists($key)
+    {
+        if ($key === 'headers') {
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * Part of the ArrayAccess Interface.
+     *
+     * Not implemented
+     *
+     * @param string $key The key to unset
+     *
+     * @return bool Always false
+     */
+    public function offsetUnset($key)
+    {
+        return false;
+    }
 }

src/VCR/Util/Assertion.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace VCR\Util;
 
 use Assert\Assertion as BaseAssertion;

src/VCR/Util/HttpClient.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace VCR\Util;
 
 use VCR\Request;

tests/VCR/LibraryHooks/StreamWrapperHookTest.php

@@ -51,4 +51,24 @@ public function testSeek()
         // invalid whence
         $this->assertFalse($hook->stream_seek(0, -1));
     }
+
+    public function testReadHeaders()
+    {
+        $hook = new StreamWrapperHook();
+        $hook->enable(function ($request) {
+            return new Response(
+                array('code' => 200, 'http_version' => '1.1', 'message' => 'OK'),
+                array('Content-Type' => 'text/plain'),
+                'A Test'
+            );
+        });
+        $hook->stream_open('http://example.com', 'r', 0, $openedPath);
+
+        $this->assertArrayHasKey('headers', $hook);
+        $expected = array(
+            'HTTP/1.1 200 OK',
+            'Content-Type: text/plain'
+        );
+        $this->assertEquals($expected, $hook['headers']);
+    }
 }

tests/VCR/Util/StreamHelperTest.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace VCR\Util;
 
 use VCR\Request;

tests/integration/soap/src/VCR/Example/ExampleSoapClient.php

@@ -1,4 +1,5 @@
 <?php
+
 namespace VCR\Example;
 
 /**