vendor/mpdf/mpdf/src/AssetFetcher.php line 78

Open in your IDE?
  1. <?php
  3. namespace Mpdf;
  5. use Mpdf\File\LocalContentLoaderInterface;
  6. use Mpdf\File\StreamWrapperChecker;
  7. use Mpdf\Http\ClientInterface;
  8. use Mpdf\Log\Context as LogContext;
  9. use Mpdf\PsrHttpMessageShim\Request;
  10. use Mpdf\PsrLogAwareTrait\PsrLogAwareTrait;
  11. use Psr\Log\LoggerInterface;
  13. class AssetFetcher implements \Psr\Log\LoggerAwareInterface
  14. {
  16.     use PsrLogAwareTrait;
  18.     private $mpdf;
  20.     private $contentLoader;
  22.     private $http;
  24.     public function __construct(Mpdf $mpdf, LocalContentLoaderInterface $contentLoader, ClientInterface $http, LoggerInterface $logger)
  25.     {
  26.         $this->mpdf = $mpdf;
  27.         $this->contentLoader = $contentLoader;
  28.         $this->http = $http;
  29.         $this->logger = $logger;
  30.     }
  32.     public function fetchDataFromPath($path, $originalSrc = null)
  33.     {
  34.         /**
  35.          * Prevents insecure PHP object injection through phar:// wrapper
  36.          * @see https://github.com/mpdf/mpdf/issues/949
  37.          * @see https://github.com/mpdf/mpdf/issues/1381
  38.          */
  39.         $wrapperChecker = new StreamWrapperChecker($this->mpdf);
  41.         if ($wrapperChecker->hasBlacklistedStreamWrapper($path)) {
  42.             throw new \Mpdf\Exception\AssetFetchingException('File contains an invalid stream. Only ' . implode(', ', $wrapperChecker->getWhitelistedStreamWrappers()) . ' streams are allowed.');
  43.         }
  45.         if ($originalSrc && $wrapperChecker->hasBlacklistedStreamWrapper($originalSrc)) {
  46.             throw new \Mpdf\Exception\AssetFetchingException('File contains an invalid stream. Only ' . implode(', ', $wrapperChecker->getWhitelistedStreamWrappers()) . ' streams are allowed.');
  47.         }
  49.         $this->mpdf->GetFullPath($path);
  51.         return $this->isPathLocal($path) || ($originalSrc !== null && $this->isPathLocal($originalSrc))
  52.             ? $this->fetchLocalContent($path, $originalSrc)
  53.             : $this->fetchRemoteContent($path);
  54.     }
  56.     public function fetchLocalContent($path, $originalSrc)
  57.     {
  58.         $data = '';
  60.         if ($originalSrc && $this->mpdf->basepathIsLocal && $check = @fopen($originalSrc, 'rb')) {
  61.             fclose($check);
  62.             $path = $originalSrc;
  63.             $this->logger->debug(sprintf('Fetching content of file "%s" with local basepath', $path), ['context' => LogContext::REMOTE_CONTENT]);
  65.             return $this->contentLoader->load($path);
  66.         }
  68.         if ($path && $check = @fopen($path, 'rb')) {
  69.             fclose($check);
  70.             $this->logger->debug(sprintf('Fetching content of file "%s" with non-local basepath', $path), ['context' => LogContext::REMOTE_CONTENT]);
  72.             return $this->contentLoader->load($path);
  73.         }
  75.         return $data;
  76.     }
  78.     public function fetchRemoteContent($path)
  79.     {
  80.         $data = '';
  82.         try {
  84.             $this->logger->debug(sprintf('Fetching remote content of file "%s"', $path), ['context' => LogContext::REMOTE_CONTENT]);
  86.             /** @var \Mpdf\PsrHttpMessageShim\Response $response */
  87.             $response = $this->http->sendRequest(new Request('GET', $path));
  89.             if (!str_starts_with((string) $response->getStatusCode(), '2')) {
  91.                 $message = sprintf('Non-OK HTTP response "%s" on fetching remote content "%s" because of an error', $response->getStatusCode(), $path);
  92.                 if ($this->mpdf->debug) {
  93.                     throw new \Mpdf\MpdfException($message);
  94.                 }
  96.                 $this->logger->info($message);
  98.                 return $data;
  99.             }
  101.             $data = $response->getBody()->getContents();
  103.         } catch (\InvalidArgumentException $e) {
  104.             $message = sprintf('Unable to fetch remote content "%s" because of an error "%s"', $path, $e->getMessage());
  105.             if ($this->mpdf->debug) {
  106.                 throw new \Mpdf\MpdfException($message, 0, E_ERROR, null, null, $e);
  107.             }
  109.             $this->logger->warning($message);
  110.         }
  112.         return $data;
  113.     }
  115.     public function isPathLocal($path)
  116.     {
  117.         return str_starts_with($path, 'file://') || strpos($path, '://') === false; // @todo More robust implementation
  118.     }
  120. }