Function processStreamingResult

src/views/SimpleChartRecBox.tsx:639–1012

(result: any)

        let pendingThought: string = '';

        const processStreamingResult = (result: any) => {
            // ── context_info: show injected rules/knowledge at the top ──
            // Rendered as already-completed tool-style steps (✓ prefix) so they
            // visually match the rest of the agent's tool-call timeline.
            if (result.type === "context_info") {
                const rules: string[] = result.rules_injected || [];
                const knowledge: Array<{category: string; title: string}> = result.knowledge_injected || [];
                let added = false;
                if (rules.length > 0) {
                    thinkingSteps.push('✓ ' + t('dataThread.rulesLoaded', { rules: rules.join(', ') }));
                    added = true;
                }
                if (knowledge.length > 0) {
                    const titles = knowledge.map(k => k.title).join(', ');
                    thinkingSteps.push('✓ ' + t('dataThread.knowledgeLoaded', { knowledge: titles }));
                    added = true;
                }
                if (added && currentDraftId) {
                    dispatch(dfActions.updateDraftRunningPlan({ draftId: currentDraftId, plan: thinkingSteps.join(STEP_SEP) }));
                }
            }

            // ── thinking_text: LLM reasoning alongside tool calls ──
            // Accumulate into pendingThought; don't create a visible step
            if (result.type === "thinking_text") {
                pendingThought += (pendingThought ? '\n' : '') + result.content;
                // Only show as a step if there are no tool/action steps yet (initial thinking)
                if (thinkingSteps.length === 0) {
                    // Show a temporary "thinking..." indicator
                    if (currentDraftId) {
                        dispatch(dfActions.updateDraftRunningPlan({ draftId: currentDraftId, plan: t('dataThread.thinking') }));
                    }
                }
            }

            // ── tool_start: agent is calling a tool (explore/inspect) ──
            if (result.type === "tool_start") {
                // Show pending thought as a visible step before the tool step
                if (pendingThought) {
                    thinkingSteps.push(pendingThought);
                    pendingThought = '';
                }
                if (result.tool === "explore") {
                    const purpose = result.purpose || '';
                    if (purpose) {
                        thinkingSteps.push(t('dataThread.runningCode') + ' ' + purpose);
                    } else {
                        const codePreview = result.code || '';
                        const meaningfulLine = codePreview.split('\n').find((l: string) => l.trim() && !l.trim().startsWith('import ') && !l.trim().startsWith('from ')) || codePreview.split('\n')[0] || '';
                        thinkingSteps.push(t('dataThread.runningCode') + (meaningfulLine ? `: ${meaningfulLine.trim()}` : ''));
                    }
                } else if (result.tool === "inspect_source_data") {
                    const tableNames = result.table_names?.join(', ') || '';
                    thinkingSteps.push(t('dataThread.inspectingData') + (tableNames ? ` ${tableNames}` : ''));
                } else if (result.tool === "search_data_tables" || result.tool === "search_knowledge") {
                    const query = result.query || '';
                    thinkingSteps.push(t('dataThread.searching') + (query ? ` "${query}"` : ''));
                } else if (["visualize", "clarify", "present", "action"].includes(result.tool)) {