From 90df84448589b56bd7fb6d1e908c7e30dcb18e94 Mon Sep 17 00:00:00 2001 From: Blax Software Date: Sat, 18 Jan 2025 16:18:02 +0100 Subject: [PATCH] I pusher --- src/Websocket/Handler.php | 36 +++++++++++++++++++------------- src/Websocket/MockConnection.php | 2 -- 2 files changed, 21 insertions(+), 17 deletions(-) diff --git a/src/Websocket/Handler.php b/src/Websocket/Handler.php index 84830fc..34e8dc9 100644 --- a/src/Websocket/Handler.php +++ b/src/Websocket/Handler.php @@ -98,21 +98,27 @@ class Handler implements MessageComponentInterface Log::channel('websocket')->info('Executing event: '.$message['event']); if (strpos($message['event'], 'pusher') !== false) { - try { - return Controller::controll_message( - $connection, - $channel, - $message, - $this->channelManager - ); - } catch (Exception $e) { - return $connection->send(json_encode([ - 'event' => $message['event'].':error', - 'data' => [ - 'message' => $e->getMessage(), - ], - ])); - } + // try { + // return Controller::controll_message( + // $connection, + // $channel, + // $message, + // $this->channelManager + // ); + // } catch (Exception $e) { + // return $connection->send(json_encode([ + // 'event' => $message['event'].':error', + // 'data' => [ + // 'message' => $e->getMessage(), + // ], + // ])); + // } + return $connection->send(json_encode([ + 'event' => $message['event'].':success', + 'data' => [ + 'message' => 'Success', + ], + ])); } $pid = pcntl_fork(); diff --git a/src/Websocket/MockConnection.php b/src/Websocket/MockConnection.php index db2cc2f..feb7f68 100644 --- a/src/Websocket/MockConnection.php +++ b/src/Websocket/MockConnection.php @@ -43,8 +43,6 @@ class MockConnection extends Connection implements \Ratchet\ConnectionInterface $this->socketId = optional($original_connection)->socketId; $this->user = optional($original_connection)->user; - $this->tenant = optional($original_connection)->tenant; - $this->tenantable = optional($original_connection)->tenantable; return $this; }