Event System & Broadcasting

// Broadcast a refresh to all users in the company
broadcast(new ClientRefresh(company()->id, 'orders_updated'));

{
  "type": "orders_updated",
  "company_id": "39WSvi21oTnZN8i028Y80FTNT1x"
}

// Broadcast a product update, excluding the current user
broadcastResourceUpdate('products', $product->id);

{
  "resource": "products",
  "id": "39XproductId...",
  "action": "updated"
}

broadcast(new OrderStatusUpdated($order, 'completed'));

// Instead of broadcasting immediately, debounce
$debouncer->debounce('products', $productId, function () use ($product) {
    broadcast(new ResourceUpdated('products', $product));
});

BROADCAST_CONNECTION=reverb
REVERB_APP_ID=your-app-id
REVERB_APP_KEY=your-app-key
REVERB_APP_SECRET=your-app-secret
REVERB_HOST=localhost
REVERB_PORT=8080

php artisan reverb:start

Broadcast::channel('company.{companyId}', function ($user, $companyId) {
    return $user->profiles()->where('company_id', $companyId)->exists();
});

import Echo from 'laravel-echo';
import Pusher from 'pusher-js';

const echo = new Echo({
    broadcaster: 'reverb',
    key: 'your-reverb-key',
    wsHost: 'localhost',
    wsPort: 8080,
    forceTLS: false,
});

// Listen for updates on the company channel
echo.private(`company.${companyId}`)
    .listen('ResourceUpdated', (event) => {
        console.log('Resource updated:', event.resource, event.id);
        // Refresh the relevant UI component
    })
    .listen('ClientRefresh', (event) => {
        console.log('Refresh requested:', event.type);
        // Trigger a full data refresh
    });

php artisan queue:work --queue=client_refresh,default

User Action (e.g., update product)
    │
    ▼
Controller → Service → Model Updated
    │
    ▼
Service dispatches event
    │
    ▼
Event queued on "client_refresh" queue
    │
    ▼
Queue worker picks up the event
    │
    ▼
BroadcastDebouncer checks for recent duplicates
    │
    ▼
Reverb broadcasts to WebSocket channel
    │
    ▼
Connected clients receive the update