vendor/mpdf/mpdf/src/Http/CurlHttpClient.php line 25

Open in your IDE?
  1. <?php
  3. namespace Mpdf\Http;
  5. use Mpdf\Log\Context as LogContext;
  6. use Mpdf\Mpdf;
  7. use Mpdf\PsrHttpMessageShim\Response;
  8. use Mpdf\PsrHttpMessageShim\Stream;
  9. use Mpdf\PsrLogAwareTrait\PsrLogAwareTrait;
  10. use Psr\Http\Message\RequestInterface;
  11. use Psr\Log\LoggerInterface;
  13. class CurlHttpClient implements \Mpdf\Http\ClientInterface, \Psr\Log\LoggerAwareInterface
  14. {
  15.     use PsrLogAwareTrait;
  17.     private $mpdf;
  19.     public function __construct(Mpdf $mpdf, LoggerInterface $logger)
  20.     {
  21.         $this->mpdf = $mpdf;
  22.         $this->logger = $logger;
  23.     }
  25.     public function sendRequest(RequestInterface $request)
  26.     {
  27.         if (null === $request->getUri()) {
  28.             return (new Response());
  29.         }
  31.         $url = $request->getUri();
  33.         $this->logger->debug(sprintf('Fetching (cURL) content of remote URL "%s"', $url), ['context' => LogContext::REMOTE_CONTENT]);
  35.         $response = new Response();
  37.         $ch = curl_init($url);
  39.         curl_setopt($ch, CURLOPT_USERAGENT, $this->mpdf->curlUserAgent);
  40.         curl_setopt($ch, CURLOPT_HEADER, 0);
  41.         curl_setopt($ch, CURLOPT_NOBODY, 0);
  42.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  43.         curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->mpdf->curlTimeout);
  45.         if ($this->mpdf->curlExecutionTimeout) {
  46.             curl_setopt($ch, CURLOPT_TIMEOUT, $this->mpdf->curlExecutionTimeout);
  47.         }
  49.         if ($this->mpdf->curlFollowLocation) {
  50.             curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
  51.         }
  53.         if ($this->mpdf->curlAllowUnsafeSslRequests) {
  54.             curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  55.             curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  56.         }
  58.         if ($this->mpdf->curlCaCertificate && is_file($this->mpdf->curlCaCertificate)) {
  59.             curl_setopt($ch, CURLOPT_CAINFO, $this->mpdf->curlCaCertificate);
  60.         }
  62.         if ($this->mpdf->curlProxy) {
  63.             curl_setopt($ch, CURLOPT_PROXY, $this->mpdf->curlProxy);
  64.             if ($this->mpdf->curlProxyAuth) {
  65.                 curl_setopt($ch, CURLOPT_PROXYUSERPWD, $this->mpdf->curlProxyAuth);
  66.             }
  67.         }
  69.         curl_setopt(
  70.             $ch,
  71.             CURLOPT_HEADERFUNCTION,
  72.             static function ($curl, $header) use (&$response) {
  73.                 $len = strlen($header);
  74.                 $header = explode(':', $header, 2);
  75.                 if (count($header) < 2) { // ignore invalid headers
  76.                     return $len;
  77.                 }
  79.                 $response = $response->withHeader(trim($header[0]), trim($header[1]));
  81.                 return $len;
  82.             }
  83.         );
  85.         $data = curl_exec($ch);
  87.         if (curl_error($ch)) {
  88.             $message = sprintf('cURL error: "%s"', curl_error($ch));
  89.             $this->logger->error($message, ['context' => LogContext::REMOTE_CONTENT]);
  91.             if ($this->mpdf->debug) {
  92.                 throw new \Mpdf\MpdfException($message);
  93.             }
  95.             curl_close($ch);
  97.             return $response;
  98.         }
  100.         $info = curl_getinfo($ch);
  101.         if (isset($info['http_code']) && !str_starts_with((string) $info['http_code'], '2')) {
  102.             $message = sprintf('HTTP error: %d', $info['http_code']);
  103.             $this->logger->error($message, ['context' => LogContext::REMOTE_CONTENT]);
  105.             if ($this->mpdf->debug) {
  106.                 throw new \Mpdf\MpdfException($message);
  107.             }
  109.             curl_close($ch);
  111.             return $response->withStatus($info['http_code']);
  112.         }
  114.         curl_close($ch);
  116.         return $response
  117.             ->withStatus($info['http_code'])
  118.             ->withBody(Stream::create($data));
  119.     }
  121. }