fix: backend error

Author: astandrik

src/services/parsers/parseMultipart.ts

@@ -58,6 +58,7 @@ export function parseMultipart({
     const data = responseText;
     const boundaryStr = `--${boundary}${CRLF}`;
     let pos = lastProcessedLength;
+    let lastProcessedPos = pos;
     const chunks: StreamingChunk[] = [];
 
     while (pos < data.length) {
@@ -87,22 +88,27 @@ export function parseMultipart({
         }
 
         // Extract content
-        const content = data.slice(contentStart, contentEnd);
+        let content = data.slice(contentStart, contentEnd);
 
         // Try to parse JSON content
         try {
             const parsedChunk = JSON.parse(content) as StreamingChunk;
             chunks.push(parsedChunk);
         } catch {
+            // try parse last chunk (has error with --boundary-- in content length)
+            content = data.slice(contentStart, contentEnd - '--boundary--'.length);
+            const parsedChunk = JSON.parse(content) as StreamingChunk;
+            chunks.push(parsedChunk);
             // Invalid JSON, skip this chunk
         }
 
         // Move position to end of content
         pos = contentEnd;
+        lastProcessedPos = pos;
     }
 
     return {
         chunks,
-        lastProcessedLength: pos,
+        lastProcessedLength: lastProcessedPos,
     };
 }

src/store/reducers/query/query.ts

@@ -259,7 +259,7 @@ interface QueryStats {
     endTime?: string | number;
 }
 
-const DEFAULT_STREAM_CHUNK_SIZE = 100;
+const DEFAULT_STREAM_CHUNK_SIZE = 2;
 const DEFAULT_CONCURRENT_RESULTS = false;
 
 export const queryApi = api.injectEndpoints({