BeyondCode\LaravelWebSockets\API\TriggerEvent::__invoke()

Complexity

Conditions	5
Paths	12

Size

Total Lines

46

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __invoke(Request $request)
    {
        $channels = $request->channels ?: [];

        if (is_string($channels)) {
            $channels = [$channels];
        }

        foreach ($channels as $channelName) {
            // Here you can use the ->find(), even if the channel
            // does not exist on the server. If it does not exist,
            // then the message simply will get broadcasted
            // across the other servers.
            $channel = $this->channelManager->find(
                $request->appId, $channelName
            );

            $payload = [
                'event' => $request->name,
                'channel' => $channelName,
                'data' => $request->data,
            ];

            if ($channel) {
                $channel->broadcastToEveryoneExcept(
                    (object) $payload,
                    $request->socket_id,
                    $request->appId
                );
            } else {
                $this->channelManager->broadcastAcrossServers(
                    $request->appId, $request->socket_id, $channelName, (object) $payload
                );
            }

            StatisticsCollector::apiMessage($request->appId);

            DashboardLogger::log($request->appId, DashboardLogger::TYPE_API_MESSAGE, [
                'event' => $request->name,
                'channel' => $channelName,
                'payload' => $request->data,
            ]);
        }

        return $request->json()->all();
    }
}