draft kevacoin driver

src/Controller/Nex/Kevacoin.php

@@ -1,3 +1,208 @@
 <?php
 
-// @TODO
+namespace Yggverse\Next\Controller\Nex;
+
+class Kevacoin extends \Yggverse\Next\Abstract\Type\Nex
+{
+    private \Yggverse\Next\Model\Kevacoin $_kevacoin;
+
+    public function init()
+    {
+        // Validate environment arguments defined for this type
+        if (!$this->_environment->get('rpcscheme'))
+        {
+            throw new \Exception(
+                _('rpcscheme argument required!')
+            );
+        }
+
+        if (!$this->_environment->get('rpchost'))
+        {
+            throw new \Exception(
+                _('rpchost argument required!')
+            );
+        }
+
+        if (!$this->_environment->get('rpcport'))
+        {
+            throw new \Exception(
+                _('rpcport argument required!')
+            );
+        }
+
+        if (!$this->_environment->get('rpcuser'))
+        {
+            throw new \Exception(
+                _('rpcuser argument required!')
+            );
+        }
+
+        if (!$this->_environment->get('rpcpassword'))
+        {
+            throw new \Exception(
+                _('rpcpassword argument required!')
+            );
+        }
+
+        if (!$this->_environment->get('namespace'))
+        {
+            throw new \Exception(
+                _('namespace argument required!')
+            );
+        }
+
+        // Init KevaCoin
+        $this->_kevacoin = new \Yggverse\Next\Model\Kevacoin(
+            $this->_environment->get('rpcscheme'),
+            $this->_environment->get('rpcuser'),
+            $this->_environment->get('rpcpassword'),
+            $this->_environment->get('rpchost'),
+            $this->_environment->get('rpcport'),
+            $this->_environment->get('namespace')
+        );
+
+        // Dump event
+        if ($this->_environment->get('dump'))
+        {
+            print(
+                str_replace(
+                    [
+                        '{time}',
+                        '{host}',
+                        '{port}',
+                        '{rpcscheme}',
+                        '{rpchost}',
+                        '{rpcport}',
+                        '{namespace}'
+                    ],
+                    [
+                        (string) date('c'),
+                        (string) $this->_environment->get('host'),
+                        (string) $this->_environment->get('port'),
+                        (string) $this->_environment->get('port'),
+                        (string) $this->_environment->get('rpcscheme'),
+                        (string) $this->_environment->get('rpchost'),
+                        (string) $this->_environment->get('rpcport'),
+                        (string) $this->_environment->get('namespace')
+                    ],
+                    _('[{time}] [init] kevacoin server at nex://{host}:{port} connected to {rpcscheme}://{rpchost}:{rpcport}/{namespace}')
+                ) . PHP_EOL
+            );
+        }
+    }
+
+    public function onMessage(
+        \Ratchet\ConnectionInterface $connection,
+        $request
+    ) {
+        // Define response
+        $response = null;
+
+        // Filter request
+        $request = trim(
+            urldecode(
+                filter_var(
+                    $request,
+                    FILTER_SANITIZE_URL
+                )
+            )
+        );
+
+        // Route
+        switch (true)
+        {
+            // Try single record
+            case $value = $this->_kevacoin->getValue($request):
+
+                $response = $value;
+
+            break;
+
+            // Try virtual FS tree listing
+            case $list = $this->_kevacoin->getTree($request):
+
+                $line = [];
+
+                foreach ($list as $item)
+                {
+                    // Build gemini text link
+                    if ($item['link'])
+                    {
+                        $link =
+                        [
+                            '=>', // gemtext format
+                            $item['file'] ? $item['link']
+                                          : $item['link'] . '/'
+                        ];
+
+                        // Append alt name on link urlencoded
+                        if ($item['name'] != $item['link'])
+                        {
+                            $link[] = $item['name'];
+                        }
+
+                        // Append link to the new line
+                        $line[] = implode(
+                            ' ',
+                            $link
+                        );
+                    }
+                }
+
+                // Merge lines to response
+                $response = implode(
+                    PHP_EOL,
+                    $line
+                );
+
+            break;
+        }
+
+        // Dump event
+        if ($this->_environment->get('dump'))
+        {
+            // Print debug from template
+            print(
+                str_ireplace(
+                    [
+                        '{time}',
+                        '{host}',
+                        '{crid}',
+                        '{path}',
+                        '{size}'
+                    ],
+                    [
+                        (string) date('c'),
+                        (string) $connection->remoteAddress,
+                        (string) $connection->resourceId,
+                        (string) $request,
+                        (string) mb_strlen(
+                            $response
+                        )
+                    ],
+                    _('[{time}] [message] incoming connection {host}#{crid} "{path}" {size} bytes')
+                ) . PHP_EOL
+            );
+        }
+
+        // Noting to return?
+        if (empty($response))
+        {
+            // Try failure file on defined
+            /* @TODO fix
+            if ($fail = $this->_filesystem->file($this->_environment->get('fail')))
+            {
+                $response = $fail;
+            }
+            */
+        }
+
+        // Send response
+        $connection->send(
+            $response
+        );
+
+        // Disconnect
+        $connection->close();
+    }
+}

src/Model/Kevacoin.php

@@ -46,4 +46,98 @@ class Kevacoin
         // Init namespace
         $this->_namespace = $namespace;
     }
+
+    // Get record by key
+    public function get(
+        string $key
+    ): ?array
+    {
+        // Skip meta entities
+        if (str_starts_with($key, '_'))
+        {
+            return null;
+        }
+
+        // Get record
+        return $this->_client->kevaGet(
+            $this->_namespace,
+            $key
+        );
+    }
+
+    // Find records by key query
+    public function find(
+        string $query
+    ): array
+    {
+        $records = [];
+
+        foreach ((array) $this->_client->kevaFilter($this->_namespace, $query) as $record)
+        {
+            // Skip meta entities
+            if (str_starts_with($record['key'], '_'))
+            {
+                continue;
+            }
+
+            // Append record
+            $records[] = $record;
+        }
+
+        return $records;
+    }
+
+    // Get record value by key
+    public function getValue(
+        string $key
+    ): ?string
+    {
+        // Use common method
+        if ($record = $this->get($key))
+        {
+            return $record['value'];
+        }
+
+        return null;
+    }
+
+    // Build records as the FS tree by virtual path prefix in keys
+    public function getTree(
+        string $prefix
+    ): array
+    {
+        $list = [];
+
+        foreach ($this->find($prefix) as $record)
+        {
+            // Remove prefix from path
+            $path = trim(
+                str_replace(
+                    $prefix,
+                    '',
+                    $record['key']
+                ),
+                '/'
+            );
+
+            // Parse segments
+            if ($part = explode('/', $path))
+            {
+                // Append this level segments only
+                $list[] =
+                [
+                    'name' => $part[0],
+                    'link' => urlencode(
+                        $part[0]
+                    ),
+                    // if more than 1 segment, the item is virtual directory
+                    'file' => count(
+                        $part
+                    ) == 1
+                ];
+            }
+        }
+
+        return $list;
+    }
 }