formatting

src/Application.php

@@ -4,6 +4,9 @@
 
 class Application
 {
+    /**
+     * Create a new application instance.
+     */
     public function __construct(
         protected string $id,
         protected string $key,

src/Channels/Channel.php

@@ -18,6 +18,9 @@ class Channel
      */
     protected $connections;
 
+    /**
+     * Create a new channel instance.
+     */
     public function __construct(protected string $name)
     {
         $this->connections = app(ChannelConnectionManager::class)->for($this->name);

src/ConfigProvider.php

@@ -8,8 +8,12 @@
 
 class ConfigProvider implements ApplicationProvider
 {
+    /**
+     * Create a new config provider instance.
+     */
     public function __construct(protected Collection $applications)
     {
+        //
     }
 
     /**

src/Contracts/Connection.php

@@ -16,10 +16,11 @@ abstract class Connection
      */
     protected $hasBeenPinged = false;
 
-    public function __construct(
-        protected Application $application,
-        protected ?string $origin
-    ) {
+    /**
+     * Create a new connection instance.
+     */
+    public function __construct(protected Application $application, protected ?string $origin)
+    {
         $this->lastSeenAt = time();
     }
 

src/Http/Connection.php

@@ -22,6 +22,9 @@ class Connection
      */
     protected string $buffer = '';
 
+    /**
+     * Create a new connection instance.
+     */
     public function __construct(protected ConnectionInterface $connection)
     {
         $this->id = (int) $connection->stream;

src/Http/Route.php

@@ -10,6 +10,9 @@ class Route
 {
     use RouteTrait;
 
+    /**
+     * Create a new route instance.
+     */
     public function __construct(string $path)
     {
         $this->route = new BaseRoute($path);

src/Http/Router.php

@@ -25,6 +25,9 @@ class Router
      */
     protected ServerNegotiator $negotiator;
 
+    /**
+     * Create a new router instance.
+     */
     public function __construct(protected UrlMatcherInterface $matcher)
     {
         $this->negotiator = new ServerNegotiator(new RequestVerifier);

src/Http/Server.php

@@ -14,6 +14,9 @@ class Server
 {
     use ClosesConnections;
 
+    /**
+     * Create a new Http server instance.
+     */
     public function __construct(protected ServerInterface $socket, protected Router $router, protected ?LoopInterface $loop = null)
     {
         gc_disable();

src/Loggers/CliLogger.php

@@ -16,6 +16,9 @@ class CliLogger implements Logger
      */
     protected $components;
 
+    /**
+     * Create a new CLI logger instance.
+     */
     public function __construct(protected OutputStyle $output)
     {
         $this->components = new Factory($output);

src/Managers/CacheChannelConnectionManager.php

@@ -12,10 +12,13 @@ class CacheChannelConnectionManager implements ChannelConnectionManager
 {
     protected string $name;
 
+    /**
+     * Create a new cache channel connection manager instance.
+     */
     public function __construct(
         protected Repository $repository,
         protected ConnectionManager $connections,
-        protected $prefix = 'reverb'
+        protected string $prefix = 'reverb'
     ) {
         //
     }

src/Managers/CacheChannelManager.php

@@ -22,10 +22,11 @@ class CacheChannelManager implements ChannelManagerInterface
      */
     protected $application;
 
-    public function __construct(
-        protected Repository $repository,
-        protected $prefix = 'reverb'
-    ) {
+    /**
+     * Create a new cache channel manager instance.
+     */
+    public function __construct(protected Repository $repository, protected string $prefix = 'reverb')
+    {
         //
     }
 

src/Managers/CacheConnectionManager.php

@@ -8,10 +8,11 @@
 
 class CacheConnectionManager implements ConnectionManager
 {
-    public function __construct(
-        protected Repository $repository,
-        protected $prefix = 'reverb'
-    ) {
+    /**
+     * Create a new cache connection manager instance.
+     */
+    public function __construct(protected Repository $repository, protected string $prefix = 'reverb')
+    {
         //
     }
 

src/Pusher/Event.php

@@ -11,6 +11,9 @@
 
 class Event
 {
+    /**
+     * Create a new Pusher event instance.
+     */
     public function __construct(protected ChannelManager $channels)
     {
         //

src/Pusher/Server.php

@@ -14,6 +14,9 @@
 
 class Server
 {
+    /**
+     * Create a new server instance.
+     */
     public function __construct(protected ChannelManager $channels, protected PusherEvent $pusher)
     {
         //

src/ServerManager.php

@@ -9,6 +9,9 @@
 
 class ServerManager extends Manager
 {
+    /**
+     * Create a new server manager instance.
+     */
     public function __construct(protected Application $app)
     {
         parent::__construct($app);

src/Servers/ApiGateway/ApiGatewayProvider.php

@@ -21,9 +21,12 @@
 
 class ApiGatewayProvider extends ServerProvider
 {
+    /**
+     * Create a new API Gateway server provider instance.
+     */
     public function __construct(protected Application $app, protected array $config)
     {
-        // 
+        //
     }
 
     /**

src/Servers/ApiGateway/Connection.php

@@ -3,11 +3,11 @@
 namespace Laravel\Reverb\Servers\ApiGateway;
 
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 use Laravel\Reverb\Concerns\SerializesConnections;
 use Laravel\Reverb\Contracts\Connection as BaseConnection;
 use Laravel\Reverb\Contracts\ConnectionManager;
 use Laravel\Reverb\Contracts\SerializableConnection;
+use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 use Laravel\Reverb\Servers\ApiGateway\Jobs\SendToConnection;
 
 class Connection extends BaseConnection implements SerializableConnection
@@ -21,6 +21,9 @@ class Connection extends BaseConnection implements SerializableConnection
      */
     protected $id;
 
+    /**
+     * Create a new connection instance.
+     */
     public function __construct(
         protected string $identifier,
         protected Application $application,

src/Servers/ApiGateway/Jobs/SendToConnection.php

@@ -18,6 +18,7 @@ class SendToConnection implements ShouldQueue
      */
     public function __construct(public string $connectionId, public string $message)
     {
+        //
     }
 
     /**

src/Servers/ApiGateway/Request.php

@@ -16,6 +16,7 @@ public function __construct(
         public string $connectionId,
         public string $event
     ) {
+        //
     }
 
     /**

src/Servers/ApiGateway/Server.php

@@ -13,10 +13,11 @@ class Server
 {
     protected ConnectionManager $connections;
 
-    public function __construct(
-        protected PusherServer $server,
-        protected ApplicationProvider $applications,
-    ) {
+    /**
+     * Create an new server instance.
+     */
+    public function __construct(protected PusherServer $server, protected ApplicationProvider $applications)
+    {
         $this->connections = app(ConnectionManager::class);
     }
 

src/Servers/Reverb/Connection.php

@@ -3,8 +3,8 @@
 namespace Laravel\Reverb\Servers\Reverb;
 
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 use Laravel\Reverb\Contracts\Connection as ConnectionContract;
+use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 use Laravel\Reverb\WebSockets\WsConnection;
 
 class Connection extends ConnectionContract
@@ -21,6 +21,9 @@ class Connection extends ConnectionContract
      */
     protected $hasBeenPinged = false;
 
+    /**
+     * Create a new connection instance.
+     */
     public function __construct(protected WsConnection $connection, Application $application, ?string $origin = null)
     {
         parent::__construct($application, $origin);

src/Servers/Reverb/Controller.php

@@ -11,6 +11,9 @@
 
 class Controller
 {
+    /**
+     * Create a new controller instance.
+     */
     public function __construct(protected PusherServer $server, protected ApplicationProvider $applications)
     {
         //

src/Servers/Reverb/ReverbProvider.php

@@ -27,6 +27,9 @@ class ReverbProvider extends ServerProvider
      */
     protected $publishesEvents;
 
+    /**
+     * Create a new Reverb server provider instance.
+     */
     public function __construct(protected Application $app, protected array $config)
     {
         $this->publishesEvents = (bool) $this->config['publish_events']['enabled'] ?? false;

src/WebSockets/WsConnection.php

@@ -40,6 +40,9 @@ class WsConnection extends EventEmitter
      */
     protected $maxMessageSize;
 
+    /**
+     * Create a new websocket connection instance.
+     */
     public function __construct(public Connection $connection)
     {
         //

tests/FakeConnection.php

@@ -4,9 +4,9 @@
 
 use Illuminate\Testing\Assert;
 use Laravel\Reverb\Application;
-use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 use Laravel\Reverb\Contracts\ApplicationProvider;
 use Laravel\Reverb\Contracts\Connection as BaseConnection;
+use Laravel\Reverb\Pusher\Concerns\GeneratesPusherIdentifiers;
 
 class FakeConnection extends BaseConnection
 {
@@ -31,6 +31,9 @@ class FakeConnection extends BaseConnection
      */
     public $id;
 
+    /**
+     * Create a new fake connection instance.
+     */
     public function __construct(?string $identifier = null)
     {
         if ($identifier) {

tests/TestConnection.php

@@ -25,6 +25,9 @@ class TestConnection
      */
     public $receivedMessages = [];
 
+    /**
+     * Create a new test connection instance.
+     */
     public function __construct(public WebSocket $connection)
     {
         $connection->on('message', function ($message) {