Rewind to previous position after logging request & response body (#63)

8p · Sep 30, 2016 · eb8746b · eb8746b
1 parent c0b7404
commit eb8746b
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/Log/LogRequest.php b/Log/LogRequest.php
@@ -100,7 +100,15 @@ protected function save(RequestInterface $request) {
         $this->setHeaders($request->getHeaders());
         $this->setProtocolVersion($request->getProtocolVersion());
         $this->setMethod($request->getMethod());
+
+        if($request->getBody()->isSeekable()) {
+            $readPosition = $request->getBody()->tell();
+        }
         $this->setBody($request->getBody() ? $request->getBody()->__toString() : null);
+        if($request->getBody()->isSeekable()) {
+            $request->getBody()->seek($readPosition);
+        }
+
     } // end: save()
 
     /**

diff --git a/Log/LogResponse.php b/Log/LogResponse.php
@@ -67,7 +67,15 @@ public function save(ResponseInterface $response) {
 
         $this->setStatusCode($response->getStatusCode());
         $this->setStatusPhrase($response->getReasonPhrase());
+
+        if($response->getBody()->isSeekable()) {
+            $readPosition = $response->getBody()->tell();
+        }
         $this->setBody($response->getBody()->__toString());
+        if($response->getBody()->isSeekable()) {
+            $response->getBody()->seek($readPosition);
+        }
+
         $this->setHeaders($response->getHeaders());
         $this->setProtocolVersion($response->getProtocolVersion());
     } // end: save()