vendor/eightpoints/guzzle-bundle/src/Middleware/SymfonyLogMiddleware.php line 39

Open in your IDE?
  1. <?php
  3. namespace EightPoints\Bundle\GuzzleBundle\Middleware;
  5. use GuzzleHttp\Exception\RequestException;
  6. use GuzzleHttp\MessageFormatter;
  7. use Psr\Log\LoggerInterface;
  9. class SymfonyLogMiddleware
  10. {
  11.     /** @var \GuzzleHttp\MessageFormatter */
  12.     protected $formatter;
  14.     /** @var \Psr\Log\LoggerInterface */
  15.     protected $logger;
  17.     /**
  18.      * @param \Psr\Log\LoggerInterface $logger
  19.      * @param \GuzzleHttp\MessageFormatter $formatter
  20.      */
  21.     public function __construct(LoggerInterface $logger, MessageFormatter $formatter)
  22.     {
  23.         $this->logger    = $logger;
  24.         $this->formatter = $formatter;
  25.     }
  27.     /**
  28.      * @param callable $handler
  29.      *
  30.      * @return \Closure
  31.      */
  32.     public function __invoke(callable $handler) : \Closure
  33.     {
  34.         $logger    = $this->logger;
  35.         $formatter = $this->formatter;
  37.         return function ($request, array $options) use ($handler, $logger, $formatter) {
  39.             return $handler($request, $options)->then(
  41.                 function ($response) use ($logger, $request, $formatter) {
  42.                     $message = $formatter->format($request, $response);
  44.                     $logger->info($message);
  46.                     return $response;
  47.                 },
  49.                 function ($reason) use ($logger, $request, $formatter) {
  50.                     $response = $reason instanceof RequestException ? $reason->getResponse() : null;
  51.                     $message  = $formatter->format($request, $response, $reason);
  53.                     $logger->notice($message);
  55.                     return \GuzzleHttp\Promise\Create::rejectionFor($reason);
  56.                 }
  57.             );
  58.         };
  59.     }
  60. }