[2.x] Asynchronous app managers

.github/workflows/ci.yml

@@ -19,22 +19,16 @@ jobs:
     strategy:
       matrix:
         php:
-          - '7.3'
-          - '7.4'
+          - '8.0'
+          - '8.1'
         laravel:
-          - 6.*
-          - 7.*
-          - 8.*
+          - 9.*
         prefer:
           - 'prefer-lowest'
           - 'prefer-stable'
         include:
-          - laravel: '6.*'
-            testbench: '4.*'
-          - laravel: '7.*'
-            testbench: '5.*'
-          - laravel: '8.*'
-            testbench: '6.*'
+          - laravel: '9.*'
+            testbench: '7.*'
 
     name: PHP ${{ matrix.php }} - Laravel ${{ matrix.laravel }} --${{ matrix.prefer }}
 
@@ -48,6 +42,13 @@ jobs:
         extensions: dom, curl, libxml, mbstring, zip, pcntl, pdo, sqlite, pdo_sqlite, bcmath, soap, intl, gd, exif, iconv
         coverage: pcov
 
+    - name: Setup MySQL
+      uses: haltuf/mysql-action@master
+      with:
+        mysql version: '8.0'
+        mysql database: 'websockets_test'
+        mysql root password: 'password'
+
     - name: Setup Redis
       uses: supercharge/redis-github-action@1.1.0
       with:

composer.json

@@ -29,29 +29,33 @@
         }
     ],
     "require": {
-        "cboden/ratchet": "^0.4.1",
-        "clue/redis-react": "^2.3",
+        "php": "^8.0|^8.1",
+        "clue/reactphp-sqlite": "^1.0",
+        "react/mysql": "^0.5",
+        "cboden/ratchet": "^0.4.4",
+        "clue/redis-react": "^2.6",
         "doctrine/dbal": "^2.9",
         "evenement/evenement": "^2.0|^3.0",
         "facade/ignition-contracts": "^1.0",
         "guzzlehttp/psr7": "^1.5",
-        "illuminate/broadcasting": "^6.3|^7.0|^8.0",
-        "illuminate/console": "^6.3|7.0|^8.0",
-        "illuminate/http": "^6.3|^7.0|^8.0",
-        "illuminate/queue": "^6.3|^7.0|^8.0",
-        "illuminate/routing": "^6.3|^7.0|^8.0",
-        "illuminate/support": "^6.3|^7.0|^8.0",
-        "pusher/pusher-php-server": "^4.0",
-        "react/promise": "^2.0",
-        "symfony/http-kernel": "^4.0|^5.0",
+        "illuminate/broadcasting": "^9.0",
+        "illuminate/console": "^9.0",
+        "illuminate/http": "^9.0",
+        "illuminate/queue": "^9.0",
+        "illuminate/routing": "^9.0",
+        "illuminate/support": "^9.0",
+        "pusher/pusher-php-server": "^6.0|^7.0",
+        "react/promise": "^2.8",
+        "symfony/http-kernel": "^5.0|^6.0",
         "symfony/psr-http-message-bridge": "^1.1|^2.0"
     },
     "require-dev": {
+        "clue/buzz-react": "^2.9",
         "clue/block-react": "^1.4",
         "laravel/legacy-factories": "^1.1",
-        "orchestra/testbench-browser-kit": "^4.0|^5.0|^6.0",
-        "orchestra/database": "^4.0|^5.0|^6.0",
-        "phpunit/phpunit": "^8.0|^9.0"
+        "orchestra/testbench-browser-kit": "^7.0",
+        "phpunit/phpunit": "^9.0",
+        "ratchet/pawl": "^0.3.5"
     },
     "suggest": {
         "ext-pcntl": "Running the server needs pcntl to listen to command signals and soft-shutdown."
@@ -73,6 +77,7 @@
         "sort-packages": true
     },
     "minimum-stability": "dev",
+    "prefer-stable": true,
     "extra": {
         "laravel": {
             "providers": [

config/websockets.php

@@ -37,13 +37,40 @@
         | the use of the TCP protocol based on, for example, a list of allowed
         | applications.
         | By default, it uses the defined array in the config file, but you can
-        | anytime implement the same interface as the class and add your own
-        | custom method to retrieve the apps.
+        | choose to use SQLite or MySQL application managers, or define a
+        | custom application manager.
         |
         */
 
         'app' => \BeyondCode\LaravelWebSockets\Apps\ConfigAppManager::class,
 
+        /*
+        |--------------------------------------------------------------------------
+        | SQLite application manager
+        |--------------------------------------------------------------------------
+        |
+        | The SQLite database to use when using the SQLite application manager.
+        |
+        */
+
+        'sqlite' => [
+            'database' => storage_path('laravel-websockets.sqlite'),
+        ],
+
+        /*
+        |--------------------------------------------------------------------------
+        | MySql application manager
+        |--------------------------------------------------------------------------
+        |
+        | The MySQL database connection to use.
+        |
+        */
+
+        'mysql' => [
+            'connection' => env('DB_CONNECTION', 'mysql'),
+
+            'table' => 'websockets_apps',
+        ],
     ],
 
     /*

database/migrations/0000_00_00_000000_create_websockets_apps_table.php

@@ -0,0 +1,40 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+class CreateWebSocketsAppsTable extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('websockets_apps', function (Blueprint $table) {
+            $table->string('id')->index();
+            $table->string('key');
+            $table->string('secret');
+            $table->string('name');
+            $table->string('host')->nullable();
+            $table->string('path')->nullable();
+            $table->boolean('enable_client_messages')->default(false);
+            $table->boolean('enable_statistics')->default(true);
+            $table->unsignedInteger('capacity')->nullable();
+            $table->string('allowed_origins');
+            $table->nullableTimestamps();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('websockets_apps');
+    }
+}

database/migrations/0000_00_00_000000_create_websockets_statistics_entries_table.php

@@ -16,9 +16,9 @@ public function up()
         Schema::create('websockets_statistics_entries', function (Blueprint $table) {
             $table->increments('id');
             $table->string('app_id');
-            $table->integer('peak_connection_count');
-            $table->integer('websocket_message_count');
-            $table->integer('api_message_count');
+            $table->integer('peak_connections_count');
+            $table->integer('websocket_messages_count');
+            $table->integer('api_messages_count');
             $table->nullableTimestamps();
         });
     }

database/migrations/sqlite/0000_00_00_000000_create_apps_table.sql

@@ -0,0 +1,12 @@
+CREATE TABLE IF NOT EXISTS apps (
+    id STRING NOT NULL,
+    key STRING NOT NULL,
+    secret STRING NOT NULL,
+    name STRING NOT NULL,
+    host STRING NULLABLE,
+    path STRING NULLABLE,
+    enable_client_messages BOOLEAN DEFAULT 0,
+    enable_statistics BOOLEAN DEFAULT 1,
+    capacity INTEGER NULLABLE,
+    allowed_origins STRING NULLABLE
+)