vendor/php-flasher/flasher-symfony/Storage/Storage.php line 71

Open in your IDE?
  1. <?php
  3. namespace Flasher\Symfony\Storage;
  5. use Flasher\Prime\Envelope;
  6. use Flasher\Prime\Stamp\UuidStamp;
  7. use Flasher\Prime\Storage\StorageInterface;
  8. use Symfony\Component\HttpFoundation\RequestStack;
  9. use Symfony\Component\HttpFoundation\Session as LegacySession;
  10. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  12. final class Storage implements StorageInterface
  13. {
  14.     const ENVELOPES_NAMESPACE = 'flasher::envelopes';
  16.     /**
  17.      * @var SessionInterface|RequestStack
  18.      */
  19.     private $requestStack;
  21.     /**
  22.      * @param SessionInterface|RequestStack $session
  23.      */
  24.     public function __construct($requestStack)
  25.     {
  26.         $this->requestStack = $requestStack;
  27.     }
  29.     public function all()
  30.     {
  31.         return $this->session()->get(self::ENVELOPES_NAMESPACE, array());
  32.     }
  34.     public function add($envelopes)
  35.     {
  36.         $envelopes = is_array($envelopes) ? $envelopes : func_get_args();
  38.         $this->session()->set(self::ENVELOPES_NAMESPACE, array_merge($this->all(), $envelopes));
  39.     }
  41.     public function update($envelopes)
  42.     {
  43.         $envelopes = is_array($envelopes) ? $envelopes : func_get_args();
  44.         $map = UuidStamp::indexByUuid($envelopes);
  46.         $store = $this->all();
  47.         foreach ($store as $index => $envelope) {
  48.             $uuid = $envelope->get('Flasher\Prime\Stamp\UuidStamp')->getUuid();
  50.             if (!isset($map[$uuid])) {
  51.                 continue;
  52.             }
  54.             $store[$index] = $map[$uuid];
  55.         }
  57.         $this->session()->set(self::ENVELOPES_NAMESPACE, $store);
  58.     }
  60.     public function remove($envelopes)
  61.     {
  62.         $envelopes = is_array($envelopes) ? $envelopes : func_get_args();
  63.         $map = UuidStamp::indexByUuid($envelopes);
  65.         $store = array_filter($this->all(), function (Envelope $envelope) use ($map) {
  66.             $uuid = $envelope->get('Flasher\Prime\Stamp\UuidStamp')->getUuid();
  68.             return !isset($map[$uuid]);
  69.         });
  71.         $this->session()->set(self::ENVELOPES_NAMESPACE, $store);
  72.     }
  74.     public function clear()
  75.     {
  76.         $this->session()->set(self::ENVELOPES_NAMESPACE, array());
  77.     }
  79.     /**
  80.      * @return SessionInterface
  81.      */
  82.     private function session()
  83.     {
  84.         if ($this->requestStack instanceof SessionInterface || $this->requestStack instanceof LegacySession) {
  85.             return $this->requestStack;
  86.         }
  88.         if (method_exists($this->requestStack, 'getSession')) {
  89.             return $this->requestStack->getSession();
  90.         }
  92.         $request = $this->requestStack->getCurrentRequest();
  94.         return $request->getSession();
  95.     }
  96. }