forked from php-cache/cache
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathPsr6SessionHandler.php
More file actions
123 lines (105 loc) · 3 KB
/
Psr6SessionHandler.php
File metadata and controls
123 lines (105 loc) · 3 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
<?php
/*
* This file is part of php-cache organization.
*
* (c) 2015 Aaron Scherer <aequasi@gmail.com>, Tobias Nyholm <tobias.nyholm@gmail.com>
*
* This source file is subject to the MIT license that is bundled
* with this source code in the file LICENSE.
*/
namespace Cache\SessionHandler;
use Psr\Cache\CacheItemPoolInterface;
/**
* @author Aaron Scherer <aequasi@gmail.com>
* @author Daniel Bannert <d.bannert@anolilab.de>
*/
class Psr6SessionHandler extends AbstractSessionHandler
{
/**
* @type CacheItemPoolInterface
*/
private $cache;
/**
* @type int Time to live in seconds
*/
private $ttl;
/**
* @type string Key prefix for shared environments.
*/
private $prefix;
/**
* @param CacheItemPoolInterface $cache
* @param array $options {
* @type int $ttl The time to live in seconds
* @type string $prefix The prefix to use for the cache keys in order to avoid collision
* }
*
* @throws \InvalidArgumentException
*/
public function __construct(CacheItemPoolInterface $cache, array $options = [])
{
$this->cache = $cache;
if ($diff = array_diff(array_keys($options), ['prefix', 'ttl'])) {
throw new \InvalidArgumentException(sprintf(
'The following options are not supported "%s"',
implode(', ', $diff)
));
}
$this->ttl = isset($options['ttl']) ? (int) $options['ttl'] : 86400;
$this->prefix = isset($options['prefix']) ? $options['prefix'] : 'psr6ses_';
}
/**
* {@inheritdoc}
*/
public function updateTimestamp($sessionId, $data)
{
$item = $this->getCacheItem($sessionId);
$item->expiresAt(\DateTime::createFromFormat('U', \time() + $this->ttl));
return $this->cache->save($item);
}
/**
* {@inheritdoc}
*
* @throws \Psr\Cache\InvalidArgumentException
*/
protected function doRead($sessionId)
{
$item = $this->getCacheItem($sessionId);
if ($item->isHit()) {
return $item->get();
}
return '';
}
/**
* {@inheritdoc}
*
* @throws \Psr\Cache\InvalidArgumentException
*/
protected function doWrite($sessionId, $data)
{
$item = $this->getCacheItem($sessionId);
$item->set($data)
->expiresAfter($this->ttl);
return $this->cache->save($item);
}
/**
* {@inheritdoc}
*
* @throws \Psr\Cache\InvalidArgumentException
*/
protected function doDestroy($sessionId)
{
return $this->cache->deleteItem($this->prefix.$sessionId);
}
/**
* @param string $sessionId
*
* @throws \Psr\Cache\InvalidArgumentException
*
* @return \Psr\Cache\CacheItemInterface
*/
private function getCacheItem($sessionId)
{
return $this->cache->getItem($this->prefix.$sessionId);
}
}