listener.php

<?php
namespace Bitrix\Sender\Internals\QueryController;
 
use Bitrix\Main\HttpRequest;
use Bitrix\Main\Context;
use Bitrix\Main\Error;
use Bitrix\Main\ErrorCollection;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Result;
 
Loc::loadMessages(__FILE__);
 
class Listener extends Base
{
    const REQUEST_METHOD_POST = 'POST';
    const REQUEST_METHOD_GET = 'GET';
 
    protected $errors;
 
    protected $action;
 
    protected $actionName;
 
    protected $actions = array();
 
    protected $request;
 
    protected $response;
 
    public static function create()
    {
        return new static();
    }
 
    public function __construct()
    {
        $this->errors = new ErrorCollection;
    }
 
    public function setActions(array $actions)
    {
        foreach ($actions as $action)
        {
            $this->addAction($action);
        }
 
        return $this;
    }
 
    public function addAction(Action $action)
    {
        $this->actions[] = $action;
        return $this;
    }
 
    protected function giveResponse()
    {
        global $APPLICATION;
        $APPLICATION->restartBuffer();
 
        $this->response->getContent()->getErrorCollection()->add($this->errors->toArray());
        $this->response->flushContent();
 
        \CMain::finalActions();
        exit;
    }
 
    public function getErrorCollection()
    {
        return $this->errors;
    }
 
    protected function check()
    {
        if(!$this->action)
        {
            $messageText = 'Action';
            if ($this->actionName)
            {
                $messageText .= ' "' . htmlspecialcharsbx($this->actionName) . '"';
            }
            $messageText .= ' not found.';
 
            $this->errors->setError(new Error($messageText));
            return;
        }
 
        if(!check_bitrix_sessid() || ($this->action->getRequestMethod() != $this->request->getRequestMethod()))
        {
            $this->errors->setError(new Error('Security error.'));
            return;
        }
    }
 
    protected function findAction()
    {
        $this->action = null;
        foreach ($this->actions as $action)
        {
            if ($action->getName() != $this->actionName)
            {
                continue;
            }
 
            $this->action = $action;
            break;
        }
 
        return $this->action;
    }
 
    protected function process()
    {
        // check
        $this->check();
        if (!$this->errors->isEmpty())
        {
            return;
        }
 
        // checkers
        $checkResult = new Result();
        $checkers = array_merge($this->getCheckers(), $this->action->getCheckers());
        static::callList($checkers, array($checkResult, $this->request));
        $this->errors->add($checkResult->getErrors());
        if (!$this->errors->isEmpty())
        {
            return;
        }
 
        // run action
        $this->action->run($this->request, $this->response);
 
        // modify response
        $modifiers = array_merge($this->getResponseModifiers(), $this->action->getResponseModifiers());
        static::callList($modifiers, array($this->response, $this->request));
    }
 
    public function run()
    {
        $this->request = $this->request ?: Context::getCurrent()->getRequest();
        $this->response = $this->response ?: new Response(Context::getCurrent());
        $this->actionName = $this->request->get('action');
 
        // find action by name
        $this->findAction();
 
        // process action
        $this->process();
 
        // give response
        $this->giveResponse();
    }
 
 
 
    protected function callList(array $list, array $parameters = array())
    {
        foreach ($list as $callee)
        {
            $result = static::call($callee, $parameters);
            if ($result instanceof Error)
            {
                $this->errors->setError($result);
                return;
            }
        }
    }
}