From 447cc71256a3e673646befd14b0cec8a617241a6 Mon Sep 17 00:00:00 2001 From: a6a2f5842 Date: Wed, 15 Oct 2025 09:35:07 +0200 Subject: [PATCH] I auth state --- src/Websocket/Handler.php | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/Websocket/Handler.php b/src/Websocket/Handler.php index a6389aa..cfff0ba 100644 --- a/src/Websocket/Handler.php +++ b/src/Websocket/Handler.php @@ -150,7 +150,6 @@ class Handler implements MessageComponentInterface $pid = pcntl_fork(); if ($pid == -1) { - Auth::logout(); Log::error('Fork error'); } elseif ($pid == 0) { try { @@ -182,7 +181,6 @@ class Handler implements MessageComponentInterface exit(0); } else { - Auth::logout(); $this->addDataCheckLoop($connection, $message, $pid); } } catch (\Throwable $e) { @@ -250,8 +248,6 @@ class Handler implements MessageComponentInterface cache()->forget('ws_connection_' . $connection->socketId); } }); - - Auth::logout(); } /** @@ -479,6 +475,7 @@ class Handler implements MessageComponentInterface protected function authenticateConnection( ConnectionInterface $connection, PrivateChannel|Channel|PresenceChannel|null $channel, + array|null|mixed $message = [] ) { if (! optional($connection)->auth && $connection->socketId && cache()->get('socket_' . $connection->socketId)) { @@ -519,6 +516,11 @@ class Handler implements MessageComponentInterface $authed_users = cache()->get('ws_socket_authed_users') ?? []; $authed_users[$connection->socketId] = $user->id; cache()->forever('ws_socket_authed_users', $authed_users); + + \BlaxSoftware\LaravelWebSockets\Services\WebsocketService::setUserAuthed( + $connection->socketId, + $user + ); } // add next in loop logout