Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
Console	[ DIR ]	drwxr-xr-x	2021-03-26 07:34
Events	[ DIR ]	drwxr-xr-x	2018-12-04 21:08
Exceptions	[ DIR ]	drwxr-xr-x	2018-12-04 21:08
Http	[ DIR ]	drwxr-xr-x	2018-12-04 21:08
Models	[ DIR ]	drwxr-xr-x	2021-03-24 12:55
Providers	[ DIR ]	drwxr-xr-x	2018-12-04 21:08
Conversation.php	166 B	-rw-r--r--	2021-05-21 11:06
Message.php	261 B	-rw-r--r--	2021-05-21 12:34
User.php	674 B	-rw-r--r--	2021-03-29 19:11
WebSocketHandler.php	2.04 KB	-rw-r--r--	2021-04-11 14:35

Rename

<?php

namespace App;

use Ratchet\ConnectionInterface;
use Ratchet\RFC6455\Messaging\MessageInterface;
use Ratchet\WebSocket\MessageComponentInterface;
use BeyondCode\LaravelWebSockets\Dashboard\DashboardLogger;
use BeyondCode\LaravelWebSockets\Facades\StatisticsLogger;
use BeyondCode\LaravelWebSockets\WebSockets\Exceptions\WebSocketException;
use BeyondCode\LaravelWebSockets\WebSockets\Messages\PusherMessageFactory;
use BeyondCode\LaravelWebSockets\QueryParameters;
use Exception;
use BeyondCode\LaravelWebSockets\Apps\App;
use BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager;
use BeyondCode\LaravelWebSockets\WebSockets\Exceptions\UnknownAppKey;

class MyCustomWebSocketHandler implements MessageComponentInterface
{

/** @var \BeyondCode\LaravelWebSockets\WebSockets\Channels\ChannelManager */
    protected $channelManager;

public function __construct(ChannelManager $channelManager)
    {
        $this->channelManager = $channelManager;
    }

public function onOpen(ConnectionInterface $connection)
    {
        $this
            ->verifyAppKey($connection)
            ->generateSocketId($connection)
            ->establishConnection($connection);
    }

public function onMessage(ConnectionInterface $connection, MessageInterface $message)
    {
        print_r($connection);
        print_r($message);
        die('ffhhhhf');

$message = PusherMessageFactory::createForMessage($message, $connection, $this->channelManager);

$message->respond();

StatisticsLogger::webSocketMessage($connection);
    }

public function onClose(ConnectionInterface $connection)
    {
        $this->channelManager->removeFromAllChannels($connection);

DashboardLogger::disconnection($connection);

StatisticsLogger::disconnection($connection);
    }

public function onError(ConnectionInterface $connection, Exception $exception)
    {
        if ($exception instanceof WebSocketException) {
            $connection->send(json_encode(
                $exception->getPayload()
            ));
        }
    }

}