SynchronizePersistentOnLoginObserver.php

Go to the documentation of this file.

<?php
namespace Magento\Persistent\Observer;

use Magento\Framework\Event\Observer;

use Magento\Framework\Event\ObserverInterface;

class SynchronizePersistentOnLoginObserver implements ObserverInterface
{
    protected $_persistentSession;

    protected $_persistentData = null;

    protected $_sessionFactory;

    protected $_customerSession;

    public function __construct(
        \Magento\Persistent\Helper\Data $persistentData,
        \Magento\Persistent\Helper\Session $persistentSession,
        \Magento\Customer\Model\Session $customerSession,
        \Magento\Persistent\Model\SessionFactory $sessionFactory
    ) {
        $this->_persistentData = $persistentData;
        $this->_persistentSession = $persistentSession;
        $this->_customerSession = $customerSession;
        $this->_sessionFactory = $sessionFactory;
    }

    public function execute(Observer $observer)
    {
        $customer = $observer->getEvent()->getCustomer();
        // Check if customer is valid (remove persistent cookie for invalid customer)
        if (!$customer || !$customer->getId() || !$this->_persistentSession->isRememberMeChecked()) {
            $this->_sessionFactory->create()->removePersistentCookie();
            return;
        }

        $persistentLifeTime = $this->_persistentData->getLifeTime();
        // Delete persistent session, if persistent could not be applied
        if ($this->_persistentData->isEnabled() && $persistentLifeTime <= 0) {
            // Remove current customer persistent session
            $this->_sessionFactory->create()->deleteByCustomerId($customer->getId());
            return;
        }

        $sessionModel = $this->_persistentSession->getSession();

        // Check if session is wrong or not exists, so create new session
        if (!$sessionModel->getId() || $sessionModel->getCustomerId() != $customer->getId()) {
            $sessionModel = $this->_sessionFactory->create();
            $sessionModel->setLoadExpired()->loadByCustomerId($customer->getId());
            if (!$sessionModel->getId()) {
                $sessionModel = $this->_sessionFactory->create();
                $sessionModel->setCustomerId($customer->getId())->save();
            }
            $this->_persistentSession->setSession($sessionModel);
        }

        // Set new cookie
        if ($sessionModel->getId()) {
            $sessionModel->setPersistentCookie(
                $persistentLifeTime,
                $this->_customerSession->getCookiePath()
            );
        }
    }
}