From: Jérôme Benoit <jerome.benoit@sap.com>
Date: Wed, 16 Aug 2023 23:03:49 +0000 (+0200)
Subject: fix: fix task function names property in worker-node
X-Git-Tag: v2.6.29~29
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=71b2b6d8c0678320a3b6390c058f0d7338b10918;p=poolifier.git

fix: fix task function names property in worker-node

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
---

diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts
index 923fe9b2..4349ed72 100644
--- a/src/pools/worker-node.ts
+++ b/src/pools/worker-node.ts
@@ -23,7 +23,6 @@ implements IWorkerNode<Worker, Data> {
   public readonly worker: Worker
   public readonly info: WorkerInfo
   public usage: WorkerUsage
-  public taskFunctions!: string[]
   private readonly tasksUsage: Map<string, WorkerUsage>
   private readonly tasksQueue: Queue<Task<Data>>
 
@@ -89,12 +88,17 @@ implements IWorkerNode<Worker, Data> {
 
   /** @inheritdoc */
   public getTaskWorkerUsage (name: string): WorkerUsage | undefined {
+    if (name === DEFAULT_TASK_NAME && !Array.isArray(this.info.taskFunctions)) {
+      throw new Error(
+        'Cannot get task worker usage for default task function name when task function names list is not yet defined'
+      )
+    }
     if (
       name === DEFAULT_TASK_NAME &&
-      Array.isArray(this.taskFunctions) &&
-      this.taskFunctions.length > 1
+      Array.isArray(this.info.taskFunctions) &&
+      this.info.taskFunctions.length > 1
     ) {
-      name = this.taskFunctions[1]
+      name = this.info.taskFunctions[1]
     }
     if (!this.tasksUsage.has(name)) {
       this.tasksUsage.set(name, this.initTaskWorkerUsage(name))