Архитектура Laravel + Centrifugo: кто за что отвечает в real-time системе

• Laravel backend — бизнес-логика, права доступа, база данных, события, очереди.
  
• Centrifugo server — WebSocket-соединения, каналы, подписки, доставка сообщений.
  
• Frontend client — подключение к Centrifugo, подписка на каналы, обновление интерфейса.

{
  "id": 7821,
  "status": "pending",
  "amount": 1500
}

namespace App\Http\Controllers\Payment;
use App\Events\OrderStatusChanged;
use App\Models\Order;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
class PaymentWebhookController
{
    public function __invoke(Request $request): JsonResponse
    {
        $order = Order::query()
            ->where('payment_id', $request->input(key: 'payment_id'))
            ->firstOrFail();
        $order->update([
            'status' => 'paid',
        ]);
        event(new OrderStatusChanged(
            orderId: $order->id,
            userId: $order->user_id,
            status: 'paid',
        ));
        return response()->json(data: [
            'success' => true,
        ]);
    }
}

namespace App\Events;
class OrderStatusChanged
{
    public function __construct(
        public readonly int $orderId,
        public readonly int $userId,
        public readonly string $status,
    ) {
    }
}

namespace App\Listeners;
use App\Events\OrderStatusChanged;
use App\Jobs\PublishOrderStatusChangedToRealtime;
class SendOrderStatusChangedToRealtime
{
    public function handle(OrderStatusChanged $event): void
    {
        PublishOrderStatusChangedToRealtime::dispatch(
            orderId: $event->orderId,
            userId: $event->userId,
            status: $event->status,
        )->afterCommit();
    }
}

namespace App\Jobs;
use App\Services\Realtime\CentrifugoPublisher;
use Illuminate\Contracts\Queue\ShouldQueue;
class PublishOrderStatusChangedToRealtime implements ShouldQueue
{
    public function __construct(
        public readonly int $orderId,
        public readonly int $userId,
        public readonly string $status,
    ) {
    }
    public function handle(CentrifugoPublisher $publisher): void
    {
        $publisher->publish(
            channel: '$users:' . $this->userId,
            data: [
                'type' => 'order.status.changed',
                'orderId' => $this->orderId,
                'status' => $this->status,
            ],
        );
    }
}

$users:15
$orders:7821
$admin:orders
chat:room:45
dashboard:payments

namespace App\Services\Realtime;
use Illuminate\Support\Facades\Http;
class CentrifugoPublisher
{
    public function publish(
        string $channel,
        array $data,
    ): void {
        Http::withHeaders(headers: [
            'Authorization' => 'apikey ' . config('services.centrifugo.api_key'),
        ])->post(
            url: config('services.centrifugo.api_url') . '/api/publish',
            data: [
                'channel' => $channel,
                'data' => $data,
            ],
        )->throw();
    }
}

{
  "type": "order.status.changed",
  "orderId": 7821,
  "status": "paid"
}

import { Centrifuge } from 'centrifuge';
const centrifuge = new Centrifuge('wss://example.com/connection/websocket', {
    getToken: async function () {
        const response = await fetch('/realtime/connection-token', {
            headers: {
                Accept: 'application/json',
            },
            credentials: 'same-origin',
        });
        const data = await response.json();
        return data.token;
    },
});
const userChannel = '$users:15';
const subscription = centrifuge.newSubscription(userChannel, {
    getToken: async function () {
        const response = await fetch('/realtime/subscription-token', {
            method: 'POST',
            headers: {
                Accept: 'application/json',
                'Content-Type': 'application/json',
            },
            credentials: 'same-origin',
            body: JSON.stringify({
                channel: userChannel,
            }),
        });
        const data = await response.json();
        return data.token;
    },
});
subscription.on('publication', function (context) {
    if (context.data.type === 'order.status.changed') {
        updateOrderStatus(
            context.data.orderId,
            context.data.status,
        );
    }
});
subscription.subscribe();
centrifuge.connect();

{
  "channel": "$users:15",
  "data": {
    "type": "order.status.changed",
    "orderId": 7821,
    "status": "paid"
  }
}

• Laravel должен оставаться источником истины. Все изменения состояния должны фиксироваться в базе данных или другом основном хранилище. WebSocket-событие не должно быть единственным доказательством того, что что-то произошло.
  
• Centrifugo должен оставаться транспортом. В нём не нужно размещать бизнес-логику, сложную авторизацию или правила предметной области.
  
• Публиковать события лучше после commit транзакции. Это снижает риск рассинхронизации между интерфейсом и API.
  
• Payload должен быть минимальным и стабильным. Полная Eloquent-модель в real-time событии - плохая идея. Лучше передавать тип события, идентификатор сущности и несколько необходимых полей.
  
• Frontend должен уметь восстановить состояние через HTTP. Если пользователь потерял соединение, закрыл ноутбук, вернулся из спящего режима или пропустил событие, интерфейс должен запросить актуальные данные у Laravel.