fix predis logging using symfony cache component

snc · Apr 11, 2018 · cfa9503 · cfa9503
1 parent e43b593
commit cfa9503
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/Client/Predis/Connection/ConnectionWrapper.php b/Client/Predis/Connection/ConnectionWrapper.php
@@ -95,7 +95,16 @@ public function isConnected()
      */
     public function writeRequest(CommandInterface $command)
     {
-        return $this->connection->writeRequest($command);
+        if (null === $this->logger) {
+            $this->connection->writeRequest($command);
+            return;
+        }
+
+        $startTime = microtime(true);
+        $this->connection->writeRequest($command);
+        $duration = (microtime(true) - $startTime) * 1000;
+
+        $this->logger->logCommand($this->commandToString($command), $duration, $this->getParameters()->alias);
     }
 
     /**