laravel-websockets/src/WebSocketServer/Messages/RespondableMessageFactory.php

<?php

namespace BeyondCode\LaravelWebSockets\WebSocketServer\Messages;

use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\Channels\ChannelManager;
use BeyondCode\LaravelWebSockets\WebSocketServer\Pusher\PusherMessage;
use Ratchet\ConnectionInterface;
use Ratchet\RFC6455\Messaging\MessageInterface;

class RespondableMessageFactory
{
    public static function createForMessage(
        MessageInterface $message,
        ConnectionInterface $connection,
        ChannelManager $channelManager): RespondableMessage
    {
        $payload = json_decode($message->getPayload());

        return starts_with($payload->event, 'pusher:')
            ? new PusherMessage($payload, $connection, $channelManager)
            : new Message($payload, $connection, $channelManager);
    }
}