blax-software
/
laravel-websockets
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

I pusher

This commit is contained in:
Blax Software 2025-01-18 16:18:02 +01:00
parent 2ef30f00ac
commit 90df844485
2 changed files with 21 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/Websocket/Handler.php
View File

@ -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();

2
src/Websocket/MockConnection.php
View File

@ -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;
}