vendor/doctrine/mongodb-odm-bundle/APM/PSRCommandLogger.php line 67

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Doctrine\Bundle\MongoDBBundle\APM;
  7. use Doctrine\ODM\MongoDB\APM\CommandLoggerInterface;
  8. use MongoDB\Driver\Monitoring\CommandFailedEvent;
  9. use MongoDB\Driver\Monitoring\CommandStartedEvent;
  10. use MongoDB\Driver\Monitoring\CommandSucceededEvent;
  11. use Psr\Log\LoggerInterface;
  13. use function json_encode;
  14. use function MongoDB\Driver\Monitoring\addSubscriber;
  15. use function MongoDB\Driver\Monitoring\removeSubscriber;
  17. final class PSRCommandLogger implements CommandLoggerInterface
  18. {
  19.     /** @var bool */
  20.     private $registered = false;
  22.     /** @var LoggerInterface|null */
  23.     private $logger;
  25.     /** @var string */
  26.     private $prefix;
  28.     public function __construct(?LoggerInterface $logger, string $prefix = 'MongoDB command: ')
  29.     {
  30.         $this->logger = $logger;
  31.         $this->prefix = $prefix;
  32.     }
  34.     public function register(): void
  35.     {
  36.         if ($this->logger === null || $this->registered) {
  37.             return;
  38.         }
  40.         $this->registered = true;
  41.         addSubscriber($this);
  42.     }
  44.     public function unregister(): void
  45.     {
  46.         if (! $this->registered) {
  47.             return;
  48.         }
  50.         removeSubscriber($this);
  51.         $this->registered = false;
  52.     }
  54.     public function commandStarted(CommandStartedEvent $event)
  55.     {
  56.         if (! $this->logger) {
  57.             return;
  58.         }
  60.         $this->logger->debug($this->prefix . json_encode($event->getCommand()));
  61.     }
  63.     public function commandSucceeded(CommandSucceededEvent $event)
  64.     {
  65.     }
  67.     public function commandFailed(CommandFailedEvent $event)
  68.     {
  69.     }
  70. }