update shared memory pool api

src/Abstract/Model/Connection.php

@@ -17,34 +17,34 @@ abstract class Connection implements \Yggverse\Yoda\Interface\Model\Connection
         $this->_pool = $pool ? $pool : new Pool;
 
         // Set defaults
-        $this->_pool->set(
+        $this->_pool->init(
             'completed'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'title'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'subtitle'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'tooltip'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'mime'
         );
-        $this->_pool->set(
+        $this->_pool->init(
             'data'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'redirect'
         );
 
-        $this->_pool->set(
+        $this->_pool->init(
             'request'
         );
     }

src/Interface/Model/Pool.php

@@ -14,18 +14,37 @@ interface Pool
         ?string $namespace = null
     );
 
+    public function init(
+        string $key,
+        int $size = 0xfffff,
+        string $flags = 'c',
+        int $mode = 0644,
+    ): ?\Shmop;
+
+    public function read(
+        string $key,
+        int $start = 0,
+        int $count = 0
+    ): ?string;
+
+    public function write(
+        string $key,
+        string $value,
+        int $offset = 0
+    ): int;
+
+    public function delete(
+        string $key
+    ): bool;
+
     public function get(
         string $key
-    ): ?string;
+    ): string;
 
     public function set(
         string $key,
-        ?string $value = null,
-        string $flags = 'c',
-        int $offset = 0,
-        int $mode = 0644,
-        ?string $encoding = null
-    ): int;
+        ?string $value = null
+    ): void;
 
     public function reset(): void;
 }

src/Model/Pool.php

@@ -18,12 +18,39 @@ class Pool implements \Yggverse\Yoda\Interface\Model\Pool
         );
     }
 
-    public function get(
+    public function init(
+        string $key,
+        int $size = 0xfffff,
+        string $flags = 'c',
+        int $mode = 0644,
+    ): ?\Shmop
+    {
+        if (isset($this->_data[$key]))
+        {
+            throw new \Exception;
+        }
+
+        return $this->_data[$key] = shmop_open(
+            crc32(
+                $this->_namespace . $key
+            ),
+            $flags,
+            $mode,
+            $size
+        );
+    }
+
+    public function read(
         string $key,
         int $start = 0,
         int $count = 0
     ): ?string
     {
+        if (!isset($this->_data[$key]))
+        {
+            throw new \Exception;
+        }
+
         if (empty($this->_data[$key]))
         {
             return null;
@@ -38,26 +65,17 @@ class Pool implements \Yggverse\Yoda\Interface\Model\Pool
         );
     }
 
-    public function set(
+    public function write(
         string $key,
-        ?string $value = null,
-        string $flags = 'c',
-        int $offset = 0,
-        int $mode = 0644,
-        ?string $encoding = null
+        string $value,
+        int $offset = 0
     ): int
     {
-        if (empty($value))
+        if (!isset($this->_data[$key]))
         {
-            // @TODO delete from memory
-
-            $this->_data[$key] = null;
-
-            return 0;
+            throw new \Exception;
         }
 
-        if ($this->_data[$key] = shmop_open(crc32($this->_namespace . $key), $flags, $mode, mb_strlen($value, $encoding)))
-        {
         return shmop_write(
             $this->_data[$key],
             $value,
@@ -65,19 +83,57 @@ class Pool implements \Yggverse\Yoda\Interface\Model\Pool
         );
     }
 
+    public function delete(
+        string $key
+    ): bool
+    {
+        if (!isset($this->_data[$key]))
+        {
             throw new \Exception;
         }
 
-    public function reset(): void
-    {
-        foreach ($this->_data as $data)
+        $result = shmop_delete(
+            $this->_data[$key]
+        );
+
+        $this->_data[$key] = null;
+
+        return $result;
+    }
+
+    public function get(
+        string $key
+    ): string
     {
-            if ($data)
+        return trim(
+            strval(
+                $this->read(
+                    $key
+                )
+            )
+        );
+    }
+
+    public function set(
+        string $key,
+        ?string $value = null
+    ): void
     {
-                shmop_delete(
-                    $data
+        $this->write(
+            $key,
+            strval(
+                $value
+            )
         );
     }
+
+    public function reset(): void
+    {
+        foreach ($this->_data as $key => $shmop)
+        {
+            $this->delete(
+                $key
+            );
         }
 
         $this->_data = [];