Инициализация сессии.

Author: ProklUng

configs/notifier.php

@@ -3,9 +3,12 @@
 namespace Symfony\Component\DependencyInjection\Loader\Configurator;
 
 use Proklung\Notifier\Email\CustomEmailChannel;
+use Proklung\Notifier\Session\SessionInitializator;
 use Symfony\Bridge\Monolog\Handler\NotifierHandler;
 use Symfony\Component\EventDispatcher\EventDispatcher;
+use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\RequestStack;
+use Symfony\Component\HttpFoundation\Session\SessionInterface;
 use Symfony\Component\Mailer\Mailer;
 use Symfony\Component\Notifier\Channel\BrowserChannel;
 use Symfony\Component\Notifier\Channel\ChannelPolicy;
@@ -52,9 +55,20 @@
     }
 
     $container->services()
+        ->set('session_migrator', SessionInitializator::class)
+
+        ->set('session_instance', SessionInterface::class)
+        ->public()
+        ->factory([service('session_migrator'), 'session'])
+
         ->set('request_stack', RequestStack::class)
+        ->call('push', [service('module_request')])
         ->set('event_dispatcher', EventDispatcher::class)
 
+        ->set('module_request', Request::class)
+        ->factory([Request::class, 'createFromGlobals'])
+        ->call('setSession', [service('session_instance')])
+
         ->set('notifier', Notifier::class)
             ->args([tagged_locator('notifier.channel', 'channel'), service('notifier.channel_policy')->ignoreOnInvalid()])
         ->public()

lib/Session/SessionInitializator.php

@@ -0,0 +1,130 @@
+<?php
+
+namespace Proklung\Notifier\Session;
+
+use Symfony\Component\HttpFoundation\Session\Flash\FlashBagInterface;
+use Symfony\Component\HttpFoundation\Session\Session;
+use Symfony\Component\HttpFoundation\Session\SessionInterface;
+use Symfony\Component\HttpFoundation\Session\Storage\PhpBridgeSessionStorage;
+
+/**
+ * Class SessionInitializator
+ * @package Proklung\Notifier\Session
+ */
+class SessionInitializator
+{
+    /**
+     * @var Session|null $session Сессии Symfony.
+     */
+    private $session;
+
+    /**
+     * Инициализация.
+     *
+     * @return void
+     */
+    public function init(): void
+    {
+        $this->session = new Session(new PhpBridgeSessionStorage());
+        // Если сессия не запущена, то запустить и мигрировать.
+        if (!$this->session->isStarted()) {
+            $this->session->start();
+            $this->migrateSession();
+        }
+    }
+
+    /**
+     * Объект Session.
+     *
+     * @return SessionInterface
+     *
+     * @since 28.10.2020 Change to interface.
+     */
+    public function session(): SessionInterface
+    {
+        if ($this->session === null) {
+            $this->init();
+        }
+
+        return $this->session;
+    }
+
+    /**
+     * FlashBag.
+     *
+     * @return FlashBagInterface
+     */
+    public function getFlashBag() : FlashBagInterface
+    {
+        if ($this->session === null) {
+            $this->init();
+        }
+
+        return $this->session->getFlashBag();
+    }
+
+    /**
+     * Флэш сообщения из сессии.
+     *
+     * @param string $message ID сообщения.
+     *
+     * @return array
+     */
+    public function getFlashMessages(string $message): array
+    {
+        if ($this->session === null) {
+            $this->init();
+        }
+
+        return $this->session->getFlashBag()->get($message);
+    }
+
+    /**
+     * Установить - получить значение ключа.
+     *
+     * @param string $key   Ключ.
+     * @param mixed  $value Значение.
+     *
+     * @return null|mixed
+     */
+    public function value(string $key, $value = null)
+    {
+        if ($this->session === null) {
+            $this->init();
+        }
+
+        if ($value === null) {
+            return $this->session->get($key);
+        }
+
+        $this->session->set($key, $value);
+
+        return null;
+    }
+
+    /**
+     * Миграция $_SESSION в сессии Symfony.
+     *
+     * @return void
+     */
+    public function migrateSession() : void
+    {
+        foreach ($_SESSION as $key => $item) {
+            $this->value($key, $item);
+        }
+    }
+
+    /**
+     * Csrf токен приложения.
+     *
+     * @return string
+     */
+    public function csrfTokenApp() : string
+    {
+        if ($this->session === null) {
+            $this->init();
+        }
+
+        return (string)$this->session->get('csrf_token');
+    }
+}