Initial commit

Author: zaxxo-dkraemer

.gitignore

@@ -0,0 +1,3 @@
+/.idea
+/vendor
+composer.lock

composer.json

@@ -0,0 +1,30 @@
+{
+    "name": "zaxxo/laravel-websockets-restart",
+    "description": "This package adds a restart command for the WebSocket server from beyondcode.",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Zaxxo",
+            "email": "[email protected]"
+        }
+    ],
+    "require": {
+        "php": "^7.1",
+        "beyondcode/laravel-websockets": "^1.0",
+        "illuminate/console": "^5.7|^6",
+        "illuminate/support": "^5.7|^6"
+    },
+    "autoload": {
+        "psr-4": {
+            "Zaxxo\\LaravelWebSocketsRestart\\": "src/"
+        }
+    },
+    "extra": {
+        "laravel": {
+            "providers": [
+                "Zaxxo\\LaravelWebSocketsRestart\\ServiceProvider"
+            ]
+        }
+    }
+}

readme.md

@@ -0,0 +1,21 @@
+# Laravel WebSockets Restart
+
+This adds a console command to restart the [Laravel WebSocket](https://github.com/beyondcode/laravel-websockets) server.
+
+Helpful if you deploy automatically (e.g. with Laravel Envoyer).
+
+## Installation
+
+```
+composer require zaxxo/laravel-websockets-restart
+```
+
+## Usage
+
+```
+php artisan websockets:restart
+```
+
+## Note
+
+This only works if the server is automatically restarted with Supervisor or something else.

src/RestartWebSocketCommand.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Zaxxo\LaravelWebSocketsRestart;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\InteractsWithTime;
+
+/**
+ * Command for restarting WebSocket server.
+ *
+ * @package Zaxxo\LaravelWebSocketsRestart
+ * @internal
+ */
+class RestartWebSocketCommand extends Command
+{
+    use InteractsWithTime;
+
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'websockets:restart';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Restart WebSocket server';
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        Cache::forever('beyondcode:websockets:restart', $this->currentTime());
+
+        $this->info('Broadcasting WebSocket server restart signal.');
+    }
+}

src/ServiceProvider.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace Zaxxo\LaravelWebSocketsRestart;
+
+use BeyondCode\LaravelWebSockets\Console\StartWebSocketServer;
+use Illuminate\Support\ServiceProvider as BaseServiceProvider;
+
+/**
+ * Service provider for Laravel WebSockets Restart package.
+ *
+ * @package Zaxxo\LaravelWebSocketsRestart
+ * @internal
+ */
+class ServiceProvider extends BaseServiceProvider
+{
+    /**
+     * Register any application services.
+     */
+    public function register()
+    {
+        $this->app->alias(StartWebSocketCommand::class, StartWebSocketServer::class);
+    }
+
+    /**
+     * Bootstrap any application services.
+     */
+    public function boot(): void
+    {
+        $this->commands(RestartWebSocketCommand::class);
+    }
+}

src/StartWebSocketCommand.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace Zaxxo\LaravelWebSocketsRestart;
+
+use BeyondCode\LaravelWebSockets\Console\StartWebSocketServer;
+use Illuminate\Support\Facades\Cache;
+
+/**
+ * Extend the command to start the WebSocket server.
+ *
+ * @package Zaxxo\LaravelWebSocketsRestart
+ * @internal
+ */
+class StartWebSocketCommand extends StartWebSocketServer
+{
+    /**
+     * The last time restart was requested.
+     *
+     * @var int
+     */
+    private $lastRestart;
+
+    /**
+     * Execute the console command.
+     */
+    public function handle()
+    {
+        $this->configureRestartTimer();
+
+        parent::handle();
+    }
+
+    /**
+     * Add a timer to check if server should be restarted.
+     */
+    protected function configureRestartTimer(): void
+    {
+        $this->lastRestart = $this->getLastRestart();
+
+        $this->loop->addPeriodicTimer(10, function () {
+            if ($this->getLastRestart() != $this->lastRestart) {
+                $this->loop->stop();
+            }
+        });
+    }
+
+    /**
+     * Get the last restart time.
+     *
+     * @return int
+     */
+    private function getLastRestart(): int
+    {
+        return Cache::get('beyondcode:websockets:restart', 0);
+    }
+}