callback.onPhaseStart(ChatPhaseCallback.PHASE_INTENT, "Analyzing...");
        assertEquals(1, events.size());
        assertEquals("start:intent:Analyzing...", events.get(0));

        // Test onPhaseComplete
        callback.onPhaseComplete(ChatPhaseCallback.PHASE_INTENT);
        assertEquals(2, events.size());
        assertEquals("complete:intent", events.get(1));

        // Test onChunk
        callback.onChunk("test content", false);

        onPhaseStart(phase, message);
    }

    /**
     * Called when a processing phase completes.
     *
     * @param phase the phase name that completed
     */
    void onPhaseComplete(String phase);

    /**
     * Called when a chunk of the response is available during streaming.
     *
     * @param content the content chunk
     * @param done true if this is the final chunk
     */

                        }
                    }
                }

                @Override
                public void onPhaseComplete(final String phase) {
                    try {
                        sendSseEvent(writer, "phase", Map.of("phase", phase, "status", "complete"));
                        if (logger.isDebugEnabled()) {

            callback.onPhaseStart(ChatPhaseCallback.PHASE_INTENT, "Analyzing your question...");
            final IntentDetectionResult intentResult = llmClientManager.detectIntent(userMessage, history);
            callback.onPhaseComplete(ChatPhaseCallback.PHASE_INTENT);

            if (logger.isDebugEnabled()) {
                logger.debug("[RAG] Phase {} completed. intent={}, query={}, reasoning={}, phaseElapsedTime={}ms",