src/Hitso/Bundle/CommonBundle/Monitor/VisitManager.php line 136

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Hitso\Bundle\CommonBundle\Monitor;
  7. use DirectoryIterator;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\Filesystem\Filesystem;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  12. class VisitManager implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var string
  16.      */
  17.     protected $statPath;
  19.     /**
  20.      * @var bool
  21.      */
  22.     protected $wasClean = true;
  24.     /**
  25.      * @var bool
  26.      */
  27.     protected $registered = false;
  29.     /**
  30.      * @var bool
  31.      */
  32.     protected $debug;
  34.     public function __construct($statPath, $lockPath, $debug)
  35.     {
  36.         $this->statPath = $statPath;
  37.         $this->debug    = $debug;
  39.         if (!is_dir($statPath)) {
  40.             $fs = new Filesystem();
  41.             $fs->mkdir($statPath);
  42.         }
  43.     }
  45.     public function logVisit($clean)
  46.     {
  47.         $statFile = $this->statPath . '/' . strtotime('midnight');
  49.         if (file_exists($statFile)) {
  50.             $stats = unserialize(file_get_contents($statFile));
  51.         } else {
  52.             $stats = [];
  53.         }
  55.         $hour = (int) strftime('%H');
  57.         if (!isset($stats[$hour])) {
  58.             $stats[$hour] = [0, 0];
  59.         }
  61.         $stats[$hour][0]++;
  63.         if (!$clean) {
  64.             $stats[$hour][1]++;
  65.         }
  67.         file_put_contents($statFile, serialize($stats));
  68.     }
  70.     public function readLogs()
  71.     {
  72.         $day  = strtotime('midnight');
  73.         $hour = (int) strftime('%H');
  75.         $results = [];
  77.         $files = new DirectoryIterator($this->statPath);
  79.         foreach ($files as $file) {
  80.             if ($file->isFile() && is_numeric($file->getFilename()) && $file->getFilename() <= $day) {
  81.                 $fday = (int) $file->getFilename();
  82.                 $data = @unserialize(file_get_contents($file->getPathname()));
  84.                 if (!is_array($data)) {
  85.                     continue;
  86.                 }
  88.                 foreach ($data as $fhour => $row) {
  89.                     if ($fday == $day && $fhour >= $hour) {
  90.                         break;
  91.                     }
  93.                     $stamp           = $fday + ($fhour * 3600);
  94.                     $results[$stamp] = $row;
  95.                 }
  96.             }
  97.         }
  99.         return $results;
  100.     }
  102.     public function clearLogs()
  103.     {
  104.         $day  = strtotime('midnight');
  105.         $hour = (int) strftime('%H');
  107.         $files = new DirectoryIterator($this->statPath);
  109.         foreach ($files as $file) {
  110.             if ($file->isFile() && is_numeric($file->getFilename()) && $file->getFilename() <= $day) {
  111.                 $fday = $file->getFilename();
  113.                 if ($fday == $day) {
  114.                     $data = @unserialize(file_get_contents($file->getPathname()));
  116.                     if (!is_array($data)) {
  117.                         @unlink($file->getPathname());
  118.                     } else {
  119.                         $newData = [];
  121.                         foreach ($data as $fhour => $row) {
  122.                             if ($fhour >= $hour) {
  123.                                 $newData[$fhour] = $row;
  124.                             }
  125.                         }
  127.                         file_put_contents($file->getPathname(), serialize($newData));
  128.                     }
  129.                 } else {
  130.                     @unlink($file->getPathname());
  131.                 }
  132.             }
  133.         }
  134.     }
  136.     public function onRequest()
  137.     {
  138.         if (!$this->registered && !$this->debug) {
  139.             register_shutdown_function(
  140.                 function () {
  141.                     $this->logVisit($this->wasClean);
  142.                 }
  143.             );
  144.         }
  146.         $this->registered = true;
  147.     }
  149.     public function onException()
  150.     {
  151.         $this->wasClean = false;
  152.     }
  154.     public static function getSubscribedEvents()
  155.     {
  156.         return [
  157.             KernelEvents::REQUEST   => ['onRequest', 512],
  158.             KernelEvents::EXCEPTION => ['onException', 512],
  159.         ];
  160.     }
  161. }