chore: test for entities

Author: astandrik

src/containers/Nodes/getNodes.ts

@@ -1,3 +1,5 @@
+// TEST FOR MANY ENTITIES
+
 import type {FetchData} from '../../components/PaginatedTable';
 import type {NodesFilters, NodesPreparedEntity} from '../../store/reducers/nodes/types';
 import {prepareNodesData} from '../../store/reducers/nodes/utils';
@@ -41,9 +43,9 @@ export const getNodes: FetchData<
             storage,
             tablets,
             limit,
-            offset,
-            sort,
+            offset: 0,
             path,
+            sort,
             database,
             filter: searchValue,
             problems_only: getProblemParamValue(problemFilter),
@@ -53,9 +55,22 @@ export const getNodes: FetchData<
     );
     const preparedResponse = prepareNodesData(response);
 
+    let mockedData = preparedResponse.Nodes?.slice();
+
+    for (let i = 0; i < 1000; i++) {
+        mockedData = mockedData?.concat(
+            preparedResponse.Nodes?.map((data, j) => ({
+                ...data,
+                NodeId: data.NodeId + i + j,
+                Host: data.Host || String(i) + j,
+            })) || [],
+        );
+    }
+    const paginatedData = mockedData?.slice(offset, offset + limit);
+
     return {
-        data: preparedResponse.Nodes || [],
-        found: preparedResponse.FoundNodes || 0,
-        total: preparedResponse.TotalNodes || 0,
+        data: paginatedData || [],
+        found: mockedData?.length || 0,
+        total: mockedData?.length || 0,
     };
 };

src/containers/Storage/StorageNodes/getNodes.ts

@@ -1,3 +1,5 @@
+// TEST FOR MANY ENTITIES
+
 import type {FetchData} from '../../../components/PaginatedTable';
 import type {
     PreparedStorageNode,
@@ -8,6 +10,10 @@ import type {NodesRequestParams} from '../../../types/api/nodes';
 import {prepareSortValue} from '../../../utils/filters';
 import {getUptimeParamValue, isSortableNodesProperty} from '../../../utils/nodes';
 
+const getConcurrentId = (limit?: number, offset?: number) => {
+    return `getStorageNodes|offset${offset}|limit${limit}`;
+};
+
 export const getStorageNodes: FetchData<
     PreparedStorageNode,
     PreparedStorageNodeFilters,
@@ -30,25 +36,42 @@ export const getStorageNodes: FetchData<
         ? prepareSortValue(columnId, sortOrder)
         : undefined;
 
-    const response = await window.api.getNodes({
-        type,
-        storage,
-        limit,
-        offset,
-        sort,
-        filter: searchValue,
-        uptime: getUptimeParamValue(nodesUptimeFilter),
-        with: visibleEntities,
-        database,
-        node_id: nodeId,
-        group_id: groupId,
-        filter_group: filterGroup,
-        filter_group_by: filterGroupBy,
-    });
+    const response = await window.api.getNodes(
+        {
+            type,
+            storage,
+            limit,
+            offset: 0,
+            sort,
+            filter: searchValue,
+            uptime: getUptimeParamValue(nodesUptimeFilter),
+            with: visibleEntities,
+            database,
+            node_id: nodeId,
+            group_id: groupId,
+            filter_group: filterGroup,
+            filter_group_by: filterGroupBy,
+        },
+        {concurrentId: getConcurrentId(limit, offset), signal: params.signal},
+    );
     const preparedResponse = prepareStorageNodesResponse(response);
+
+    let mockedData = preparedResponse.nodes?.slice();
+
+    for (let i = 0; i < 1000; i++) {
+        mockedData = mockedData?.concat(
+            preparedResponse.nodes?.map((data, j) => ({
+                ...data,
+                NodeId: data.NodeId + i + j,
+                Host: data.Host || String(i) + j,
+            })) || [],
+        );
+    }
+    const paginatedData = mockedData?.slice(offset, offset + limit);
+
     return {
-        data: preparedResponse.nodes || [],
-        found: preparedResponse.found || 0,
-        total: preparedResponse.total || 0,
+        data: paginatedData || [],
+        found: mockedData?.length || 0,
+        total: mockedData?.length || 0,
     };
 };