fix server workers 500 error

Bump version 2.4.0 (#548 )
Add workers to servers (#547 )
2025-07-01 05:56:16 +00:00 · 2025-03-16 14:38:10 +01:00 · 2025-03-16 14:10:55 +01:00 · 2025-03-16 14:09:15 +01:00 · 2025-03-13 20:53:14 +01:00 · 2025-03-12 22:59:25 +01:00
504 changed files with 6961 additions and 2618 deletions
--- a/.github/workflows/code-quality.yml
+++ b/.github/workflows/code-quality.yml
@ -0,0 +1,42 @@
+name: code-quality
+
+on:
+  push:
+    branches:
+      - 2.x
+  pull_request:
+    branches:
+      - 2.x
+
+jobs:
+  tests:
+    runs-on: ubuntu-22.04
+
+    strategy:
+      fail-fast: true
+      matrix:
+        php: [ 8.2 ]
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Setup PHP
+        uses: shivammathur/setup-php@v2
+        with:
+          php-version: ${{ matrix.php }}
+
+      - name: Cache Composer packages
+        id: composer-cache
+        uses: actions/cache@v4
+        with:
+          path: vendor
+          key: ${{ runner.os }}-php-${{ hashFiles('**/composer.lock') }}
+          restore-keys: |
+            ${{ runner.os }}-php-
+
+      - name: Install dependencies
+        if: steps.composer-cache.outputs.cache-hit != 'true'
+        run: composer install --prefer-dist --no-progress --no-suggest
+
+      - name: Run PHPStan
+        run: ./vendor/bin/phpstan analyse
--- a/.github/workflows/code-style.yml
+++ b/.github/workflows/code-style.yml
@ -19,7 +19,7 @@ jobs:
        node-version: [ "20.x" ]

    steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4

      - name: Setup PHP
        uses: shivammathur/setup-php@v2
@ -28,7 +28,7 @@ jobs:

      - name: Cache Composer packages
        id: composer-cache
-        uses: actions/cache@v2
+        uses: actions/cache@v4
        with:
          path: vendor
          key: ${{ runner.os }}-php-${{ hashFiles('**/composer.lock') }}
@ -43,7 +43,7 @@ jobs:
        run: ./vendor/bin/pint --test

      - name: Setup Node.js
-        uses: actions/setup-node@v2
+        uses: actions/setup-node@v4
        with:
          node-version: "20.x"

--- a/.github/workflows/docker-latest.yml
+++ b/.github/workflows/docker-latest.yml
@ -11,16 +11,16 @@ jobs:
    runs-on: ubuntu-latest
    steps:
      - name: Checkout code
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4

      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
+        uses: docker/setup-qemu-action@v2

      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
+        uses: docker/setup-buildx-action@v2

      - name: Login to Docker Hub
-        uses: docker/login-action@v2
+        uses: docker/login-action@v3
        with:
          username: ${{ secrets.DOCKER_USERNAME }}
          password: ${{ secrets.DOCKER_PASSWORD }}
--- a/.github/workflows/docker-release.yml
+++ b/.github/workflows/docker-release.yml
@ -10,16 +10,16 @@ jobs:
    runs-on: ubuntu-latest
    steps:
      - name: Checkout code
-        uses: actions/checkout@v2
+        uses: actions/checkout@v4

      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
+        uses: docker/setup-qemu-action@v2

      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
+        uses: docker/setup-buildx-action@v2

      - name: Login to Docker Hub
-        uses: docker/login-action@v2
+        uses: docker/login-action@v3
        with:
          username: ${{ secrets.DOCKER_USERNAME }}
          password: ${{ secrets.DOCKER_PASSWORD }}
--- a/.github/workflows/tests.yml
+++ b/.github/workflows/tests.yml
@ -18,7 +18,7 @@ jobs:
        php: [ 8.2 ]

    steps:
-      - uses: actions/checkout@v2
+      - uses: actions/checkout@v4

      - name: Setup PHP
        uses: shivammathur/setup-php@v2
@ -27,12 +27,13 @@ jobs:

      - name: Cache Composer packages
        id: composer-cache
-        uses: actions/cache@v2
+        uses: actions/cache@v4
        with:
          path: vendor
          key: ${{ runner.os }}-php-${{ hashFiles('**/composer.lock') }}
          restore-keys: |
            ${{ runner.os }}-php-
+
      - name: Install dependencies
        if: steps.composer-cache.outputs.cache-hit != 'true'
        run: composer install --prefer-dist --no-progress --no-suggest
--- a/app/Actions/CronJob/CreateCronJob.php
+++ b/app/Actions/CronJob/CreateCronJob.php
@ -10,6 +10,9 @@

 class CreateCronJob
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(Server $server, array $input): CronJob
    {
        $cronJob = new CronJob([
@ -28,6 +31,10 @@ public function create(Server $server, array $input): CronJob
        return $cronJob;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<mixed>>
+     */
    public static function rules(array $input, Server $server): array
    {
        $rules = [
--- a/app/Actions/Database/CreateDatabase.php
+++ b/app/Actions/Database/CreateDatabase.php
@ -5,20 +5,30 @@
 use App\Enums\DatabaseStatus;
 use App\Models\Database;
 use App\Models\Server;
+use App\Models\Service;
 use Illuminate\Validation\Rule;
 use Illuminate\Validation\ValidationException;

 class CreateDatabase
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(Server $server, array $input): Database
    {
        $database = new Database([
            'server_id' => $server->id,
+            'charset' => $input['charset'],
+            'collation' => $input['collation'],
            'name' => $input['name'],
        ]);
+
+        /** @var Service $service */
+        $service = $server->database();
+
        /** @var \App\SSH\Services\Database\Database $databaseHandler */
-        $databaseHandler = $server->database()->handler();
-        $databaseHandler->create($database->name);
+        $databaseHandler = $service->handler();
+        $databaseHandler->create($database->name, $database->charset, $database->collation);
        $database->status = DatabaseStatus::READY;
        $database->save();

@ -32,6 +42,9 @@ public function create(Server $server, array $input): Database
    }

    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     *
     * @throws ValidationException
     */
    public static function rules(Server $server, array $input): array
@ -42,6 +55,14 @@ public static function rules(Server $server, array $input): array
                'alpha_dash',
                Rule::unique('databases', 'name')->where('server_id', $server->id),
            ],
+            'charset' => [
+                'required',
+                'string',
+            ],
+            'collation' => [
+                'required',
+                'string',
+            ],
        ];
        if (isset($input['user']) && $input['user']) {
            $rules['username'] = [
--- a/app/Actions/Database/CreateDatabaseUser.php
+++ b/app/Actions/Database/CreateDatabaseUser.php
@ -5,6 +5,7 @@
 use App\Enums\DatabaseUserStatus;
 use App\Models\DatabaseUser;
 use App\Models\Server;
+use App\Models\Service;
 use App\SSH\Services\Database\Database;
 use Illuminate\Validation\Rule;
 use Illuminate\Validation\ValidationException;
@ -12,6 +13,9 @@
 class CreateDatabaseUser
 {
    /**
+     * @param  array<string, mixed>  $input
+     * @param  array<string>  $links
+     *
     * @throws ValidationException
     */
    public function create(Server $server, array $input, array $links = []): DatabaseUser
@ -23,8 +27,12 @@ public function create(Server $server, array $input, array $links = []): Databas
            'host' => (isset($input['remote']) && $input['remote']) || isset($input['host']) ? $input['host'] : 'localhost',
            'databases' => $links,
        ]);
+
+        /** @var Service $service */
+        $service = $server->database();
+
        /** @var Database $databaseHandler */
-        $databaseHandler = $server->database()->handler();
+        $databaseHandler = $service->handler();
        $databaseHandler->createUser(
            $databaseUser->username,
            $databaseUser->password,
@ -41,6 +49,9 @@ public function create(Server $server, array $input, array $links = []): Databas
    }

    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     *
     * @throws ValidationException
     */
    public static function rules(Server $server, array $input): array
--- a/app/Actions/Database/DeleteDatabase.php
+++ b/app/Actions/Database/DeleteDatabase.php
@ -4,12 +4,17 @@

 use App\Models\Database;
 use App\Models\Server;
+use App\Models\Service;

 class DeleteDatabase
 {
    public function delete(Server $server, Database $database): void
    {
-        $server->database()->handler()->delete($database->name);
+        /** @var Service $service */
+        $service = $server->database();
+        /** @var \App\SSH\Services\Database\Database $handler */
+        $handler = $service->handler();
+        $handler->delete($database->name);
        $database->delete();
    }
 }
--- a/app/Actions/Database/DeleteDatabaseUser.php
+++ b/app/Actions/Database/DeleteDatabaseUser.php
@ -4,12 +4,18 @@

 use App\Models\DatabaseUser;
 use App\Models\Server;
+use App\Models\Service;
+use App\SSH\Services\Database\Database;

 class DeleteDatabaseUser
 {
    public function delete(Server $server, DatabaseUser $databaseUser): void
    {
-        $server->database()->handler()->deleteUser($databaseUser->username, $databaseUser->host);
+        /** @var Service $service */
+        $service = $server->database();
+        /** @var Database $handler */
+        $handler = $service->handler();
+        $handler->deleteUser($databaseUser->username, $databaseUser->host);
        $databaseUser->delete();
    }
 }
--- a/app/Actions/Database/LinkUser.php
+++ b/app/Actions/Database/LinkUser.php
@ -5,12 +5,16 @@
 use App\Models\Database;
 use App\Models\DatabaseUser;
 use App\Models\Server;
+use App\Models\Service;
 use Illuminate\Validation\Rule;
 use Illuminate\Validation\ValidationException;

 class LinkUser
 {
    /**
+     * @param  array<string, mixed>  $input
+     * @return DatabaseUser $databaseUser
+     *
     * @throws ValidationException
     */
    public function link(DatabaseUser $databaseUser, array $input): DatabaseUser
@ -29,14 +33,20 @@ public function link(DatabaseUser $databaseUser, array $input): DatabaseUser

        $databaseUser->databases = $input['databases'];

+        /** @var Service $service */
+        $service = $databaseUser->server->database();
+
+        /** @var \App\SSH\Services\Database\Database $handler */
+        $handler = $service->handler();
+
        // Unlink the user from all databases
-        $databaseUser->server->database()->handler()->unlink(
+        $handler->unlink(
            $databaseUser->username,
            $databaseUser->host
        );

        // Link the user to the selected databases
-        $databaseUser->server->database()->handler()->link(
+        $handler->link(
            $databaseUser->username,
            $databaseUser->host,
            $databaseUser->databases
@ -49,6 +59,10 @@ public function link(DatabaseUser $databaseUser, array $input): DatabaseUser
        return $databaseUser;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(Server $server, array $input): array
    {
        return [
--- a/app/Actions/Database/ManageBackup.php
+++ b/app/Actions/Database/ManageBackup.php
@ -14,6 +14,8 @@
 class ManageBackup
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws AuthorizationException
     * @throws ValidationException
     */
@ -35,6 +37,9 @@ public function create(Server $server, array $input): Backup
        return $backup;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(Backup $backup, array $input): void
    {
        $backup->interval = $input['interval'] == 'custom' ? $input['custom_interval'] : $input['interval'];
@ -47,7 +52,7 @@ public function delete(Backup $backup): void
        $backup->status = BackupStatus::DELETING;
        $backup->save();

-        dispatch(function () use ($backup) {
+        dispatch(function () use ($backup): void {
            $files = $backup->files;
            foreach ($files as $file) {
                $file->status = BackupFileStatus::DELETING;
@ -60,6 +65,10 @@ public function delete(Backup $backup): void
        });
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(Server $server, array $input): array
    {
        $rules = [
--- a/app/Actions/Database/ManageBackupFile.php
+++ b/app/Actions/Database/ManageBackupFile.php
@ -28,7 +28,7 @@ public function delete(BackupFile $file): void
        $file->status = BackupFileStatus::DELETING;
        $file->save();

-        dispatch(function () use ($file) {
+        dispatch(function () use ($file): void {
            $file->deleteFile();
        });
    }
--- a/app/Actions/Database/RestoreBackup.php
+++ b/app/Actions/Database/RestoreBackup.php
@ -5,9 +5,13 @@
 use App\Enums\BackupFileStatus;
 use App\Models\BackupFile;
 use App\Models\Database;
+use App\Models\Service;

 class RestoreBackup
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function restore(BackupFile $backupFile, array $input): void
    {
        /** @var Database $database */
@ -16,19 +20,24 @@ public function restore(BackupFile $backupFile, array $input): void
        $backupFile->restored_to = $database->name;
        $backupFile->save();

-        dispatch(function () use ($backupFile, $database) {
+        dispatch(function () use ($backupFile, $database): void {
+            /** @var Service $service */
+            $service = $database->server->database();
            /** @var \App\SSH\Services\Database\Database $databaseHandler */
-            $databaseHandler = $database->server->database()->handler();
+            $databaseHandler = $service->handler();
            $databaseHandler->restoreBackup($backupFile, $database->name);
            $backupFile->status = BackupFileStatus::RESTORED;
            $backupFile->restored_at = now();
            $backupFile->save();
-        })->catch(function () use ($backupFile) {
+        })->catch(function () use ($backupFile): void {
            $backupFile->status = BackupFileStatus::RESTORE_FAILED;
            $backupFile->save();
        })->onConnection('ssh');
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Database/RunBackup.php
+++ b/app/Actions/Database/RunBackup.php
@ -6,6 +6,7 @@
 use App\Enums\BackupStatus;
 use App\Models\Backup;
 use App\Models\BackupFile;
+use App\Models\Service;
 use App\SSH\Services\Database\Database;
 use Illuminate\Support\Str;

@ -20,9 +21,11 @@ public function run(Backup $backup): BackupFile
        ]);
        $file->save();

-        dispatch(function () use ($file, $backup) {
+        dispatch(function () use ($file, $backup): void {
+            /** @var Service $service */
+            $service = $backup->server->database();
            /** @var Database $databaseHandler */
-            $databaseHandler = $file->backup->server->database()->handler();
+            $databaseHandler = $service->handler();
            $databaseHandler->runBackup($file);
            $file->status = BackupFileStatus::CREATED;
            $file->save();
@ -31,7 +34,7 @@ public function run(Backup $backup): BackupFile
                $backup->status = BackupStatus::RUNNING;
                $backup->save();
            }
-        })->catch(function () use ($file, $backup) {
+        })->catch(function () use ($file, $backup): void {
            $backup->status = BackupStatus::FAILED;
            $backup->save();
            $file->status = BackupFileStatus::FAILED;
--- a/app/Actions/Database/SyncDatabaseUsers.php
+++ b/app/Actions/Database/SyncDatabaseUsers.php
@ -0,0 +1,50 @@
+<?php
+
+namespace App\Actions\Database;
+
+use App\Enums\DatabaseUserStatus;
+use App\Models\DatabaseUser;
+use App\Models\Server;
+use App\SSH\Services\Database\Database;
+
+class SyncDatabaseUsers
+{
+    public function sync(Server $server): void
+    {
+        $service = $server->database();
+        if (! $service instanceof \App\Models\Service) {
+            return;
+        }
+        /** @var Database $handler */
+        $handler = $service->handler();
+
+        $this->updateUsers($server, $handler);
+    }
+
+    private function updateUsers(Server $server, Database $handler): void
+    {
+        $users = $handler->getUsers();
+        foreach ($users as $user) {
+            $databases = $user[2] != 'NULL' ? explode(',', $user[2]) : [];
+
+            /** @var ?DatabaseUser $databaseUser */
+            $databaseUser = $server->databaseUsers()
+                ->where('username', $user[0])
+                ->first();
+
+            if ($databaseUser === null) {
+                $server->databaseUsers()->create([
+                    'username' => $user[0],
+                    'host' => $user[1],
+                    'databases' => $databases,
+                    'status' => DatabaseUserStatus::READY,
+                ]);
+
+                continue;
+            }
+
+            $databaseUser->databases = $databases;
+            $databaseUser->save();
+        }
+    }
+}
--- a/app/Actions/Database/SyncDatabases.php
+++ b/app/Actions/Database/SyncDatabases.php
@ -0,0 +1,63 @@
+<?php
+
+namespace App\Actions\Database;
+
+use App\Enums\DatabaseStatus;
+use App\Models\Server;
+use App\Models\Service;
+use App\SSH\Services\Database\Database;
+
+class SyncDatabases
+{
+    public function sync(Server $server): void
+    {
+        $service = $server->database();
+        if (! $service instanceof \App\Models\Service) {
+            return;
+        }
+        /** @var Database $handler */
+        $handler = $service->handler();
+
+        $this->updateCharsets($service, $handler);
+        $this->updateDatabases($server, $handler);
+    }
+
+    private function updateCharsets(Service $service, Database $handler): void
+    {
+        $data = $service->type_data ?? [];
+        $charsets = $handler->getCharsets();
+        $data['charsets'] = $charsets['charsets'] ?? [];
+        $data['defaultCharset'] = $charsets['defaultCharset'] ?? '';
+        $service->type_data = $data;
+        $service->save();
+    }
+
+    private function updateDatabases(Server $server, Database $handler): void
+    {
+        $databases = $handler->getDatabases();
+        foreach ($databases as $database) {
+            /** @var ?\App\Models\Database $db */
+            $db = $server->databases()
+                ->where('name', $database[0])
+                ->first();
+
+            if ($db === null) {
+                $server->databases()->create([
+                    'name' => $database[0],
+                    'collation' => $database[2],
+                    'charset' => $database[1],
+                    'status' => DatabaseStatus::READY,
+                ]);
+
+                continue;
+            }
+
+            if ($db->collation !== $database[2] || $db->charset !== $database[1]) {
+                $db->update([
+                    'collation' => $database[2],
+                    'charset' => $database[1],
+                ]);
+            }
+        }
+    }
+}
--- a/app/Actions/FileManager/FetchFiles.php
+++ b/app/Actions/FileManager/FetchFiles.php
@ -11,6 +11,8 @@
 class FetchFiles
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws SSHError
     */
    public function fetch(User $user, Server $server, array $input): void
@ -24,6 +26,9 @@ public function fetch(User $user, Server $server, array $input): void
        );
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/FirewallRule/ManageRule.php
+++ b/app/Actions/FirewallRule/ManageRule.php
@ -5,10 +5,16 @@
 use App\Enums\FirewallRuleStatus;
 use App\Models\FirewallRule;
 use App\Models\Server;
+use App\Models\Service;
 use App\SSH\Services\Firewall\Firewall;
+use Exception;

 class ManageRule
 {
+    /**
+     * @param  array<string, mixed>  $input
+     * @return FirewallRule $rule
+     */
    public function create(Server $server, array $input): FirewallRule
    {
        $sourceAny = $input['source_any'] ?? empty($input['source'] ?? null);
@ -30,6 +36,10 @@ public function create(Server $server, array $input): FirewallRule
        return $rule;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return FirewallRule $rule
+     */
    public function update(FirewallRule $rule, array $input): FirewallRule
    {
        $sourceAny = $input['source_any'] ?? empty($input['source'] ?? null);
@ -56,18 +66,20 @@ public function delete(FirewallRule $rule): void
        dispatch(fn () => $this->applyRule($rule));
    }

-    protected function applyRule($rule): void
+    protected function applyRule(FirewallRule $rule): void
    {
        try {
+            /** @var Service $service */
+            $service = $rule->server->firewall();
            /** @var Firewall $handler */
-            $handler = $rule->server->firewall()->handler();
+            $handler = $service->handler();
            $handler->applyRules();
-        } catch (\Exception $e) {
+        } catch (Exception) {
            $rule->server->firewallRules()
                ->where('status', '!=', FirewallRuleStatus::READY)
                ->update(['status' => FirewallRuleStatus::FAILED]);

-            throw $e;
+            return;
        }

        if ($rule->status === FirewallRuleStatus::DELETING) {
@ -80,6 +92,9 @@ protected function applyRule($rule): void
        $rule->save();
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Monitoring/GetMetrics.php
+++ b/app/Actions/Monitoring/GetMetrics.php
@ -11,6 +11,10 @@

 class GetMetrics
 {
+    /**
+     * @param  array<string, mixed>  $input
+     * @return Collection<int, mixed>
+     */
    public function filter(Server $server, array $input): Collection
    {
        if (isset($input['from']) && isset($input['to']) && $input['from'] === $input['to']) {
@ -32,6 +36,9 @@ public function filter(Server $server, array $input): Collection
        );
    }

+    /**
+     * @return Collection<int, mixed>
+     */
    private function metrics(
        Server $server,
        Carbon $fromDate,
@ -57,13 +64,16 @@ private function metrics(
            ->groupByRaw('date_interval')
            ->orderBy('date_interval')
            ->get()
-            ->map(function ($item) {
+            ->map(function ($item): \stdClass {
                $item->date = Carbon::parse($item->date)->format('Y-m-d H:i');

                return $item;
            });
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function getFromDate(array $input): Carbon
    {
        if ($input['period'] === 'custom') {
@ -73,6 +83,9 @@ private function getFromDate(array $input): Carbon
        return Carbon::parse('-'.convert_time_format($input['period']));
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function getToDate(array $input): Carbon
    {
        if ($input['period'] === 'custom') {
@ -82,6 +95,9 @@ private function getToDate(array $input): Carbon
        return Carbon::now();
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function getInterval(array $input): Expression
    {
        if ($input['period'] === 'custom') {
@ -107,6 +123,10 @@ private function getInterval(array $input): Expression
        return DB::raw("strftime('%Y-%m-%d 00:00:00', created_at) as date_interval");
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    public static function rules(array $input): array
    {
        $rules = [
--- a/app/Actions/Monitoring/UpdateMetricSettings.php
+++ b/app/Actions/Monitoring/UpdateMetricSettings.php
@ -3,19 +3,29 @@
 namespace App\Actions\Monitoring;

 use App\Models\Server;
+use App\Models\Service;
+use App\SSH\Services\ServiceInterface;

 class UpdateMetricSettings
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(Server $server, array $input): void
    {
+        /** @var Service $service */
        $service = $server->monitoring();
-
-        $data = $service->handler()->data();
+        /** @var ServiceInterface $handler */
+        $handler = $service->handler();
+        $data = $handler->data();
        $data['data_retention'] = $input['data_retention'];
        $service->type_data = $data;
        $service->save();
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/NodeJS/ChangeDefaultCli.php
+++ b/app/Actions/NodeJS/ChangeDefaultCli.php
@ -3,24 +3,38 @@
 namespace App\Actions\NodeJS;

 use App\Enums\ServiceStatus;
+use App\Exceptions\SSHError;
 use App\Models\Server;
+use App\Models\Service;
 use App\SSH\Services\NodeJS\NodeJS;
 use Illuminate\Validation\ValidationException;

 class ChangeDefaultCli
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     * @throws SSHError
+     */
    public function change(Server $server, array $input): void
    {
        $this->validate($server, $input);
+        /** @var Service $service */
        $service = $server->nodejs($input['version']);
        /** @var NodeJS $handler */
        $handler = $service->handler();
        $handler->setDefaultCli();
-        $server->defaultService('nodejs')->update(['is_default' => 0]);
+        $server->defaultService('nodejs')?->update(['is_default' => 0]);
        $service->update(['is_default' => 1]);
        $service->update(['status' => ServiceStatus::READY]);
    }

+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function validate(Server $server, array $input): void
    {
        if (! isset($input['version']) || ! in_array($input['version'], $server->installedNodejsVersions())) {
--- a/app/Actions/NodeJS/InstallNewNodeJsVersion.php
+++ b/app/Actions/NodeJS/InstallNewNodeJsVersion.php
@ -10,6 +10,9 @@

 class InstallNewNodeJsVersion
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function install(Server $server, array $input): void
    {
        $nodejs = new Service([
@ -23,15 +26,18 @@ public function install(Server $server, array $input): void
        ]);
        $nodejs->save();

-        dispatch(function () use ($nodejs) {
+        dispatch(function () use ($nodejs): void {
            $nodejs->handler()->install();
            $nodejs->status = ServiceStatus::READY;
            $nodejs->save();
-        })->catch(function () use ($nodejs) {
+        })->catch(function () use ($nodejs): void {
            $nodejs->delete();
        })->onConnection('ssh');
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/NodeJS/UninstallNodeJS.php
+++ b/app/Actions/NodeJS/UninstallNodeJS.php
@ -10,6 +10,11 @@

 class UninstallNodeJS
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function uninstall(Server $server, array $input): void
    {
        $this->validate($server, $input);
@ -19,16 +24,18 @@ public function uninstall(Server $server, array $input): void
        $nodejs->status = ServiceStatus::UNINSTALLING;
        $nodejs->save();

-        dispatch(function () use ($nodejs) {
+        dispatch(function () use ($nodejs): void {
            $nodejs->handler()->uninstall();
            $nodejs->delete();
-        })->catch(function () use ($nodejs) {
+        })->catch(function () use ($nodejs): void {
            $nodejs->status = ServiceStatus::FAILED;
            $nodejs->save();
        })->onConnection('ssh');
    }

    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    private function validate(Server $server, array $input): void
--- a/app/Actions/NotificationChannels/AddChannel.php
+++ b/app/Actions/NotificationChannels/AddChannel.php
@ -11,8 +11,9 @@
 class AddChannel
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
-     * @throws Exception
     */
    public function add(User $user, array $input): void
    {
@ -42,13 +43,19 @@ public function add(User $user, array $input): void
        } catch (Exception $e) {
            $channel->delete();

-            throw $e;
+            throw ValidationException::withMessages([
+                'provider' => $e->getMessage(),
+            ]);
        }

        $channel->connected = true;
        $channel->save();
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(array $input): array
    {
        $rules = [
@ -59,9 +66,13 @@ public static function rules(array $input): array
            'label' => 'required',
        ];

-        return array_merge($rules, static::providerRules($input));
+        return array_merge($rules, self::providerRules($input));
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    private static function providerRules(array $input): array
    {
        if (! isset($input['provider'])) {
--- a/app/Actions/NotificationChannels/EditChannel.php
+++ b/app/Actions/NotificationChannels/EditChannel.php
@ -7,6 +7,9 @@

 class EditChannel
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function edit(NotificationChannel $notificationChannel, User $user, array $input): void
    {
        $notificationChannel->fill([
@ -16,6 +19,10 @@ public function edit(NotificationChannel $notificationChannel, User $user, array
        $notificationChannel->save();
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, string>
+     */
    public static function rules(array $input): array
    {
        return [
--- a/app/Actions/PHP/ChangeDefaultCli.php
+++ b/app/Actions/PHP/ChangeDefaultCli.php
@ -3,24 +3,37 @@
 namespace App\Actions\PHP;

 use App\Enums\ServiceStatus;
+use App\Exceptions\SSHError;
 use App\Models\Server;
+use App\Models\Service;
 use App\SSH\Services\PHP\PHP;
 use Illuminate\Validation\ValidationException;

 class ChangeDefaultCli
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws SSHError
+     */
    public function change(Server $server, array $input): void
    {
        $this->validate($server, $input);
+        /** @var Service $service */
        $service = $server->php($input['version']);
        /** @var PHP $handler */
        $handler = $service->handler();
        $handler->setDefaultCli();
-        $server->defaultService('php')->update(['is_default' => 0]);
+        $server->defaultService('php')?->update(['is_default' => 0]);
        $service->update(['is_default' => 1]);
        $service->update(['status' => ServiceStatus::READY]);
    }

+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function validate(Server $server, array $input): void
    {
        if (! isset($input['version']) || ! in_array($input['version'], $server->installedPHPVersions())) {
--- a/app/Actions/PHP/GetPHPIni.php
+++ b/app/Actions/PHP/GetPHPIni.php
@ -4,17 +4,25 @@

 use App\Enums\PHPIniType;
 use App\Models\Server;
+use App\Models\Service;
 use App\SSH\Services\PHP\PHP;
 use Illuminate\Support\Facades\Validator;
 use Illuminate\Validation\Rule;
 use Illuminate\Validation\ValidationException;
+use Throwable;

 class GetPHPIni
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function getIni(Server $server, array $input): string
    {
        $this->validate($server, $input);

+        /** @var Service $php */
        $php = $server->php($input['version']);

        try {
@ -22,13 +30,18 @@ public function getIni(Server $server, array $input): string
            $handler = $php->handler();

            return $handler->getPHPIni($input['type']);
-        } catch (\Throwable $e) {
+        } catch (Throwable $e) {
            throw ValidationException::withMessages(
                ['ini' => $e->getMessage()]
            );
        }
    }

+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function validate(Server $server, array $input): void
    {
        Validator::make($input, [
--- a/app/Actions/PHP/InstallNewPHP.php
+++ b/app/Actions/PHP/InstallNewPHP.php
@ -10,6 +10,9 @@

 class InstallNewPHP
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function install(Server $server, array $input): void
    {
        $php = new Service([
@ -26,15 +29,18 @@ public function install(Server $server, array $input): void
        ]);
        $php->save();

-        dispatch(function () use ($php) {
+        dispatch(function () use ($php): void {
            $php->handler()->install();
            $php->status = ServiceStatus::READY;
            $php->save();
-        })->catch(function () use ($php) {
+        })->catch(function () use ($php): void {
            $php->delete();
        })->onConnection('ssh');
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/PHP/InstallPHPExtension.php
+++ b/app/Actions/PHP/InstallPHPExtension.php
@ -2,7 +2,6 @@

 namespace App\Actions\PHP;

-use App\Exceptions\SSHCommandError;
 use App\Models\Server;
 use App\Models\Service;
 use App\SSH\Services\PHP\PHP;
@ -11,6 +10,11 @@

 class InstallPHPExtension
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function install(Server $server, array $input): Service
    {
        /** @var Service $service */
@ -23,20 +27,17 @@ public function install(Server $server, array $input): Service
        }

        $typeData = $service->type_data;
-        $typeData['extensions'] = $typeData['extensions'] ?? [];
+        $typeData['extensions'] ??= [];
        $typeData['extensions'][] = $input['extension'];
        $service->type_data = $typeData;
        $service->save();

        dispatch(
-            /**
-             * @throws SSHCommandError
-             */
-            function () use ($service, $input) {
+            function () use ($service, $input): void {
                /** @var PHP $handler */
                $handler = $service->handler();
                $handler->installExtension($input['extension']);
-            })->catch(function () use ($service, $input) {
+            })->catch(function () use ($service, $input): void {
                $service->refresh();
                $typeData = $service->type_data;
                $typeData['extensions'] = array_values(array_diff($typeData['extensions'], [$input['extension']]));
@ -47,6 +48,9 @@ function () use ($service, $input) {
        return $service;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/PHP/UninstallPHP.php
+++ b/app/Actions/PHP/UninstallPHP.php
@ -10,6 +10,11 @@

 class UninstallPHP
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function uninstall(Server $server, array $input): void
    {
        $this->validate($server, $input);
@ -19,16 +24,18 @@ public function uninstall(Server $server, array $input): void
        $php->status = ServiceStatus::UNINSTALLING;
        $php->save();

-        dispatch(function () use ($php) {
+        dispatch(function () use ($php): void {
            $php->handler()->uninstall();
            $php->delete();
-        })->catch(function () use ($php) {
+        })->catch(function () use ($php): void {
            $php->status = ServiceStatus::FAILED;
            $php->save();
        })->onConnection('ssh');
    }

    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    private function validate(Server $server, array $input): void
--- a/app/Actions/PHP/UpdatePHPIni.php
+++ b/app/Actions/PHP/UpdatePHPIni.php
@ -4,6 +4,7 @@

 use App\Enums\PHPIniType;
 use App\Models\Server;
+use App\Models\Service;
 use Illuminate\Filesystem\FilesystemAdapter;
 use Illuminate\Support\Facades\Storage;
 use Illuminate\Support\Str;
@ -14,10 +15,13 @@
 class UpdatePHPIni
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function update(Server $server, array $input): void
    {
+        /** @var Service $service */
        $service = $server->php($input['version']);

        $tmpName = Str::random(10).strtotime('now');
@ -48,6 +52,9 @@ private function deleteTempFile(string $name): void
        }
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/Projects/AddUser.php
+++ b/app/Actions/Projects/AddUser.php
@ -9,6 +9,9 @@

 class AddUser
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function add(Project $project, array $input): void
    {
        /** @var User $user */
@ -18,13 +21,16 @@ public function add(Project $project, array $input): void
        $project->users()->attach($user);
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Project $project): array
    {
        return [
            'user' => [
                'required',
                Rule::exists('users', 'id'),
-                Rule::unique('user_project', 'user_id')->where(function (Builder $query) use ($project) {
+                Rule::unique('user_project', 'user_id')->where(function (Builder $query) use ($project): void {
                    $query->where('project_id', $project->id);
                }),
            ],
--- a/app/Actions/Projects/CreateProject.php
+++ b/app/Actions/Projects/CreateProject.php
@ -8,10 +8,13 @@

 class CreateProject
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(User $user, array $input): Project
    {
        if (isset($input['name'])) {
-            $input['name'] = strtolower($input['name']);
+            $input['name'] = strtolower((string) $input['name']);
        }

        $this->validate($input);
@ -27,6 +30,9 @@ public function create(User $user, array $input): Project
        return $project;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
@ -40,6 +46,9 @@ public static function rules(): array
        ];
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function validate(array $input): void
    {
        Validator::make($input, self::rules())->validate();
--- a/app/Actions/Projects/UpdateProject.php
+++ b/app/Actions/Projects/UpdateProject.php
@ -8,10 +8,13 @@

 class UpdateProject
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(Project $project, array $input): Project
    {
        if (isset($input['name'])) {
-            $input['name'] = strtolower($input['name']);
+            $input['name'] = strtolower((string) $input['name']);
        }

        $this->validate($project, $input);
@ -23,6 +26,9 @@ public function update(Project $project, array $input): Project
        return $project;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Project $project): array
    {
        return [
@ -36,6 +42,9 @@ public static function rules(Project $project): array
        ];
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function validate(Project $project, array $input): void
    {
        Validator::make($input, self::rules($project))->validate();
--- a/app/Actions/Queue/CreateQueue.php
+++ b/app/Actions/Queue/CreateQueue.php
@ -1,72 +0,0 @@
-<?php
-
-namespace App\Actions\Queue;
-
-use App\Enums\QueueStatus;
-use App\Models\Queue;
-use App\Models\Server;
-use App\Models\Site;
-use App\SSH\Services\ProcessManager\ProcessManager;
-use Illuminate\Validation\Rule;
-use Illuminate\Validation\ValidationException;
-
-class CreateQueue
-{
-    /**
-     * @throws ValidationException
-     */
-    public function create(mixed $queueable, array $input): void
-    {
-        $queue = new Queue([
-            'server_id' => $queueable instanceof Server ? $queueable->id : $queueable->server_id,
-            'site_id' => $queueable instanceof Site ? $queueable->id : null,
-            'command' => $input['command'],
-            'user' => $input['user'],
-            'auto_start' => $input['auto_start'] ? 1 : 0,
-            'auto_restart' => $input['auto_restart'] ? 1 : 0,
-            'numprocs' => $input['numprocs'],
-            'status' => QueueStatus::CREATING,
-        ]);
-        $queue->save();
-
-        dispatch(function () use ($queue) {
-            /** @var ProcessManager $processManager */
-            $processManager = $queue->server->processManager()->handler();
-            $processManager->create(
-                $queue->id,
-                $queue->command,
-                $queue->user,
-                $queue->auto_start,
-                $queue->auto_restart,
-                $queue->numprocs,
-                $queue->getLogFile(),
-                $queue->site_id
-            );
-            $queue->status = QueueStatus::RUNNING;
-            $queue->save();
-        })->catch(function () use ($queue) {
-            $queue->delete();
-        })->onConnection('ssh');
-    }
-
-    public static function rules(Site $site): array
-    {
-        return [
-            'command' => [
-                'required',
-            ],
-            'user' => [
-                'required',
-                Rule::in([
-                    'root',
-                    $site->user,
-                ]),
-            ],
-            'numprocs' => [
-                'required',
-                'numeric',
-                'min:1',
-            ],
-        ];
-    }
-}
--- a/app/Actions/Queue/DeleteQueue.php
+++ b/app/Actions/Queue/DeleteQueue.php
@ -1,13 +0,0 @@
-<?php
-
-namespace App\Actions\Queue;
-
-use App\Models\Queue;
-
-class DeleteQueue
-{
-    public function delete(Queue $queue): void
-    {
-        $queue->delete();
-    }
-}
--- a/app/Actions/Queue/EditQueue.php
+++ b/app/Actions/Queue/EditQueue.php
@ -1,72 +0,0 @@
-<?php
-
-namespace App\Actions\Queue;
-
-use App\Enums\QueueStatus;
-use App\Models\Queue;
-use App\Models\Server;
-use App\SSH\Services\ProcessManager\ProcessManager;
-use Illuminate\Validation\Rule;
-use Illuminate\Validation\ValidationException;
-
-class EditQueue
-{
-    /**
-     * @throws ValidationException
-     */
-    public function edit(Queue $queue, array $input): void
-    {
-        $queue->fill([
-            'command' => $input['command'],
-            'user' => $input['user'],
-            'auto_start' => $input['auto_start'] ? 1 : 0,
-            'auto_restart' => $input['auto_restart'] ? 1 : 0,
-            'numprocs' => $input['numprocs'],
-            'status' => QueueStatus::RESTARTING,
-        ]);
-        $queue->save();
-
-        dispatch(function () use ($queue) {
-            /** @var ProcessManager $processManager */
-            $processManager = $queue->server->processManager()->handler();
-            $processManager->delete($queue->id, $queue->site_id);
-
-            $processManager->create(
-                $queue->id,
-                $queue->command,
-                $queue->user,
-                $queue->auto_start,
-                $queue->auto_restart,
-                $queue->numprocs,
-                $queue->getLogFile(),
-                $queue->site_id
-            );
-            $queue->status = QueueStatus::RUNNING;
-            $queue->save();
-        })->catch(function () use ($queue) {
-            $queue->status = QueueStatus::FAILED;
-            $queue->save();
-        })->onConnection('ssh');
-    }
-
-    public static function rules(Server $server): array
-    {
-        return [
-            'command' => [
-                'required',
-            ],
-            'user' => [
-                'required',
-                Rule::in([
-                    'root',
-                    $server->ssh_user,
-                ]),
-            ],
-            'numprocs' => [
-                'required',
-                'numeric',
-                'min:1',
-            ],
-        ];
-    }
-}
--- a/app/Actions/Queue/GetQueueLogs.php
+++ b/app/Actions/Queue/GetQueueLogs.php
@ -1,13 +0,0 @@
-<?php
-
-namespace App\Actions\Queue;
-
-use App\Models\Queue;
-
-class GetQueueLogs
-{
-    public function getLogs(Queue $queue): string
-    {
-        return $queue->server->processManager()->handler()->getLogs($queue->user, $queue->getLogFile());
-    }
-}
--- a/app/Actions/Queue/ManageQueue.php
+++ b/app/Actions/Queue/ManageQueue.php
@ -1,42 +0,0 @@
-<?php
-
-namespace App\Actions\Queue;
-
-use App\Enums\QueueStatus;
-use App\Models\Queue;
-
-class ManageQueue
-{
-    public function start(Queue $queue): void
-    {
-        $queue->status = QueueStatus::STARTING;
-        $queue->save();
-        dispatch(function () use ($queue) {
-            $queue->server->processManager()->handler()->start($queue->id, $queue->site_id);
-            $queue->status = QueueStatus::RUNNING;
-            $queue->save();
-        })->onConnection('ssh');
-    }
-
-    public function stop(Queue $queue): void
-    {
-        $queue->status = QueueStatus::STOPPING;
-        $queue->save();
-        dispatch(function () use ($queue) {
-            $queue->server->processManager()->handler()->stop($queue->id, $queue->site_id);
-            $queue->status = QueueStatus::STOPPED;
-            $queue->save();
-        })->onConnection('ssh');
-    }
-
-    public function restart(Queue $queue): void
-    {
-        $queue->status = QueueStatus::RESTARTING;
-        $queue->save();
-        dispatch(function () use ($queue) {
-            $queue->server->processManager()->handler()->restart($queue->id, $queue->site_id);
-            $queue->status = QueueStatus::RUNNING;
-            $queue->save();
-        })->onConnection('ssh');
-    }
-}
--- a/app/Actions/SSL/CreateSSL.php
+++ b/app/Actions/SSL/CreateSSL.php
@ -5,6 +5,7 @@
 use App\Enums\SslStatus;
 use App\Enums\SslType;
 use App\Models\ServerLog;
+use App\Models\Service;
 use App\Models\Site;
 use App\Models\Ssl;
 use App\SSH\Services\Webserver\Webserver;
@ -14,6 +15,8 @@
 class CreateSSL
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function create(Site $site, array $input): void
@ -40,19 +43,25 @@ public function create(Site $site, array $input): void
        $ssl->log_id = ServerLog::log($site->server, 'create-ssl', '', $site)->id;
        $ssl->save();

-        dispatch(function () use ($site, $ssl) {
+        dispatch(function () use ($site, $ssl): void {
+            /** @var Service $service */
+            $service = $site->server->webserver();
            /** @var Webserver $webserver */
-            $webserver = $site->server->webserver()->handler();
+            $webserver = $service->handler();
            $webserver->setupSSL($ssl);
            $ssl->status = SslStatus::CREATED;
            $ssl->save();
            $webserver->updateVHost($site);
-        })->catch(function () use ($ssl) {
+        })->catch(function () use ($ssl): void {
            $ssl->status = SslStatus::FAILED;
            $ssl->save();
        })->onConnection('ssh');
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(array $input): array
    {
        $rules = [
--- a/app/Actions/SSL/DeleteSSL.php
+++ b/app/Actions/SSL/DeleteSSL.php
@ -3,6 +3,7 @@
 namespace App\Actions\SSL;

 use App\Enums\SslStatus;
+use App\Models\Service;
 use App\Models\Ssl;
 use App\SSH\Services\Webserver\Webserver;

@ -12,8 +13,10 @@ public function delete(Ssl $ssl): void
    {
        $ssl->status = SslStatus::DELETING;
        $ssl->save();
+        /** @var Service $service */
+        $service = $ssl->site->server->webserver();
        /** @var Webserver $webserver */
-        $webserver = $ssl->site->server->webserver()->handler();
+        $webserver = $service->handler();
        $webserver->removeSSL($ssl);
        $ssl->delete();
    }
--- a/app/Actions/Script/CreateScript.php
+++ b/app/Actions/Script/CreateScript.php
@ -7,6 +7,9 @@

 class CreateScript
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(User $user, array $input): Script
    {
        $script = new Script([
@ -20,6 +23,9 @@ public function create(User $user, array $input): Script
        return $script;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Script/EditScript.php
+++ b/app/Actions/Script/EditScript.php
@ -7,6 +7,9 @@

 class EditScript
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function edit(Script $script, User $user, array $input): Script
    {
        $script->name = $input['name'];
@ -18,6 +21,9 @@ public function edit(Script $script, User $user, array $input): Script
        return $script;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Script/ExecuteScript.php
+++ b/app/Actions/Script/ExecuteScript.php
@ -11,6 +11,9 @@

 class ExecuteScript
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function execute(Script $script, array $input): ScriptExecution
    {
        $execution = new ScriptExecution([
@ -22,16 +25,19 @@ public function execute(Script $script, array $input): ScriptExecution
        ]);
        $execution->save();

-        dispatch(function () use ($execution, $script) {
+        dispatch(function () use ($execution, $script): void {
+            /** @var Server $server */
+            $server = $execution->server;
+
            $content = $execution->getContent();
-            $log = ServerLog::make($execution->server, 'script-'.$script->id.'-'.strtotime('now'));
+            $log = ServerLog::newLog($server, 'script-'.$script->id.'-'.strtotime('now'));
            $log->save();
            $execution->server_log_id = $log->id;
            $execution->save();
-            $execution->server->os()->runScript('~/', $content, $log, $execution->user);
+            $server->os()->runScript('~/', $content, $log, $execution->user);
            $execution->status = ScriptExecutionStatus::COMPLETED;
            $execution->save();
-        })->catch(function () use ($execution) {
+        })->catch(function () use ($execution): void {
            $execution->status = ScriptExecutionStatus::FAILED;
            $execution->save();
        })->onConnection('ssh');
@ -39,12 +45,16 @@ public function execute(Script $script, array $input): ScriptExecution
        return $execution;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(array $input): array
    {
        $users = ['root'];
        if (isset($input['server'])) {
-            /** @var ?Server $server */
-            $server = Server::query()->find($input['server']);
+            /** @var Server $server */
+            $server = Server::query()->findOrFail($input['server']);
            $users = $server->getSshUsers();
        }

--- a/app/Actions/Server/CreateServer.php
+++ b/app/Actions/Server/CreateServer.php
@ -24,6 +24,9 @@

 class CreateServer
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(User $creator, Project $project, array $input): Server
    {
        $server = new Server([
@ -81,7 +84,7 @@ public function create(User $creator, Project $project, array $input): Server

    private function install(Server $server): void
    {
-        dispatch(function () use ($server) {
+        dispatch(function () use ($server): void {
            $maxWait = 180;
            while ($maxWait > 0) {
                sleep(10);
@ -102,7 +105,7 @@ private function install(Server $server): void
            ]);
            Notifier::send($server, new ServerInstallationSucceed($server));
        })
-            ->catch(function (Throwable $e) use ($server) {
+            ->catch(function (Throwable $e) use ($server): void {
                $server->update([
                    'status' => ServerStatus::INSTALLATION_FAILED,
                ]);
@ -114,6 +117,10 @@ private function install(Server $server): void
            ->onConnection('ssh');
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(Project $project, array $input): array
    {
        $rules = [
@ -129,28 +136,22 @@ public static function rules(Project $project, array $input): array
                Rule::in(config('core.operating_systems')),
            ],
            'server_provider' => [
-                Rule::when(function () use ($input) {
-                    return isset($input['provider']) && $input['provider'] != ServerProvider::CUSTOM;
-                }, [
+                Rule::when(fn (): bool => isset($input['provider']) && $input['provider'] != ServerProvider::CUSTOM, [
                    'required',
-                    Rule::exists('server_providers', 'id')->where(function (Builder $query) use ($project) {
+                    Rule::exists('server_providers', 'id')->where(function (Builder $query) use ($project): void {
                        $query->where('project_id', $project->id)
                            ->orWhereNull('project_id');
                    }),
                ]),
            ],
            'ip' => [
-                Rule::when(function () use ($input) {
-                    return isset($input['provider']) && $input['provider'] == ServerProvider::CUSTOM;
-                }, [
+                Rule::when(fn (): bool => isset($input['provider']) && $input['provider'] == ServerProvider::CUSTOM, [
                    'required',
                    new RestrictedIPAddressesRule,
                ]),
            ],
            'port' => [
-                Rule::when(function () use ($input) {
-                    return isset($input['provider']) && $input['provider'] == ServerProvider::CUSTOM;
-                }, [
+                Rule::when(fn (): bool => isset($input['provider']) && $input['provider'] == ServerProvider::CUSTOM, [
                    'required',
                    'numeric',
                    'min:1',
@ -162,6 +163,10 @@ public static function rules(Project $project, array $input): array
        return array_merge($rules, self::typeRules($input), self::providerRules($input));
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    private static function typeRules(array $input): array
    {
        if (! isset($input['type']) || ! in_array($input['type'], config('core.server_types'))) {
@ -173,6 +178,10 @@ private static function typeRules(array $input): array
        return $server->type()->createRules($input);
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    private static function providerRules(array $input): array
    {
        if (
--- a/app/Actions/Server/CreateServerLog.php
+++ b/app/Actions/Server/CreateServerLog.php
@ -8,6 +8,8 @@
 class CreateServerLog
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function create(Server $server, array $input): void
@ -20,6 +22,9 @@ public function create(Server $server, array $input): void
        ]);
    }

+    /**
+     * @return array<string, string>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Server/EditServer.php
+++ b/app/Actions/Server/EditServer.php
@ -10,6 +10,9 @@
 class EditServer
 {
    /**
+     * @param  array<string, mixed>  $input
+     * @return Server $server
+     *
     * @throws ValidationException
     */
    public function edit(Server $server, array $input): Server
@ -42,6 +45,9 @@ public function edit(Server $server, array $input): Server
        return $server;
    }

+    /**
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(Server $server): array
    {
        return [
--- a/app/Actions/Server/Update.php
+++ b/app/Actions/Server/Update.php
@ -13,11 +13,11 @@ public function update(Server $server): void
    {
        $server->status = ServerStatus::UPDATING;
        $server->save();
-        dispatch(function () use ($server) {
+        dispatch(function () use ($server): void {
            $server->os()->upgrade();
            $server->checkConnection();
            $server->checkForUpdates();
-        })->catch(function () use ($server) {
+        })->catch(function () use ($server): void {
            Notifier::send($server, new ServerUpdateFailed($server));
            $server->checkConnection();
        })->onConnection('ssh');
--- a/app/Actions/ServerProvider/CreateServerProvider.php
+++ b/app/Actions/ServerProvider/CreateServerProvider.php
@ -3,6 +3,7 @@
 namespace App\Actions\ServerProvider;

 use App\Models\Project;
+use App\Models\Server;
 use App\Models\ServerProvider;
 use App\Models\User;
 use App\ServerProviders\ServerProvider as ServerProviderContract;
@ -13,11 +14,13 @@
 class CreateServerProvider
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function create(User $user, Project $project, array $input): ServerProvider
    {
-        $provider = static::getProvider($input['provider']);
+        $provider = self::getProvider($input['provider']);

        try {
            $provider->connect($input);
@ -40,13 +43,19 @@ public function create(User $user, Project $project, array $input): ServerProvid
        return $serverProvider;
    }

-    private static function getProvider($name): ServerProviderContract
+    private static function getProvider(string $name): ServerProviderContract
    {
        $providerClass = config('core.server_providers_class.'.$name);
+        /** @var ServerProviderContract $provider */
+        $provider = new $providerClass(new ServerProvider, new Server);

-        return new $providerClass;
+        return $provider;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(array $input): array
    {
        $rules = [
@ -60,15 +69,19 @@ public static function rules(array $input): array
            ],
        ];

-        return array_merge($rules, static::providerRules($input));
+        return array_merge($rules, self::providerRules($input));
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    private static function providerRules(array $input): array
    {
        if (! isset($input['provider'])) {
            return [];
        }

-        return static::getProvider($input['provider'])->credentialValidationRules($input);
+        return self::getProvider($input['provider'])->credentialValidationRules($input);
    }
 }
--- a/app/Actions/ServerProvider/EditServerProvider.php
+++ b/app/Actions/ServerProvider/EditServerProvider.php
@ -7,6 +7,9 @@

 class EditServerProvider
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function edit(ServerProvider $serverProvider, Project $project, array $input): ServerProvider
    {
        $serverProvider->profile = $input['name'];
@ -17,6 +20,9 @@ public function edit(ServerProvider $serverProvider, Project $project, array $in
        return $serverProvider;
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Service/Install.php
+++ b/app/Actions/Service/Install.php
@ -10,6 +10,9 @@

 class Install
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function install(Server $server, array $input): Service
    {
        $input['type'] = config('core.service_types')[$input['name']];
@ -28,11 +31,11 @@ public function install(Server $server, array $input): Service

        $service->save();

-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $service->handler()->install();
            $service->status = ServiceStatus::READY;
            $service->save();
-        })->catch(function () use ($service) {
+        })->catch(function () use ($service): void {
            $service->status = ServiceStatus::INSTALLATION_FAILED;
            $service->save();
        })->onConnection('ssh');
@ -40,6 +43,10 @@ public function install(Server $server, array $input): Service
        return $service;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(array $input): array
    {
        $rules = [
--- a/app/Actions/Service/Manage.php
+++ b/app/Actions/Service/Manage.php
@ -11,7 +11,7 @@ public function start(Service $service): void
    {
        $service->status = ServiceStatus::STARTING;
        $service->save();
-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $status = $service->server->systemd()->start($service->unit);
            if (str($status)->contains('Active: active')) {
                $service->status = ServiceStatus::READY;
@ -26,7 +26,7 @@ public function stop(Service $service): void
    {
        $service->status = ServiceStatus::STOPPING;
        $service->save();
-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $status = $service->server->systemd()->stop($service->unit);
            if (str($status)->contains('Active: inactive')) {
                $service->status = ServiceStatus::STOPPED;
@ -41,7 +41,7 @@ public function restart(Service $service): void
    {
        $service->status = ServiceStatus::RESTARTING;
        $service->save();
-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $status = $service->server->systemd()->restart($service->unit);
            if (str($status)->contains('Active: active')) {
                $service->status = ServiceStatus::READY;
@ -56,7 +56,7 @@ public function enable(Service $service): void
    {
        $service->status = ServiceStatus::ENABLING;
        $service->save();
-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $status = $service->server->systemd()->enable($service->unit);
            if (str($status)->contains('Active: active')) {
                $service->status = ServiceStatus::READY;
@ -71,7 +71,7 @@ public function disable(Service $service): void
    {
        $service->status = ServiceStatus::DISABLING;
        $service->save();
-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $status = $service->server->systemd()->disable($service->unit);
            if (str($status)->contains('Active: inactive')) {
                $service->status = ServiceStatus::DISABLED;
--- a/app/Actions/Service/Uninstall.php
+++ b/app/Actions/Service/Uninstall.php
@ -20,10 +20,10 @@ public function uninstall(Service $service): void
        $service->status = ServiceStatus::UNINSTALLING;
        $service->save();

-        dispatch(function () use ($service) {
+        dispatch(function () use ($service): void {
            $service->handler()->uninstall();
            $service->delete();
-        })->catch(function () use ($service) {
+        })->catch(function () use ($service): void {
            $service->status = ServiceStatus::FAILED;
            $service->save();
        })->onConnection('ssh');
--- a/app/Actions/Site/CreateCommand.php
+++ b/app/Actions/Site/CreateCommand.php
@ -0,0 +1,35 @@
+<?php
+
+namespace App\Actions\Site;
+
+use App\Models\Command;
+use App\Models\Site;
+
+class CreateCommand
+{
+    /**
+     * @param  array<string, mixed>  $input
+     */
+    public function create(Site $site, array $input): Command
+    {
+        $script = new Command([
+            'site_id' => $site->id,
+            'name' => $input['name'],
+            'command' => $input['command'],
+        ]);
+        $script->save();
+
+        return $script;
+    }
+
+    /**
+     * @return array<string, array<string>>
+     */
+    public static function rules(): array
+    {
+        return [
+            'name' => ['required', 'string', 'max:255'],
+            'command' => ['required', 'string'],
+        ];
+    }
+}
--- a/app/Actions/Site/CreateSite.php
+++ b/app/Actions/Site/CreateSite.php
@ -19,6 +19,11 @@

 class CreateSite
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function create(Server $server, array $input): Site
    {
        DB::beginTransaction();
@ -40,7 +45,7 @@ public function create(Server $server, array $input): Site
            // check has access to repository
            try {
                if ($site->sourceControl) {
-                    $site->sourceControl?->getRepo($site->repository);
+                    $site->sourceControl->getRepo($site->repository);
                }
            } catch (SourceControlIsNotConnected) {
                throw ValidationException::withMessages([
@ -68,15 +73,18 @@ public function create(Server $server, array $input): Site
                'content' => '',
            ]);

+            // create base commands if any
+            $site->commands()->createMany($site->type()->baseCommands());
+
            // install site
-            dispatch(function () use ($site) {
+            dispatch(function () use ($site): void {
                $site->type()->install();
                $site->update([
                    'status' => SiteStatus::READY,
                    'progress' => 100,
                ]);
                Notifier::send($site, new SiteInstallationSucceed($site));
-            })->catch(function () use ($site) {
+            })->catch(function () use ($site): void {
                $site->status = SiteStatus::INSTALLATION_FAILED;
                $site->save();
                Notifier::send($site, new SiteInstallationFailed($site));
@ -93,6 +101,10 @@ public function create(Server $server, array $input): Site
        }
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(Server $server, array $input): array
    {
        $rules = [
@ -103,9 +115,7 @@ public static function rules(Server $server, array $input): array
            'domain' => [
                'required',
                new DomainRule,
-                Rule::unique('sites', 'domain')->where(function ($query) use ($server) {
-                    return $query->where('server_id', $server->id);
-                }),
+                Rule::unique('sites', 'domain')->where(fn ($query) => $query->where('server_id', $server->id)),
            ],
            'aliases.*' => [
                new DomainRule,
@ -122,6 +132,10 @@ public static function rules(Server $server, array $input): array
        return array_merge($rules, self::typeRules($server, $input));
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     */
    private static function typeRules(Server $server, array $input): array
    {
        if (! isset($input['type']) || ! in_array($input['type'], config('core.site_types'))) {
--- a/app/Actions/Site/DeleteSite.php
+++ b/app/Actions/Site/DeleteSite.php
@ -3,6 +3,7 @@
 namespace App\Actions\Site;

 use App\Exceptions\SSHError;
+use App\Models\Service;
 use App\Models\Site;
 use App\SSH\Services\PHP\PHP;
 use App\SSH\Services\Webserver\Webserver;
@ -14,13 +15,18 @@ class DeleteSite
     */
    public function delete(Site $site): void
    {
+        /** @var Service $service */
+        $service = $site->server->webserver();
+
        /** @var Webserver $webserverHandler */
-        $webserverHandler = $site->server->webserver()->handler();
+        $webserverHandler = $service->handler();
        $webserverHandler->deleteSite($site);

        if ($site->isIsolated()) {
+            /** @var Service $phpService */
+            $phpService = $site->server->php();
            /** @var PHP $php */
-            $php = $site->server->php()->handler();
+            $php = $phpService->handler();
            $php->removeFpmPool($site->user, $site->php_version, $site->id);

            $os = $site->server->os();
--- a/app/Actions/Site/Deploy.php
+++ b/app/Actions/Site/Deploy.php
@ -39,9 +39,8 @@ public function run(Site $site): Deployment
        }
        $deployment->save();

-        dispatch(function () use ($site, $deployment) {
-            /** @var ServerLog $log */
-            $log = ServerLog::make($site->server, 'deploy-'.strtotime('now'))
+        dispatch(function () use ($site, $deployment): void {
+            $log = ServerLog::newLog($site->server, 'deploy-'.strtotime('now'))
                ->forSite($site);
            $log->save();
            $deployment->log_id = $log->id;
@ -56,7 +55,7 @@ public function run(Site $site): Deployment
            $deployment->status = DeploymentStatus::FINISHED;
            $deployment->save();
            Notifier::send($site, new DeploymentCompleted($deployment, $site));
-        })->catch(function () use ($deployment, $site) {
+        })->catch(function () use ($deployment, $site): void {
            $deployment->status = DeploymentStatus::FAILED;
            $deployment->save();
            Notifier::send($site, new DeploymentCompleted($deployment, $site));
--- a/app/Actions/Site/EditCommand.php
+++ b/app/Actions/Site/EditCommand.php
@ -0,0 +1,31 @@
+<?php
+
+namespace App\Actions\Site;
+
+use App\Models\Command;
+
+class EditCommand
+{
+    /**
+     * @param  array<string, mixed>  $input
+     */
+    public function edit(Command $command, array $input): Command
+    {
+        $command->name = $input['name'];
+        $command->command = $input['command'];
+        $command->save();
+
+        return $command;
+    }
+
+    /**
+     * @return array<string, array<string>>
+     */
+    public static function rules(): array
+    {
+        return [
+            'name' => ['required', 'string', 'max:255'],
+            'command' => ['required', 'string'],
+        ];
+    }
+}
--- a/app/Actions/Site/ExecuteCommand.php
+++ b/app/Actions/Site/ExecuteCommand.php
@ -0,0 +1,65 @@
+<?php
+
+namespace App\Actions\Site;
+
+use App\Enums\CommandExecutionStatus;
+use App\Models\Command;
+use App\Models\CommandExecution;
+use App\Models\ServerLog;
+use App\Models\User;
+
+class ExecuteCommand
+{
+    /**
+     * @param  array<string, mixed>  $input
+     */
+    public function execute(Command $command, User $user, array $input): CommandExecution
+    {
+        $execution = new CommandExecution([
+            'command_id' => $command->id,
+            'server_id' => $command->site->server_id,
+            'user_id' => $user->id,
+            'variables' => $input['variables'] ?? [],
+            'status' => CommandExecutionStatus::EXECUTING,
+        ]);
+        $execution->save();
+
+        dispatch(function () use ($execution, $command): void {
+            $content = $execution->getContent();
+            $log = ServerLog::newLog($execution->server, 'command-'.$command->id.'-'.strtotime('now'));
+            $log->save();
+            $execution->server_log_id = $log->id;
+            $execution->save();
+            $execution->server->os()->runScript(
+                path: $command->site->path,
+                script: $content,
+                serverLog: $log,
+                user: $command->site->user,
+                variables: $execution->variables
+            );
+            $execution->status = CommandExecutionStatus::COMPLETED;
+            $execution->save();
+        })->catch(function () use ($execution): void {
+            $execution->status = CommandExecutionStatus::FAILED;
+            $execution->save();
+        })->onConnection('ssh');
+
+        return $execution;
+    }
+
+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, string|array<int, mixed>>
+     */
+    public static function rules(array $input): array
+    {
+        return [
+            'variables' => 'array',
+            'variables.*' => [
+                'required',
+                'string',
+                'max:255',
+            ],
+        ];
+    }
+}
--- a/app/Actions/Site/UpdateAliases.php
+++ b/app/Actions/Site/UpdateAliases.php
@ -2,23 +2,33 @@

 namespace App\Actions\Site;

+use App\Models\Service;
 use App\Models\Site;
 use App\SSH\Services\Webserver\Webserver;
 use App\ValidationRules\DomainRule;

 class UpdateAliases
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(Site $site, array $input): void
    {
        $site->aliases = $input['aliases'] ?? [];

+        /** @var Service $service */
+        $service = $site->server->webserver();
+
        /** @var Webserver $webserver */
-        $webserver = $site->server->webserver()->handler();
+        $webserver = $service->handler();
        $webserver->updateVHost($site);

        $site->save();
    }

+    /**
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Site/UpdateBranch.php
+++ b/app/Actions/Site/UpdateBranch.php
@ -5,23 +5,24 @@
 use App\Exceptions\SSHError;
 use App\Models\Site;
 use App\SSH\Git\Git;
-use Illuminate\Validation\ValidationException;

 class UpdateBranch
 {
    /**
-     * @throws ValidationException
+     * @param  array<string, mixed>  $input
+     *
     * @throws SSHError
     */
    public function update(Site $site, array $input): void
    {
        $site->branch = $input['branch'];
+        app(Git::class)->fetchOrigin($site);
        app(Git::class)->checkout($site);
        $site->save();
    }

    /**
-     * @throws ValidationException
+     * @return array<string, string>
     */
    public static function rules(): array
    {
--- a/app/Actions/Site/UpdateDeploymentScript.php
+++ b/app/Actions/Site/UpdateDeploymentScript.php
@ -2,23 +2,24 @@

 namespace App\Actions\Site;

+use App\Models\DeploymentScript;
 use App\Models\Site;
-use Illuminate\Validation\ValidationException;

 class UpdateDeploymentScript
 {
    /**
-     * @throws ValidationException
+     * @param  array<string, mixed>  $input
     */
    public function update(Site $site, array $input): void
    {
+        /** @var DeploymentScript $script */
        $script = $site->deploymentScript;
        $script->content = $input['script'];
        $script->save();
    }

    /**
-     * @throws ValidationException
+     * @return array<string, array<string>>
     */
    public static function rules(): array
    {
--- a/app/Actions/Site/UpdateEnv.php
+++ b/app/Actions/Site/UpdateEnv.php
@ -8,6 +8,8 @@
 class UpdateEnv
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws SSHError
     */
    public function update(Site $site, array $input): void
@ -15,7 +17,7 @@ public function update(Site $site, array $input): void
        $site->server->os()->editFileAs(
            $site->path.'/.env',
            $site->user,
-            trim($input['env']),
+            trim((string) $input['env']),
        );
    }
 }
--- a/app/Actions/Site/UpdateLoadBalancer.php
+++ b/app/Actions/Site/UpdateLoadBalancer.php
@ -9,6 +9,9 @@

 class UpdateLoadBalancer
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(Site $site, array $input): void
    {
        $site->loadBalancerServers()->delete();
@ -27,6 +30,9 @@ public function update(Site $site, array $input): void
        $site->webserver()->updateVHost($site);
    }

+    /**
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(Site $site): array
    {
        return [
--- a/app/Actions/Site/UpdatePHPVersion.php
+++ b/app/Actions/Site/UpdatePHPVersion.php
@ -8,6 +8,9 @@

 class UpdatePHPVersion
 {
+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(Site $site): array
    {
        return [
@ -21,6 +24,8 @@ public static function rules(Site $site): array
    }

    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws SSHError
     */
    public function update(Site $site, array $input): void
--- a/app/Actions/Site/UpdateSourceControl.php
+++ b/app/Actions/Site/UpdateSourceControl.php
@ -11,12 +11,17 @@

 class UpdateSourceControl
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function update(Site $site, array $input): void
    {
        $site->source_control_id = $input['source_control'];
        try {
            if ($site->sourceControl) {
-                $site->sourceControl?->getRepo($site->repository);
+                $site->sourceControl->getRepo($site->repository);
            }
        } catch (SourceControlIsNotConnected) {
            throw ValidationException::withMessages([
@ -34,6 +39,9 @@ public function update(Site $site, array $input): void
        $site->save();
    }

+    /**
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/SourceControl/ConnectSourceControl.php
+++ b/app/Actions/SourceControl/ConnectSourceControl.php
@ -4,14 +4,18 @@

 use App\Models\Project;
 use App\Models\SourceControl;
-use App\Models\User;
 use Illuminate\Support\Arr;
 use Illuminate\Validation\Rule;
 use Illuminate\Validation\ValidationException;

 class ConnectSourceControl
 {
-    public function connect(User $user, Project $project, array $input): SourceControl
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
+    public function connect(Project $project, array $input): SourceControl
    {
        $sourceControl = new SourceControl([
            'provider' => $input['provider'],
@ -34,6 +38,10 @@ public function connect(User $user, Project $project, array $input): SourceContr
        return $sourceControl;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(array $input): array
    {
        $rules = [
@ -46,10 +54,13 @@ public static function rules(array $input): array
            ],
        ];

-        return array_merge($rules, static::providerRules($input));
+        return array_merge($rules, self::providerRules($input));
    }

    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<string>>
+     *
     * @throws ValidationException
     */
    private static function providerRules(array $input): array
--- a/app/Actions/SourceControl/EditSourceControl.php
+++ b/app/Actions/SourceControl/EditSourceControl.php
@ -8,6 +8,11 @@

 class EditSourceControl
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function edit(SourceControl $sourceControl, Project $project, array $input): SourceControl
    {
        $sourceControl->profile = $input['name'];
@ -27,6 +32,10 @@ public function edit(SourceControl $sourceControl, Project $project, array $inpu
        return $sourceControl;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<int, mixed>>
+     */
    public static function rules(SourceControl $sourceControl, array $input): array
    {
        $rules = [
@ -35,10 +44,13 @@ public static function rules(SourceControl $sourceControl, array $input): array
            ],
        ];

-        return array_merge($rules, static::providerRules($sourceControl, $input));
+        return array_merge($rules, self::providerRules($sourceControl, $input));
    }

    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, array<int, mixed>>
+     *
     * @throws ValidationException
     */
    private static function providerRules(SourceControl $sourceControl, array $input): array
--- a/app/Actions/SshKey/CreateSshKey.php
+++ b/app/Actions/SshKey/CreateSshKey.php
@ -10,6 +10,8 @@
 class CreateSshKey
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function create(User $user, array $input): SshKey
@ -25,7 +27,7 @@ public function create(User $user, array $input): SshKey
    }

    /**
-     * @throws ValidationException
+     * @return array<string, mixed>
     */
    public static function rules(): array
    {
--- a/app/Actions/SshKey/DeleteKeyFromServer.php
+++ b/app/Actions/SshKey/DeleteKeyFromServer.php
@ -3,11 +3,15 @@
 namespace App\Actions\SshKey;

 use App\Enums\SshKeyStatus;
+use App\Exceptions\SSHError;
 use App\Models\Server;
 use App\Models\SshKey;

 class DeleteKeyFromServer
 {
+    /**
+     * @throws SSHError
+     */
    public function delete(Server $server, SshKey $sshKey): void
    {
        $sshKey->servers()->updateExistingPivot($server->id, [
--- a/app/Actions/SshKey/DeployKeyToServer.php
+++ b/app/Actions/SshKey/DeployKeyToServer.php
@ -3,6 +3,7 @@
 namespace App\Actions\SshKey;

 use App\Enums\SshKeyStatus;
+use App\Exceptions\SSHError;
 use App\Models\Server;
 use App\Models\SshKey;
 use App\Models\User;
@ -10,6 +11,11 @@

 class DeployKeyToServer
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws SSHError
+     */
    public function deploy(Server $server, array $input): void
    {
        /** @var SshKey $sshKey */
@ -23,6 +29,9 @@ public function deploy(Server $server, array $input): void
        ]);
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(User $user, Server $server): array
    {
        return [
--- a/app/Actions/StorageProvider/CreateStorageProvider.php
+++ b/app/Actions/StorageProvider/CreateStorageProvider.php
@ -11,6 +11,8 @@
 class CreateStorageProvider
 {
    /**
+     * @param  array<string, mixed>  $input
+     *
     * @throws ValidationException
     */
    public function create(User $user, Project $project, array $input): StorageProvider
@ -41,6 +43,10 @@ public function create(User $user, Project $project, array $input): StorageProvi
        return $storageProvider;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     * @return array<string, mixed>
+     */
    public static function rules(array $input): array
    {
        $rules = [
--- a/app/Actions/StorageProvider/EditStorageProvider.php
+++ b/app/Actions/StorageProvider/EditStorageProvider.php
@ -4,10 +4,12 @@

 use App\Models\Project;
 use App\Models\StorageProvider;
-use Illuminate\Validation\ValidationException;

 class EditStorageProvider
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function edit(StorageProvider $storageProvider, Project $project, array $input): StorageProvider
    {
        $storageProvider->profile = $input['name'];
@ -19,7 +21,7 @@ public function edit(StorageProvider $storageProvider, Project $project, array $
    }

    /**
-     * @throws ValidationException
+     * @return array<string, mixed>
     */
    public static function rules(): array
    {
--- a/app/Actions/Tag/CreateTag.php
+++ b/app/Actions/Tag/CreateTag.php
@ -9,6 +9,11 @@

 class CreateTag
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function create(User $user, array $input): Tag
    {
        $tag = Tag::query()
@ -22,7 +27,7 @@ public function create(User $user, array $input): Tag
        }

        $tag = new Tag([
-            'project_id' => $user->currentProject->id,
+            'project_id' => $user->currentProject?->id,
            'name' => $input['name'],
            'color' => $input['color'],
        ]);
@ -31,6 +36,9 @@ public function create(User $user, array $input): Tag
        return $tag;
    }

+    /**
+     * @return array<string, mixed>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Tag/EditTag.php
+++ b/app/Actions/Tag/EditTag.php
@ -7,6 +7,9 @@

 class EditTag
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function edit(Tag $tag, array $input): void
    {
        $tag->name = $input['name'];
@ -15,6 +18,9 @@ public function edit(Tag $tag, array $input): void
        $tag->save();
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/Tag/SyncTags.php
+++ b/app/Actions/Tag/SyncTags.php
@ -5,12 +5,14 @@
 use App\Models\Server;
 use App\Models\Site;
 use App\Models\Tag;
-use App\Models\User;
 use Illuminate\Validation\Rule;

 class SyncTags
 {
-    public function sync(User $user, array $input): void
+    /**
+     * @param  array<string, mixed>  $input
+     */
+    public function sync(array $input): void
    {
        /** @var Server|Site $taggable */
        $taggable = $input['taggable_type']::findOrFail($input['taggable_id']);
@ -20,6 +22,9 @@ public function sync(User $user, array $input): void
        $taggable->tags()->sync($tags->pluck('id'));
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(int $projectId): array
    {
        return [
--- a/app/Actions/User/CreateUser.php
+++ b/app/Actions/User/CreateUser.php
@ -9,6 +9,9 @@

 class CreateUser
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function create(array $input): User
    {
        $this->validate($input);
@ -25,11 +28,17 @@ public function create(array $input): User
        return $user;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function validate(array $input): void
    {
        Validator::make($input, self::rules())->validate();
    }

+    /**
+     * @return array<string, mixed>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/User/PasswordValidationRules.php
+++ b/app/Actions/User/PasswordValidationRules.php
@ -7,9 +7,7 @@
 trait PasswordValidationRules
 {
    /**
-     * Get the validation rules used to validate passwords.
-     *
-     * @return array<int, \Illuminate\Contracts\Validation\Rule|array|string>
+     * @return array<int, mixed>
     */
    protected function passwordRules(): array
    {
--- a/app/Actions/User/UpdateProjects.php
+++ b/app/Actions/User/UpdateProjects.php
@ -5,9 +5,15 @@
 use App\Models\Project;
 use App\Models\User;
 use Illuminate\Validation\Rule;
+use Illuminate\Validation\ValidationException;

 class UpdateProjects
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function update(User $user, array $input): void
    {
        $this->validate($input);
@ -20,7 +26,7 @@ public function update(User $user, array $input): void

        $user->refresh();

-        /** @var Project $firstProject */
+        /** @var ?Project $firstProject */
        $firstProject = $user->projects->first();
        if (! $user->currentProject && $firstProject) {
            $user->current_project_id = $firstProject->id;
@ -28,11 +34,19 @@ public function update(User $user, array $input): void
        }
    }

+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    private function validate(array $input): void
    {
        validator($input, self::rules())->validate();
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/User/UpdateUser.php
+++ b/app/Actions/User/UpdateUser.php
@ -9,6 +9,9 @@

 class UpdateUser
 {
+    /**
+     * @param  array<string, mixed>  $input
+     */
    public function update(User $user, array $input): User
    {
        $this->validate($user, $input);
@ -27,11 +30,17 @@ public function update(User $user, array $input): User
        return $user;
    }

+    /**
+     * @param  array<string, mixed>  $input
+     */
    private function validate(User $user, array $input): void
    {
        Validator::make($input, self::rules($user))->validate();
    }

+    /**
+     * @return array<string, mixed>
+     */
    public static function rules(User $user): array
    {
        return [
--- a/app/Actions/User/UpdateUserPassword.php
+++ b/app/Actions/User/UpdateUserPassword.php
@ -6,6 +6,10 @@

 class UpdateUserPassword
 {
+    /**
+     * @param  mixed  $user
+     * @param  array<string, mixed>  $input
+     */
    public function update($user, array $input): void
    {
        $user->forceFill([
@ -13,6 +17,9 @@ public function update($user, array $input): void
        ])->save();
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(): array
    {
        return [
--- a/app/Actions/User/UpdateUserProfileInformation.php
+++ b/app/Actions/User/UpdateUserProfileInformation.php
@ -4,9 +4,15 @@

 use App\Models\User;
 use Illuminate\Validation\Rule;
+use Illuminate\Validation\ValidationException;

 class UpdateUserProfileInformation
 {
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
    public function update(User $user, array $input): void
    {
        if ($input['email'] !== $user->email) {
@ -20,6 +26,9 @@ public function update(User $user, array $input): void
        }
    }

+    /**
+     * @return array<string, array<string>>
+     */
    public static function rules(User $user): array
    {
        return [
@ -33,7 +42,7 @@ public static function rules(User $user): array
    }

    /**
-     * Update the given verified user's profile information.
+     * @param  array<string, mixed>  $input
     */
    protected function updateVerifiedUser(User $user, array $input): void
    {
--- a/app/Actions/Worker/CreateWorker.php
+++ b/app/Actions/Worker/CreateWorker.php
@ -0,0 +1,77 @@
+<?php
+
+namespace App\Actions\Worker;
+
+use App\Enums\WorkerStatus;
+use App\Models\Server;
+use App\Models\Service;
+use App\Models\Site;
+use App\Models\Worker;
+use App\SSH\Services\ProcessManager\ProcessManager;
+use Illuminate\Validation\Rule;
+use Illuminate\Validation\ValidationException;
+
+class CreateWorker
+{
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
+    public function create(Server $server, array $input, ?Site $site = null): void
+    {
+        $worker = new Worker([
+            'server_id' => $server->id,
+            'site_id' => $site?->id,
+            'command' => $input['command'],
+            'user' => $input['user'],
+            'auto_start' => $input['auto_start'] ? 1 : 0,
+            'auto_restart' => $input['auto_restart'] ? 1 : 0,
+            'numprocs' => $input['numprocs'],
+            'status' => WorkerStatus::CREATING,
+        ]);
+        $worker->save();
+
+        dispatch(function () use ($worker): void {
+            /** @var Service $service */
+            $service = $worker->server->processManager();
+            /** @var ProcessManager $processManager */
+            $processManager = $service->handler();
+            $processManager->create(
+                $worker->id,
+                $worker->command,
+                $worker->user,
+                $worker->auto_start,
+                $worker->auto_restart,
+                $worker->numprocs,
+                $worker->getLogFile(),
+                $worker->site_id
+            );
+            $worker->status = WorkerStatus::RUNNING;
+            $worker->save();
+        })->catch(function () use ($worker): void {
+            $worker->delete();
+        })->onConnection('ssh');
+    }
+
+    /**
+     * @return array<string, array<string>>
+     */
+    public static function rules(Server $server, ?Site $site = null): array
+    {
+        return [
+            'command' => [
+                'required',
+            ],
+            'user' => [
+                'required',
+                Rule::in($site?->getSshUsers() ?? $server->getSshUsers()),
+            ],
+            'numprocs' => [
+                'required',
+                'numeric',
+                'min:1',
+            ],
+        ];
+    }
+}
--- a/app/Actions/Worker/DeleteWorker.php
+++ b/app/Actions/Worker/DeleteWorker.php
@ -0,0 +1,13 @@
+<?php
+
+namespace App\Actions\Worker;
+
+use App\Models\Worker;
+
+class DeleteWorker
+{
+    public function delete(Worker $worker): void
+    {
+        $worker->delete();
+    }
+}
--- a/app/Actions/Worker/EditWorker.php
+++ b/app/Actions/Worker/EditWorker.php
@ -0,0 +1,78 @@
+<?php
+
+namespace App\Actions\Worker;
+
+use App\Enums\WorkerStatus;
+use App\Models\Server;
+use App\Models\Service;
+use App\Models\Site;
+use App\Models\Worker;
+use App\SSH\Services\ProcessManager\ProcessManager;
+use Illuminate\Validation\Rule;
+use Illuminate\Validation\ValidationException;
+
+class EditWorker
+{
+    /**
+     * @param  array<string, mixed>  $input
+     *
+     * @throws ValidationException
+     */
+    public function edit(Worker $worker, array $input): void
+    {
+        $worker->fill([
+            'command' => $input['command'],
+            'user' => $input['user'],
+            'auto_start' => $input['auto_start'] ? 1 : 0,
+            'auto_restart' => $input['auto_restart'] ? 1 : 0,
+            'numprocs' => $input['numprocs'],
+            'status' => WorkerStatus::RESTARTING,
+        ]);
+        $worker->save();
+
+        dispatch(function () use ($worker): void {
+            /** @var Service $service */
+            $service = $worker->server->processManager();
+            /** @var ProcessManager $processManager */
+            $processManager = $service->handler();
+            $processManager->delete($worker->id, $worker->site_id);
+
+            $processManager->create(
+                $worker->id,
+                $worker->command,
+                $worker->user,
+                $worker->auto_start,
+                $worker->auto_restart,
+                $worker->numprocs,
+                $worker->getLogFile(),
+                $worker->site_id
+            );
+            $worker->status = WorkerStatus::RUNNING;
+            $worker->save();
+        })->catch(function () use ($worker): void {
+            $worker->status = WorkerStatus::FAILED;
+            $worker->save();
+        })->onConnection('ssh');
+    }
+
+    /**
+     * @return array<string, array<string>>
+     */
+    public static function rules(Server $server, ?Site $site = null): array
+    {
+        return [
+            'command' => [
+                'required',
+            ],
+            'user' => [
+                'required',
+                Rule::in($site?->getSshUsers() ?? $server->getSshUsers()),
+            ],
+            'numprocs' => [
+                'required',
+                'numeric',
+                'min:1',
+            ],
+        ];
+    }
+}
--- a/app/Actions/Worker/GetWorkerLogs.php
+++ b/app/Actions/Worker/GetWorkerLogs.php
@ -0,0 +1,21 @@
+<?php
+
+namespace App\Actions\Worker;
+
+use App\Models\Service;
+use App\Models\Worker;
+use App\SSH\Services\ProcessManager\ProcessManager;
+
+class GetWorkerLogs
+{
+    public function getLogs(Worker $worker): string
+    {
+        /** @var Service $service */
+        $service = $worker->server->processManager();
+
+        /** @var ProcessManager $handler */
+        $handler = $service->handler();
+
+        return $handler->getLogs($worker->user, $worker->getLogFile());
+    }
+}
--- a/app/Actions/Worker/ManageWorker.php
+++ b/app/Actions/Worker/ManageWorker.php
@ -0,0 +1,56 @@
+<?php
+
+namespace App\Actions\Worker;
+
+use App\Enums\WorkerStatus;
+use App\Models\Service;
+use App\Models\Worker;
+use App\SSH\Services\ProcessManager\ProcessManager;
+
+class ManageWorker
+{
+    public function start(Worker $worker): void
+    {
+        $worker->status = WorkerStatus::STARTING;
+        $worker->save();
+        dispatch(function () use ($worker): void {
+            /** @var Service $service */
+            $service = $worker->server->processManager();
+            /** @var ProcessManager $handler */
+            $handler = $service->handler();
+            $handler->start($worker->id, $worker->site_id);
+            $worker->status = WorkerStatus::RUNNING;
+            $worker->save();
+        })->onConnection('ssh');
+    }
+
+    public function stop(Worker $worker): void
+    {
+        $worker->status = WorkerStatus::STOPPING;
+        $worker->save();
+        dispatch(function () use ($worker): void {
+            /** @var Service $service */
+            $service = $worker->server->processManager();
+            /** @var ProcessManager $handler */
+            $handler = $service->handler();
+            $handler->stop($worker->id, $worker->site_id);
+            $worker->status = WorkerStatus::STOPPED;
+            $worker->save();
+        })->onConnection('ssh');
+    }
+
+    public function restart(Worker $worker): void
+    {
+        $worker->status = WorkerStatus::RESTARTING;
+        $worker->save();
+        dispatch(function () use ($worker): void {
+            /** @var Service $service */
+            $service = $worker->server->processManager();
+            /** @var ProcessManager $handler */
+            $handler = $service->handler();
+            $handler->restart($worker->id, $worker->site_id);
+            $worker->status = WorkerStatus::RUNNING;
+            $worker->save();
+        })->onConnection('ssh');
+    }
+}
--- a/app/Console/Commands/ClearLogsCommand.php
+++ b/app/Console/Commands/ClearLogsCommand.php
@ -0,0 +1,26 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\ServerLog;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\File;
+use Illuminate\Support\Facades\Storage;
+
+class ClearLogsCommand extends Command
+{
+    protected $signature = 'logs:clear';
+
+    protected $description = 'Clear all server logs';
+
+    public function handle(): void
+    {
+        $this->info('Clearing logs...');
+
+        ServerLog::query()->delete();
+
+        File::cleanDirectory(Storage::disk('server-logs')->path(''));
+
+        $this->info('Logs cleared!');
+    }
+}
--- a/app/Console/Commands/DeleteOlderMetricsCommand.php
+++ b/app/Console/Commands/DeleteOlderMetricsCommand.php
@ -11,10 +11,10 @@ class DeleteOlderMetricsCommand extends Command

    protected $description = 'Delete older metrics from database';

-    public function handle()
+    public function handle(): void
    {
-        Service::query()->where('type', 'monitoring')->chunk(100, function ($services) {
-            $services->each(function ($service) {
+        Service::query()->where('type', 'monitoring')->chunk(100, function ($services): void {
+            $services->each(function ($service): void {
                $this->info("Deleting older metrics for service {$service->server->name}");
                $service
                    ->server
--- a/app/Console/Commands/GetMetricsCommand.php
+++ b/app/Console/Commands/GetMetricsCommand.php
@ -15,10 +15,10 @@ class GetMetricsCommand extends Command
    public function handle(): void
    {
        $checkedMetrics = 0;
-        Server::query()->whereHas('services', function (Builder $query) {
+        Server::query()->whereHas('services', function (Builder $query): void {
            $query->where('type', 'monitoring')
                ->where('name', 'remote-monitor');
-        })->chunk(10, function ($servers) use (&$checkedMetrics) {
+        })->chunk(10, function ($servers) use (&$checkedMetrics): void {
            /** @var Server $server */
            foreach ($servers as $server) {
                $info = $server->os()->resourceInfo();
--- a/app/Console/Commands/MigrateFromMysqlToSqlite.php
+++ b/app/Console/Commands/MigrateFromMysqlToSqlite.php
@ -16,9 +16,9 @@ public function handle(): void
    {
        $this->info('Migrating from Mysql to SQLite...');

-        File::exists(storage_path('database.sqlite'))
-            ? File::delete(storage_path('database.sqlite'))
-            : null;
+        if (File::exists(storage_path('database.sqlite'))) {
+            File::delete(storage_path('database.sqlite'));
+        }

        File::put(storage_path('database.sqlite'), '');

@ -37,7 +37,7 @@ public function handle(): void
        $this->migrateModel(\App\Models\GitHook::class);
        $this->migrateModel(\App\Models\NotificationChannel::class);
        $this->migrateModel(\App\Models\Project::class);
-        $this->migrateModel(\App\Models\Queue::class);
+        $this->migrateModel(\App\Models\Worker::class);
        $this->migrateModel(\App\Models\Server::class);
        $this->migrateModel(\App\Models\ServerLog::class);
        $this->migrateModel(\App\Models\ServerProvider::class);
--- a/app/Console/Commands/RunBackupCommand.php
+++ b/app/Console/Commands/RunBackupCommand.php
@ -20,7 +20,7 @@ public function handle(): void
        Backup::query()
            ->where('interval', $this->argument('interval'))
            ->where('status', BackupStatus::RUNNING)
-            ->chunk(100, function ($backups) use (&$total) {
+            ->chunk(100, function ($backups) use (&$total): void {
                /** @var Backup $backup */
                foreach ($backups as $backup) {
                    app(RunBackup::class)->run($backup);
--- a/app/Console/Kernel.php
+++ b/app/Console/Kernel.php
@ -26,7 +26,5 @@ protected function schedule(Schedule $schedule): void
    protected function commands(): void
    {
        $this->load(__DIR__.'/Commands');
-
-        require base_path('routes/console.php');
    }
 }
--- a/app/Enums/CommandExecutionStatus.php
+++ b/app/Enums/CommandExecutionStatus.php
@ -0,0 +1,12 @@
+<?php
+
+namespace App\Enums;
+
+final class CommandExecutionStatus
+{
+    const EXECUTING = 'executing';
+
+    const COMPLETED = 'completed';
+
+    const FAILED = 'failed';
+}
--- a/app/Enums/SiteFeature.php
+++ b/app/Enums/SiteFeature.php
@ -10,5 +10,7 @@ final class SiteFeature

    const SSL = 'ssl';

-    const QUEUES = 'queues';
+    const WORKERS = 'workers';
+
+    const COMMANDS = 'commands';
 }
--- a/app/Enums/WorkerStatus.php
+++ b/app/Enums/WorkerStatus.php
@ -2,7 +2,7 @@

 namespace App\Enums;

-final class QueueStatus
+final class WorkerStatus
 {
    const RUNNING = 'running';

--- a/app/Exceptions/Handler.php
+++ b/app/Exceptions/Handler.php
@ -43,7 +43,7 @@ class Handler extends ExceptionHandler
     */
    public function register(): void
    {
-        $this->reportable(function (Throwable $e) {
+        $this->reportable(function (Throwable $e): void {
            //
        });
    }
--- a/app/Exceptions/SSHError.php
+++ b/app/Exceptions/SSHError.php
@ -8,12 +8,8 @@

 class SSHError extends Exception
 {
-    protected ?ServerLog $log;
-
-    public function __construct(string $message = '', int $code = 0, ?Throwable $previous = null, ?ServerLog $log = null)
+    public function __construct(string $message = '', int $code = 0, ?Throwable $previous = null, protected ?ServerLog $log = null)
    {
-        $this->log = $log;
-
        parent::__construct($message, $code, $previous);
    }

--- a/app/Facades/FTP.php
+++ b/app/Facades/FTP.php
@ -7,7 +7,7 @@
 use Illuminate\Support\Facades\Facade;

 /**
- * @method static bool|Connection connect(string $host, string $port, bool $ssl = false)
+ * @method static bool|Connection connect(string $host, int $port, bool $ssl = false)
 * @method static bool login(string $username, string $password, bool|Connection $connection)
 * @method static void close(bool|Connection $connection)
 * @method static bool passive(bool|Connection $connection, bool $passive)
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Saeed Vaziry	f89e7af34e	fix server workers 500 error	2025-03-16 14:38:10 +01:00
Saeed Vaziry	7886e2a113	Bump version 2.4.0 (#548 )	2025-03-16 14:10:55 +01:00
Saeed Vaziry	72352aad8d	Add workers to servers (#547 )	2025-03-16 14:09:15 +01:00
Saeed Vaziry	48ae561ea4	code-style	2025-03-13 20:53:14 +01:00
Saeed Vaziry	0f06d81aac	Add database and database users sync (#537 ) * Add database and database users sync * get mysl users * add mariadb and postgres * fix phpstan	2025-03-12 22:59:25 +01:00
Saeed Vaziry	493cbb0849	Add phpstan level 7(#544 )	2025-03-12 13:31:10 +01:00
Dimitar Yanakiev	c22bb1fa80	Add isolated users to headless console (#533 )	2025-03-07 00:14:45 +01:00
Saeed Vaziry	babf59350b	Fix run_action helper (#540 ) * Fix run_action helper * upgrade actions * upgrade actions	2025-03-05 20:36:18 +01:00
Richard Anderson	5a12ed76bb	Database collations (#489 ) * SyncDatabases * Collation on Create inc WordPress * Refactored Enum * Resolve sync issue * Fix for PostgreSQL * pint * reversed enum * style adjustments * add unit tests * style * fix tests * more tests --------- Co-authored-by: Saeed Vaziry <61919774+saeedvaziry@users.noreply.github.com> Co-authored-by: Saeed Vaziry <mr.saeedvaziry@gmail.com>	2025-03-02 17:18:27 +01:00
Dimitar Yanakiev	269ee8d962	Fix: Sail default container name to match docker-compose.yml (#532 ) By default, Sail looks for the `laravel.test` container when running `sail artisan`, but the `docker-compose.yml` in this project defines the service as `app`. This caused `sail artisan` and other Sail commands to fail locally. Updated the `APP_SERVICE` environment variable in `sail` to default to `app` instead of `laravel.test`, ensuring consistency with the service name in `docker-compose.yml`.	2025-03-02 14:06:58 +01:00
Saeed Vaziry	a060a06e73	add default commands	2025-03-02 12:08:18 +01:00
Dimitar Yanakiev	49137a757b	Fix console working directory for root user (#525 ) Previously, `$(pwd)` was expanded too early by the parent shell, leading to incorrect working directory output when `cd` was executed within `$request->command`. Replaced `echo "VITO_WORKING_DIR: $(pwd)"` with `echo -n "VITO_WORKING_DIR: " && pwd` to ensure `pwd` executes at the right moment inside the same shell session. Closes #515	2025-03-02 10:55:06 +01:00
Dimitar Yanakiev	97e20206e8	ite Commands (#298 ) (#519 ) * feat: Implement Site Commands (#298) - Introduced a Commands widget/table for Site view, allowing users to create, edit, delete, and execute commands. - Each Site Type now has a predefined set of commands inserted upon site creation. - A migration script ensures commands are created for existing sites. - Implemented necessary policies for command management. - Added feature tests to validate functionality. * I'm trying to fix the tests, but it seems like it might not work. I'm having trouble running the tests locally for some reason. * I'm trying to fix the tests, but it seems like it might not work. I'm having trouble running the tests locally for some reason. * I'm trying to fix the tests, but it seems like it might not work. I'm having trouble running the tests locally for some reason. * I'm trying to fix the tests, but it seems like it might not work. I'm having trouble running the tests locally for some reason. * Remove feature tests for commands due to inconsistencies for now * fixes * add tests for commands * ui fix and add to wordpress --------- Co-authored-by: Saeed Vaziry <mr.saeedvaziry@gmail.com>	2025-03-02 10:43:26 +01:00
Dimitar Yanakiev	176ff3bbc4	fix: Fix variables not being saved in database when executing a script (#518 )	2025-02-28 23:26:18 +01:00
Dimitar Yanakiev	b2440586d6	fix: Fix regex in File Manager to support hyphenated usernames and groups (#516 )	2025-02-28 19:49:33 +01:00
Dimitar Yanakiev	4b8e798e66	fix: prevent "null" from appearing in console after user selection (#501 ) (#514 ) Ensure a default working directory is returned when fetching the console working directory. Previously, if a user is switched before running any commands, `Cache::get` would return `null`. Now, it defaults to `'~'` if no value exists. Closes #501.	2025-02-28 19:44:12 +01:00
Dimitar Yanakiev	6143eb94b4	feat: display repository and branch in site details (#512 ) Added `repository` and `branch` fields to the site details view. These fields are now visible when a site has a corresponding repository or branch and are formatted accordingly.	2025-02-28 19:43:20 +01:00
Dimitar Yanakiev	e52903c649	fix: ensure newly created branches are available for switching (#511 ) Fixed an issue where the "Change Branch" button didn't work when switching to a newly created remote branch after initially cloning the repository. Added `git fetch origin` to update branch references before switching.	2025-02-28 19:38:38 +01:00
Dimitar Yanakiev	1a5cf4c57a	fix: add missing php-intl package (#510 ) Added `php{{ $version }}-intl` to the installation list as it was missing. This package is a standard component in most projects and should be included by default.	2025-02-28 19:38:10 +01:00
Saeed Vaziry	d8ece27964	Add logs:clear command (#509 )	2025-02-27 22:19:50 +01:00
Saeed Vaziry	f54c754971	update docker publish script	2025-02-26 21:22:59 +01:00