Reverb infra + Kanban live refresh

- laravel/reverb instalat + reverb:install (config/reverb.php, channels.php)
- routes/channels.php: tenant.{slug} private channel cu auth check
  user.company_id == tenant.id
- App\Events\WorkOrderUpdated implements ShouldBroadcast pe
  PrivateChannel('tenant.{slug}'); broadcastAs 'work-order.updated'
- WorkOrder::booted dispatch event la fiecare update (skip if broadcast=log)
- Filament panel BODY_END inject:
  - Pusher JS de la CDN (compatibil Reverb)
  - Echo client conectat la Reverb (config dinamic din env)
  - Subscribe pe tenant private channel; la 'work-order.updated' →
    Livewire.all().forEach($refresh)
- Kanban view: wire:poll.5s (live refresh fallback) +
  x-on:autocrm:wo-updated.window=$refresh (instant când WS e activ)

Pentru moment BROADCAST_CONNECTION=log în Coolify (Reverb nu e deployat).
Când deployezi Reverb container separat:
  Coolify → New App → Same repo → CMD override:
    php artisan reverb:start --host=0.0.0.0 --port=8080
  → FQDN: ws.service.mir.md:8080
  → Set BROADCAST_CONNECTION=reverb pe AutoCRM app
  → Real-time instant fără cod nou.
This commit is contained in:
2026-05-07 14:25:26 +00:00
parent 09fd0bada2
commit 7ce78c350c
10 changed files with 1299 additions and 5 deletions
+39
View File
@@ -0,0 +1,39 @@
<?php
namespace App\Events;
use App\Models\Tenant\WorkOrder;
use Illuminate\Broadcasting\InteractsWithSockets;
use Illuminate\Broadcasting\PrivateChannel;
use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
use Illuminate\Foundation\Events\Dispatchable;
use Illuminate\Queue\SerializesModels;
class WorkOrderUpdated implements ShouldBroadcast
{
use Dispatchable, InteractsWithSockets, SerializesModels;
public function __construct(public WorkOrder $workOrder, public string $tenantSlug) {}
public function broadcastOn(): array
{
return [new PrivateChannel('tenant.' . $this->tenantSlug)];
}
public function broadcastAs(): string
{
return 'work-order.updated';
}
public function broadcastWith(): array
{
return [
'id' => $this->workOrder->id,
'number' => $this->workOrder->number,
'status' => $this->workOrder->status,
'pay_status' => $this->workOrder->pay_status,
'total' => (float) $this->workOrder->total,
'updated_at' => $this->workOrder->updated_at?->toIso8601String(),
];
}
}
+13 -1
View File
@@ -109,7 +109,7 @@ class WorkOrder extends Model
return sprintf('WO-%s-%04d', $year, $count + 1);
}
/** Auto-send 'ready' email when status transitions to 'ready'. */
/** Auto-send 'ready' email + broadcast WS event on status change. */
protected static function booted(): void
{
static::updated(function (self $wo) {
@@ -120,6 +120,18 @@ class WorkOrder extends Model
) {
app(\App\Services\NotificationDispatcher::class)->workOrderReady($wo);
}
// Broadcast real-time update on any field change (skip if broadcasting=log).
if (config('broadcasting.default') !== 'log') {
try {
$company = \App\Models\Central\Company::withoutGlobalScopes()->find($wo->company_id);
if ($company) {
\App\Events\WorkOrderUpdated::dispatch($wo, $company->slug);
}
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::debug('WO broadcast skipped: ' . $e->getMessage());
}
}
});
}
}
+41 -2
View File
@@ -130,7 +130,15 @@ class TenantPanelProvider extends PanelProvider
)
->renderHook(
PanelsRenderHook::BODY_END,
fn (): string => <<<'HTML'
fn (): string => Blade::render(<<<'BLADE'
@php
$tenant = app(\App\Tenancy\TenantManager::class)->current();
$reverbKey = config('broadcasting.connections.reverb.key');
$reverbHost = config('broadcasting.connections.reverb.options.host');
$reverbPort = config('broadcasting.connections.reverb.options.port');
$reverbScheme = config('broadcasting.connections.reverb.options.scheme', 'https');
$broadcastEnabled = config('broadcasting.default') === 'reverb' && $reverbKey && $reverbHost;
@endphp
<script>
if ('serviceWorker' in navigator) {
window.addEventListener('load', () => {
@@ -138,7 +146,38 @@ class TenantPanelProvider extends PanelProvider
});
}
</script>
HTML
@if ($broadcastEnabled && $tenant)
<script src="https://js.pusher.com/8.4/pusher.min.js"></script>
<script>
(function() {
if (typeof Pusher === 'undefined') return;
Pusher.logToConsole = false;
window.AutoCRMEcho = new Pusher('{{ $reverbKey }}', {
wsHost: '{{ $reverbHost }}',
wsPort: {{ $reverbPort ?: ($reverbScheme === 'https' ? 443 : 80) }},
wssPort: {{ $reverbPort ?: 443 }},
forceTLS: {{ $reverbScheme === 'https' ? 'true' : 'false' }},
enabledTransports: ['ws', 'wss'],
cluster: 'mt1',
authEndpoint: '/broadcasting/auth',
auth: {
headers: {
'X-CSRF-TOKEN': document.querySelector('meta[name="csrf-token"]')?.content || ''
}
}
});
const ch = window.AutoCRMEcho.subscribe('private-tenant.{{ $tenant->slug }}');
ch.bind('work-order.updated', function(payload) {
window.dispatchEvent(new CustomEvent('autocrm:wo-updated', { detail: payload }));
// If we're on the kanban or a WO list page, refresh the Livewire component.
if (typeof Livewire !== 'undefined') {
Livewire.all().forEach(c => c.$refresh && c.$refresh());
}
});
})();
</script>
@endif
BLADE)
);
}
}