Add fields_required=-1 parameter to sysinfo API call for thread data

Co-authored-by: adameat <[email protected]>

Author: Copilot

src/services/api/viewer.ts

@@ -66,6 +66,7 @@ export class ViewerAPI extends BaseYdbAPI {
             this.getPath('/viewer/json/sysinfo?enums=true'),
             {
                 node_id: id,
+                fields_required: -1,
             },
             {concurrentId, requestConfig: {signal}, timeout},
         );
@@ -600,17 +601,4 @@ export class ViewerAPI extends BaseYdbAPI {
             {concurrentId, requestConfig: {signal}},
         );
     }
-
-    getNodeThreads(nodeId: string | number, {concurrentId, signal}: AxiosOptions = {}) {
-        // TODO: This endpoint needs to be implemented in the YDB backend
-        // For now, we'll use the existing sysinfo endpoint and extract thread data
-        // In the future, this should be a dedicated /viewer/json/threads endpoint
-        return this.get<TEvSystemStateResponse>(
-            this.getPath('/viewer/json/sysinfo?enums=true'),
-            {
-                node_id: nodeId,
-            },
-            {concurrentId: concurrentId || `getNodeThreads|${nodeId}`, requestConfig: {signal}},
-        );
-    }
 }

src/store/reducers/node/node.ts

@@ -30,9 +30,22 @@ export const nodeApi = api.injectEndpoints({
         getNodeThreads: build.query({
             queryFn: async ({nodeId}: {nodeId: string}, {signal}) => {
                 try {
-                    const data = await window.api.viewer.getNodeThreads(nodeId, {signal});
-                    // TODO: Transform the data to extract detailed thread information
-                    // For now, return mock data matching the issue requirements
+                    const data = await window.api.viewer.getNodeInfo(nodeId, {signal});
+
+                    // Extract thread information from the response
+                    // If the backend provides Threads field with detailed info, use it
+                    // Otherwise, fall back to mock data for development
+                    if (data.Threads && data.Threads.length > 0) {
+                        return {
+                            data: {
+                                Threads: data.Threads,
+                                ResponseTime: data.ResponseTime,
+                                ResponseDuration: data.ResponseDuration,
+                            },
+                        };
+                    }
+
+                    // Fallback to mock data for development until backend is fully implemented
                     const mockThreadData = {
                         Threads: [
                             {

src/types/api/systemState.ts

@@ -1,4 +1,5 @@
 import type {TSystemStateInfo} from './nodes';
+import type {TThreadPoolInfo} from './threads';
 
 /**
  * endpoint: /viewer/json/sysinfo
@@ -7,6 +8,8 @@ import type {TSystemStateInfo} from './nodes';
  */
 export interface TEvSystemStateResponse {
     SystemStateInfo?: TSystemStateInfo[];
+    /** Detailed thread information when fields_required=-1 is used */
+    Threads?: TThreadPoolInfo[];
     /** uint64 */
     ResponseTime?: string;
     ResponseDuration?: number;