feat: add chat streaming functionality and corresponding tests

Author: estefanoquiriconi

routes/web.php

@@ -1,5 +1,6 @@
 <?php
 
+use App\Http\Controllers\ChatController;
 use Illuminate\Support\Facades\Route;
 use Inertia\Inertia;
 use Laravel\Fortify\Features;
@@ -14,4 +15,8 @@
     return Inertia::render('dashboard');
 })->middleware(['auth', 'verified'])->name('dashboard');
 
+Route::middleware(['auth', 'verified'])->group(function () {
+    Route::post('chat/stream', [ChatController::class, 'stream'])->name('chat.stream');
+});
+
 require __DIR__.'/settings.php';

tests/Feature/Ai/Agents/CustomerSupportTest.php

@@ -0,0 +1,37 @@
+<?php
+
+use App\Ai\Agents\CustomerSupport;
+use Laravel\Ai\Prompts\AgentPrompt;
+
+beforeEach(function () {
+    CustomerSupport::fake([
+        'Hello! How can I help you today?',
+        'I can help you with that. Let me look into it.',
+    ]);
+});
+
+it('can respond to a customer prompt', function () {
+    $response = (new CustomerSupport)->prompt('I need help with my order.');
+
+    expect($response->text)->toBe('Hello! How can I help you today?');
+
+    CustomerSupport::assertPrompted(function (AgentPrompt $prompt) {
+        return $prompt->contains('order');
+    });
+});
+
+it('can handle multiple prompts in sequence', function () {
+    $agent = new CustomerSupport;
+
+    $first = $agent->prompt('I have a question.');
+    $second = $agent->prompt('Can you tell me more?');
+
+    expect($first->text)->toBe('Hello! How can I help you today?');
+    expect($second->text)->toBe('I can help you with that. Let me look into it.');
+});
+
+it('has proper instructions', function () {
+    $agent = new CustomerSupport;
+
+    expect($agent->instructions())->toContain('customer support agent');
+});

tests/Feature/Chat/ChatControllerTest.php

@@ -0,0 +1,63 @@
+<?php
+
+use App\Ai\Agents\CustomerSupport;
+use App\Models\User;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Str;
+
+beforeEach(function () {
+    CustomerSupport::fake([
+        'Hello! How can I help you today?',
+    ]);
+});
+
+test('guests cannot access the stream endpoint', function () {
+    $this->postJson(route('chat.stream'), [
+        'message' => 'Hello',
+    ])->assertUnauthorized();
+});
+
+test('stream endpoint validates the message field', function () {
+    $this->actingAs(User::factory()->create())
+        ->postJson(route('chat.stream'), [])
+        ->assertJsonValidationErrors(['message']);
+});
+
+test('stream endpoint validates conversation_id is a uuid', function () {
+    $this->actingAs(User::factory()->create())
+        ->postJson(route('chat.stream'), [
+            'message' => 'Hello',
+            'conversation_id' => 'not-a-uuid',
+        ])
+        ->assertJsonValidationErrors(['conversation_id']);
+});
+
+test('stream endpoint returns a streamed response', function () {
+    $this->actingAs(User::factory()->create())
+        ->post(route('chat.stream'), [
+            'message' => 'Hello',
+        ])
+        ->assertOk()
+        ->assertStreamed();
+});
+
+test('stream endpoint prevents access to another user\'s conversation', function () {
+    $owner = User::factory()->create();
+    $other = User::factory()->create();
+    $conversationId = (string) Str::uuid7();
+
+    DB::table('agent_conversations')->insert([
+        'id' => $conversationId,
+        'user_id' => $owner->id,
+        'title' => 'Private conversation',
+        'created_at' => now(),
+        'updated_at' => now(),
+    ]);
+
+    $this->actingAs($other)
+        ->postJson(route('chat.stream'), [
+            'message' => 'Hello',
+            'conversation_id' => $conversationId,
+        ])
+        ->assertForbidden();
+});