callback.php

<?php
namespace Bitrix\Rest\Event;
 
use Bitrix\Rest\AppTable;
use Bitrix\Rest\EventTable;
use Bitrix\Rest\Tools\Diagnostics\LoggerManager;
 
class Callback
{
    public static function __callStatic($name, $arguments)
    {
        $logger = LoggerManager::getInstance()->getLogger();
        $event = Sender::parseEventName($name);
        if ($logger)
        {
            $logger->debug(
                "\n{delimiter}\n"
                . "{date} - {host}\n{delimiter}\n"
                . "Event {eventName} starts. \n{delimiter}\n"
                . "{arguments}",
                [
                    'eventName' => $event['EVENT'],
                    'arguments' => $arguments,
                ]
            );
        }
 
        $provider = new \CRestProvider();
        $description = $provider->getDescription();
 
        foreach($description as $scope => $scopeMethods)
        {
            if(
                array_key_exists(\CRestUtil::EVENTS, $scopeMethods)
                && is_array($scopeMethods[\CRestUtil::EVENTS])
            )
            {
                foreach($scopeMethods[\CRestUtil::EVENTS] as $key => $restEvent)
                {
                    if($restEvent[0] == $event['MODULE_ID'] && toUpper($restEvent[1]) == $event['EVENT'])
                    {
                        $event['EVENT_REST'] = array(
                            'EVENT' => $key,
                            'HANDLER' => $restEvent[2],
                            'ADDITIONAL' => array(),
                        );
 
                        if(isset($restEvent[3]) && is_array($restEvent[3]))
                        {
                            $event['EVENT_REST']['ADDITIONAL'] = $restEvent[3];
                        }
 
                        break;
                    }
                }
            }
 
            if(array_key_exists('EVENT_REST', $event))
            {
                break;
            }
        }
 
        $handlerFound = false;
        $appHoldExceptId = 0;
        if (!empty($arguments[1]['REST_EVENT_HOLD_EXCEPT_APP']))
        {
            $app = AppTable::getByClientId($arguments[1]['REST_EVENT_HOLD_EXCEPT_APP']);
            if ($app['ID'] > 0)
            {
                $appHoldExceptId = $app['ID'];
            }
        }
 
        if(array_key_exists('EVENT_REST', $event))
        {
            $filter = [
                '=EVENT_NAME' => mb_strtoupper($event['EVENT_REST']['EVENT']),
            ];
            if ($appHoldExceptId > 0)
            {
                $filter['=APP_ID'] = $appHoldExceptId;
            }
 
            $dbRes = EventTable::getList(
                [
                    'filter' => $filter,
                    'select' => [
                        '*',
                        'APP_CODE' => 'REST_APP.CLIENT_ID',
                        'APP_ACTIVE' => 'REST_APP.ACTIVE',
                        'APP_INSTALLED' => 'REST_APP.INSTALLED',
                    ],
                ]
            );
 
            $dataProcessed = !is_array($event['EVENT_REST']['HANDLER']) || !is_callable($event['EVENT_REST']['HANDLER']);
            $call = array();
            while ($handler = $dbRes->fetch())
            {
                if (!empty($handler['APP_CODE']))
                {
                    if (
                        $handler['APP_ACTIVE'] !== AppTable::ACTIVE
                        || $handler['APP_INSTALLED'] !== AppTable::INSTALLED
                    )
                    {
                        if ($logger)
                        {
                            $logger->error(
                                "\n{delimiter}\n"
                                . "{date} - {host}\n{delimiter}\n"
                                . "Event {eventName} skipped because inactive app: \n"
                                . "{handler}",
                                [
                                    'eventName' => $event['EVENT'],
                                    'handler' => $handler,
                                ]
                            );
                        }
 
                        continue;
                    }
 
                    $appStatus = AppTable::getAppStatusInfo($handler['APP_CODE'], '');
                    if ($appStatus['PAYMENT_EXPIRED'] === 'Y')
                    {
                        if ($logger)
                        {
                            $logger->error(
                                "\n{delimiter}\n"
                                . "{date} - {host}\n{delimiter}\n"
                                . "Event {eventName} skipped because PAYMENT_EXPIRED: \n"
                                . "{appStatus}",
                                [
                                    'eventName' => $event['EVENT'],
                                    'appStatus' => $appStatus,
                                ]
                            );
                        }
 
                        continue;
                    }
                }
 
                $handlerArguments = $arguments;
                $handlerFound = true;
 
                if(!$dataProcessed)
                {
                    try
                    {
                        $handlerArguments = call_user_func_array($event['EVENT_REST']['HANDLER'], array($handlerArguments, $handler));
                        $call[] = array($handler, $handlerArguments, $event['EVENT_REST']['ADDITIONAL']);
                    }
                    catch(\Exception $e)
                    {
                        if ($logger)
                        {
                            $logger->error(
                                "\n{delimiter}\n"
                                . "{date} - {host}\n{delimiter}\n"
                                . "Event {eventName} exception: \n"
                                . "{errorCode}: {errorMessage}",
                                [
                                    'eventName' => $event['EVENT'],
                                    'errorCode' => $e->getCode(),
                                    'errorMessage' => $e->getMessage(),
                                ]
                            );
                        }
                    }
                }
                else
                {
                    $call[] = array($handler, $handlerArguments, $event['EVENT_REST']['ADDITIONAL']);
                }
            }
 
            if(count($call) > 0)
            {
                Sender::call($call);
            }
        }
 
        if(!$handlerFound)
        {
            Sender::unbind($event['MODULE_ID'], $event['EVENT']);
        }
    }
}