move streaming fix to right level

Author: icecrasher321

apps/sim/app/chat/hooks/use-chat-streaming.ts

@@ -314,22 +314,9 @@ export function useChatStreaming() {
                 let finalContent = accumulatedText
 
                 if (formattedOutputs.length > 0) {
-                  const trimmedStreamingContent = accumulatedText.trim()
-
-                  const uniqueOutputs = formattedOutputs.filter((output) => {
-                    const trimmedOutput = output.trim()
-                    if (!trimmedOutput) return false
-
-                    // Skip outputs that are already in the streamed content to avoid duplication
-                    if (trimmedStreamingContent?.includes(trimmedOutput)) {
-                      return false
-                    }
-
-                    return true
-                  })
-
-                  if (uniqueOutputs.length > 0) {
-                    const combinedOutputs = uniqueOutputs.join('\n\n')
+                  const nonEmptyOutputs = formattedOutputs.filter((output) => output.trim())
+                  if (nonEmptyOutputs.length > 0) {
+                    const combinedOutputs = nonEmptyOutputs.join('\n\n')
                     finalContent = finalContent
                       ? `${finalContent.trim()}\n\n${combinedOutputs}`
                       : combinedOutputs

apps/sim/lib/workflows/streaming/streaming.ts

@@ -203,6 +203,10 @@ export async function createStreamingResponse(
 
           for (const outputId of streamConfig.selectedOutputs) {
             const blockId = extractBlockIdFromOutputId(outputId)
+            if (streamedContent.has(blockId)) {
+              continue
+            }
+
             const path = extractPathFromOutputId(outputId, blockId)
 
             if (result.logs) {