SynchronizePersistentOnLoginObserver.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Persistent\Observer;
  7. use Magento\Framework\Event\Observer;
  8. use Magento\Framework\Event\ObserverInterface;
  9. /**
  10. * Persistent Session Observer
  11. */
  12. class SynchronizePersistentOnLoginObserver implements ObserverInterface
  13. {
  14. /**
  15. * Persistent session
  16. *
  17. * @var \Magento\Persistent\Helper\Session
  18. */
  19. protected $_persistentSession;
  20. /**
  21. * Persistent data
  22. *
  23. * @var \Magento\Persistent\Helper\Data
  24. */
  25. protected $_persistentData = null;
  26. /**
  27. * Session factory
  28. *
  29. * @var \Magento\Persistent\Model\SessionFactory
  30. */
  31. protected $_sessionFactory;
  32. /**
  33. * Customer session
  34. *
  35. * @var \Magento\Customer\Model\Session
  36. */
  37. protected $_customerSession;
  38. /**
  39. * Constructor
  40. *
  41. * @param \Magento\Persistent\Helper\Data $persistentData
  42. * @param \Magento\Persistent\Helper\Session $persistentSession
  43. * @param \Magento\Customer\Model\Session $customerSession
  44. * @param \Magento\Persistent\Model\SessionFactory $sessionFactory
  45. */
  46. public function __construct(
  47. \Magento\Persistent\Helper\Data $persistentData,
  48. \Magento\Persistent\Helper\Session $persistentSession,
  49. \Magento\Customer\Model\Session $customerSession,
  50. \Magento\Persistent\Model\SessionFactory $sessionFactory
  51. ) {
  52. $this->_persistentData = $persistentData;
  53. $this->_persistentSession = $persistentSession;
  54. $this->_customerSession = $customerSession;
  55. $this->_sessionFactory = $sessionFactory;
  56. }
  57. /**
  58. * @param Observer $observer
  59. * @return void
  60. * @SuppressWarnings(PHPMD.CyclomaticComplexity)
  61. */
  62. public function execute(Observer $observer)
  63. {
  64. /** @var $customer \Magento\Customer\Api\Data\CustomerInterface */
  65. $customer = $observer->getEvent()->getCustomer();
  66. // Check if customer is valid (remove persistent cookie for invalid customer)
  67. if (!$customer || !$customer->getId() || !$this->_persistentSession->isRememberMeChecked()) {
  68. $this->_sessionFactory->create()->removePersistentCookie();
  69. return;
  70. }
  71. $persistentLifeTime = $this->_persistentData->getLifeTime();
  72. // Delete persistent session, if persistent could not be applied
  73. if ($this->_persistentData->isEnabled() && $persistentLifeTime <= 0) {
  74. // Remove current customer persistent session
  75. $this->_sessionFactory->create()->deleteByCustomerId($customer->getId());
  76. return;
  77. }
  78. /** @var $sessionModel \Magento\Persistent\Model\Session */
  79. $sessionModel = $this->_persistentSession->getSession();
  80. // Check if session is wrong or not exists, so create new session
  81. if (!$sessionModel->getId() || $sessionModel->getCustomerId() != $customer->getId()) {
  82. /** @var \Magento\Persistent\Model\Session $sessionModel */
  83. $sessionModel = $this->_sessionFactory->create();
  84. $sessionModel->setLoadExpired()->loadByCustomerId($customer->getId());
  85. if (!$sessionModel->getId()) {
  86. /** @var \Magento\Persistent\Model\Session $sessionModel */
  87. $sessionModel = $this->_sessionFactory->create();
  88. $sessionModel->setCustomerId($customer->getId())->save();
  89. }
  90. $this->_persistentSession->setSession($sessionModel);
  91. }
  92. // Set new cookie
  93. if ($sessionModel->getId()) {
  94. $sessionModel->setPersistentCookie(
  95. $persistentLifeTime,
  96. $this->_customerSession->getCookiePath()
  97. );
  98. }
  99. }
  100. }