use direct command for status

Author: giurgiur99

src/@types/Provider.ts

@@ -43,14 +43,46 @@ export interface ServiceEndpoint {
   urlPath: string
 }
 
+export interface NodeStatusProvider {
+  chainId: string
+  network: string
+}
+
+export interface NodeStatusIndexer {
+  chainId: string
+  network: string
+  block: string
+}
+
 export interface NodeStatus {
-  nodeId: string
-  chainIds: string[]
-  providerAddress: string
-  nodePublicKey: Record<string, number>
-  serviceEndpoints: Record<string, [string, string]>
-  software: string
+  id: string
+  publicKey: string
+  friendlyName: string
+  address: string
   version: string
+  http: boolean
+  p2p: boolean
+  provider: NodeStatusProvider[]
+  indexer: NodeStatusIndexer[]
+  escrowAddress: Record<string, string>
+  supportedStorage: Record<string, boolean>
+  platform: {
+    cpus: number
+    freemem: number
+    totalmem: number
+    loadavg: number[]
+    arch: string
+    machine: string
+    platform: string
+    osType: string
+    node: string
+  }
+  codeHash: string
+  allowedAdmins: {
+    addresses: string[]
+    accessLists: string[] | null
+  }
+  uptime: number
 }
 export interface UserCustomParameters {
   [key: string]: any

src/services/providers/HttpProvider.ts

@@ -57,7 +57,23 @@ export class HttpProvider {
   }
 
   public async getNodeStatus(nodeUri: string, signal?: AbortSignal): Promise<NodeStatus> {
-    return this.getEndpoints(nodeUri)
+    const providerEndpoints = await this.getEndpoints(nodeUri)
+    const serviceEndpoints = await this.getServiceEndpoints(nodeUri, providerEndpoints)
+    const endpoint = this.getEndpointURL(serviceEndpoints, 'directCommand')
+    if (!endpoint?.urlPath) return null
+    try {
+      const response = await fetch(endpoint.urlPath, {
+        method: 'POST',
+        headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({ command: PROTOCOL_COMMANDS.STATUS }),
+        signal
+      })
+      if (response?.ok) return response.json()
+      return null
+    } catch (e) {
+      LoggerInstance.error('getNodeStatus failed:', e)
+      return null
+    }
   }
 
   public async getNodeJobs(

test/integration/Provider.test.ts

@@ -58,9 +58,10 @@ describe('Provider tests', async () => {
   it('Alice tests getNodeStatus', async () => {
     const status = await ProviderInstance.getNodeStatus(config.oceanNodeUri)
     assert(status, 'No status returned')
-    assert(status.providerAddress, 'Status missing provider address')
-    assert(status.nodeId, 'Status missing nodeId')
-    assert(Array.isArray(status.chainIds), 'Status missing chainIds')
+    assert(status.id, 'Status missing id')
+    assert(status.address, 'Status missing address')
+    assert(status.version, 'Status missing version')
+    assert(Array.isArray(status.provider), 'Status missing provider array')
   })
 
   it('Alice tests getNodeJobs', async () => {