1 files changed, 104 insertions, 0 deletions
diff --git a/lib/SparkPost/SparkPostResponse.php b/lib/SparkPost/SparkPostResponse.php
new file mode 100644
index 0000000..161b864
--- /dev/null
+++ b/lib/SparkPost/SparkPostResponse.php
@@ -0,0 +1,104 @@
+<?php
+
+namespace SparkPost;
+
+use Psr\Http\Message\ResponseInterface as ResponseInterface;
+use Psr\Http\Message\StreamInterface as StreamInterface;
+
+class SparkPostResponse implements ResponseInterface {
+
+	private $response;
+
+	public function __construct(ResponseInterface $response) {
+		$this->response = $response;
+	}
+
+    public function getBody()
+    {
+        $body = $this->response->getBody();
+        $body_string = $body->__toString();
+        
+        if (is_string($body_string)) {
+            $json = json_decode($body_string, true);
+            
+            if (json_last_error() == JSON_ERROR_NONE) {
+                return $json;
+            }
+            else {
+                return $body;
+            }
+        }
+
+        return $body;
+    }
+
+    // pass these down to the response given in the constructor
+
+    public function getProtocolVersion()
+    {
+        return $this->response->getProtocolVersion();
+    }
+
+    public function withProtocolVersion($version)
+    {
+        return $this->response->withProtocolVersion($version);
+    }
+
+    public function getHeaders()
+    {
+        return $this->response->getHeaders();
+    }
+
+    public function hasHeader($name)
+    {
+        return $this->response->hasHeader($name);
+    }
+
+    public function getHeader($name)
+    {
+        return $this->response->getHeader($name);
+    }
+
+    public function getHeaderLine($name)
+    {
+        return $this->response->getHeaderLine($name);
+    }
+
+    public function withHeader($name, $value)
+    {
+        return $this->response->withHeader($name, $value);
+    }
+
+    public function withAddedHeader($name, $value)
+    {
+        return $this->response->withAddedHeader($name, $value);
+    }
+
+    public function withoutHeader($name)
+    {
+        return $this->response->withoutHeader($name);
+    }
+
+    public function withBody(StreamInterface $body)
+    {
+        return $this->response->withBody($body);
+    }
+
+	public function getStatusCode()
+    {
+        return $this->response->getStatusCode();
+    }
+
+    public function withStatus($code, $reasonPhrase = '')
+    {
+        return $this->response->withStatus($code, $reasonPhrase);
+    }
+    
+    public function getReasonPhrase()
+    {
+        $this->response->getReasonPhrase();
+    }
+
+}
+
+?>
+\ No newline at end of file