forked from codeigniter4/CodeIgniter4
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathLockManager.php
More file actions
65 lines (53 loc) · 1.84 KB
/
Copy pathLockManager.php
File metadata and controls
65 lines (53 loc) · 1.84 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
<?php
declare(strict_types=1);
/**
* This file is part of CodeIgniter 4 framework.
*
* (c) CodeIgniter Foundation <admin@codeigniter.com>
*
* For the full copyright and license information, please view
* the LICENSE file that was distributed with this source code.
*/
namespace CodeIgniter\Lock;
use CodeIgniter\Cache\CacheInterface;
use CodeIgniter\Cache\Exceptions\CacheException;
use CodeIgniter\Cache\LockStoreInterface;
use CodeIgniter\Cache\LockStoreProviderInterface;
use CodeIgniter\Exceptions\InvalidArgumentException;
use CodeIgniter\Lock\Exceptions\LockException;
final readonly class LockManager
{
private const KEY_PREFIX = 'lock_';
private LockStoreInterface $store;
/**
* @param CacheInterface&LockStoreProviderInterface $cache Cache handler that supports lock stores.
*
* @throws LockException When the cache handler does not support locks.
*/
public function __construct(CacheInterface $cache)
{
if (! $cache instanceof LockStoreProviderInterface) {
throw LockException::forUnsupportedStore($cache::class);
}
try {
$this->store = $cache->lockStore();
} catch (CacheException) {
throw LockException::forUnsupportedStore($cache::class);
}
}
public function create(string $name, int $ttl = 300, ?string $owner = null): LockInterface
{
if ($name === '') {
throw new InvalidArgumentException('Lock name cannot be empty.');
}
return new Lock($this->store, $this->key($name), $ttl, $owner ?? bin2hex(random_bytes(16)));
}
public function restore(string $name, string $owner, int $ttl = 300): LockInterface
{
return $this->create($name, $ttl, $owner);
}
private function key(string $name): string
{
return self::KEY_PREFIX . hash('xxh128', $name);
}
}