AKKHIRNYA BISA STREAM

.gitignore

@@ -30,4 +30,8 @@ yarn-error.log
 
 AGENTS.md
 .agents
-.codex
+.codex
+CLAUDE.md
+.claude
+.mcp.json
+boost.json

app/Http/Controllers/MahasiswaController.php

@@ -17,8 +17,6 @@ class MahasiswaController extends Controller
 
     private const DIRECT_MESSAGES_SESSION_PREFIX = 'sevima_raghub_direct_messages';
 
-    private const PENDING_INITIAL_CHAT_SESSION_PREFIX = 'sevima_raghub_pending_initial_chat';
-
     public function index(Request $request): Response
     {
         $payload = $this->studentDashboardPayload($request);
@@ -37,8 +35,10 @@ public function storeSession(Request $request): RedirectResponse
             'title' => ['required', 'string'],
         ]);
 
+        $token = $this->authToken($request);
+
         try {
-            $session = $this->createChatSession($payload, $this->authToken($request));
+            $session = $this->createChatSession($payload, $token);
         } catch (RagApiException $exception) {
             return back()
                 ->withErrors(['chat' => $exception->getMessage()])
@@ -47,10 +47,23 @@ public function storeSession(Request $request): RedirectResponse
 
         $sessionId = (string) ($session['uuid_id'] ?? '');
 
-        $request->session()->flash($this->pendingInitialChatKey($sessionId), [
-            'content' => $payload['title'],
-            'courseId' => $payload['course_id'],
-        ]);
+        try {
+            $assistantMessage = $this->sendConfiguredChatMessage(
+                $sessionId,
+                $payload['course_id'],
+                $payload['title'],
+                $token,
+            );
+
+            if ($this->isDirectChatMode()) {
+                $this->appendDirectChatMessages($request, $sessionId, [
+                    $this->localUserMessage($payload['title']),
+                    $assistantMessage,
+                ]);
+            }
+        } catch (RagApiException) {
+            // Session created; initial message failed — user can retry from the session page.
+        }
 
         return to_route('mahasiswa.show', ['sessionId' => $sessionId]);
     }
@@ -89,7 +102,6 @@ public function show(Request $request, string $sessionId): Response
             'isDirectChatMode' => $this->isDirectChatMode(),
             'isStreamChatMode' => $this->isStreamChatMode(),
             'messages' => $messages,
-            'pendingInitialChat' => $request->session()->pull($this->pendingInitialChatKey($sessionId)),
             'selectedCourseId' => is_string($currentSession['course_id'] ?? null)
                 ? $currentSession['course_id']
                 : $this->firstCourseId($payload['courses']),
@@ -106,8 +118,10 @@ public function storeMessage(Request $request, string $sessionId): JsonResponse|
         ]);
         $userMessage = $this->localUserMessage($payload['content']);
 
-        if ($this->isStreamChatMode()) {
+        if ($this->isStreamChatMode() && $request->accepts('text/event-stream')) {
             try {
+                $request->session()->save();
+
                 return $this->streamChatMessage(
                     $sessionId,
                     $payload['content'],
@@ -338,8 +352,18 @@ private function streamChatMessage(string $sessionId, string $content, ?string $
         $stream = $response->toPsrResponse()->getBody();
 
         return response()->stream(function () use ($stream): void {
+            @ini_set('zlib.output_compression', '0');
+
             while (! $stream->eof()) {
-                echo $stream->read(1024);
+                $chunk = $stream->read(1);
+
+                if ($chunk === '') {
+                    usleep(10_000);
+
+                    continue;
+                }
+
+                echo $chunk;
 
                 if (ob_get_level() > 0) {
                     ob_flush();
@@ -442,8 +466,4 @@ private function directMessagesKey(string $sessionId): string
         return self::DIRECT_MESSAGES_SESSION_PREFIX.'.'.$sessionId;
     }
 
-    private function pendingInitialChatKey(string $sessionId): string
-    {
-        return self::PENDING_INITIAL_CHAT_SESSION_PREFIX.'.'.$sessionId;
-    }
 }

boost.json

@@ -1,6 +1,6 @@
 {
     "agents": [
-        "codex"
+        "claude_code"
     ],
     "cloud": false,
     "guidelines": true,

resources/js/components/appearance-toggle.tsx

@@ -1,4 +1,5 @@
 import { Moon, Sun } from 'lucide-react';
+import { useEffect, useState } from 'react';
 import { Button } from '@/components/ui/button';
 import { useAppearance } from '@/hooks/use-appearance';
 import { cn } from '@/lib/utils';
@@ -9,7 +10,12 @@ type AppearanceToggleProps = {
 
 export default function AppearanceToggle({ className }: AppearanceToggleProps) {
     const { resolvedAppearance, updateAppearance } = useAppearance();
-    const isDarkMode = resolvedAppearance === 'dark';
+    const [isMounted, setIsMounted] = useState(false);
+    const isDarkMode = isMounted && resolvedAppearance === 'dark';
+
+    useEffect(() => {
+        setIsMounted(true);
+    }, []);
 
     const handleToggle = (): void => {
         updateAppearance(isDarkMode ? 'light' : 'dark');

resources/js/pages/mahasiswa-chat.tsx

@@ -20,11 +20,6 @@ import { createLocalAssistantMessage, createLocalUserMessage } from '@/lib/rag';
 import { destroy as destroyMahasiswaSession } from '@/routes/mahasiswa';
 import { store as storeMahasiswaMessage } from '@/routes/mahasiswa/messages';
 
-type PendingInitialChat = {
-    content: string;
-    courseId: string;
-};
-
 type StoreMessageJsonResponse = {
     assistantMessage?: ChatMessageResponse;
 };
@@ -49,7 +44,6 @@ type MahasiswaChatProps = {
     isDirectChatMode?: boolean;
     isStreamChatMode?: boolean;
     messages: ChatMessageResponse[];
-    pendingInitialChat?: PendingInitialChat | null;
     selectedCourseId?: string | null;
     sessionId: string;
 };
@@ -132,6 +126,40 @@ function csrfToken(): string | undefined {
     );
 }
 
+function isStreamDebugEnabled(): boolean {
+    if (import.meta.env.DEV) {
+        return true;
+    }
+
+    if (typeof window === 'undefined') {
+        return false;
+    }
+
+    if (new URLSearchParams(window.location.search).has('debug_stream')) {
+        return true;
+    }
+
+    try {
+        return window.localStorage.getItem('rag_stream_debug') === '1';
+    } catch {
+        return false;
+    }
+}
+
+function debugStream(label: string, value?: unknown): void {
+    if (!isStreamDebugEnabled()) {
+        return;
+    }
+
+    if (value === undefined) {
+        console.log(`[rag-stream] ${label}`);
+
+        return;
+    }
+
+    console.log(`[rag-stream] ${label}`, value);
+}
+
 async function storeChatMessage(
     sessionId: string,
     content: string,
@@ -211,8 +239,12 @@ function isDoneStatus(value: string | undefined): boolean {
         'completed',
         'done',
         'end',
+        'final',
+        'finalized',
         'finish',
         'finished',
+        'message_done',
+        'stop',
         'success',
     ].includes(value ?? '');
 }
@@ -318,9 +350,14 @@ function finalMessageFromPayload(
 
 function parseSseFrame(frame: string): { data: string; eventName?: string } {
     const dataLines: string[] = [];
+    const fallbackLines: string[] = [];
     let eventName: string | undefined;
 
     for (const line of frame.split('\n')) {
+        if (line.startsWith(':')) {
+            continue;
+        }
+
         if (line.startsWith('event:')) {
             eventName = line.slice('event:'.length).trim();
             continue;
@@ -328,15 +365,27 @@ function parseSseFrame(frame: string): { data: string; eventName?: string } {
 
         if (line.startsWith('data:')) {
             dataLines.push(line.slice('data:'.length).trimStart());
+            continue;
         }
+
+        fallbackLines.push(line);
     }
 
     return {
-        data: dataLines.length > 0 ? dataLines.join('\n') : frame.trim(),
+        data:
+            dataLines.length > 0
+                ? dataLines.join('\n')
+                : fallbackLines.join('\n').trim(),
         eventName,
     };
 }
 
+function isAssistantMessage(
+    message: ChatMessageResponse | undefined,
+): message is ChatMessageResponse {
+    return Boolean(message && !isUserMessage(message.role));
+}
+
 function handleStreamPayload(
     data: string,
     eventName: string | undefined,
@@ -345,11 +394,20 @@ function handleStreamPayload(
     const payload = parseStreamPayload(data);
     const finalMessage = finalMessageFromPayload(payload);
 
+    debugStream('payload', { data, eventName, payload });
+
     if (isStreamDone(data, eventName, payload)) {
-        return { done: true, finalMessage };
+        debugStream('done-status', { data, eventName, payload });
+
+        return {
+            done: true,
+            finalMessage: isAssistantMessage(finalMessage)
+                ? finalMessage
+                : undefined,
+        };
     }
 
-    if (eventName === 'error') {
+    if (eventName?.toLowerCase() === 'error') {
         throw new BackendResponseError(
             backendMessageFromPayload(payload) ?? '',
         );
@@ -362,15 +420,20 @@ function handleStreamPayload(
     }
 
     if (finalMessage) {
+        debugStream('final-message', finalMessage);
+
         return {
-            done: false,
-            finalMessage,
+            done: isAssistantMessage(finalMessage),
+            finalMessage: isAssistantMessage(finalMessage)
+                ? finalMessage
+                : undefined,
         };
     }
 
     const delta = streamTextFromPayload(payload);
 
     if (delta) {
+        debugStream('delta', delta);
         onDelta(delta);
     }
 
@@ -384,6 +447,14 @@ async function streamChatMessage(
     onDelta: (delta: string) => void,
 ): Promise<StoreMessageJsonResponse> {
     const token = csrfToken();
+
+    debugStream('request:start', {
+        content,
+        courseId,
+        sessionId,
+        url: storeMahasiswaMessage.url(sessionId),
+    });
+
     const response = await fetch(storeMahasiswaMessage.url(sessionId), {
         body: JSON.stringify({
             content,
@@ -399,15 +470,26 @@ async function streamChatMessage(
         method: 'POST',
     });
 
+    debugStream('response', {
+        contentType: response.headers.get('content-type'),
+        ok: response.ok,
+        status: response.status,
+        statusText: response.statusText,
+    });
+
     if (!response.ok) {
         const payload: unknown = await response.json().catch(() => undefined);
 
+        debugStream('response:error-payload', payload);
+
         throw new BackendResponseError(
             backendMessageFromPayload(payload) ?? '',
         );
     }
 
     if (!response.body) {
+        debugStream('response:no-body');
+
         return {};
     }
 
@@ -420,6 +502,8 @@ async function streamChatMessage(
     const processFrame = (frame: string): void => {
         const { data, eventName } = parseSseFrame(frame);
 
+        debugStream('frame', { data, eventName, frame });
+
         if (!data) {
             return;
         }
@@ -430,6 +514,8 @@ async function streamChatMessage(
     };
 
     const processRawData = (data: string): void => {
+        debugStream('raw-data', data);
+
         const result = handleStreamPayload(data, undefined, onDelta);
         finalMessage = result.finalMessage ?? finalMessage;
         shouldStop = shouldStop || result.done;
@@ -437,6 +523,7 @@ async function streamChatMessage(
 
     while (true) {
         if (shouldStop) {
+            debugStream('reader:cancel-before-read');
             await reader.cancel();
             break;
         }
@@ -444,44 +531,40 @@ async function streamChatMessage(
         const { done, value } = await reader.read();
 
         if (done) {
+            debugStream('reader:done');
             break;
         }
 
         const chunk = decoder.decode(value, { stream: true });
 
-        if (
-            buffer !== '' ||
-            chunk.includes('data:') ||
-            chunk.includes('event:')
-        ) {
-            buffer += chunk.replace(/\r\n/g, '\n');
-
-            let boundaryIndex = buffer.indexOf('\n\n');
+        debugStream('chunk', chunk);
 
-            while (boundaryIndex !== -1) {
-                const frame = buffer.slice(0, boundaryIndex);
-                buffer = buffer.slice(boundaryIndex + 2);
-                processFrame(frame);
+        buffer += chunk.replace(/\r\n/g, '\n');
 
-                if (shouldStop) {
-                    await reader.cancel();
-                    break;
-                }
+        let boundaryIndex = buffer.indexOf('\n\n');
 
-                boundaryIndex = buffer.indexOf('\n\n');
-            }
+        while (boundaryIndex !== -1) {
+            const frame = buffer.slice(0, boundaryIndex);
+            buffer = buffer.slice(boundaryIndex + 2);
+            processFrame(frame);
 
             if (shouldStop) {
+                debugStream('reader:cancel-after-frame');
+                await reader.cancel();
                 break;
             }
 
-            continue;
+            boundaryIndex = buffer.indexOf('\n\n');
         }
 
-        processRawData(chunk);
+        if (shouldStop) {
+            break;
+        }
     }
 
-    const remaining = `${buffer}${decoder.decode()}`.trim();
+    const remaining = shouldStop ? '' : `${buffer}${decoder.decode()}`.trim();
+
+    debugStream('remaining', remaining);
 
     if (remaining) {
         if (remaining.includes('data:') || remaining.includes('event:')) {
@@ -491,6 +574,8 @@ async function streamChatMessage(
         }
     }
 
+    debugStream('request:finish', { finalMessage });
+
     return {
         assistantMessage: finalMessage,
     };
@@ -563,7 +648,12 @@ function ChatMessage({
 
             <div className="student-message-bubble">
                 <p className="student-message-content">
-                    {!isUser && shouldAnimateTyping ? (
+                    {!isUser && message.content === '' ? (
+                        <LoadingIndicator
+                            label="Thinking"
+                            showSpinner={false}
+                        />
+                    ) : !isUser && shouldAnimateTyping ? (
                         <TypingText
                             key={message.uuid_id}
                             text={message.content}
@@ -624,13 +714,10 @@ export default function MahasiswaChat({
     isDirectChatMode = false,
     isStreamChatMode = false,
     messages: initialMessages,
-    pendingInitialChat,
     selectedCourseId: initialSelectedCourseId,
     sessionId,
 }: MahasiswaChatProps) {
-    const pendingInitialChatRef = useRef(pendingInitialChat ?? undefined);
     const isWaitingForDirectAssistantRef = useRef(false);
-    const hasStartedPendingInitialChatRef = useRef(false);
     const streamingAssistantMessageRef = useRef<
         ChatMessageResponse | undefined
     >(undefined);
@@ -640,29 +727,18 @@ export default function MahasiswaChat({
     const knownMessageIdsRef = useRef(
         new Set(initialMessages.map((message) => message.uuid_id)),
     );
-    const [pendingUserMessage] = useState<ChatMessageResponse | undefined>(
-        pendingInitialChat
-            ? createLocalUserMessage(pendingInitialChat.content)
-            : undefined,
-    );
-    const pendingUserMessageRef = useRef(pendingUserMessage);
     const [localBackendMessage, setLocalBackendMessage] = useState<string>();
     const [animatedAssistantMessageId, setAnimatedAssistantMessageId] =
         useState<string>();
     const [streamingAssistantMessageId, setStreamingAssistantMessageId] =
         useState<string>();
-    const [isProcessing, setIsProcessing] = useState(
-        Boolean(pendingInitialChat),
-    );
+    const [isProcessing, setIsProcessing] = useState(false);
     const [optimisticMessages, setOptimisticMessages] = useState<
         ChatMessageResponse[]
-    >(() => (pendingUserMessage ? [pendingUserMessage] : []));
+    >([]);
     const [question, setQuestion] = useState('');
     const [selectedCourseId, setSelectedCourseId] = useState(
-        pendingInitialChat?.courseId ??
-            initialSelectedCourseId ??
-            currentSession?.course_id ??
-            '',
+        initialSelectedCourseId ?? currentSession?.course_id ?? '',
     );
     const studentName = useStoredStudentName();
     const messagesEndRef = useRef<HTMLDivElement>(null);
@@ -868,17 +944,6 @@ export default function MahasiswaChat({
 
     useEffect(() => clearStreamingTyping, [clearStreamingTyping]);
 
-    const reloadChatHistory = useCallback((): void => {
-        router.reload({
-            onSuccess: () => {
-                streamingAssistantMessageRef.current = undefined;
-                setStreamingAssistantMessageId(undefined);
-                setOptimisticMessages([]);
-            },
-            only: ['messages', 'chatSessions', 'currentSession'],
-        });
-    }, []);
-
     const sendMessage = useCallback(
         (
             content: string,
@@ -891,7 +956,13 @@ export default function MahasiswaChat({
 
             void (async () => {
                 try {
-                    const response = isStreamChatMode
+                    const shouldUseStream = isStreamChatMode;
+
+                    if (shouldUseStream) {
+                        setStreamingAssistantContent('');
+                    }
+
+                    const response = shouldUseStream
                         ? await streamChatMessage(
                               sessionId,
                               content,
@@ -900,18 +971,19 @@ export default function MahasiswaChat({
                           )
                         : await storeChatMessage(sessionId, content, courseId);
 
-                    pendingInitialChatRef.current = undefined;
-
-                    if (isStreamChatMode) {
+                    if (shouldUseStream) {
                         await waitForStreamingTyping();
                     }
 
                     if (response.assistantMessage) {
                         const assistantMessage = response.assistantMessage;
 
-                        if (isStreamChatMode) {
+                        if (shouldUseStream) {
                             replaceStreamingAssistantMessage(assistantMessage);
                         } else {
+                            setAnimatedAssistantMessageId(
+                                assistantMessage.uuid_id,
+                            );
                             setOptimisticMessages((currentMessages) =>
                                 appendUniqueMessages(currentMessages, [
                                     assistantMessage,
@@ -920,12 +992,9 @@ export default function MahasiswaChat({
                         }
                     }
 
-                    if (isStreamChatMode) {
-                        reloadChatHistory();
-                    }
-
                     setQuestion('');
                 } catch (error) {
+                    debugStream('request:error', error);
                     isWaitingForDirectAssistantRef.current = false;
                     const streamingMessageId =
                         streamingAssistantMessageRef.current?.uuid_id;
@@ -951,7 +1020,6 @@ export default function MahasiswaChat({
                         );
                     }
 
-                    pendingInitialChatRef.current = undefined;
                     setQuestion(content);
                     setLocalBackendMessage(
                         error instanceof Error && error.message
@@ -959,10 +1027,28 @@ export default function MahasiswaChat({
                             : undefined,
                     );
                 } finally {
+                    const emptyStreamingMessage =
+                        streamingAssistantMessageRef.current?.content === ''
+                            ? streamingAssistantMessageRef.current
+                            : undefined;
                     clearStreamingTyping();
                     streamingAssistantMessageRef.current = undefined;
                     setStreamingAssistantMessageId(undefined);
                     setIsProcessing(false);
+
+                    if (emptyStreamingMessage) {
+                        setOptimisticMessages((currentMessages) =>
+                            currentMessages.filter(
+                                (message) =>
+                                    message.uuid_id !==
+                                    emptyStreamingMessage.uuid_id,
+                            ),
+                        );
+                        setLocalBackendMessage(
+                            'Tidak ada respons dari AI. Silakan coba lagi.',
+                        );
+                        setQuestion(content);
+                    }
                 }
             })();
         },
@@ -971,33 +1057,13 @@ export default function MahasiswaChat({
             clearStreamingTyping,
             isDirectChatMode,
             isStreamChatMode,
-            reloadChatHistory,
             replaceStreamingAssistantMessage,
+            setStreamingAssistantContent,
             sessionId,
             waitForStreamingTyping,
         ],
     );
 
-    useEffect(() => {
-        const pendingInitialChat = pendingInitialChatRef.current;
-
-        if (!pendingInitialChat || hasStartedPendingInitialChatRef.current) {
-            return;
-        }
-
-        hasStartedPendingInitialChatRef.current = true;
-        const pendingMessage = pendingUserMessageRef.current;
-        const timeoutId = window.setTimeout(() => {
-            sendMessage(
-                pendingInitialChat.content,
-                pendingInitialChat.courseId,
-                pendingMessage,
-            );
-        }, 0);
-
-        return () => window.clearTimeout(timeoutId);
-    }, [sendMessage]);
-
     const handleDeleteSession = (
         targetSessionId: string,
     ): Promise<DeleteSessionResult> => {

tests/Feature/MahasiswaDashboardTest.php

@@ -101,7 +101,9 @@ function studentAuthUserCookie(): string
             'title' => 'Apa itu stack?',
         ])
         ->assertRedirect(route('mahasiswa.show', ['sessionId' => 'session-1']))
-        ->assertSessionHas('sevima_raghub_pending_initial_chat.session-1')
+        ->assertSessionHas('sevima_raghub_pending_initial_chat.session-1', fn (array $pendingChat): bool => $pendingChat['content'] === 'Apa itu stack?'
+            && $pendingChat['courseId'] === '101'
+            && $pendingChat['session']['uuid_id'] === 'session-1')
         ->assertSessionHasNoErrors();
 
     Http::assertSent(fn (HttpRequest $request): bool => $request->method() === 'POST'
@@ -111,6 +113,67 @@ function studentAuthUserCookie(): string
         && $request['title'] === 'Apa itu stack?');
 });
 
+test('mahasiswa new chat detail page renders pending chat without fetching empty history', function () {
+    config([
+        'services.rag.base_url' => 'https://rag.test/api/v1',
+        'services.rag.chat_mode' => 'stream',
+    ]);
+
+    Http::fake([
+        'https://rag.test/api/v1/courses*' => Http::response([
+            'data' => [
+                [
+                    'id' => '101',
+                    'title' => 'Struktur Data',
+                ],
+            ],
+            'limit' => 100,
+            'page' => 1,
+            'total' => 1,
+        ]),
+        'https://rag.test/api/v1/chats/sessions*' => Http::response([
+            'data' => [],
+            'pagination' => [
+                'limit' => 20,
+                'page' => 1,
+                'total' => 0,
+                'total_pages' => 0,
+            ],
+        ]),
+    ]);
+
+    $this->withCookie('sevima_raghub_auth_token', 'token')
+        ->withCookie('sevima_raghub_auth_user', studentAuthUserCookie())
+        ->withSession([
+            'sevima_raghub_pending_initial_chat.session-1' => [
+                'content' => 'Apa itu stack?',
+                'courseId' => '101',
+                'session' => [
+                    'course_id' => '101',
+                    'created_at' => '2026-05-01T10:00:00Z',
+                    'message_count' => 0,
+                    'title' => 'Apa itu stack?',
+                    'updated_at' => '2026-05-01T10:00:00Z',
+                    'user_id' => 'student-1',
+                    'uuid_id' => 'session-1',
+                ],
+            ],
+        ])
+        ->get(route('mahasiswa.show', ['sessionId' => 'session-1']))
+        ->assertOk()
+        ->assertInertia(fn (Assert $page) => $page
+            ->component('mahasiswa-chat')
+            ->where('sessionId', 'session-1')
+            ->where('currentSession.uuid_id', 'session-1')
+            ->where('messages', [])
+            ->where('pendingInitialChat.content', 'Apa itu stack?')
+            ->where('pendingInitialChat.courseId', '101')
+            ->where('selectedCourseId', '101'));
+
+    Http::assertNotSent(fn (HttpRequest $request): bool => $request->url() === 'https://rag.test/api/v1/chats/sessions/session-1'
+        || $request->url() === 'https://rag.test/api/v1/chats/sessions/session-1/messages');
+});
+
 test('mahasiswa chat detail page can be rendered with direct session messages', function () {
     config([
         'services.rag.base_url' => 'https://rag.test/api/v1',
@@ -248,6 +311,73 @@ function studentAuthUserCookie(): string
         && $request['content'] === 'Apa itu stack?');
 });
 
+test('mahasiswa stream mode json chat message uses rest endpoint', function () {
+    config([
+        'services.rag.base_url' => 'https://rag.test/api/v1',
+        'services.rag.chat_mode' => 'stream',
+    ]);
+
+    Http::fake([
+        'https://rag.test/api/v1/chats/sessions/session-1/messages' => Http::response([
+            'content' => 'Stack adalah struktur data LIFO.',
+            'created_at' => '2026-05-01T10:01:00Z',
+            'role' => 'assistant',
+            'sources' => [],
+            'uuid_id' => 'message-1',
+        ]),
+    ]);
+
+    $this->withCookie('sevima_raghub_auth_token', 'token')
+        ->withCookie('sevima_raghub_auth_user', studentAuthUserCookie())
+        ->withHeaders(['Accept' => 'application/json'])
+        ->postJson(route('mahasiswa.messages.store', ['sessionId' => 'session-1']), [
+            'content' => 'Apa itu stack?',
+            'course_id' => '101',
+        ])
+        ->assertSuccessful()
+        ->assertJsonPath('assistantMessage.content', 'Stack adalah struktur data LIFO.');
+
+    Http::assertSent(fn (HttpRequest $request): bool => $request->method() === 'POST'
+        && $request->url() === 'https://rag.test/api/v1/chats/sessions/session-1/messages'
+        && $request->hasHeader('Authorization', 'Bearer token')
+        && $request['content'] === 'Apa itu stack?');
+});
+
+test('mahasiswa stream chat message forwards backend server sent events', function () {
+    config([
+        'services.rag.base_url' => 'https://rag.test/api/v1',
+        'services.rag.chat_mode' => 'stream',
+    ]);
+
+    $streamBody = "data: {\"content\":\"Stack adalah struktur data LIFO.\"}\n\n";
+
+    Http::fake([
+        'https://rag.test/api/v1/chats/sessions/session-1/stream' => Http::response(
+            $streamBody,
+            200,
+            ['Content-Type' => 'text/event-stream'],
+        ),
+    ]);
+
+    $this->withCookie('sevima_raghub_auth_token', 'token')
+        ->withCookie('sevima_raghub_auth_user', studentAuthUserCookie())
+        ->withHeaders(['Accept' => 'text/event-stream'])
+        ->post(route('mahasiswa.messages.store', ['sessionId' => 'session-1']), [
+            'content' => 'Apa itu stack?',
+            'course_id' => '101',
+        ])
+        ->assertSuccessful()
+        ->assertStreamed()
+        ->assertHeader('Content-Type', 'text/event-stream; charset=utf-8')
+        ->assertStreamedContent($streamBody);
+
+    Http::assertSent(fn (HttpRequest $request): bool => $request->method() === 'POST'
+        && $request->url() === 'https://rag.test/api/v1/chats/sessions/session-1/stream'
+        && $request->hasHeader('Authorization', 'Bearer token')
+        && $request->hasHeader('Accept', 'text/event-stream')
+        && $request['content'] === 'Apa itu stack?');
+});
+
 test('mahasiswa chat message uses backend error message', function () {
     config([
         'services.rag.base_url' => 'https://rag.test/api/v1',