vendor/novaway/elasticsearch-bundle/src/DataCollector/ElasticsearchDataCollector.php line 51

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  4. namespace Novaway\ElasticsearchBundle\DataCollector;
  6. use Novaway\ElasticsearchBundle\Event\SearchQuery;
  7. use Novaway\ElasticsearchBundle\Event\SearchResult;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpFoundation\Request;
  10. use Symfony\Component\HttpFoundation\Response;
  11. use Symfony\Component\HttpKernel\DataCollector\DataCollector;
  13. class ElasticsearchDataCollector  extends DataCollector implements EventSubscriberInterface
  14. {
  15.     const QUERIES_KEY = 'queries';
  16.     const RESULTS_KEY = 'results';
  18.     public function collect(Request $request, Response $response, \Throwable $exception = null)
  19.     {
  20.         // everything is collected via Events
  21.     }
  23.     public function getName()
  24.     {
  25.         return 'novaway_elasticsearch.data_collector';
  26.     }
  28.     public function reset()
  29.     {
  30.         $this->data = [
  31.             self::QUERIES_KEY => [],
  32.             self::RESULTS_KEY => [],
  33.         ];
  34.     }
  36.     public function getQueries(): array
  37.     {
  38.         return $this->data[self::QUERIES_KEY] ?? [];
  39.     }
  41.     public function getResults(): array
  42.     {
  43.         return $this->data[self::RESULTS_KEY] ?? [];
  44.     }
  46.     public function onSearchQuery(SearchQuery $event)
  47.     {
  48.         $this->data[self::QUERIES_KEY][$event->getTimestamp()] = $event->getBody();
  49.     }
  51.     public function onSearchResult(SearchResult $event)
  52.     {
  53.         $this->data[self::RESULTS_KEY][$event->getTimestamp()] = $event->getBody();
  54.     }
  56.     public static function getSubscribedEvents()
  57.     {
  58.         yield SearchQuery::NAME => 'onSearchQuery';
  59.         yield SearchResult::NAME => 'onSearchResult';
  60.     }
  63. }