fix: better parseMultipart

Author: astandrik

src/services/parsers/parseMultipart.ts

@@ -1,4 +1,3 @@
-/* eslint-disable camelcase */
 import type {StreamingChunk} from '../../types/store/streaming';
 
 interface MultipartResult {
@@ -9,25 +8,20 @@ interface MultipartResult {
 const CRLF = '\r\n';
 const HEADER_VALUE_DELIMITER = ': ';
 
-interface ParsedHeaders {
-    contentType?: string;
-    contentLength?: number;
-}
-
-function parseHeaders(data: string, startPos: number): [ParsedHeaders, number] {
-    const headers: ParsedHeaders = {};
+function getContentHeadersData(data: string, startPos: number): [number, number] {
+    let contentLength = 0;
     let pos = startPos;
 
     while (pos < data.length) {
         // Check for end of headers
         if (data.startsWith(CRLF, pos)) {
-            return [headers, pos + CRLF.length];
+            return [contentLength, pos + CRLF.length];
         }
 
         const nextCRLF = data.indexOf(CRLF, pos);
         if (nextCRLF === -1) {
             // Headers are incomplete
-            return [headers, startPos];
+            return [contentLength, startPos];
         }
 
         const line = data.slice(pos, nextCRLF);
@@ -37,12 +31,10 @@ function parseHeaders(data: string, startPos: number): [ParsedHeaders, number] {
             const header = line.slice(0, colonIndex).toLowerCase();
             const value = line.slice(colonIndex + HEADER_VALUE_DELIMITER.length, nextCRLF);
 
-            if (header.toLowerCase() === 'content-type') {
-                headers.contentType = value;
-            } else if (header.toLowerCase() === 'content-length') {
+            if (header.toLowerCase() === 'content-length') {
                 const length = parseInt(value, 10);
                 if (!isNaN(length)) {
-                    headers.contentLength = length;
+                    contentLength = length;
                 }
             }
         }
@@ -51,7 +43,7 @@ function parseHeaders(data: string, startPos: number): [ParsedHeaders, number] {
     }
 
     // Headers are incomplete
-    return [headers, startPos];
+    return [contentLength, startPos];
 }
 
 export function parseMultipart({
@@ -79,15 +71,15 @@ export function parseMultipart({
         pos = boundaryPos + boundaryStr.length;
 
         // Parse headers
-        const [headers, contentStart] = parseHeaders(data, pos);
-        if (contentStart === pos || !headers.contentLength) {
+        const [contentLength, contentStart] = getContentHeadersData(data, pos);
+        if (contentStart === pos || !contentLength) {
             // Headers were incomplete or invalid
             pos = lastProcessedLength;
             break;
         }
 
         // Check if we have enough data for the content
-        const contentEnd = contentStart + headers.contentLength;
+        const contentEnd = contentStart + contentLength;
         if (contentEnd > data.length) {
             // Content is incomplete
             pos = lastProcessedLength;
@@ -99,10 +91,8 @@ export function parseMultipart({
 
         // Try to parse JSON content
         try {
-            if (headers.contentType === 'application/json') {
-                const parsedChunk = JSON.parse(content) as StreamingChunk;
-                chunks.push(parsedChunk);
-            }
+            const parsedChunk = JSON.parse(content) as StreamingChunk;
+            chunks.push(parsedChunk);
         } catch {
             // Invalid JSON, skip this chunk
         }