consent.php

<?php
namespace Bitrix\Main\UserConsent;
 
use Bitrix\Main\Event;
use Bitrix\Main\EventResult;
use Bitrix\Main\Context;
use Bitrix\Main\Localization\Loc;
 
Loc::loadLanguageFile(__FILE__);
 
class Consent
{
    const EVENT_NAME_LIST = 'OnUserConsentProviderList';
 
    public static function addByContext($agreementId, $originatorId = null, $originId = null, array $params = array())
    {
        $agreement = new Agreement($agreementId);
        if (!$agreement->isExist() || !$agreement->isActive())
        {
            return null;
        }
 
        $request = Context::getCurrent()->getRequest();
        $parameters = array(
            'AGREEMENT_ID' => $agreementId
        );
 
        if (isset($params['USER_ID']) && intval($params['USER_ID']) > 0)
        {
            $parameters['USER_ID'] = intval($params['USER_ID']);
        }
        else if (isset($GLOBALS['USER']) && is_object($GLOBALS['USER']) && $GLOBALS['USER']->GetID())
        {
            $parameters['USER_ID'] = $GLOBALS['USER']->GetID();
        }
 
        $parameters['IP'] = (isset($params['IP']) && $params['IP']) ? $params['IP'] : $request->getRemoteAddress();
        if (isset($params['URL']) && $params['URL'])
        {
            $parameters['URL'] = $params['URL'];
        }
        else
        {
            $parameters['URL'] = ($request->isHttps() ? "https" : "http")."://".$request->getHttpHost() . $request->getRequestUri();
        }
 
        if (mb_strlen($parameters['URL']) > 4000)
        {
            $parameters['URL'] = mb_substr($parameters['URL'], 0, 4000);
        }
 
        if ($originatorId && $originId)
        {
            $parameters['ORIGINATOR_ID'] = $originatorId;
            $parameters['ORIGIN_ID'] = $originId;
        }
        $addResult = Internals\ConsentTable::add($parameters);
        if ($addResult->isSuccess())
        {
            $userConsentId = $addResult->getId();
 
            if (isset($params['ITEMS']) && is_array($params['ITEMS']))
            {
                Internals\UserConsentItemTable::addItems($userConsentId, $params['ITEMS']);
            }
 
            return $userConsentId;
        }
        else
        {
            return null;
        }
    }
 
    public static function getByContext($agreementId, $originatorId = null, $originId = null, $params = Array())
    {
        $agreement = new Agreement($agreementId);
        if (!$agreement->isExist() || !$agreement->isActive())
        {
            return null;
        }
 
        $filter = array(
            '=AGREEMENT_ID' => $agreementId
        );
 
        if (isset($params['USER_ID']) && intval($params['USER_ID']) > 0)
        {
            $filter['=USER_ID'] = intval($params['USER_ID']);
        }
        else if (isset($GLOBALS['USER']) && is_object($GLOBALS['USER']) && $GLOBALS['USER']->GetID())
        {
            $filter['=USER_ID'] = $GLOBALS['USER']->GetID();
        }
 
        if ($originatorId && $originId)
        {
            $filter['=ORIGINATOR_ID'] = $originatorId;
            $filter['=ORIGIN_ID'] = $originId;
        }
 
        $addResult = Internals\ConsentTable::getList(Array(
            'filter' => $filter
        ))->fetch();
 
        return $addResult?: null;
    }
 
    public static function getOriginData($originatorId, $originId = null)
    {
        $list = self::getList();
        foreach ($list as $provider)
        {
            if ($provider['CODE'] != $originatorId)
            {
                continue;
            }
            $name = null;
            $url = null;
            if ($originId)
            {
                $data = $provider['DATA']($originId);
                if (!is_array($data))
                {
                    return null;
                }
 
                if (isset($data['NAME']))
                {
                    $name = $data['NAME'];
                }
                else
                {
                    return null;
                }
 
                if (isset($data['URL']))
                {
                    $url = $data['URL'];
                }
            }
            else
            {
                if (isset($provider['NAME']))
                {
                    $name = $provider['NAME'];
                }
                else
                {
                    return null;
                }
            }
 
            return array(
                'NAME' => $name,
                'URL' => $url
            );
        }
 
        return null;
    }
 
    public static function getItems($originatorId, $items = [])
    {
        $list = self::getList();
        foreach ($list as $provider)
        {
            if ($provider['CODE'] != $originatorId)
            {
                continue;
            }
 
            $values = [];
 
            if ($items)
            {
                foreach ($items as $item)
                {
                    if (!isset($item['VALUE']))
                    {
                        return null;
                    }
                    $values[] = $provider['ITEMS']($item['VALUE']);
                }
            }
            else
            {
                return null;
            }
 
            return implode(', ', $values);
        }
 
        return null;
    }
 
    protected static function getList()
    {
        $data = array();
        $event = new Event('main', self::EVENT_NAME_LIST, array($data));
        $event->send();
 
        static $list = null;
        if ($list !== null)
        {
            return $list;
        }
 
        $list = array();
        foreach ($event->getResults() as $eventResult)
        {
            if ($eventResult->getType() == EventResult::ERROR)
            {
                continue;
            }
 
            $params = $eventResult->getParameters();
            if(!$params || !is_array($params))
            {
                continue;
            }
 
            foreach ($params as $item)
            {
                if (!is_array($item) || !isset($item['CODE']) || !isset($item['NAME']))
                {
                    continue;
                }
 
                if (!isset($item['DATA']) || !is_callable($item['DATA']))
                {
                    continue;
                }
 
                $list[] = $item;
            }
        }
 
        return $list;
    }
}