Build an AI Chatbot in Reverb Livewire with Laravel 12 Step-by-Step

# Install Laravel 12 with Livewire starter kit composer create-project laravel/laravel ai-chatbot cd ai-chatbot # Install Livewire starter kit php artisan install:broadcasting --reverb # Set up environment variables cp .env.example .env php artisan key:generate 

DB_CONNECTION=mysql DB_HOST=127.0.0.1 DB_PORT=3306 DB_DATABASE=ai_chatbot DB_USERNAME=your_username DB_PASSWORD=your_password # Reverb Configuration REVERB_APP_ID=your_app_id REVERB_APP_KEY=your_app_key REVERB_APP_SECRET=your_app_secret REVERB_HOST="localhost" REVERB_PORT=8080 REVERB_SCHEME=http # AI Service Configuration (OpenAI example) OPENAI_API_KEY=your_openai_api_key 

# Run migrations php artisan migrate # Install Laravel Breeze for authentication (optional) composer require laravel/breeze --dev php artisan breeze:install blade npm install && npm run build 

# Install Reverb (if not already installed with starter kit) php artisan install:broadcasting --reverb # Publish Reverb configuration php artisan vendor:publish --provider="Laravel\Reverb\ReverbServiceProvider" # Start the Reverb server php artisan reverb:start 

<?php return [ 'default' => env('BROADCAST_DRIVER', 'reverb'), 'connections' => [ 'reverb' => [ 'driver' => 'reverb', 'app_id' => env('REVERB_APP_ID'), 'app_key' => env('REVERB_APP_KEY'), 'app_secret' => env('REVERB_APP_SECRET'), 'host' => env('REVERB_HOST', 'localhost'), 'port' => env('REVERB_PORT', 8080), 'scheme' => env('REVERB_SCHEME', 'http'), ], ], ]; 

<?php namespace App\Events; use App\Models\Message; use Illuminate\Broadcasting\Channel; use Illuminate\Broadcasting\InteractsWithSockets; use Illuminate\Broadcasting\PresenceChannel; use Illuminate\Contracts\Broadcasting\ShouldBroadcast; use Illuminate\Foundation\Events\Dispatchable; use Illuminate\Queue\SerializesModels; class MessageSent implements ShouldBroadcast { use Dispatchable, InteractsWithSockets, SerializesModels; public function __construct( public Message $message ) {} public function broadcastOn(): array { return [ new PresenceChannel('chat.' . $this->message->conversation_id), ]; } public function broadcastWith(): array { return [ 'id' => $this->message->id, 'content' => $this->message->content, 'user_id' => $this->message->user_id, 'is_ai' => $this->message->is_ai, 'created_at' => $this->message->created_at, ]; } } 

composer require livewire/livewire php artisan livewire:publish --config 

php artisan make:livewire ChatInterface 

<?php namespace App\Livewire; use App\Events\MessageSent; use App\Models\Conversation; use App\Models\Message; use App\Services\AIService; use Illuminate\Support\Facades\Auth; use Livewire\Attributes\On; use Livewire\Component; class ChatInterface extends Component { public $message = ''; public $conversation; public $messages = []; public $isTyping = false; public function mount() { $this->conversation = Conversation::firstOrCreate([ 'user_id' => Auth::id(), ]); $this->loadMessages(); } public function loadMessages() { $this->messages = $this->conversation ->messages() ->with('user') ->orderBy('created_at') ->get() ->toArray(); } public function sendMessage() { if (empty(trim($this->message))) { return; } // Create user message $userMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => Auth::id(), 'content' => $this->message, 'is_ai' => false, ]); // Broadcast user message broadcast(new MessageSent($userMessage)); // Clear input and show typing indicator $this->message = ''; $this->isTyping = true; // Process AI response asynchronously $this->processAIResponse($userMessage->content); } private function processAIResponse($userMessage) { // This would typically be dispatched to a queue $aiService = app(AIService::class); $aiResponse = $aiService->generateResponse($userMessage, $this->conversation); // Create AI message $aiMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => null, 'content' => $aiResponse, 'is_ai' => true, ]); // Broadcast AI message broadcast(new MessageSent($aiMessage)); $this->isTyping = false; } #[On('echo:chat.{conversation.id},MessageSent')] public function messageReceived($event) { $this->messages[] = $event; $this->dispatch('scroll-to-bottom'); } public function render() { return view('livewire.chat-interface'); } } 

<div class="flex flex-col h-screen max-w-4xl mx-auto bg-white shadow-lg rounded-lg overflow-hidden"> <!-- Chat Header --> <div class="bg-blue-600 text-white p-4 flex items-center justify-between"> <div class="flex items-center space-x-3"> <div class="w-8 h-8 bg-blue-500 rounded-full flex items-center justify-center"> <svg class="w-5 h-5" fill="currentColor" viewBox="0 0 20 20"> <path d="M2 5a2 2 0 012-2h7a2 2 0 012 2v4a2 2 0 01-2 2H9l-3 3v-3H4a2 2 0 01-2-2V5z"/> <path d="M15 7v2a4 4 0 01-4 4H9.828l-1.766 1.767c.28.149.599.233.938.233h2l3 3v-3h2a2 2 0 002-2V9a2 2 0 00-2-2h-1z"/> </svg> </div> <div> <h3 class="font-semibold">AI Assistant</h3> <p class="text-sm text-blue-200">Always here to help</p> </div> </div> <div class="flex items-center space-x-2"> @if($isTyping) <div class="flex space-x-1"> <div class="w-2 h-2 bg-white rounded-full animate-bounce"></div> <div class="w-2 h-2 bg-white rounded-full animate-bounce" style="animation-delay: 0.1s"></div> <div class="w-2 h-2 bg-white rounded-full animate-bounce" style="animation-delay: 0.2s"></div> </div> <span class="text-sm">AI is typing...</span> @endif </div> </div> <!-- Messages Container --> <div class="flex-1 overflow-y-auto p-4 space-y-4" id="messages-container"> @forelse($messages as $msg) <div class="flex {{ $msg['is_ai'] ? 'justify-start' : 'justify-end' }}"> <div class="max-w-xs lg:max-w-md px-4 py-2 rounded-lg {{ $msg['is_ai'] ? 'bg-gray-200 text-gray-800' : 'bg-blue-600 text-white' }}"> <p class="text-sm">{{ $msg['content'] }}</p> <p class="text-xs mt-1 opacity-70"> {{ \Carbon\Carbon::parse($msg['created_at'])->format('H:i') }} </p> </div> </div> @empty <div class="text-center text-gray-500 py-8"> <svg class="w-12 h-12 mx-auto mb-4 text-gray-300" fill="currentColor" viewBox="0 0 20 20"> <path fill-rule="evenodd" d="M18 10c0 3.866-3.582 7-8 7a8.841 8.841 0 01-4.083-.98L2 17l1.338-3.123C2.493 12.767 2 11.434 2 10c0-3.866 3.582-7 8-7s8 3.134 8 7zM7 9H5v2h2V9zm8 0h-2v2h2V9zM9 9h2v2H9V9z" clip-rule="evenodd"/> </svg> <p class="text-lg font-medium">Start a conversation</p> <p class="text-sm">Send a message to begin chatting with the AI assistant</p> </div> @endforelse </div> <!-- Message Input --> <div class="border-t bg-gray-50 p-4"> <form wire:submit="sendMessage" class="flex space-x-2"> <input type="text" wire:model="message" placeholder="Type your message..." class="flex-1 border border-gray-300 rounded-lg px-4 py-2 focus:outline-none focus:ring-2 focus:ring-blue-500" maxlength="1000" > <button type="submit" class="bg-blue-600 text-white px-6 py-2 rounded-lg hover:bg-blue-700 focus:outline-none focus:ring-2 focus:ring-blue-500 disabled:opacity-50" wire:loading.attr="disabled" > <span wire:loading.remove>Send</span> <span wire:loading> <svg class="animate-spin h-4 w-4" fill="none" viewBox="0 0 24 24"> <circle class="opacity-25" cx="12" cy="12" r="10" stroke="currentColor" stroke-width="4"></circle> <path class="opacity-75" fill="currentColor" d="M4 12a8 8 0 018-8V0C5.373 0 0 5.373 0 12h4zm2 5.291A7.962 7.962 0 014 12H0c0 3.042 1.135 5.824 3 7.938l3-2.647z"></path> </svg> </span> </button> </form> </div> </div> <script> document.addEventListener('livewire:initialized', () => { Livewire.on('scroll-to-bottom', () => { const container = document.getElementById('messages-container'); container.scrollTop = container.scrollHeight; }); }); </script> 

php artisan make:model Conversation -m php artisan make:model Message -m 

<?php use Illuminate\Database\Migrations\Migration; use Illuminate\Database\Schema\Blueprint; use Illuminate\Support\Facades\Schema; return new class extends Migration { public function up(): void { Schema::create('conversations', function (Blueprint $table) { $table->id(); $table->foreignId('user_id')->constrained()->onDelete('cascade'); $table->string('title')->nullable(); $table->json('context')->nullable(); // Store conversation context for AI $table->timestamps(); }); } public function down(): void { Schema::dropIfExists('conversations'); } }; 

<?php use Illuminate\Database\Migrations\Migration; use Illuminate\Database\Schema\Blueprint; use Illuminate\Support\Facades\Schema; return new class extends Migration { public function up(): void { Schema::create('messages', function (Blueprint $table) { $table->id(); $table->foreignId('conversation_id')->constrained()->onDelete('cascade'); $table->foreignId('user_id')->nullable()->constrained()->onDelete('cascade'); $table->text('content'); $table->boolean('is_ai')->default(false); $table->json('metadata')->nullable(); // Store additional data like tokens used, etc. $table->timestamps(); $table->index(['conversation_id', 'created_at']); }); } public function down(): void { Schema::dropIfExists('messages'); } }; 

<?php namespace App\Models; use Illuminate\Database\Eloquent\Factories\HasFactory; use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Relations\BelongsTo; use Illuminate\Database\Eloquent\Relations\HasMany; class Conversation extends Model { use HasFactory; protected $fillable = [ 'user_id', 'title', 'context', ]; protected $casts = [ 'context' => 'array', ]; public function user(): BelongsTo { return $this->belongsTo(User::class); } public function messages(): HasMany { return $this->hasMany(Message::class); } public function getLastMessageAttribute() { return $this->messages()->latest()->first(); } } 

<?php namespace App\Models; use Illuminate\Database\Eloquent\Factories\HasFactory; use Illuminate\Database\Eloquent\Model; use Illuminate\Database\Eloquent\Relations\BelongsTo; class Message extends Model { use HasFactory; protected $fillable = [ 'conversation_id', 'user_id', 'content', 'is_ai', 'metadata', ]; protected $casts = [ 'is_ai' => 'boolean', 'metadata' => 'array', ]; public function conversation(): BelongsTo { return $this->belongsTo(Conversation::class); } public function user(): BelongsTo { return $this->belongsTo(User::class); } } 

php artisan migrate 

php artisan make:class Services/AIService 

<?php namespace App\Services; use App\Models\Conversation; use Illuminate\Http\Client\Response; use Illuminate\Support\Facades\Http; class AIService { private string $apiKey; private string $apiUrl; public function __construct() { $this->apiKey = config('services.openai.api_key'); $this->apiUrl = 'https://api.openai.com/v1/chat/completions'; } public function generateResponse(string $message, Conversation $conversation): string { $context = $this->buildContext($conversation); $response = Http::withHeaders([ 'Authorization' => 'Bearer ' . $this->apiKey, 'Content-Type' => 'application/json', ])->post($this->apiUrl, [ 'model' => 'gpt-3.5-turbo', 'messages' => array_merge($context, [ ['role' => 'user', 'content' => $message] ]), 'max_tokens' => 500, 'temperature' => 0.7, ]); if ($response->successful()) { return $response->json('choices.0.message.content'); } return 'I apologize, but I encountered an error processing your request. Please try again.'; } private function buildContext(Conversation $conversation): array { $context = [ [ 'role' => 'system', 'content' => 'You are a helpful AI assistant. Provide concise, accurate, and friendly responses.' ] ]; // Add recent conversation history for context $recentMessages = $conversation->messages() ->orderBy('created_at', 'desc') ->take(10) ->get() ->reverse(); foreach ($recentMessages as $msg) { $context[] = [ 'role' => $msg->is_ai ? 'assistant' : 'user', 'content' => $msg->content ]; } return $context; } } 

<?php return [ // ... other services 'openai' => [ 'api_key' => env('OPENAI_API_KEY'), ], ]; 

php artisan make:job ProcessAIResponse 

<?php namespace App\Jobs; use App\Events\MessageSent; use App\Models\Conversation; use App\Models\Message; use App\Services\AIService; use Illuminate\Bus\Queueable; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\SerializesModels; class ProcessAIResponse implements ShouldQueue { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; public function __construct( private string $userMessage, private Conversation $conversation ) {} public function handle(AIService $aiService): void { try { $aiResponse = $aiService->generateResponse($this->userMessage, $this->conversation); $aiMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => null, 'content' => $aiResponse, 'is_ai' => true, ]); broadcast(new MessageSent($aiMessage)); } catch (\Exception $e) { // Log error and send fallback message logger()->error('AI response failed: ' . $e->getMessage()); $errorMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => null, 'content' => 'I apologize, but I\'m experiencing technical difficulties. Please try again in a moment.', 'is_ai' => true, ]); broadcast(new MessageSent($errorMessage)); } } } 

private function processAIResponse($userMessage) { ProcessAIResponse::dispatch($userMessage, $this->conversation); } 

# Configure queue driver in .env QUEUE_CONNECTION=database # Create queue tables php artisan queue:table php artisan migrate # Start queue worker php artisan queue:work 

$aiMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => null, 'content' => $aiResponse, 'is_ai' => true, 'metadata' => [ 'model' => 'gpt-3.5-turbo', 'tokens_used' => $response->json('usage.total_tokens'), 'processing_time' => microtime(true) - $startTime, ], ]); 

<!-- In your main layout file --> @vite(['resources/js/app.js']) <script> import Echo from 'laravel-echo'; import Pusher from 'pusher-js'; window.Pusher = Pusher; window.Echo = new Echo({ broadcaster: 'reverb', key: import.meta.env.VITE_REVERB_APP_KEY, wsHost: import.meta.env.VITE_REVERB_HOST, wsPort: import.meta.env.VITE_REVERB_PORT, wssPort: import.meta.env.VITE_REVERB_PORT, forceTLS: (import.meta.env.VITE_REVERB_SCHEME ?? 'https') === 'https', enabledTransports: ['ws', 'wss'], }); </script> 

// Add to ChatInterface component public $showTypingIndicator = false; public function showTyping() { $this->showTypingIndicator = true; $this->dispatch('typing-started'); } public function hideTyping() { $this->showTypingIndicator = false; $this->dispatch('typing-stopped'); } #[On('echo:chat.{conversation.id},UserTyping')] public function userTyping($event) { if ($event['user_id'] !== auth()->id()) { $this->showTypingIndicator = true; // Hide after 3 seconds of inactivity $this->dispatch('hide-typing-after-delay'); } } 

// Add to AIService public function generateResponse(string $message, Conversation $conversation): string { try { // Validate input if (strlen($message) > 1000) { throw new \InvalidArgumentException('Message too long'); } if (empty(trim($message))) { throw new \InvalidArgumentException('Empty message'); } $context = $this->buildContext($conversation); $response = Http::timeout(30) ->withHeaders([ 'Authorization' => 'Bearer ' . $this->apiKey, 'Content-Type' => 'application/json', ]) ->post($this->apiUrl, [ 'model' => 'gpt-3.5-turbo', 'messages' => array_merge($context, [ ['role' => 'user', 'content' => $message] ]), 'max_tokens' => 500, 'temperature' => 0.7, ]); if ($response->successful()) { $content = $response->json('choices.0.message.content'); if (empty($content)) { throw new \Exception('Empty AI response'); } return $content; } // Handle specific API errors if ($response->status() === 429) { throw new \Exception('Rate limit exceeded. Please try again in a moment.'); } if ($response->status() === 401) { throw new \Exception('AI service authentication failed.'); } throw new \Exception('AI service temporarily unavailable.'); } catch (\InvalidArgumentException $e) { return 'Please provide a valid message to continue our conversation.'; } catch (\Exception $e) { logger()->error('AI Service Error: ' . $e->getMessage()); return 'I apologize, but I encountered an error processing your request. Please try again.'; } } 

// Add to ChatInterface component public function mount() { // Ensure user is authenticated if (!Auth::check()) { return redirect()->route('login'); } $this->conversation = Conversation::firstOrCreate([ 'user_id' => Auth::id(), ]); $this->loadMessages(); } // Add middleware to routes Route::middleware(['auth', 'verified'])->group(function () { Route::get('/chat', function () { return view('chat'); })->name('chat'); }); 

// Add to ChatInterface component use Illuminate\Support\Facades\RateLimiter; public function sendMessage() { // Rate limiting $key = 'chat-message:' . Auth::id(); if (RateLimiter::tooManyAttempts($key, 10)) { $this->addError('message', 'Too many messages. Please wait before sending another.'); return; } RateLimiter::hit($key, 60); // 10 messages per minute // Input validation and sanitization $this->validate([ 'message' => 'required|string|max:1000|min:1', ]); $sanitizedMessage = strip_tags(trim($this->message)); if (empty($sanitizedMessage)) { $this->addError('message', 'Please enter a valid message.'); return; } // Profanity filter (optional) if ($this->containsProfanity($sanitizedMessage)) { $this->addError('message', 'Please keep the conversation respectful.'); return; } // Create user message $userMessage = Message::create([ 'conversation_id' => $this->conversation->id, 'user_id' => Auth::id(), 'content' => $sanitizedMessage, 'is_ai' => false, ]); // Broadcast user message broadcast(new MessageSent($userMessage)); // Clear input and process AI response $this->message = ''; ProcessAIResponse::dispatch($sanitizedMessage, $this->conversation); } private function containsProfanity(string $message): bool { // Implement your profanity filter logic here $profanityWords = ['badword1', 'badword2']; // Replace with actual implementation foreach ($profanityWords as $word) { if (stripos($message, $word) !== false) { return true; } } return false; } 

server { listen 443 ssl http2; server_name yourdomain.com; # SSL configuration ssl_certificate /path/to/ssl/cert.pem; ssl_certificate_key /path/to/ssl/private.key; # Main application location / { proxy_pass http://127.0.0.1:8000; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header X-Forwarded-Proto $scheme; } # WebSocket proxy for Reverb location /app/ { proxy_pass http://127.0.0.1:8080; proxy_http_version 1.1; proxy_set_header Upgrade $http_upgrade; proxy_set_header Connection "upgrade"; proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for; proxy_set_header X-Forwarded-Proto $scheme; proxy_cache_bypass $http_upgrade; } } 

# .env production settings APP_ENV=production APP_DEBUG=false APP_URL=https://yourdomain.com # Database DB_CONNECTION=mysql DB_HOST=your-db-host DB_DATABASE=ai_chatbot_prod DB_USERNAME=your-db-user DB_PASSWORD=your-secure-password # Queue QUEUE_CONNECTION=redis REDIS_HOST=your-redis-host # Reverb REVERB_APP_ID=your-prod-app-id REVERB_APP_KEY=your-prod-app-key REVERB_APP_SECRET=your-prod-app-secret REVERB_HOST=yourdomain.com REVERB_PORT=443 REVERB_SCHEME=https # Broadcasting BROADCAST_DRIVER=reverb 

# /etc/supervisor/conf.d/laravel-worker.conf [program:laravel-worker] process_name=%(program_name)s_%(process_num)02d command=php /var/www/html/artisan queue:work redis --sleep=3 --tries=3 --max-time=3600 autostart=true autorestart=true stopasgroup=true killasgroup=true user=www-data numprocs=4 redirect_stderr=true stdout_logfile=/var/log/laravel-worker.log stopwaitsecs=3600 [program:laravel-reverb] process_name=%(program_name)s command=php /var/www/html/artisan reverb:start --host=0.0.0.0 --port=8080 autostart=true autorestart=true stopasgroup=true killasgroup=true user=www-data redirect_stderr=true stdout_logfile=/var/log/laravel-reverb.log 

php artisan make:test ChatInterfaceTest php artisan make:test AIServiceTest 

<?php namespace Tests\Feature; use App\Livewire\ChatInterface; use App\Models\Conversation; use App\Models\User; use Illuminate\Foundation\Testing\RefreshDatabase; use Livewire\Livewire; use Tests\TestCase; class ChatInterfaceTest extends TestCase { use RefreshDatabase; public function test_authenticated_user_can_access_chat() { $user = User::factory()->create(); $this->actingAs($user); Livewire::test(ChatInterface::class) ->assertStatus(200) ->assertSet('conversation.user_id', $user->id); } public function test_user_can_send_message() { $user = User::factory()->create(); $this->actingAs($user); Livewire::test(ChatInterface::class) ->set('message', 'Hello, AI!') ->call('sendMessage') ->assertSet('message', '') // Input should be cleared ->assertDispatched('echo:chat.*,MessageSent'); } public function test_message_validation() { $user = User::factory()->create(); $this->actingAs($user); Livewire::test(ChatInterface::class) ->set('message', '') ->call('sendMessage') ->assertHasErrors(['message']); } public function test_rate_limiting_works() { $user = User::factory()->create(); $this->actingAs($user); $component = Livewire::test(ChatInterface::class); // Send 10 messages (should work) for ($i = 0; $i < 10; $i++) { $component->set('message', "Message $i") ->call('sendMessage'); } // 11th message should be rate limited $component->set('message', 'This should fail') ->call('sendMessage') ->assertHasErrors(['message']); } } 

<?php namespace Tests\Unit; use App\Models\Conversation; use App\Models\User; use App\Services\AIService; use Illuminate\Foundation\Testing\RefreshDatabase; use Illuminate\Support\Facades\Http; use Tests\TestCase; class AIServiceTest extends TestCase { use RefreshDatabase; public function test_generates_ai_response() { Http::fake([ 'api.openai.com/*' => Http::response([ 'choices' => [ [ 'message' => [ 'content' => 'Hello! How can I help you today?' ] ] ] ]) ]); $user = User::factory()->create(); $conversation = Conversation::factory()->create(['user_id' => $user->id]); $aiService = new AIService(); $response = $aiService->generateResponse('Hello!', $conversation); $this->assertEquals('Hello! How can I help you today?', $response); } public function test_handles_api_errors_gracefully() { Http::fake([ 'api.openai.com/*' => Http::response([], 500) ]); $user = User::factory()->create(); $conversation = Conversation::factory()->create(['user_id' => $user->id]); $aiService = new AIService(); $response = $aiService->generateResponse('Hello!', $conversation); $this->assertStringContainsString('error processing your request', $response); } } 

# Check Reverb server status php artisan reverb:start --debug # Monitor broadcasting events php artisan tinker >>> broadcast(new App\Events\MessageSent($message)); # Debug Livewire components # Add to your component: public function debug() { dd($this->messages, $this->conversation); } 

// Check Echo connection Echo.connector.pusher.connection.state // Listen for all events Echo.private('chat.1') .listen('.MessageSent', (e) => { console.log('Message received:', e); }); // Debug WebSocket connection Echo.connector.pusher.connection.bind('state_change', function(states) { console.log('Connection state changed', states.current); }); 

// config/queue.php - Redis queue optimization 'redis' => [ 'driver' => 'redis', 'connection' => 'default', 'queue' => env('REDIS_QUEUE', 'default'), 'retry_after' => 90, 'block_for' => null, 'after_commit' => false, 'processes' => 4, // Run multiple processes ], 

use Illuminate\Bus\Batch; use Illuminate\Support\Facades\Bus; // Process multiple AI requests in batches public function processBatchedResponses(array $messages) { $jobs = collect($messages)->map(function ($message) { return new ProcessAIResponse($message['content'], $message['conversation']); }); Bus::batch($jobs) ->then(function (Batch $batch) { // All jobs completed successfully logger()->info("Batch {$batch->id} completed successfully"); }) ->catch(function (Batch $batch, Throwable $e) { // First batch job failure detected logger()->error("Batch {$batch->id} failed: " . $e->getMessage()); }) ->dispatch(); } 

// Create a batch event for multiple messages class MessagesBatch implements ShouldBroadcast { use Dispatchable, InteractsWithSockets, SerializesModels; public function __construct( public Collection $messages, public string $conversationId ) {} public function broadcastOn(): array { return [ new PresenceChannel('chat.' . $this->conversationId), ]; } public function broadcastWith(): array { return [ 'messages' => $this->messages->map(function ($message) { return [ 'id' => $message->id, 'content' => $message->content, 'user_id' => $message->user_id, 'is_ai' => $message->is_ai, 'created_at' => $message->created_at, ]; })->toArray(), ]; } } 

// Optimize message loading with eager loading and pagination public function loadMessages($page = 1, $perPage = 50) { $this->messages = $this->conversation ->messages() ->with('user:id,name') // Only load necessary columns ->select(['id', 'conversation_id', 'user_id', 'content', 'is_ai', 'created_at']) ->orderBy('created_at', 'desc') ->limit($perPage) ->offset(($page - 1) * $perPage) ->get() ->reverse() ->values() ->toArray(); } // Add database indexes for better performance // In your migration: $table->index(['conversation_id', 'created_at']); $table->index(['user_id', 'created_at']); $table->index(['is_ai', 'conversation_id']); 

// Add to AIService public function processCommand(string $message, Conversation $conversation): ?string { if (!str_starts_with($message, '/')) { return null; } $command = strtolower(trim(substr($message, 1))); return match ($command) { 'help' => $this->getHelpMessage(), 'clear' => $this->clearConversation($conversation), 'history' => $this->getConversationHistory($conversation), 'joke' => $this->tellJoke(), 'weather' => 'Please specify a location: /weather [city name]', default => "Unknown command: /{$command}. Type /help for available commands." }; } private function getHelpMessage(): string { return "Available commands:\n" . "• /help - Show this help message\n" . "• /clear - Clear conversation history\n" . "• /history - Show recent messages\n" . "• /joke - Tell a random joke\n" . "• /weather [city] - Get weather information"; } private function clearConversation(Conversation $conversation): string { $conversation->messages()->delete(); return "✅ Conversation history cleared!"; } // Add emoji reactions public function addReaction(Message $message, string $emoji) { $reactions = $message->metadata['reactions'] ?? []; $userId = auth()->id(); if (isset($reactions[$emoji])) { if (in_array($userId, $reactions[$emoji])) { // Remove reaction $reactions[$emoji] = array_diff($reactions[$emoji], [$userId]); if (empty($reactions[$emoji])) { unset($reactions[$emoji]); } } else { // Add reaction $reactions[$emoji][] = $userId; } } else { $reactions[$emoji] = [$userId]; } $message->update(['metadata' => array_merge($message->metadata ?? [], ['reactions' => $reactions])]); broadcast(new MessageReactionUpdated($message)); } 

composer require stichoza/google-translate-php 

// Add to AIService use Stichoza\GoogleTranslate\GoogleTranslate; public function translateMessage(string $message, string $targetLanguage = 'en'): string { try { $translator = new GoogleTranslate(); return $translator->setTarget($targetLanguage)->translate($message); } catch (\Exception $e) { logger()->error('Translation failed: ' . $e->getMessage()); return $message; // Return original if translation fails } } // Add language detection and auto-translation public function generateResponseWithTranslation(string $message, Conversation $conversation): array { $detectedLanguage = $this->detectLanguage($message); // Translate to English for AI processing if needed $englishMessage = $detectedLanguage !== 'en' ? $this->translateMessage($message, 'en') : $message; // Generate AI response in English $englishResponse = $this->generateResponse($englishMessage, $conversation); // Translate back to user's language if needed $finalResponse = $detectedLanguage !== 'en' ? $this->translateMessage($englishResponse, $detectedLanguage) : $englishResponse; return [ 'response' => $finalResponse, 'detected_language' => $detectedLanguage, 'original_message' => $message, ]; } 

// Enhanced context building with conversation memory private function buildContext(Conversation $conversation): array { $systemPrompt = "You are a helpful AI assistant. "; // Add user preferences from conversation context if ($conversation->context) { $preferences = $conversation->context['preferences'] ?? []; if (isset($preferences['language'])) { $systemPrompt .= "Respond in {$preferences['language']}. "; } if (isset($preferences['tone'])) { $systemPrompt .= "Use a {$preferences['tone']} tone. "; } } $context = [ ['role' => 'system', 'content' => $systemPrompt] ]; // Add conversation summary for long conversations $messageCount = $conversation->messages()->count(); if ($messageCount > 50) { $summary = $this->generateConversationSummary($conversation); $context[] = ['role' => 'system', 'content' => "Conversation summary: " . $summary]; } // Add recent messages $recentMessages = $conversation->messages() ->orderBy('created_at', 'desc') ->take(20) ->get() ->reverse(); foreach ($recentMessages as $msg) { $context[] = [ 'role' => $msg->is_ai ? 'assistant' : 'user', 'content' => $msg->content ]; } return $context; }