vendor/symfony/http-kernel/Profiler/FileProfilerStorage.php line 139

Open in your IDE?
  1. <?php
  2. /*
  3.  * This file is part of the Symfony package.
  4.  *
  5.  * (c) Fabien Potencier <fabien@symfony.com>
  6.  *
  7.  * For the full copyright and license information, please view the LICENSE
  8.  * file that was distributed with this source code.
  9.  */
  10. namespace Symfony\Component\HttpKernel\Profiler;
  11. /**
  12.  * Storage for profiler using files.
  13.  *
  14.  * @author Alexandre Salomé <alexandre.salome@gmail.com>
  15.  */
  16. class FileProfilerStorage implements ProfilerStorageInterface
  17. {
  18.     /**
  19.      * Folder where profiler data are stored.
  20.      *
  21.      * @var string
  22.      */
  23.     private $folder;
  24.     /**
  25.      * Constructs the file storage using a "dsn-like" path.
  26.      *
  27.      * Example : "file:/path/to/the/storage/folder"
  28.      *
  29.      * @throws \RuntimeException
  30.      */
  31.     public function __construct(string $dsn)
  32.     {
  33.         if (!== strpos($dsn'file:')) {
  34.             throw new \RuntimeException(sprintf('Please check your configuration. You are trying to use FileStorage with an invalid dsn "%s". The expected format is "file:/path/to/the/storage/folder".'$dsn));
  35.         }
  36.         $this->folder substr($dsn5);
  37.         if (!is_dir($this->folder) && false === @mkdir($this->folder0777true) && !is_dir($this->folder)) {
  38.             throw new \RuntimeException(sprintf('Unable to create the storage directory (%s).'$this->folder));
  39.         }
  40.     }
  41.     /**
  42.      * {@inheritdoc}
  43.      */
  44.     public function find($ip$url$limit$method$start null$end null$statusCode null)
  45.     {
  46.         $file $this->getIndexFilename();
  47.         if (!file_exists($file)) {
  48.             return array();
  49.         }
  50.         $file fopen($file'r');
  51.         fseek($file0SEEK_END);
  52.         $result = array();
  53.         while (\count($result) < $limit && $line $this->readLineFromFile($file)) {
  54.             $values str_getcsv($line);
  55.             list($csvToken$csvIp$csvMethod$csvUrl$csvTime$csvParent$csvStatusCode) = $values;
  56.             $csvTime = (int) $csvTime;
  57.             if ($ip && false === strpos($csvIp$ip) || $url && false === strpos($csvUrl$url) || $method && false === strpos($csvMethod$method) || $statusCode && false === strpos($csvStatusCode$statusCode)) {
  58.                 continue;
  59.             }
  60.             if (!empty($start) && $csvTime $start) {
  61.                 continue;
  62.             }
  63.             if (!empty($end) && $csvTime $end) {
  64.                 continue;
  65.             }
  66.             $result[$csvToken] = array(
  67.                 'token' => $csvToken,
  68.                 'ip' => $csvIp,
  69.                 'method' => $csvMethod,
  70.                 'url' => $csvUrl,
  71.                 'time' => $csvTime,
  72.                 'parent' => $csvParent,
  73.                 'status_code' => $csvStatusCode,
  74.             );
  75.         }
  76.         fclose($file);
  77.         return array_values($result);
  78.     }
  79.     /**
  80.      * {@inheritdoc}
  81.      */
  82.     public function purge()
  83.     {
  84.         $flags = \FilesystemIterator::SKIP_DOTS;
  85.         $iterator = new \RecursiveDirectoryIterator($this->folder$flags);
  86.         $iterator = new \RecursiveIteratorIterator($iterator, \RecursiveIteratorIterator::CHILD_FIRST);
  87.         foreach ($iterator as $file) {
  88.             if (is_file($file)) {
  89.                 unlink($file);
  90.             } else {
  91.                 rmdir($file);
  92.             }
  93.         }
  94.     }
  95.     /**
  96.      * {@inheritdoc}
  97.      */
  98.     public function read($token)
  99.     {
  100.         if (!$token || !file_exists($file $this->getFilename($token))) {
  101.             return;
  102.         }
  103.         return $this->createProfileFromData($tokenunserialize(file_get_contents($file)));
  104.     }
  105.     /**
  106.      * {@inheritdoc}
  107.      *
  108.      * @throws \RuntimeException
  109.      */
  110.     public function write(Profile $profile)
  111.     {
  112.         $file $this->getFilename($profile->getToken());
  113.         $profileIndexed is_file($file);
  114.         if (!$profileIndexed) {
  115.             // Create directory
  116.             $dir = \dirname($file);
  117.             if (!is_dir($dir) && false === @mkdir($dir0777true) && !is_dir($dir)) {
  118.                 throw new \RuntimeException(sprintf('Unable to create the storage directory (%s).'$dir));
  119.             }
  120.         }
  121.         $profileToken $profile->getToken();
  122.         // when there are errors in sub-requests, the parent and/or children tokens
  123.         // may equal the profile token, resulting in infinite loops
  124.         $parentToken $profile->getParentToken() !== $profileToken $profile->getParentToken() : null;
  125.         $childrenToken array_filter(array_map(function (Profile $p) use ($profileToken) {
  126.             return $profileToken !== $p->getToken() ? $p->getToken() : null;
  127.         }, $profile->getChildren()));
  128.         // Store profile
  129.         $data = array(
  130.             'token' => $profileToken,
  131.             'parent' => $parentToken,
  132.             'children' => $childrenToken,
  133.             'data' => $profile->getCollectors(),
  134.             'ip' => $profile->getIp(),
  135.             'method' => $profile->getMethod(),
  136.             'url' => $profile->getUrl(),
  137.             'time' => $profile->getTime(),
  138.             'status_code' => $profile->getStatusCode(),
  139.         );
  140.         if (false === file_put_contents($fileserialize($data))) {
  141.             return false;
  142.         }
  143.         if (!$profileIndexed) {
  144.             // Add to index
  145.             if (false === $file fopen($this->getIndexFilename(), 'a')) {
  146.                 return false;
  147.             }
  148.             fputcsv($file, array(
  149.                 $profile->getToken(),
  150.                 $profile->getIp(),
  151.                 $profile->getMethod(),
  152.                 $profile->getUrl(),
  153.                 $profile->getTime(),
  154.                 $profile->getParentToken(),
  155.                 $profile->getStatusCode(),
  156.             ));
  157.             fclose($file);
  158.         }
  159.         return true;
  160.     }
  161.     /**
  162.      * Gets filename to store data, associated to the token.
  163.      *
  164.      * @param string $token
  165.      *
  166.      * @return string The profile filename
  167.      */
  168.     protected function getFilename($token)
  169.     {
  170.         // Uses 4 last characters, because first are mostly the same.
  171.         $folderA substr($token, -22);
  172.         $folderB substr($token, -42);
  173.         return $this->folder.'/'.$folderA.'/'.$folderB.'/'.$token;
  174.     }
  175.     /**
  176.      * Gets the index filename.
  177.      *
  178.      * @return string The index filename
  179.      */
  180.     protected function getIndexFilename()
  181.     {
  182.         return $this->folder.'/index.csv';
  183.     }
  184.     /**
  185.      * Reads a line in the file, backward.
  186.      *
  187.      * This function automatically skips the empty lines and do not include the line return in result value.
  188.      *
  189.      * @param resource $file The file resource, with the pointer placed at the end of the line to read
  190.      *
  191.      * @return mixed A string representing the line or null if beginning of file is reached
  192.      */
  193.     protected function readLineFromFile($file)
  194.     {
  195.         $line '';
  196.         $position ftell($file);
  197.         if (=== $position) {
  198.             return;
  199.         }
  200.         while (true) {
  201.             $chunkSize min($position1024);
  202.             $position -= $chunkSize;
  203.             fseek($file$position);
  204.             if (=== $chunkSize) {
  205.                 // bof reached
  206.                 break;
  207.             }
  208.             $buffer fread($file$chunkSize);
  209.             if (false === ($upTo strrpos($buffer"\n"))) {
  210.                 $line $buffer.$line;
  211.                 continue;
  212.             }
  213.             $position += $upTo;
  214.             $line substr($buffer$upTo 1).$line;
  215.             fseek($filemax(0$position), SEEK_SET);
  216.             if ('' !== $line) {
  217.                 break;
  218.             }
  219.         }
  220.         return '' === $line null $line;
  221.     }
  222.     protected function createProfileFromData($token$data$parent null)
  223.     {
  224.         $profile = new Profile($token);
  225.         $profile->setIp($data['ip']);
  226.         $profile->setMethod($data['method']);
  227.         $profile->setUrl($data['url']);
  228.         $profile->setTime($data['time']);
  229.         $profile->setStatusCode($data['status_code']);
  230.         $profile->setCollectors($data['data']);
  231.         if (!$parent && $data['parent']) {
  232.             $parent $this->read($data['parent']);
  233.         }
  234.         if ($parent) {
  235.             $profile->setParent($parent);
  236.         }
  237.         foreach ($data['children'] as $token) {
  238.             if (!$token || !file_exists($file $this->getFilename($token))) {
  239.                 continue;
  240.             }
  241.             $profile->addChild($this->createProfileFromData($tokenunserialize(file_get_contents($file)), $profile));
  242.         }
  243.         return $profile;
  244.     }
  245. }