tracking.php

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

<?php
 
namespace Bitrix\Main\Mail;
 
use Bitrix\Main;
use Bitrix\Main\Application;
use Bitrix\Main\Config;
use Bitrix\Main\EventResult;
use Bitrix\Main\Security\Sign\BadSignatureException;
use Bitrix\Main\Security\Sign\Signer;
use Bitrix\Main\SystemException;

class Tracking
{
    const SIGN_SALT_ACTION = 'event_mail_tracking';
 
    const onRead = 'OnMailEventMailRead';
    const onClick = 'OnMailEventMailClick';
    const onUnsubscribe = 'OnMailEventSubscriptionDisable';
    const onChangeStatus = 'OnMailEventMailChangeStatus';
    const CUSTOM_SIGNER_KEY = 'signer_sender_mail_key';

    public static function getTag($moduleId, $fields)
    {
 
        $moduleId = str_replace(".", "--", $moduleId);
        return $moduleId . "." . base64_encode(json_encode($fields));
    }

    public static function parseTag($tag)
    {
        $data = explode(".", $tag);
        $moduleId = str_replace("--", ".", $data[0]);
        unset($data[0]);
 
        return array('MODULE_ID' => $moduleId, 'FIELDS' => (array) json_decode(base64_decode(implode('.', $data))));
    }

    public static function getSignedTag($moduleId, $fields)
    {
        $tag = static::getTag($moduleId, $fields);
        $signer = new Signer;
        return $signer->sign($tag, static::SIGN_SALT_ACTION);
    }

    public static function parseSignedTag($signedTag)
    {
        try
        {
            $signer = new Signer;
            $unsignedTag = $signer->unsign($signedTag, static::SIGN_SALT_ACTION);
            return static::parseTag($unsignedTag);
        }
        catch (BadSignatureException $e)
        {
        }
 
        $signer->setKey(self::getSignKey());
        $unsignedTag = $signer->unsign($signedTag, static::SIGN_SALT_ACTION);
        return static::parseTag($unsignedTag);
    }

    public static function getLinkRead($moduleId, $fields, $urlPage = null)
    {
        return static::getTaggedLink(
            static::getTag($moduleId, $fields),
            'read',
            $urlPage
        );
    }

    public static function getLinkClick($moduleId, $fields, $urlPage = null)
    {
        return static::getTaggedLink(
            static::getTag($moduleId, $fields),
            'click',
            $urlPage
        );
    }

    public static function getLinkUnsub($moduleId, $fields, $urlPage = null)
    {
        return static::getTaggedLink(
            static::getSignedTag($moduleId, $fields),
            'unsub',
            $urlPage
        );
    }

    protected static function getTaggedLink($tag, $opCode, $uri = null)
    {
        if(!$uri)
        {
            $uri = Application::getInstance()->getPersonalRoot();
            $uri .= "/tools/track_mail_$opCode.php";
        }
 
        $uri = $uri . (!str_contains($uri, "?") ? "?" : "&");
        $uri .= 'tag=' . urlencode($tag);
 
        return $uri;
    }

    public static function getSign($value)
    {
        static $cached = array();
        foreach ($cached as $cache)
        {
            if ($cache[0] == $value)
            {
                return $cache[1];
            }
        }
 
        $signer = new Signer;
        $sign = $signer->getSignature($value, static::SIGN_SALT_ACTION);
 
        $cached[] = array($value, $sign);
        if (count($cached) > 10)
        {
            array_shift($cached);
        }
 
        return $sign;
    }

    public static function validateSign($value, $signature)
    {
        try
        {
            $signer = new Signer;
            $result = $signer->validate($value, $signature, static::SIGN_SALT_ACTION);
        }
        catch (BadSignatureException $exception)
        {
            $result = false;
        }
 
        if(!$result)
        {
            return self::validateSignWithStoredKey($value, $signature);
        }
 
        return $result;
    }
 
    private static function validateSignWithStoredKey($value, $signature)
    {
        try
        {
            $signer = new Signer;
            $key = self::getSignKey();
 
            if (is_string($key))
            {
                $signer->setKey($key);
            }
 
            return $signer->validate($value, $signature, static::SIGN_SALT_ACTION);
        }
        catch (BadSignatureException $exception)
        {
            return false;
        }
    }
 
    private static function getSignKey()
    {
        $key = Config\Option::get('sender', self::CUSTOM_SIGNER_KEY, null);
        if (!$key)
        {
            $key = Config\Option::get('main', 'signer_default_key', null);
            if (is_string($key))
            {
                Config\Option::set('sender', self::CUSTOM_SIGNER_KEY, $key);
            }
        }
 
        return $key;
    }

    public static function getSubscriptionList($data)
    {
        $subscription = array();
 
        if(array_key_exists('MODULE_ID', $data))
            $filter = array($data['MODULE_ID']);
        else
            $filter = null;
 
        if(!is_array($data['FIELDS'])) return false;
 
        $event = new Main\Event("main", "OnMailEventSubscriptionList", array($data['FIELDS']), $filter);
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
 
            $subscriptionList = $eventResult->getParameters();
            if($subscriptionList && is_array($subscriptionList['LIST']))
            {
                $subscription = array_merge(
                    $subscription,
                    array($eventResult->getModuleId() => $subscriptionList['LIST'])
                );
            }
        }
 
        if (empty($data['MODULE_ID']) || $data['MODULE_ID'] === 'main')
        {
            if (empty($subscription['main']))
            {
                $subscription['main'] = [];
            }
            $subscription['main'] = array_merge(
                $subscription['main'],
                EventManager::onMailEventSubscriptionList($data)
            );
        }
 
        if(array_key_exists('MODULE_ID', $data))
            $subscription = $subscription[$data['MODULE_ID']];
 
        return $subscription;
    }

    public static function subscribe($data)
    {
        if(!is_array($data['FIELDS'])) return false;
 
        $event = new Main\Event("main", "OnMailEventSubscriptionEnable", array($data['FIELDS']), array($data['MODULE_ID']));
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
        }
 
        return true;
    }

    public static function unsubscribe($data)
    {
        if(!is_array($data['FIELDS'])) return false;
 
        $event = new Main\Event("main", "OnMailEventSubscriptionDisable", array($data['FIELDS']), array($data['MODULE_ID']));
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
        }
 
        if (!empty($data['MODULE_ID']) && $data['MODULE_ID'] === 'main')
        {
            return EventManager::onMailEventSubscriptionDisable($data);
        }
 
        return true;
    }

    public static function click(array $data)
    {
        if (Main\Config\Option::get('main', 'track_outgoing_emails_click', 'Y') != 'Y')
        {
            return false;
        }
 
        if(array_key_exists('MODULE_ID', $data))
            $filter = array($data['MODULE_ID']);
        else
            $filter = null;
 
        $event = new Main\Event("main", "OnMailEventMailClick", array($data['FIELDS']), $filter);
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
        }
 
        return true;
    }

    public static function clickFromRequest()
    {
        $request = Main\Context::getCurrent()->getRequest();
        $url = $request->get('url');
        $sign = $request->get('sign');
        $tag = $request->get('tag');
 
        if ($tag)
        {
            try
            {
                $tag = static::parseTag($tag);
                $tag['FIELDS']['IP'] = $request->getRemoteAddress();
                $tag['FIELDS']['URL'] = $url;
                static::click($tag);
            }
            catch (SystemException $exception)
            {
 
            }
        }
 
        $isValidate = static::validateSign($url, $sign);
        $skipSecCheck = ($sign && $url && $isValidate);
        $url = $url ?: '/';
        if ($isValidate)
        {
            LocalRedirect($url, $skipSecCheck);
        }
        else
        {
            ShowError('Failed to verify the security of the url address');
        }
    }

    public static function readFromRequest()
    {
        $request = Main\Context::getCurrent()->getRequest();
        $tag = $request->get('tag');
        if (!$tag)
        {
            return false;
        }
 
        try
        {
            $data = static::parseTag($tag);
            $data['FIELDS']['IP'] = $request->getRemoteAddress();
            return static::read($data);
        }
        catch (SystemException $exception)
        {
            return false;
        }
    }

    public static function read(array $data)
    {
        if (Main\Config\Option::get('main', 'track_outgoing_emails_read', 'Y') != 'Y')
        {
            return false;
        }
 
        if(array_key_exists('MODULE_ID', $data))
            $filter = array($data['MODULE_ID']);
        else
            $filter = null;
 
        $event = new Main\Event("main", "OnMailEventMailRead", array($data['FIELDS']), $filter);
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
        }
 
        return true;
    }

    public static function changeStatus(Callback\Result $callbackResult)
    {
        if($callbackResult->getModuleId())
        {
            $filter = [$callbackResult->getModuleId()];
        }
        else
        {
            $filter = null;
        }
 
        $event = new Main\Event("main", self::onChangeStatus, [$callbackResult], $filter);
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                return false;
            }
        }
 
        return true;
    }
}