application.php

<?php
namespace Bitrix\Main;
 
use Bitrix\Main\Config\Configuration;
use Bitrix\Main\Data;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Main\Diag;
use Bitrix\Main\Routing\Route;
use Bitrix\Main\Routing\Router;
use Bitrix\Main\Session\CompositeSessionManager;
use Bitrix\Main\Session\KernelSessionProxy;
use Bitrix\Main\Session\SessionConfigurationResolver;
use Bitrix\Main\Session\SessionInterface;
 
abstract class Application
{
    const JOB_PRIORITY_NORMAL = 100;
    const JOB_PRIORITY_LOW = 50;
 
    protected static $instance;
 
    protected bool $initialized = false;
 
    protected $context;
 
    protected $router;
 
    protected $currentRoute;
 
    protected $connectionPool;
 
    protected $managedCache;
 
    protected $taggedCache;
 
    protected $session;
    protected $kernelSession;
    protected $compositeSessionManager;
    protected $sessionLocalStorageManager;
 
    /*
     * @var \SplPriorityQueue
     */
    protected $backgroundJobs;
 
    protected $license;
 
    protected function __construct()
    {
        ServiceLocator::getInstance()->registerByGlobalSettings();
        $this->backgroundJobs = new \SplPriorityQueue();
        $this->initializeExceptionHandler();
        $this->initializeCache();
        $this->createDatabaseConnection();
    }
 
    public static function getInstance()
    {
        if (!isset(static::$instance))
        {
            static::$instance = new static();
        }
        return static::$instance;
    }
 
    public static function hasInstance()
    {
        return isset(static::$instance);
    }
 
    public function initializeBasicKernel()
    {
    }
 
    public function initializeExtendedKernel(array $params)
    {
        $this->initializeContext($params);
 
        if (!$this->initialized)
        {
            $this->initializeSessions();
            $this->initializeSessionLocalStorage();
 
            $this->initialized = true;
        }
    }
 
    private function initializeSessions()
    {
        $resolver = new SessionConfigurationResolver(Configuration::getInstance());
        $resolver->resolve();
 
        $this->session = $resolver->getSession();
        $this->kernelSession = $resolver->getKernelSession();
 
        $this->compositeSessionManager = new CompositeSessionManager(
            $this->kernelSession,
            $this->session
        );
    }
 
    private function initializeSessionLocalStorage()
    {
        $cacheEngine = Data\Cache::createCacheEngine();
        if ($cacheEngine instanceof Data\LocalStorage\Storage\CacheEngineInterface)
        {
            $localSessionStorage = new Data\LocalStorage\Storage\CacheStorage($cacheEngine);
        }
        else
        {
            $localSessionStorage = new Data\LocalStorage\Storage\NativeSessionStorage(
                $this->getSession()
            );
        }
 
        $this->sessionLocalStorageManager = new Data\LocalStorage\SessionLocalStorageManager($localSessionStorage);
        $configLocalStorage = Config\Configuration::getValue("session_local_storage") ?: [];
        if (isset($configLocalStorage['ttl']))
        {
            $this->sessionLocalStorageManager->setTtl($configLocalStorage['ttl']);
        }
    }
 
    public function getRouter(): Router
    {
        return $this->router;
    }
 
    public function setRouter(Router $router): void
    {
        $this->router = $router;
    }
 
    public function getCurrentRoute(): Route
    {
        return $this->currentRoute;
    }
 
    public function setCurrentRoute(Route $currentRoute): void
    {
        $this->currentRoute = $currentRoute;
    }
 
    abstract protected function initializeContext(array $params);
 
    abstract public function start();
 
    public function run()
    {
    }
 
    public function end($status = 0, Response $response = null)
    {
        if($response === null)
        {
            //use default response
            $response = $this->context->getResponse();
 
            //it's possible to have open buffers
            $content = '';
            $n = ob_get_level();
            while(($c = ob_get_clean()) !== false && $n > 0)
            {
                $content .= $c;
                $n--;
            }
 
            if($content <> '')
            {
                $response->appendContent($content);
            }
        }
 
        $this->handleResponseBeforeSend($response);
        //this is the last point of output - all output below will be ignored
        $response->send();
 
        $this->terminate($status);
    }
 
    protected function handleResponseBeforeSend(Response $response): void
    {
        $kernelSession = $this->getKernelSession();
        if (!($kernelSession instanceof KernelSessionProxy) && $kernelSession->isStarted())
        {
            //save session data in cookies
            $kernelSession->getSessionHandler()->setResponse($response);
            $kernelSession->save();
        }
    }
 
    public function terminate($status = 0)
    {
        //old kernel staff
        \CMain::RunFinalActionsInternal();
 
        //Release session
        session_write_close();
 
        $pool = $this->getConnectionPool();
 
        $pool->useMasterOnly(true);
 
        $this->runBackgroundJobs();
 
        $pool->useMasterOnly(false);
 
        Data\ManagedCache::finalize();
 
        $pool->disconnect();
 
        exit($status);
    }
 
    protected function initializeExceptionHandler()
    {
        $exceptionHandler = new Diag\ExceptionHandler();
 
        $exceptionHandling = Config\Configuration::getValue("exception_handling");
        if ($exceptionHandling == null)
            $exceptionHandling = array();
 
        if (!isset($exceptionHandling["debug"]) || !is_bool($exceptionHandling["debug"]))
            $exceptionHandling["debug"] = false;
        $exceptionHandler->setDebugMode($exceptionHandling["debug"]);
 
        if (!empty($exceptionHandling['track_modules']) && is_array($exceptionHandling['track_modules']))
        {
            $exceptionHandler->setTrackModules($exceptionHandling['track_modules']);
        }
 
        if (isset($exceptionHandling["handled_errors_types"]) && is_int($exceptionHandling["handled_errors_types"]))
            $exceptionHandler->setHandledErrorsTypes($exceptionHandling["handled_errors_types"]);
 
        if (isset($exceptionHandling["exception_errors_types"]) && is_int($exceptionHandling["exception_errors_types"]))
            $exceptionHandler->setExceptionErrorsTypes($exceptionHandling["exception_errors_types"]);
 
        if (isset($exceptionHandling["ignore_silence"]) && is_bool($exceptionHandling["ignore_silence"]))
            $exceptionHandler->setIgnoreSilence($exceptionHandling["ignore_silence"]);
 
        if (isset($exceptionHandling["assertion_throws_exception"]) && is_bool($exceptionHandling["assertion_throws_exception"]))
            $exceptionHandler->setAssertionThrowsException($exceptionHandling["assertion_throws_exception"]);
 
        if (isset($exceptionHandling["assertion_error_type"]) && is_int($exceptionHandling["assertion_error_type"]))
            $exceptionHandler->setAssertionErrorType($exceptionHandling["assertion_error_type"]);
 
        $exceptionHandler->initialize(
            array($this, "createExceptionHandlerOutput"),
            array($this, "createExceptionHandlerLog")
        );
 
        ServiceLocator::getInstance()->addInstance('exceptionHandler', $exceptionHandler);
    }
 
    public function createExceptionHandlerLog()
    {
        $exceptionHandling = Config\Configuration::getValue("exception_handling");
 
        if (!is_array($exceptionHandling) || !isset($exceptionHandling["log"]) || !is_array($exceptionHandling["log"]))
        {
            return null;
        }
 
        $options = $exceptionHandling["log"];
 
        $log = null;
 
        if (isset($options["class_name"]) && !empty($options["class_name"]))
        {
            if (isset($options["extension"]) && !empty($options["extension"]) && !extension_loaded($options["extension"]))
            {
                return null;
            }
 
            if (isset($options["required_file"]) && !empty($options["required_file"]) && ($requiredFile = Loader::getLocal($options["required_file"])) !== false)
            {
                require_once($requiredFile);
            }
 
            $className = $options["class_name"];
            if (!class_exists($className))
            {
                return null;
            }
 
            $log = new $className();
        }
        elseif (isset($options["settings"]) && is_array($options["settings"]))
        {
            $log = new Diag\FileExceptionHandlerLog();
        }
        else
        {
            return null;
        }
 
        $log->initialize(
            isset($options["settings"]) && is_array($options["settings"]) ? $options["settings"] : array()
        );
 
        return $log;
    }
 
    public function createExceptionHandlerOutput()
    {
        return new Diag\ExceptionHandlerOutput();
    }
 
    protected function createDatabaseConnection()
    {
        $this->connectionPool = new Data\ConnectionPool();
    }
 
    protected function initializeCache()
    {
        //TODO: Should be transfered to where GET parameter is defined in future
        //magic parameters: show cache usage statistics
        $show_cache_stat = "";
        if (isset($_GET["show_cache_stat"]))
        {
            $show_cache_stat = (strtoupper($_GET["show_cache_stat"]) == "Y" ? "Y" : "");
            @setcookie("show_cache_stat", $show_cache_stat, false, "/");
        }
        elseif (isset($_COOKIE["show_cache_stat"]))
        {
            $show_cache_stat = $_COOKIE["show_cache_stat"];
        }
        Data\Cache::setShowCacheStat($show_cache_stat === "Y");
 
        if (isset($_GET["clear_cache_session"]))
            Data\Cache::setClearCacheSession($_GET["clear_cache_session"] === 'Y');
        if (isset($_GET["clear_cache"]))
            Data\Cache::setClearCache($_GET["clear_cache"] === 'Y');
    }
 
    public function getExceptionHandler()
    {
        return ServiceLocator::getInstance()->get('exceptionHandler');
    }
 
    public function getConnectionPool()
    {
        return $this->connectionPool;
    }
 
    public function getContext()
    {
        return $this->context;
    }
 
    public function setContext(Context $context)
    {
        $this->context = $context;
    }
 
    public function getLicense(): License
    {
        if (!$this->license)
        {
            $this->license = new License();
        }
 
        return $this->license;
    }
 
    public static function getConnection($name = "")
    {
        $pool = Application::getInstance()->getConnectionPool();
        return $pool->getConnection($name);
    }
 
    public function getCache()
    {
        return Data\Cache::createInstance();
    }
 
    public function getManagedCache()
    {
        if ($this->managedCache == null)
        {
            $this->managedCache = new Data\ManagedCache();
        }
 
        return $this->managedCache;
    }
 
    public function getTaggedCache()
    {
        if ($this->taggedCache == null)
        {
            $this->taggedCache = new Data\TaggedCache();
        }
 
        return $this->taggedCache;
    }
 
    final public function getSessionLocalStorageManager(): Data\LocalStorage\SessionLocalStorageManager
    {
        return $this->sessionLocalStorageManager;
    }
 
    final public function getLocalSession($name): Data\LocalStorage\SessionLocalStorage
    {
        return $this->sessionLocalStorageManager->get($name);
    }
 
    final public function getKernelSession(): SessionInterface
    {
        return $this->kernelSession;
    }
 
    final public function getSession(): SessionInterface
    {
        return $this->session;
    }
 
    final public function getCompositeSessionManager(): CompositeSessionManager
    {
        return $this->compositeSessionManager;
    }
 
    public static function getUserTypeManager()
    {
        global $USER_FIELD_MANAGER;
        return $USER_FIELD_MANAGER;
    }
 
    public static function isUtfMode()
    {
        static $isUtfMode = null;
        if ($isUtfMode === null)
        {
            $isUtfMode = Config\Configuration::getValue("utf_mode");
            if ($isUtfMode === null)
                $isUtfMode = false;
        }
        return $isUtfMode;
    }
 
    public static function getDocumentRoot()
    {
        static $documentRoot = null;
        if ($documentRoot != null)
            return $documentRoot;
 
        $context = Application::getInstance()->getContext();
        if ($context != null)
        {
            $server = $context->getServer();
            if ($server != null)
                return $documentRoot = $server->getDocumentRoot();
        }
 
        return Loader::getDocumentRoot();
    }
 
    public static function getPersonalRoot()
    {
        static $personalRoot = null;
        if ($personalRoot != null)
            return $personalRoot;
 
        $context = Application::getInstance()->getContext();
        if ($context != null)
        {
            $server = $context->getServer();
            if ($server != null)
                return $personalRoot = $server->getPersonalRoot();
        }
 
        return $_SERVER["BX_PERSONAL_ROOT"] ?? '/bitrix';
    }
 
    public static function resetAccelerator()
    {
        if (defined("BX_NO_ACCELERATOR_RESET"))
            return;
 
        $fl = Config\Configuration::getValue("no_accelerator_reset");
        if ($fl)
            return;
 
        if (function_exists("accelerator_reset"))
            accelerator_reset();
        elseif (function_exists("wincache_refresh_if_changed"))
            wincache_refresh_if_changed();
    }
 
    public function addBackgroundJob(callable $job, array $args = [], $priority = self::JOB_PRIORITY_NORMAL)
    {
        $this->backgroundJobs->insert([$job, $args], $priority);
 
        return $this;
    }
 
    protected function runBackgroundJobs()
    {
        $lastException = null;
        $exceptionHandler = $this->getExceptionHandler();
 
        //jobs can be added from jobs
        while($this->backgroundJobs->valid())
        {
            //clear the queue
            $jobs = [];
            foreach ($this->backgroundJobs as $job)
            {
                $jobs[] = $job;
            }
 
            //do job
            foreach ($jobs as $job)
            {
                try
                {
                    call_user_func_array($job[0], $job[1]);
                }
                catch (\Throwable $exception)
                {
                    $lastException = $exception;
                    $exceptionHandler->writeToLog($exception);
                }
            }
        }
 
        if ($lastException !== null)
        {
            throw $lastException;
        }
    }
 
    public function isInitialized()
    {
        return $this->initialized;
    }
}