Pass through logger from client

Author: brawlins

src/Client.php

@@ -578,7 +578,7 @@ public function request(string $path, string $method = Request::GET, $data = [],
         }
 
         try {
-            $response = $this->_lastResponse = $request->send();
+            $response = $this->_lastResponse = $request->send($this->_logger);
         } catch (ConnectionException $e) {
             $this->_connectionPool->onFail($connection, $e, $this);
             $this->_logger->error(sprintf('Elastica Request Failure %s', $requestName), [

src/Connection.php

@@ -4,6 +4,8 @@
 
 use Elastica\Exception\InvalidException;
 use Elastica\Transport\AbstractTransport;
+use Psr\Log\LoggerInterface;
+use Psr\Log\NullLogger;
 
 /**
  * Elastica connection instance to an elasticasearch node.
@@ -248,11 +250,11 @@ public function isEnabled()
      *
      * @return AbstractTransport Transport object
      */
-    public function getTransportObject()
+    public function getTransportObject(LoggerInterface $logger)
     {
         $transport = $this->getTransport();
 
-        return AbstractTransport::create($transport, $this);
+        return AbstractTransport::create($transport, $this, [], $logger = new NullLogger());
     }
 
     /**

src/Request.php

@@ -5,6 +5,7 @@
 use Elastica\Exception\ConnectionException;
 use Elastica\Exception\InvalidException;
 use Elastica\Exception\ResponseException;
+use Psr\Log\LoggerInterface;
 
 /**
  * Elastica Request object.
@@ -175,9 +176,9 @@ public function getContentType(): string
      * @throws ResponseException
      * @throws ConnectionException
      */
-    public function send(): Response
+    public function send(LoggerInterface $logger): Response
     {
-        $transport = $this->getConnection()->getTransportObject();
+        $transport = $this->getConnection()->getTransportObject($logger);
 
         // Refactor: Not full toArray needed in exec?
         return $transport->exec($this, $this->getConnection()->toArray());

src/Transport/AbstractTransport.php

@@ -9,6 +9,7 @@
 use Elastica\Param;
 use Elastica\Request;
 use Elastica\Response;
+use Psr\Log\LoggerInterface;
 
 /**
  * Elastica Abstract Transport object.
@@ -22,14 +23,22 @@ abstract class AbstractTransport extends Param
      */
     protected $_connection;
 
+    /**
+     * @var LoggerInterface
+     */
+    protected $_logger;
+
     /**
      * Construct transport.
      */
-    public function __construct(?Connection $connection = null)
+    public function __construct(LoggerInterface $logger, ?Connection $connection = null)
     {
         if ($connection) {
             $this->setConnection($connection);
         }
+        if ($logger) {
+            $this->setLogger($logger);
+        }
     }
 
     public function getConnection(): Connection
@@ -47,6 +56,21 @@ public function setConnection(Connection $connection): AbstractTransport
         return $this;
     }
 
+    public function getLogger(): LoggerInterface
+    {
+        return $this->_logger;
+    }
+
+    /**
+     * @return $this
+     */
+    public function setLogger(LoggerInterface $logger): AbstractTransport
+    {
+        $this->_logger = $logger;
+
+        return $this;
+    }
+
     /**
      * Executes the transport request.
      *
@@ -93,7 +117,7 @@ public function sanityzeQueryStringBool(array $query)
      *
      * @throws InvalidException
      */
-    public static function create($transport, Connection $connection, array $params = []): AbstractTransport
+    public static function create($transport, Connection $connection, array $params = [], LoggerInterface $logger = null): AbstractTransport
     {
         if (\is_array($transport) && isset($transport['type'])) {
             $transportParams = $transport;
@@ -113,7 +137,11 @@ public static function create($transport, Connection $connection, array $params
             $classNames = ["Elastica\\Transport\\{$transport}", $transport];
             foreach ($classNames as $className) {
                 if (\class_exists($className)) {
-                    $transport = new $className();
+                    if ($transport === 'Http') {
+                        $transport = new $className($logger, $connection);
+                    } else {
+                        $transport = new $className();
+                    }
                     break;
                 }
             }