add lock collection

Author: mmasiukevich

src/InMemoryLockCollection.php

@@ -0,0 +1,56 @@
+<?php
+
+/**
+ * PHP Mutex implementation.
+ *
+ * @author  Maksim Masiukevich <[email protected]>
+ * @license MIT
+ * @license https://opensource.org/licenses/MIT
+ */
+
+declare(strict_types = 1);
+
+namespace ServiceBus\Mutex;
+
+use Amp\Promise;
+use Amp\Success;
+use ServiceBus\Mutex\Storage\InMemoryCollectionStorage;
+
+/**
+ *
+ */
+final class InMemoryLockCollection implements LockCollection
+{
+    public function __destruct()
+    {
+        InMemoryCollectionStorage::instance()->reset();
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function has(string $key): Promise
+    {
+        return new Success(InMemoryCollectionStorage::instance()->has($key));
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function place(string $key, Lock $lock): Promise
+    {
+        InMemoryCollectionStorage::instance()->add($key, $lock);
+
+        return new Success();
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function remove(string $key): Promise
+    {
+        InMemoryCollectionStorage::instance()->remove($key);
+
+        return new Success();
+    }
+}

src/LockCollection.php

@@ -0,0 +1,27 @@
+<?php
+
+/**
+ * PHP Mutex implementation.
+ *
+ * @author  Maksim Masiukevich <[email protected]>
+ * @license MIT
+ * @license https://opensource.org/licenses/MIT
+ */
+
+declare(strict_types = 1);
+
+namespace ServiceBus\Mutex;
+
+use Amp\Promise;
+
+/**
+ *
+ */
+interface LockCollection
+{
+    public function has(string $key): Promise;
+
+    public function place(string $key, Lock $lock): Promise;
+
+    public function remove(string $key): Promise;
+}

src/Storage/InMemoryCollectionStorage.php

@@ -0,0 +1,79 @@
+<?php
+
+/**
+ * PHP Mutex implementation.
+ *
+ * @author  Maksim Masiukevich <[email protected]>
+ * @license MIT
+ * @license https://opensource.org/licenses/MIT
+ */
+
+declare(strict_types = 1);
+
+namespace ServiceBus\Mutex\Storage;
+
+use ServiceBus\Mutex\Lock;
+
+/**
+ * @internal
+ */
+final class InMemoryCollectionStorage
+{
+    /**
+     * @psalm-var array<string, \ServiceBus\Mutex\Lock>
+     */
+    private $localStorage = [];
+
+    /** @var self|null */
+    private static $instance = null;
+
+    /**
+     * @return self
+     */
+    public static function instance(): self
+    {
+        if(self::$instance === null)
+        {
+            self::$instance = new self();
+        }
+
+        return self::$instance;
+    }
+
+    public function has(string $key): bool
+    {
+        return isset($this->localStorage[$key]);
+    }
+
+    public function remove(string $key): void
+    {
+        unset($this->localStorage[$key]);
+    }
+
+    public function add(string $key, Lock $lock): void
+    {
+        $this->localStorage[$key] = $lock;
+    }
+
+    /**
+     * Reset instance.
+     */
+    public function reset(): void
+    {
+        self::$instance = null;
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    private function __clone()
+    {
+    }
+
+    /**
+     * @codeCoverageIgnore
+     */
+    private function __construct()
+    {
+    }
+}