Allow Database Hosts to have multiple Nodes

app/Filament/Resources/DatabaseHostResource/Pages/CreateDatabaseHost.php

@@ -79,12 +79,13 @@ public function form(Form $form): Form
                             ->revealable()
                             ->maxLength(255)
                             ->required(),
-                        Select::make('node_id')
+                        Select::make('node_ids')
+                            ->multiple()
                             ->searchable()
                             ->preload()
                             ->helperText('This setting only defaults to this database host when adding a database to a server on the selected node.')
-                            ->label('Linked Node')
-                            ->relationship('node', 'name'),
+                            ->label('Linked Nodes')
+                            ->relationship('nodes', 'name'),
                     ]),
             ]);
     }

app/Filament/Resources/DatabaseHostResource/Pages/EditDatabaseHost.php

@@ -74,12 +74,13 @@ public function form(Form $form): Form
                             ->password()
                             ->revealable()
                             ->maxLength(255),
-                        Select::make('node_id')
+                        Select::make('nodes')
+                            ->multiple()
                             ->searchable()
                             ->preload()
                             ->helperText('This setting only defaults to this database host when adding a database to a server on the selected node.')
-                            ->label('Linked Node')
-                            ->relationship('node', 'name'),
+                            ->label('Linked Nodes')
+                            ->relationship('nodes', 'name'),
                     ]),
             ]);
     }

app/Filament/Resources/DatabaseHostResource/Pages/ListDatabaseHosts.php

@@ -36,8 +36,9 @@ public function table(Table $table): Table
                     ->counts('databases')
                     ->icon('tabler-database')
                     ->label('Databases'),
-                TextColumn::make('node.name')
+                TextColumn::make('nodes.name')
                     ->icon('tabler-server-2')
+                    ->badge()
                     ->placeholder('No Nodes')
                     ->sortable(),
             ])

app/Models/DatabaseHost.php

@@ -2,8 +2,8 @@
 
 namespace App\Models;
 
+use Illuminate\Database\Eloquent\Relations\BelongsToMany;
 use Illuminate\Database\Eloquent\Relations\HasMany;
-use Illuminate\Database\Eloquent\Relations\BelongsTo;
 
 /**
  * @property int $id
@@ -39,7 +39,7 @@ class DatabaseHost extends Model
      * Fields that are mass assignable.
      */
     protected $fillable = [
-        'name', 'host', 'port', 'username', 'password', 'max_databases', 'node_id',
+        'name', 'host', 'port', 'username', 'password', 'max_databases',
     ];
 
     /**
@@ -51,15 +51,15 @@ class DatabaseHost extends Model
         'port' => 'required|numeric|between:1,65535',
         'username' => 'required|string|max:32',
         'password' => 'nullable|string',
-        'node_id' => 'sometimes|nullable|integer|exists:nodes,id',
+        'node_ids' => 'nullable|array',
+        'node_ids.*' => 'required|integer,exists:nodes,id',
     ];
 
     protected function casts(): array
     {
         return [
             'id' => 'integer',
             'max_databases' => 'integer',
-            'node_id' => 'integer',
             'password' => 'encrypted',
             'created_at' => 'immutable_datetime',
             'updated_at' => 'immutable_datetime',
@@ -71,12 +71,9 @@ public function getRouteKeyName(): string
         return 'id';
     }
 
-    /**
-     * Gets the node associated with a database host.
-     */
-    public function node(): BelongsTo
+    public function nodes(): BelongsToMany
     {
-        return $this->belongsTo(Node::class);
+        return $this->belongsToMany(Node::class);
     }
 
     /**

app/Models/Node.php

@@ -5,6 +5,7 @@
 use App\Exceptions\Service\HasActiveServersException;
 use App\Repositories\Daemon\DaemonConfigurationRepository;
 use Exception;
+use Illuminate\Database\Eloquent\Relations\BelongsToMany;
 use Illuminate\Database\Eloquent\Relations\HasMany;
 use Illuminate\Database\Eloquent\Relations\HasManyThrough;
 use Illuminate\Notifications\Notifiable;
@@ -381,4 +382,9 @@ public function ipAddresses(): array
             return $ips->all();
         });
     }
+
+    public function databaseHosts(): BelongsToMany
+    {
+        return $this->belongsToMany(DatabaseHost::class);
+    }
 }

app/Services/Databases/DeployServerDatabaseService.php

@@ -27,15 +27,15 @@ public function handle(Server $server, array $data): Database
         Assert::notEmpty($data['database'] ?? null);
         Assert::notEmpty($data['remote'] ?? null);
 
-        $hosts = DatabaseHost::query()->get()->toBase();
+        $hosts = DatabaseHost::query()->get();
         if ($hosts->isEmpty()) {
             throw new NoSuitableDatabaseHostException();
-        } else {
-            $nodeHosts = $hosts->where('node_id', $server->node_id)->toBase();
+        }
 
-            if ($nodeHosts->isEmpty() && !config('panel.client_features.databases.allow_random')) {
-                throw new NoSuitableDatabaseHostException();
-            }
+        $nodeHosts = $server->node->databaseHosts()->get();
+        // TODO: @areyouscared remove allow random feature for database hosts
+        if ($nodeHosts->isEmpty() && !config('panel.client_features.databases.allow_random')) {
+            throw new NoSuitableDatabaseHostException();
         }
 
         return $this->managementService->create($server, [

app/Services/Databases/Hosts/HostCreationService.php

@@ -34,9 +34,10 @@ public function handle(array $data): DatabaseHost
                 'port' => array_get($data, 'port'),
                 'username' => array_get($data, 'username'),
                 'max_databases' => array_get($data, 'max_databases'),
-                'node_id' => array_get($data, 'node_id'),
             ]);
 
+            $host->nodes()->sync(array_get($data, 'node_ids', []));
+
             // Confirm access using the provided credentials before saving data.
             $this->dynamic->set('dynamic', $host);
             $this->databaseManager->connection('dynamic')->getPdo();

app/Transformers/Api/Application/DatabaseHostTransformer.php

@@ -5,15 +5,14 @@
 use App\Models\Node;
 use App\Models\Database;
 use App\Models\DatabaseHost;
-use League\Fractal\Resource\Item;
 use League\Fractal\Resource\Collection;
 use League\Fractal\Resource\NullResource;
 
 class DatabaseHostTransformer extends BaseTransformer
 {
     protected array $availableIncludes = [
         'databases',
-        'node',
+        'nodes',
     ];
 
     /**
@@ -35,7 +34,6 @@ public function transform(DatabaseHost $model): array
             'host' => $model->host,
             'port' => $model->port,
             'username' => $model->username,
-            'node' => $model->node_id,
             'created_at' => $model->created_at->toAtomString(),
             'updated_at' => $model->updated_at->toAtomString(),
         ];
@@ -56,16 +54,16 @@ public function includeDatabases(DatabaseHost $model): Collection|NullResource
     }
 
     /**
-     * Include the node associated with this host.
+     * Include the nodes associated with this host.
      */
-    public function includeNode(DatabaseHost $model): Item|NullResource
+    public function includeNodes(DatabaseHost $model): Collection|NullResource
     {
         if (!$this->authorize(Node::RESOURCE_NAME)) {
             return $this->null();
         }
 
-        $model->loadMissing('node');
+        $model->loadMissing('nodes');
 
-        return $this->item($model->getRelation('node'), $this->makeTransformer(NodeTransformer::class), Node::RESOURCE_NAME);
+        return $this->collection($model->getRelation('nodes'), $this->makeTransformer(NodeTransformer::class), Node::RESOURCE_NAME);
     }
 }

database/migrations/2017_02_09_174834_SetupPermissionsPivotTable.php

@@ -31,6 +31,9 @@ public function up(): void
                 $table->dropIndex('permissions_server_id_foreign');
                 $table->dropForeign('permissions_user_id_foreign');
                 $table->dropIndex('permissions_user_id_foreign');
+            } else {
+                $table->dropForeign(['server_id']);
+                $table->dropForeign(['user_id']);
             }
 
             $table->dropColumn('server_id');

database/migrations/2020_09_13_110007_drop_packs_from_servers.php

@@ -12,10 +12,7 @@
     public function up(): void
     {
         Schema::table('servers', function (Blueprint $table) {
-            if (Schema::getConnection()->getDriverName() !== 'sqlite') {
-                $table->dropForeign(['pack_id']);
-            }
-
+            $table->dropForeign(['pack_id']);
             $table->dropColumn('pack_id');
         });
     }

database/migrations/2024_03_12_154408_remove_nests_table.php

@@ -30,14 +30,15 @@ public function up(): void
         Schema::table('eggs', function (Blueprint $table) {
             if (Schema::getConnection()->getDriverName() !== 'sqlite') {
                 $table->dropForeign('service_options_nest_id_foreign');
+            } else {
+                $table->dropForeign(['nest_id']);
             }
+
             $table->dropColumn('nest_id');
         });
 
         Schema::table('servers', function (Blueprint $table) {
-            if (Schema::getConnection()->getDriverName() !== 'sqlite') {
-                $table->dropForeign('servers_nest_id_foreign');
-            }
+            $table->dropForeign(['nest_id']);
             $table->dropColumn('nest_id');
         });
 

database/migrations/2024_03_14_055537_remove_locations_table.php

@@ -27,10 +27,7 @@ public function up(): void
         }
 
         Schema::table('nodes', function (Blueprint $table) {
-            if (Schema::getConnection()->getDriverName() !== 'sqlite') {
-                $table->dropForeign('nodes_location_id_foreign');
-            }
-
+            $table->dropForeign(['location_id']);
             $table->dropColumn('location_id');
         });
 

database/migrations/2024_10_31_203540_change_database_hosts_to_belong_to_many_nodes.php

@@ -0,0 +1,48 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('database_host_node', function (Blueprint $table) {
+            $table->id();
+            $table->foreignId('node_id')->references('id')->on('nodes');
+            $table->foreignId('database_host_id')->references('id')->on('database_hosts');
+            $table->timestamps();
+        });
+
+        $databaseNodes = DB::table('database_hosts')->whereNotNull('node_id')->get();
+        $newJoinEntries = $databaseNodes->map(fn ($record) => [
+            'node_id' => $record->node_id,
+            'database_host_id' => $record->id,
+            'created_at' => now(),
+            'updated_at' => now(),
+        ]);
+
+        DB::table('database_host_node')->insert($newJoinEntries->toArray());
+
+        Schema::table('database_hosts', function (Blueprint $table) {
+            $table->dropForeign(['node_id']);
+            $table->dropColumn('node_id');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::table('database_hosts', function (Blueprint $table) {
+            $table->foreignId('node_id')->nullable()->references('id')->on('nodes');
+        });
+
+        foreach (DB::table('database_host_node')->get() as $record) {
+            DB::table('database_hosts')
+                ->where('id', $record->database_host_id)
+                ->update(['node_id' => $record->node_id]);
+        }
+
+        Schema::drop('database_host_node');
+    }
+};