diff --git a/composer.json b/composer.json index 72d7ac06c630..3013fb636555 100644 --- a/composer.json +++ b/composer.json @@ -146,7 +146,7 @@ "phpunit/phpunit": "Required to use assertions and run tests (^9.4).", "predis/predis": "Required to use the predis connector (^1.1.2).", "psr/http-message": "Required to allow Storage::put to accept a StreamInterface (^1.0).", - "pusher/pusher-php-server": "Required to use the Pusher broadcast driver (^4.0|^5.0).", + "pusher/pusher-php-server": "Required to use the Pusher broadcast driver (^5.0).", "symfony/cache": "Required to PSR-6 cache bridge (^5.3).", "symfony/filesystem": "Required to enable support for relative symbolic links (^5.3).", "symfony/psr-http-message-bridge": "Required to use PSR-7 bridging features (^2.0).", diff --git a/src/Illuminate/Broadcasting/Broadcasters/PusherBroadcaster.php b/src/Illuminate/Broadcasting/Broadcasters/PusherBroadcaster.php index 15695e114e6f..fde951e9dbca 100644 --- a/src/Illuminate/Broadcasting/Broadcasters/PusherBroadcaster.php +++ b/src/Illuminate/Broadcasting/Broadcasters/PusherBroadcaster.php @@ -111,46 +111,19 @@ public function broadcast(array $channels, $event, array $payload = []) { $socket = Arr::pull($payload, 'socket'); - if ($this->pusherServerIsVersionFiveOrGreater()) { - $parameters = $socket !== null ? ['socket_id' => $socket] : []; - - try { - $this->pusher->trigger( - $this->formatChannels($channels), $event, $payload, $parameters - ); - } catch (ApiErrorException $e) { - throw new BroadcastException( - sprintf('Pusher error: %s.', $e->getMessage()) - ); - } - } else { - $response = $this->pusher->trigger( - $this->formatChannels($channels), $event, $payload, $socket, true - ); - - if ((is_array($response) && $response['status'] >= 200 && $response['status'] <= 299) - || $response === true) { - return; - } + $parameters = $socket !== null ? ['socket_id' => $socket] : []; + try { + $this->pusher->trigger( + $this->formatChannels($channels), $event, $payload, $parameters + ); + } catch (ApiErrorException $e) { throw new BroadcastException( - ! empty($response['body']) - ? sprintf('Pusher error: %s.', $response['body']) - : 'Failed to connect to Pusher.' + sprintf('Pusher error: %s.', $e->getMessage()) ); } } - /** - * Determine if the Pusher PHP server is version 5.0 or greater. - * - * @return bool - */ - protected function pusherServerIsVersionFiveOrGreater() - { - return class_exists(ApiErrorException::class); - } - /** * Get the Pusher SDK instance. * diff --git a/src/Illuminate/Broadcasting/composer.json b/src/Illuminate/Broadcasting/composer.json index 347b74164c1b..5224a0edaea4 100644 --- a/src/Illuminate/Broadcasting/composer.json +++ b/src/Illuminate/Broadcasting/composer.json @@ -34,7 +34,7 @@ } }, "suggest": { - "pusher/pusher-php-server": "Required to use the Pusher broadcast driver (^4.0|^5.0)." + "pusher/pusher-php-server": "Required to use the Pusher broadcast driver (^5.0)." }, "config": { "sort-packages": true