Merge pull request #91 from nevermined-io/fix/missed-logs

fix: missed logs

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@nevermined-io/payments",
-  "version": "0.7.4",
+  "version": "0.7.5",
   "description": "Typescript SDK to interact with the Nevermined Payments Protocol",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",

src/api/nvm-backend.ts

@@ -2,9 +2,9 @@ import axios from 'axios'
 import { decodeJwt } from 'jose'
 import { io } from 'socket.io-client'
 import { sleep } from '../common/helper'
-import { AgentExecutionStatus, TaskLogMessage, TaskCallback } from '../common/types'
-import { isEthereumAddress } from '../utils'
 import { PaymentsError } from '../common/payments.error'
+import { AgentExecutionStatus, TaskCallback, TaskLogMessage } from '../common/types'
+import { isEthereumAddress } from '../utils'
 
 export interface BackendApiOptions {
   /**
@@ -214,7 +214,9 @@ export class NVMBackendApi {
       })
 
       await this.socketClient.emit('_join-tasks', JSON.stringify({ tasks, history }))
-      await this.socketClient.on('task-log', this.handleTaskLog.bind(this, tasks))
+      this.socketClient.on('_join-tasks_', async () => {
+        this.socketClient.on('task-log', this.handleTaskLog.bind(this, tasks))
+      })
     } catch (error) {
       throw new PaymentsError(
         `Unable to initialize websocket client: ${this.opts.webSocketHost} - ${(error as Error).message}`,