4 * This file is part of the Symfony package.
6 * (c) Fabien Potencier <fabien@symfony.com>
8 * For the full copyright and license information, please view the LICENSE
9 * file that was distributed with this source code.
12 namespace Symfony\Component\HttpKernel\Profiler;
15 * Storage for profiler using files.
17 * @author Alexandre Salomé <alexandre.salome@gmail.com>
19 class FileProfilerStorage implements ProfilerStorageInterface
22 * Folder where profiler data are stored.
29 * Constructs the file storage using a "dsn-like" path.
31 * Example : "file:/path/to/the/storage/folder"
33 * @param string $dsn The DSN
35 * @throws \RuntimeException
37 public function __construct($dsn)
39 if (0 !== strpos($dsn, 'file:')) {
40 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));
42 $this->folder = substr($dsn, 5);
44 if (!is_dir($this->folder) && false === @mkdir($this->folder, 0777, true) && !is_dir($this->folder)) {
45 throw new \RuntimeException(sprintf('Unable to create the storage directory (%s).', $this->folder));
52 public function find($ip, $url, $limit, $method, $start = null, $end = null, $statusCode = null)
54 $file = $this->getIndexFilename();
56 if (!file_exists($file)) {
60 $file = fopen($file, 'r');
61 fseek($file, 0, SEEK_END);
64 while (count($result) < $limit && $line = $this->readLineFromFile($file)) {
65 $values = str_getcsv($line);
66 list($csvToken, $csvIp, $csvMethod, $csvUrl, $csvTime, $csvParent, $csvStatusCode) = $values;
67 $csvTime = (int) $csvTime;
69 if ($ip && false === strpos($csvIp, $ip) || $url && false === strpos($csvUrl, $url) || $method && false === strpos($csvMethod, $method) || $statusCode && false === strpos($csvStatusCode, $statusCode)) {
73 if (!empty($start) && $csvTime < $start) {
77 if (!empty($end) && $csvTime > $end) {
81 $result[$csvToken] = array(
84 'method' => $csvMethod,
87 'parent' => $csvParent,
88 'status_code' => $csvStatusCode,
94 return array_values($result);
100 public function purge()
102 $flags = \FilesystemIterator::SKIP_DOTS;
103 $iterator = new \RecursiveDirectoryIterator($this->folder, $flags);
104 $iterator = new \RecursiveIteratorIterator($iterator, \RecursiveIteratorIterator::CHILD_FIRST);
106 foreach ($iterator as $file) {
107 if (is_file($file)) {
118 public function read($token)
120 if (!$token || !file_exists($file = $this->getFilename($token))) {
124 return $this->createProfileFromData($token, unserialize(file_get_contents($file)));
130 * @throws \RuntimeException
132 public function write(Profile $profile)
134 $file = $this->getFilename($profile->getToken());
136 $profileIndexed = is_file($file);
137 if (!$profileIndexed) {
139 $dir = dirname($file);
140 if (!is_dir($dir) && false === @mkdir($dir, 0777, true) && !is_dir($dir)) {
141 throw new \RuntimeException(sprintf('Unable to create the storage directory (%s).', $dir));
147 'token' => $profile->getToken(),
148 'parent' => $profile->getParentToken(),
149 'children' => array_map(function ($p) { return $p->getToken(); }, $profile->getChildren()),
150 'data' => $profile->getCollectors(),
151 'ip' => $profile->getIp(),
152 'method' => $profile->getMethod(),
153 'url' => $profile->getUrl(),
154 'time' => $profile->getTime(),
155 'status_code' => $profile->getStatusCode(),
158 if (false === file_put_contents($file, serialize($data))) {
162 if (!$profileIndexed) {
164 if (false === $file = fopen($this->getIndexFilename(), 'a')) {
168 fputcsv($file, array(
169 $profile->getToken(),
171 $profile->getMethod(),
174 $profile->getParentToken(),
175 $profile->getStatusCode(),
184 * Gets filename to store data, associated to the token.
186 * @param string $token
188 * @return string The profile filename
190 protected function getFilename($token)
192 // Uses 4 last characters, because first are mostly the same.
193 $folderA = substr($token, -2, 2);
194 $folderB = substr($token, -4, 2);
196 return $this->folder.'/'.$folderA.'/'.$folderB.'/'.$token;
200 * Gets the index filename.
202 * @return string The index filename
204 protected function getIndexFilename()
206 return $this->folder.'/index.csv';
210 * Reads a line in the file, backward.
212 * This function automatically skips the empty lines and do not include the line return in result value.
214 * @param resource $file The file resource, with the pointer placed at the end of the line to read
216 * @return mixed A string representing the line or null if beginning of file is reached
218 protected function readLineFromFile($file)
221 $position = ftell($file);
223 if (0 === $position) {
228 $chunkSize = min($position, 1024);
229 $position -= $chunkSize;
230 fseek($file, $position);
232 if (0 === $chunkSize) {
237 $buffer = fread($file, $chunkSize);
239 if (false === ($upTo = strrpos($buffer, "\n"))) {
240 $line = $buffer.$line;
245 $line = substr($buffer, $upTo + 1).$line;
246 fseek($file, max(0, $position), SEEK_SET);
253 return '' === $line ? null : $line;
256 protected function createProfileFromData($token, $data, $parent = null)
258 $profile = new Profile($token);
259 $profile->setIp($data['ip']);
260 $profile->setMethod($data['method']);
261 $profile->setUrl($data['url']);
262 $profile->setTime($data['time']);
263 $profile->setStatusCode($data['status_code']);
264 $profile->setCollectors($data['data']);
266 if (!$parent && $data['parent']) {
267 $parent = $this->read($data['parent']);
271 $profile->setParent($parent);
274 foreach ($data['children'] as $token) {
275 if (!$token || !file_exists($file = $this->getFilename($token))) {
279 $profile->addChild($this->createProfileFromData($token, unserialize(file_get_contents($file)), $profile));