fix: temporary last chunk fix

Author: astandrik

src/components/QueryResultTable/QueryResultTable.tsx

@@ -3,6 +3,7 @@ import React from 'react';
 import DataTable from '@gravity-ui/react-data-table';
 import type {Column, Settings} from '@gravity-ui/react-data-table';
 
+import {INDEX_COLUMN} from '../../store/reducers/query/query';
 import type {ColumnType, KeyValueRow} from '../../types/api/query';
 import {cn} from '../../utils/cn';
 import {DEFAULT_TABLE_SETTINGS} from '../../utils/constants';
@@ -21,7 +22,6 @@ const TABLE_SETTINGS: Settings = {
     ...DEFAULT_TABLE_SETTINGS,
     stripedRows: true,
     sortable: false,
-    displayIndices: true,
 };
 
 export const b = cn('ydb-query-result-table');
@@ -99,11 +99,16 @@ export const QueryResultTable = (props: QueryResultTableProps) => {
         return <div className={b('message')}>{i18n('empty')}</div>;
     }
 
+    const settings = {
+        ...TABLE_SETTINGS,
+        displayIndices: columns.filter(({name}) => INDEX_COLUMN.name === name).length === 0,
+    };
+
     return (
         <ResizeableDataTable
             data={data}
             columns={columns}
-            settings={TABLE_SETTINGS}
+            settings={settings}
             // prevent accessing row.id in case it is present but is not the PK (i.e. may repeat)
             rowKey={getRowIndex}
             visibleRowIndex={getVisibleRowIndex}

src/components/ResizeableDataTable/ResizeableDataTable.tsx

@@ -1,7 +1,6 @@
 import type {DataTableProps, Settings} from '@gravity-ui/react-data-table';
 import DataTable, {updateColumnsWidth} from '@gravity-ui/react-data-table';
 
-import {INDEX_COLUMN} from '../../store/reducers/query/query';
 import {cn} from '../../utils/cn';
 import {useTableResize} from '../../utils/hooks/useTableResize';
 
@@ -28,7 +27,6 @@ export function ResizeableDataTable<T>({
     const newSettings: Settings = {
         ...settings,
         defaultResizeable: true,
-        displayIndices: columns.filter(({name}) => INDEX_COLUMN.name === name).length === 0,
     };
 
     return (

src/services/parsers/parseMultipart.ts

@@ -8,6 +8,9 @@ interface MultipartResult {
 const CRLF = '\r\n';
 const HEADER_VALUE_DELIMITER = ': ';
 
+// temporary spike for backend problems
+const BACKEND_LAST_CHUNK_BOUNDARY = '--boundary--';
+
 function getContentHeadersData(data: string, startPos: number): [number, number] {
     let contentLength = 0;
     let pos = startPos;
@@ -80,25 +83,27 @@ export function parseMultipart({
         }
 
         // Check if we have enough data for the content
-        const contentEnd = contentStart + contentLength;
+        let contentEnd = contentStart + contentLength;
         if (contentEnd > data.length) {
-            // Content is incomplete
-            pos = lastProcessedLength;
-            break;
+            // last chunk has error with --boundary-- in content length
+            // eslint-disable-next-line no-negated-condition
+            if (data.indexOf(BACKEND_LAST_CHUNK_BOUNDARY, contentStart) !== -1) {
+                contentEnd = data.indexOf(BACKEND_LAST_CHUNK_BOUNDARY, contentStart) - 2;
+            } else {
+                // Content is incomplete
+                pos = lastProcessedLength;
+                break;
+            }
         }
 
         // Extract content
-        let content = data.slice(contentStart, contentEnd);
+        const 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
         }