vendor/friendsofsymfony/elastica-bundle/src/Logger/ElasticaLogger.php line 25

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the FOSElasticaBundle package.
  5.  *
  6.  * (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace FOS\ElasticaBundle\Logger;
  14. use Psr\Log\AbstractLogger;
  15. use Psr\Log\LoggerInterface;
  17. /**
  18.  * Logger for the Elastica.
  19.  *
  20.  * The {@link logQuery()} method is configured as the logger callable in the
  21.  * service container.
  22.  *
  23.  * @author Gordon Franke <info@nevalon.de>
  24.  */
  25. class ElasticaLogger extends AbstractLogger
  26. {
  27.     protected ?LoggerInterface $logger;
  28.     protected array $queries = [];
  29.     protected bool $debug;
  31.     public function __construct(?LoggerInterface $logger = null, bool $debug = false)
  32.     {
  33.         $this->logger = $logger;
  34.         $this->debug = $debug;
  35.     }
  37.     /**
  38.      * Logs a query.
  39.      *
  40.      * @param string       $path       Path to call
  41.      * @param string       $method     Rest method to use (GET, POST, DELETE, PUT)
  42.      * @param array|string $data       Arguments
  43.      * @param float        $queryTime  Execution time (in seconds)
  44.      * @param array        $connection Host, port, transport, and headers of the query
  45.      * @param array        $query      Arguments
  46.      * @param int          $engineTime
  47.      */
  48.     public function logQuery(string $path, string $method, $data, $queryTime, $connection = [], $query = [], $engineTime = 0, int $itemCount = 0)
  49.     {
  50.         $executionMS = $queryTime * 1000;
  52.         if ($this->debug) {
  53.             $e = new \Exception();
  54.             if (\is_string($data)) {
  55.                 $jsonStrings = \explode("\n", $data);
  56.                 $data = [];
  57.                 foreach ($jsonStrings as $json) {
  58.                     if ('' != $json) {
  59.                         $data[] = \json_decode($json, true);
  60.                     }
  61.                 }
  62.             } else {
  63.                 $data = [$data];
  64.             }
  66.             $this->queries[] = [
  67.                 'path' => $path,
  68.                 'method' => $method,
  69.                 'data' => $data,
  70.                 'executionMS' => $executionMS,
  71.                 'engineMS' => $engineTime,
  72.                 'connection' => $connection,
  73.                 'queryString' => $query,
  74.                 'itemCount' => $itemCount,
  75.                 'backtrace' => $e->getTraceAsString(),
  76.             ];
  77.         }
  79.         if (null !== $this->logger) {
  80.             $message = \sprintf('%s (%s) %0.2f ms', $path, $method, $executionMS);
  81.             $this->logger->info($message, (array) $data);
  82.         }
  83.     }
  85.     /**
  86.      * Returns the number of queries that have been logged.
  87.      */
  88.     public function getNbQueries(): int
  89.     {
  90.         return \count($this->queries);
  91.     }
  93.     /**
  94.      * Returns a human-readable array of queries logged.
  95.      */
  96.     public function getQueries(): array
  97.     {
  98.         return $this->queries;
  99.     }
  101.     /**
  102.      * {@inheritdoc}
  103.      */
  104.     public function log($level, $message, array $context = []): void
  105.     {
  106.         $this->logger->log($level, $message, $context);
  107.     }
  109.     public function reset(): void
  110.     {
  111.         $this->queries = [];
  112.     }
  113. }