qruto / laravel-wave
Painless Laravel Broadcasting with SSE.
Fund package maintenance!
qruto
revolut.me/slavarazum
Installs: 16 722
Dependents: 0
Suggesters: 0
Security: 0
Stars: 753
Watchers: 5
Forks: 29
Open Issues: 1
Requires
- php: ^8.1
- illuminate/broadcasting: ^10.0|^11.0.6
- illuminate/console: ^10.0|^11.0.6
- illuminate/contracts: ^10.0|^11.0.6
- illuminate/http: ^10.0|^11.0.6
- illuminate/queue: ^10.0|^11.0.6
- illuminate/routing: ^10.0|^11.0.6
- laravel/prompts: ^0.1.16
- spatie/laravel-package-tools: ^1.14.1
Requires (Dev)
- larastan/larastan: ^2.9
- laravel/pint: ^1.14
- m6web/redis-mock: v5.6
- nunomaduro/collision: ^7.10|^8.1
- orchestra/testbench: ^8.14|^9.0
- pestphp/pest: ^v2.34
- pestphp/pest-plugin-laravel: ^2.3.0
- pestphp/pest-plugin-watch: ^2.1.0
- phpstan/extension-installer: ^1.3
- phpstan/phpstan-deprecation-rules: ^1.1
- phpstan/phpstan-phpunit: ^1.3.10
- rector/rector: ^0.19
- spatie/laravel-ray: ^1.35
README
Bring live to your application
Introduction
Unlock the power of
Laravel's broadcasting system
with Wave. Imagine that real-time server broadcasting is possible over
native HTTP without any WebSockets setup.
Meet the
Server-sent Events 🛜
Works seamlessly with Laravel's default redis
broadcasting driver and
supports Laravel Echo.
Experience it live with our demo streaming tweets 🐤.
Server-Sent Events (SSE) is specially tuned for real-time server-to-client communication.
🌟 Key Features
⚡ Works with native Redis Driver: Wave seamlessly integrates with Laravel's
default redis
broadcasting driver, ensuring efficient real-time data transfer.
🔄 Resume From Last: Connection drops? No problem! Wave intelligently resumes the event stream from the last event, ensuring no crucial data is lost in transit.
🟢 Live Models: With a simple interface that respects Laravel's native conventions for Model Events Broadcasting and Broadcast Notifications, Wave turbocharges your application with real-time updates.e
🍃 Resource-Friendly Broadcasting with pauseInactive
: This feature
maximizes resource efficiency by closing the data stream when user inactive (
such as when the user minimizes the browser) and automatically reopens it upon
resumption of visibility. Turned off by default.
🎛️️ Full Requests Control: Wave hands you the reins over connection and authentication requests, granting you the freedom to shape your broadcasting setup to your exact requirements.
Installation
Laravel 11 or higher
Install the package via Composer at first, then install broadcasting setup:
composer require qruto/laravel-wave php artisan install:broadcasting
Laravel 10 or lower
Install Wave on both server and client sides using Composer and npm:
composer require qruto/laravel-wave npm install laravel-wave
Then, set your .env
file to use the redis
broadcasting driver:
BROADCAST_DRIVER = redis
Usage
After installing Wave, your server is ready to broadcast events.
You can use it with Echo as usual or try Wave
model API to work with
predefined Eloquent events.
In Laravel 11 or higher, after install:broadcasting
, you will find:
- broadcasting channel authorization file in
routes/channels.php
- broadcasting configuration file in
config/broadcasting.php
- echo instance in
resources/echo.js
- (optional) Wave configuration file in
config/wave.php
Manual usage
Import Laravel Echo with WaveConnector
and pass it to the broadcaster option:
import Echo from 'laravel-echo'; import { WaveConnector } from 'laravel-wave'; window.Echo = new Echo({broadcaster: WaveConnector});
For Laravel 10 or lower, locate Echo connection configuration in resources/js/bootstrap.js file.
- import Echo from 'laravel-echo'; - import Pusher from 'pusher-js'; - window.Pusher = Pusher; - window.Echo = new Echo({ - broadcaster: 'pusher', - key: import.meta.env.VITE_PUSHER_APP_KEY, - wsHost: import.meta.env.VITE_PUSHER_HOST ?? `ws-${import.meta.env.VITE_PUSHER_APP_CLUSTER}.pusher.com`, - wsPort: import.meta.env.VITE_PUSHER_PORT ?? 80, - wssPort: import.meta.env.VITE_PUSHER_PORT ?? 443, - forceTLS: (import.meta.env.VITE_PUSHER_SCHEME ?? 'https') === 'https', - enabledTransports: ['ws', 'wss'], - }); + import Echo from 'laravel-echo'; + import { WaveConnector } from 'laravel-wave'; + window.Echo = new Echo({ broadcaster: WaveConnector });
Use Echo as you typically would.
📞 Receiving Broadcasts documentation.
Use Live Eloquent Models
With native conventions of Model Events Broadcasting and Broadcast Notifications you can use Wave models to receive model events and notifications.
import { Wave } from 'laravel-wave'; window.Wave = new Wave(); wave.model('User', '1') .notification('team.invite', (notification) => { console.log(notification); }) .updated((user) => console.log('user updated', user)) .deleted((user) => console.log('user deleted', user)) .trashed((user) => console.log('user trashed', user)) .restored((user) => console.log('user restored', user)) .updated('Team', (team) => console.log('team updated', team));
Start by calling the model
method on the Wave
instance with the model name
and key.
By default, Wave prefixes model names with App.Models
namespace. You can
customize this with the namespace
option:
window.Wave = new Wave({namespace: 'App.Path.Models'});
📄 Check out full Laravel Broadcasting documentation
Configuration
Client Options
These options can be passed to the Wave
or Echo
instance:
new Echo({ broadcaster: WaveConnector, endpoint: '/sse-endpoint', bearerToken: 'bearer-token', //... }); // or new Wave({ authEndpoint: '/custom-broadcasting/auth', csrfToken: 'csrf-token', })
Server Options
You can publish the Wave configuration file with:
php artisan vendor:publish --tag="wave-config"
Here are the contents of the published configuration file:
return [ /* |-------------------------------------------------------------------------- | Resume Lifetime |-------------------------------------------------------------------------- | | Define how long (in seconds) you wish an event stream to persist so it | can be resumed after a reconnect. The connection automatically | re-establishes with every closed response. | | * Requires a cache driver to be configured. | */ 'resume_lifetime' => 60, /* |-------------------------------------------------------------------------- | Reconnection Time |-------------------------------------------------------------------------- | | This value determines how long (in milliseconds) to wait before | attempting a reconnect to the server after a connection has been lost. | By default, the client attempts to reconnect immediately. For more | information, please refer to the Mozilla developer's guide on event | stream format. | https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events/Using_server-sent_events#Event_stream_format | */ 'retry' => null, /* |-------------------------------------------------------------------------- | Ping |-------------------------------------------------------------------------- | | A ping event is automatically sent on every SSE connection request if the | last event occurred before the set `frequency` value (in seconds). This | ensures the connection remains persistent. | | By setting the `eager_env` option, a ping event will be sent with each | request. This is useful for development or for applications that do not | frequently expect events. The `eager_env` option can be set as an `array` or `null`. | | For manual control of the ping event with the `sse:ping` command, you can | disable this option. | */ 'ping' => [ 'enable' => true, 'frequency' => 30, 'eager_env' => 'local', // null or array ], /* |-------------------------------------------------------------------------- | Routes Path |-------------------------------------------------------------------------- | | This path is used to register the necessary routes for establishing the | Wave connection, storing presence channel users, and handling simple whisper events. | */ 'path' => 'wave', /* |-------------------------------------------------------------------------- | Route Middleware |-------------------------------------------------------------------------- | | Define which middleware Wave should assign to the routes that it registers. | You may modify these middleware as needed. However, the default value is | typically sufficient. | */ 'middleware' => [ 'web', ], /* |-------------------------------------------------------------------------- | Auth & Guard |-------------------------------------------------------------------------- | | Define the default authentication middleware and guard type for | authenticating users for presence channels and whisper events. | */ 'auth_middleware' => 'auth', 'guard' => 'web', ];
Persistent Connection with Nginx + PHP FPM
Wave is designed to automatically reconnect after a request timeout.
During reconnection, you won't lose any events because Wave stores event history
for one minute by default
and resumes it. You can adjust the duration of event history storage by
modifying the resume_lifetime
value
in the config file.
However, if you want to maintain a persistent connection, let's configure your web server.
fastcgi_read_timeout
By default, the fastcgi_read_timeout
value is 60s
for Nginx + PHP FastCGI
server setup.
Option 1. Without changing the fastcgi_read_timeout
value
Ensure that the interval between events pushed into Wave connection is shorter than the read timeout value
To enhance the certainty of events occurring more frequently than the standard
timeout,
Wave attempts to send a ping event with each Server-Sent Events (SSE) connection
request,
provided that the previous event occurred prior to the ping.frequency
configuration value.
If your application doesn't expect many real-time connections,
specify the list of environments in which a ping event will be sent
with each Wave connection. By default, this is set to local
.
Option 2. Manual ping control
To ensure accurate frequency sending a ping event:
- Disable automatic sending by changing the
ping.enable
config value tofalse
- Use the
sse:ping
command to manually send a single ping or operate at an interval
Run the command with the --interval
option to send a ping event at a specified
interval in seconds,
for example let's send a ping event every 30s
:
php artisan sse:ping --interval=30
So, every 30s
, the command will send a ping event to all active connections
and
ensure that the connection remains persistent, because the frequency of sending
events is less than 60s
.
Alternatively, use the
Laravel Tasks scheduler
to send a ping event every minute or more often
if fastcgi_read_timeout
value is greater than 60s
:
protected function schedule(Schedule $schedule) { $schedule->command('sse:ping')->everyMinute(); }
request_terminate_timeout
Some platforms, such as Laravel Forge, configure
the PHP FPM pool with request_terminate_timeout = 60
, terminating all requests
after 60s
.
You can disable this in the /etc/php/8.1/fpm/pool.d/www.conf
config file:
request_terminate_timeout = 0
or you can configure a separate pool for the SSE connection.
Future Plans
📍 Local broadcasting driver
📥 📤 two ways live models syncing
📡 Something awesome with opened live abilities...
Testing
composer test
Support
In light of recent events in Ukraine, my life has taken an unexpected turn. Since February 24th, I've lost my commercial work, my permanent residence, and my ability to plan for the future.
During these challenging times, I derive strength and purpose from creating open source projects, such as Wave.
I welcome you to visit my GitHub Sponsorships profile. There, you can discover more about my current work, future ambitions, and aspirations. Every ⭐ you give brings joy to my day, and your sponsorship can make a profound difference in my ability to continue creating.
I'm truly grateful for your support, whether it's a shout-out or a heartfelt " thank you".
Changelog
Please see CHANGELOG for more information on what has changed recently.
Contributing
Please see CONTRIBUTING for details.
Security Vulnerabilities
Please review our security policy on how to report security vulnerabilities.
Credits
Package template based on Spatie Laravel Skeleton.
License
The MIT License (MIT). Please see License File for more information.