analyticsevent.php

См. документацию.

<?php
 
declare(strict_types=1);
 
namespace Bitrix\Main\Analytics;
 
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Config\Configuration;
use Bitrix\Main\Context;
use Bitrix\Main\Event;
use Bitrix\Main\Loader;
use Bitrix\Main\Diag\FileLogger;
use Bitrix\Main\Diag\JsonLinesFormatter;
 
final class AnalyticsEvent
{
    public const STATUS_SUCCESS = 'success';
    public const STATUS_ERROR = 'error';
    public const STATUS_ATTEMPT = 'attempt';
    public const STATUS_CANCEL = 'cancel';
 
    private ?string $section;
    private ?string $subSection;
    private ?string $element;
    private ?string $type;
    private ?string $p1;
    private ?string $p2;
    private ?string $p3;
    private ?string $p4;
    private ?string $p5;
    private string $status = self::STATUS_SUCCESS;
    private ?int $userId;
    private string $userAgent;
    private string $host;
    private string $dbname;
 
    private bool $isInvalid = false;
 
    public function __construct(
        private readonly string $event,
        private readonly string $tool,
        private readonly string $category,
    )
    {
        $userAgent = Context::getCurrent()?->getRequest()->getUserAgent();
        if ($userAgent && \is_string($userAgent))
        {
            $this->setUserAgent($userAgent);
        }
 
        $httpHost = Context::getCurrent()?->getServer()->getHttpHost();
        if ($httpHost && \is_string($httpHost))
        {
            $this->setHost($httpHost);
        }
 
        $dbname = \defined('BX24_DB_NAME') ? BX24_DB_NAME : null;
        if ($dbname && \is_string($dbname))
        {
            $this->setDbName($dbname);
        }
    }
 
    public function setUserId(int $userId): self
    {
        $this->userId = $userId;
 
        return $this;
    }
 
    public function setSection(string $section): self
    {
        $this->section = $section;
 
        return $this;
    }
 
    public function setSubSection(string $subSection): self
    {
        $this->subSection = $subSection;
 
        return $this;
    }
 
    public function setElement(string $element): self
    {
        $this->element = $element;
 
        return $this;
    }
 
    public function setType(string $type): self
    {
        $this->type = $type;
 
        return $this;
    }

    public function setP1(string $p1): self
    {
        $this->validatePField($p1);
        $this->p1 = $p1;
 
        return $this;
    }

    public function setP2(string $p2): self
    {
        $this->validatePField($p2);
        $this->p2 = $p2;
 
        return $this;
    }

    public function setP3(string $p3): self
    {
        $this->validatePField($p3);
        $this->p3 = $p3;
 
        return $this;
    }

    public function setP4(string $p4): self
    {
        $this->validatePField($p4);
        $this->p4 = $p4;
 
        return $this;
    }

    public function setP5(string $p5): self
    {
        $this->validatePField($p5);
        $this->p5 = $p5;
 
        return $this;
    }
 
    public function setStatus(string $status): self
    {
        $this->status = $status;
 
        return $this;
    }
 
    public function setUserAgent(string $userAgent): self
    {
        $this->userAgent = $userAgent;
 
        return $this;
    }
 
    public function setHost(string $host): self
    {
        $this->host = $host;
 
        return $this;
    }
 
    public function setDbName(string $dbname): self
    {
        $this->dbname = $dbname;
 
        return $this;
    }
 
    public function markAsSuccess(): self
    {
        return $this->setStatus(self::STATUS_SUCCESS);
    }
 
    public function markAsCanceled(): self
    {
        return $this->setStatus(self::STATUS_CANCEL);
    }
 
    public function markAsError(): self
    {
        return $this->setStatus(self::STATUS_ERROR);
    }
 
    public function markAsAttempt(): self
    {
        return $this->setStatus(self::STATUS_ATTEMPT);
    }

    private function validatePField(string $value): void
    {
        $invalidValue = substr_count($value, '_') > 1;
        if ($invalidValue)
        {
            $this->isInvalid = true;
        }
 
        if ($invalidValue && $this->isDevMode())
        {
            throw new ArgumentException('Value for p{1-5} field must contain a single underscore.');
        }
    }

    private function validateRequiredFields(): void
    {
        if (empty($this->event) || empty($this->tool) || empty($this->category))
        {
            $this->isInvalid = true;
 
            if ($this->isDevMode())
            {
                throw new ArgumentException('Event, tool and category fields are required and should be filled.');
            }
        }
    }
 
    private function isDevMode(): bool
    {
        $exceptionHandling = Configuration::getValue('exception_handling');
 
        return !empty($exceptionHandling['debug']);
    }
 
    public function exportToArray(): array
    {
        return [
            'event' => $this->event,
            'tool' => $this->tool,
            'category' => $this->category,
            'section' => $this->section ?? null,
            'subSection' => $this->subSection ?? null,
            'element' => $this->element ?? null,
            'type' => $this->type ?? null,
            'p1' => $this->p1 ?? null,
            'p2' => $this->p2 ?? null,
            'p3' => $this->p3 ?? null,
            'p4' => $this->p4 ?? null,
            'p5' => $this->p5 ?? null,
            'status' => $this->status ?? null,
            'userAgent' => $this->userAgent ?? null,
        ];
    }

    public function send(): void
    {
        if (!\defined('ANALYTICS_V2_FILENAME') || !is_writable(ANALYTICS_V2_FILENAME))
        {
            return;
        }
 
        $this->validateRequiredFields();
        if ($this->isInvalid)
        {
            return;
        }
 
        if (!isset($this->userId) && !\defined('BX_CHECK_AGENT_START') && ($GLOBALS['USER'] instanceof \CUser))
        {
            $this->userId = (int)$GLOBALS['USER']->getId();
        }
 
        $data = $this->buildLogData();
        if ($this->isDevMode())
        {
            $this->triggerDebugEvent($data);
        }
 
        $logger = new FileLogger(ANALYTICS_V2_FILENAME, 0);
        $logger->setFormatter(new JsonLinesFormatter());
        $logger->debug('', $data);
    }
 
    private function triggerDebugEvent(array $data): void
    {
        $event = new Event('main', 'OnAnalyticsEvent', ['analyticsEvent' => $this, 'eventData' => $data]);
        $event->send();
    }
 
    private function buildLogData(): array
    {
        $data = [
            'date' => date('Y-m-d H:i:s'),
            'host' => $this->host ?? null,
            'dbname' => $this->dbname ?? null,
            'userId' => $this->userId ?? 0,
            'event' => $this->exportToArray(),
        ];
 
        if (Loader::includeModule('bitrix24'))
        {
            $data['license'] = \CBitrix24::getLicenseType();
        }
 
        return $data;
    }
}