init shared memory buffer for async operations

src/Abstract/Model/Connection.php

@@ -4,107 +4,183 @@ declare(strict_types=1);
 
 namespace Yggverse\Yoda\Abstract\Model;
 
+use \Yggverse\Yoda\Model\Buffer;
+
 abstract class Connection implements \Yggverse\Yoda\Interface\Model\Connection
 {
-    // Status
-    private bool $_completed = false;
+    private Buffer $_buffer;
+
+    public function __construct(
+        Buffer $buffer
+    ) {
+        // Use shared memory for async operations
+        $this->_buffer = $buffer;
 
-    // Response
-    private ?string $_title = null;
-    private ?string $_subtitle = null;
-    private ?string $_tooltip = null;
-    private ?string $_mime = null;
-    private ?string $_data = null;
-    private ?string $_redirect = null;
-    private ?array  $_request = null;
+        // Set defaults
+        $this->_buffer->set(
+            'completed',
+            false
+        );
+
+        $this->_buffer->set(
+            'title',
+            null
+        );
+
+        $this->_buffer->set(
+            'subtitle',
+            null
+        );
+
+        $this->_buffer->set(
+            'tooltip',
+            null
+        );
+
+        $this->_buffer->set(
+            'mime',
+            null
+        );
+        $this->_buffer->set(
+            'data',
+            null
+        );
+
+        $this->_buffer->set(
+            'redirect',
+            null
+        );
+
+        $this->_buffer->set(
+            'request',
+            null
+        );
+    }
 
     public function isCompleted(): bool
     {
-        return $this->_completed;
+        return $this->_buffer->get(
+            'completed'
+        );
     }
 
     public function setCompleted(
         bool $completed
     ): void
     {
-        $this->_completed = $completed;
+        $this->_buffer->set(
+            'completed',
+            $completed
+        );
     }
 
     public function getTitle(): ?string
     {
-        return $this->_title;
+        return $this->_buffer->get(
+            'title'
+        );
     }
 
     public function setTitle(
         ?string $title = null
     ): void
     {
-        $this->_title = $title;
+        $this->_buffer->set(
+            'title',
+            $title
+        );
     }
 
     public function getSubtitle(): ?string
     {
-        return $this->_subtitle;
+        return $this->_buffer->get(
+            'subtitle'
+        );
     }
 
     public function setSubtitle(
         ?string $subtitle = null
     ): void
     {
-        $this->_subtitle = $subtitle;
+        $this->_buffer->set(
+            'subtitle',
+            $subtitle
+        );
     }
 
     public function getTooltip(): ?string
     {
-        return $this->_tooltip;
+        return $this->_buffer->get(
+            'tooltip'
+        );
     }
 
     public function setTooltip(
         ?string $tooltip = null
     ): void
     {
-        $this->_tooltip = $tooltip;
+        $this->_buffer->set(
+            'tooltip',
+            $tooltip
+        );
     }
 
     public function getMime(): ?string
     {
-        return $this->_mime;
+        return $this->_buffer->get(
+            'mime'
+        );
     }
 
     public function setMime(
         ?string $mime = null
     ): void
     {
-        $this->_mime = $mime;
+        $this->_buffer->set(
+            'mime',
+            $mime
+        );
     }
 
     public function getData(): ?string
     {
-        return $this->_data;
+        return $this->_buffer->get(
+            'data'
+        );
     }
 
     public function setData(
         ?string $data = null
     ): void
     {
-        $this->_data = $data;
+        $this->_buffer->set(
+            'data',
+            $data
+        );
     }
 
     public function getRedirect(): ?string
     {
-        return $this->_redirect;
+        return $this->_buffer->get(
+            'redirect'
+        );
     }
 
     public function setRedirect(
         ?string $redirect = null
     ): void
     {
-        $this->_redirect = $redirect;
+        $this->_buffer->set(
+            'redirect',
+            $redirect
+        );
     }
 
     public function getRequest(): ?array
     {
-        return $this->_request;
+        return $this->_buffer->get(
+            'request'
+        );
     }
 
     public function setRequest(
@@ -112,21 +188,29 @@ abstract class Connection implements \Yggverse\Yoda\Interface\Model\Connection
         bool $visible = true
     ): void
     {
-        $this->_request = [
+        $this->_buffer->set(
+            'request',
+            [
                 'placeholder' => $placeholder,
                 'visible'     => $visible
-        ];
+            ]
+        );
     }
 
     public function unsetRequest(): void
     {
-        $this->_request = null;
+        $this->_buffer->set(
+            'request',
+            null
+        );
     }
 
     public function getLength(): ?int
     {
         return mb_strlen(
-            $this->_data
+            $this->_buffer->get(
+                'data'
+            )
         );
     }
 }

src/Interface/Model/Buffer.php

@@ -0,0 +1,21 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yggverse\Yoda\Interface\Model;
+
+/*
+ * Shared memory API for async operations
+ *
+ */
+interface Buffer
+{
+    public function get(
+        string $key
+    ): mixed;
+
+    public function set(
+        string $key,
+        mixed $value
+    ): void;
+}