Code Refactor: data resiliency improvements.

src/Actions/ActionManager.php

@@ -3,8 +3,7 @@
 namespace Conveyor\Actions;
 
 use Conveyor\Actions\Interfaces\ActionInterface;
-use Conveyor\Models\Interfaces\GenericPersistenceInterface;
-use Conveyor\SocketHandlers\SocketMessageRouter;
+use Conveyor\Persistence\Interfaces\GenericPersistenceInterface;
 use Exception;
 use League\Pipeline\PipelineBuilder;
 use League\Pipeline\PipelineInterface;
@@ -40,6 +39,8 @@ public static function make(array $actions = [], bool $fresh = false): static
     }
 
     /**
+     * This method adds default actions to the manager.
+     *
      * @param bool $fresh
      *
      * @return static

src/Actions/Traits/HasPersistence.php

@@ -2,10 +2,10 @@
 
 namespace Conveyor\Actions\Traits;
 
-use Conveyor\Models\Interfaces\ChannelPersistenceInterface;
-use Conveyor\Models\Interfaces\GenericPersistenceInterface;
-use Conveyor\Models\Interfaces\ListenerPersistenceInterface;
-use Conveyor\Models\Interfaces\UserAssocPersistenceInterface;
+use Conveyor\Persistence\Interfaces\ChannelPersistenceInterface;
+use Conveyor\Persistence\Interfaces\GenericPersistenceInterface;
+use Conveyor\Persistence\Interfaces\ListenerPersistenceInterface;
+use Conveyor\Persistence\Interfaces\UserAssocPersistenceInterface;
 
 trait HasPersistence
 {

src/Models/Sqlite/WsAssociation.php → src/Models/WsAssociation.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Conveyor\Models\Sqlite;
+namespace Conveyor\Models;
 
 use Illuminate\Database\Eloquent\Model;
 
@@ -9,6 +9,7 @@ class WsAssociation extends Model
     const TABLE_NAME = 'wsassociations';
 
     protected $table = self::TABLE_NAME;
+    protected $connection = 'socket-conveyor';
 
     protected $fillable = [
         'fd',

src/Models/Sqlite/WsChannel.php → src/Models/WsChannel.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Conveyor\Models\Sqlite;
+namespace Conveyor\Models;
 
 use Illuminate\Database\Eloquent\Model;
 
@@ -10,6 +10,7 @@ class WsChannel extends Model
 
     /** @var string */
     protected $table = self::TABLE_NAME;
+    protected $connection = 'socket-conveyor';
 
     protected $fillable = [
         'fd',

src/Models/Sqlite/WsListener.php → src/Models/WsListener.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Conveyor\Models\Sqlite;
+namespace Conveyor\Models;
 
 use Illuminate\Database\Eloquent\Model;
 
@@ -10,6 +10,7 @@ class WsListener extends Model
 
 
     protected $table = self::TABLE_NAME;
+    protected $connection = 'socket-conveyor';
 
     protected $fillable = [
         'fd',

src/Persistence/Abstracts/GenericPersistence.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace Conveyor\Persistence\Abstracts;
+
+use Conveyor\Persistence\DTO\DatabaseConnectionDTO;
+use Conveyor\Persistence\Interfaces\GenericPersistenceInterface;
+
+abstract class GenericPersistence implements GenericPersistenceInterface
+{
+    /**
+     * @param @param DatabaseConnectionDTO|array{driver:string,database:string,username:string,password:string,charset:string,collation:string,prefix:string} $databaseOptions
+     */
+    public function __construct(
+        protected DatabaseConnectionDTO|array $databaseOptions = [
+            'driver' => 'sqlite',
+            'database' => __DIR__ . '/../../../../../database/database.sqlite',
+            'username' => null,
+            'password' => null,
+            'charset' => 'utf8',
+            'collation' => 'utf8_unicode_ci',
+            'prefix' => '',
+        ],
+    ) {
+        if (is_array($this->databaseOptions)) {
+            $this->databaseOptions = DatabaseConnectionDTO::fromArray($this->databaseOptions);
+        }
+
+        $this->refresh(true);
+    }
+
+    abstract public function refresh(bool $fresh = false): static;
+}

src/Persistence/DTO/DatabaseConnectionDTO.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace Conveyor\Persistence\DTO;
+
+use ArrayAccess;
+
+class DatabaseConnectionDTO implements ArrayAccess
+{
+    public function __construct(
+        public string $driver,
+        public string $database,
+        public ?string $username = null,
+        public ?string $password = null,
+        public string $charset = 'utf8',
+        public string $collation = 'utf8_unicode_ci',
+        public string $prefix = '',
+    ) {}
+
+    public static function fromArray(array $data): self
+    {
+        return new self(
+            $data['driver'],
+            $data['database'],
+            $data['username'] ?? null,
+            $data['password'] ?? null,
+            $data['charset'] ?? 'utf8',
+            $data['collation'] ?? 'utf8_unicode_ci',
+            $data['prefix'] ?? ''
+        );
+    }
+
+    public function toArray(): array
+    {
+        return [
+            'driver' => $this->driver,
+            'database' => $this->database,
+            'username' => $this->username,
+            'password' => $this->password,
+            'charset' => $this->charset,
+            'collation' => $this->collation,
+            'prefix' => $this->prefix,
+        ];
+    }
+
+    public function offsetExists($offset): bool
+    {
+        return property_exists($this, $offset);
+    }
+
+    public function offsetGet($offset): mixed
+    {
+        return $this->{$offset};
+    }
+
+    public function offsetSet($offset, $value): void
+    {
+        $this->{$offset} = $value;
+    }
+
+    public function offsetUnset($offset): void
+    {
+        $this->{$offset} = null;
+    }
+}