fetchnodelogs p2p method

Author: giurgiur99

src/@types/Provider.ts

@@ -127,3 +127,21 @@ export const PROTOCOL_COMMANDS = {
   GET_LOGS: 'getLogs',
   JOBS: 'jobs'
 }
+
+export interface NodeLogsParams {
+  logId?: string
+  startTime?: string
+  endTime?: string
+  maxLogs?: number
+  moduleName?: string
+  level?: string
+  page?: number
+}
+
+export interface NodeLogEntry {
+  timestamp: string
+  level: string
+  moduleName: string
+  message: string
+  meta?: Record<string, any>
+}

src/services/providers/BaseProvider.ts

@@ -21,7 +21,9 @@ import {
   dockerRegistryAuth,
   DownloadResponse,
   NodeStatus,
-  NodeComputeJob
+  NodeComputeJob,
+  NodeLogsParams,
+  NodeLogEntry
 } from '../../@types/index.js'
 import { type DDO, type ValidateMetadata } from '@oceanprotocol/ddo-js'
 import { decodeJwt } from '../../utils/Jwt.js'
@@ -439,7 +441,7 @@ export class BaseProvider {
     level?: string,
     page?: number,
     signal?: AbortSignal
-  ): Promise<any> {
+  ): Promise<NodeLogEntry[]> {
     return this.getImpl(nodeUri).downloadNodeLogs(
       nodeUri,
       signer,
@@ -486,6 +488,20 @@ export class BaseProvider {
     return this.p2pProvider.getMultiaddrFromPeerId(peerId)
   }
 
+  /**
+   * Fetch node logs via P2P with a pre-signed payload.
+   * For auto-signed log fetching (HTTP or P2P), use downloadNodeLogs().
+   */
+  public async fetchNodeLogs(
+    nodeUri: string | Multiaddr[],
+    address: string,
+    signature: string,
+    nonce: string,
+    logParams?: NodeLogsParams
+  ): Promise<NodeLogEntry[]> {
+    return this.p2pProvider.fetchNodeLogs(nodeUri, address, signature, nonce, logParams)
+  }
+
   public async fetchConfig(
     nodeUri: string | Multiaddr[],
     payload: Record<string, any>

src/services/providers/HttpProvider.ts

@@ -20,7 +20,8 @@ import {
   dockerRegistryAuth,
   ComputeResultStream,
   NodeStatus,
-  NodeComputeJob
+  NodeComputeJob,
+  NodeLogEntry
 } from '../../@types/index.js'
 import { PROTOCOL_COMMANDS } from '../../@types/Provider.js'
 import { type DDO, type ValidateMetadata } from '@oceanprotocol/ddo-js'
@@ -1439,7 +1440,7 @@ export class HttpProvider {
     level?: string,
     page?: number,
     signal?: AbortSignal
-  ): Promise<any> {
+  ): Promise<NodeLogEntry[]> {
     const providerEndpoints = await this.getEndpoints(nodeUri)
     const serviceEndpoints = await this.getServiceEndpoints(nodeUri, providerEndpoints)
 

src/services/providers/P2pProvider.ts

@@ -36,7 +36,7 @@ import {
   NodeStatus,
   NodeComputeJob
 } from '../../@types/index.js'
-import { PROTOCOL_COMMANDS } from '../../@types/Provider.js'
+import { PROTOCOL_COMMANDS, NodeLogsParams, NodeLogEntry } from '../../@types/Provider.js'
 import { type DDO, type ValidateMetadata } from '@oceanprotocol/ddo-js'
 import { signRequest } from '../../utils/SignatureUtils.js'
 import { getConsumerAddress, getSignature, getAuthorization } from './BaseProvider.js'
@@ -1404,7 +1404,7 @@ export class P2pProvider {
     level?: string,
     page?: number,
     signal?: AbortSignal
-  ): Promise<any> {
+  ): Promise<NodeLogEntry[]> {
     const consumerAddress = await signer.getAddress()
     const nonce = ((await this.getNonce(nodeUri, consumerAddress, signal)) + 1).toString()
     const signature = await this.getSignature(signer, nonce, PROTOCOL_COMMANDS.GET_LOGS)
@@ -1424,6 +1424,25 @@ export class P2pProvider {
     return this.sendP2pCommand(nodeUri, PROTOCOL_COMMANDS.GET_LOGS, body, signer, signal)
   }
 
+  /**
+   * Fetch node logs via P2P with a pre-signed payload.
+   * P2P only — use downloadNodeLogs() for the auto-signed variant.
+   */
+  public async fetchNodeLogs(
+    nodeUri: string | Multiaddr[],
+    address: string,
+    signature: string,
+    nonce: string,
+    logParams?: NodeLogsParams
+  ): Promise<NodeLogEntry[]> {
+    return this.sendP2pCommand(nodeUri, PROTOCOL_COMMANDS.GET_LOGS, {
+      address,
+      signature,
+      nonce,
+      ...logParams
+    })
+  }
+
   /**
    * Fetch node configuration via P2P. Accepts a pre-signed payload —
    * the caller is responsible for nonce retrieval and signing.