vendor/eightpoints/guzzle-bundle/src/Middleware/LogMiddleware.php line 49

Open in your IDE?
  1. <?php
  3. namespace EightPoints\Bundle\GuzzleBundle\Middleware;
  5. use GuzzleHttp\Exception\RequestException;
  6. use GuzzleHttp\MessageFormatter;
  7. use EightPoints\Bundle\GuzzleBundle\Log\LoggerInterface;
  9. class LogMiddleware
  10. {
  11.     /** @var \GuzzleHttp\MessageFormatter */
  12.     protected $formatter;
  14.     /** @var \EightPoints\Bundle\GuzzleBundle\Log\LoggerInterface */
  15.     protected $logger;
  17.     /**
  18.      * @param \EightPoints\Bundle\GuzzleBundle\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.      * Logging each Request
  29.      *
  30.      * @return \Closure
  31.      */
  32.     public function log() : \Closure
  33.     {
  34.         $logger    = $this->logger;
  35.         $formatter = $this->formatter;
  37.         return function (callable $handler) use ($logger, $formatter) {
  39.             return function ($request, array $options) use ($handler, $logger, $formatter) {
  40.                 // generate id that will be used to supplement the log with information
  41.                 $requestId = uniqid('eight_points_guzzle_');
  43.                 // initial registration of log
  44.                 $logger->info('', compact('request', 'requestId'));
  46.                 // this id will be used by RequestTimeMiddleware
  47.                 $options['request_id'] = $requestId;
  49.                 return $handler($request, $options)->then(
  51.                     function ($response) use ($logger, $request, $formatter, $requestId) {
  53.                         $message = $formatter->format($request, $response);
  54.                         $context = compact('request', 'response', 'requestId');
  56.                         $logger->info($message, $context);
  58.                         return $response;
  59.                     },
  61.                     function ($reason) use ($logger, $request, $formatter, $requestId) {
  63.                         $response = $reason instanceof RequestException ? $reason->getResponse() : null;
  64.                         $message  = $formatter->format($request, $response, $reason);
  65.                         $context  = compact('request', 'response', 'requestId');
  67.                         $logger->notice($message, $context);
  69.                         return \GuzzleHttp\Promise\Create::rejectionFor($reason);
  70.                     }
  71.                 );
  72.             };
  73.         };
  74.     }
  75. }