Rename err to sendErr and add pm2.disconnect after send

src/App/utils/pm2Service.ts

@@ -97,55 +97,80 @@ class Pm2Service {
     id?: number,
     processName = 'ep-api',
   ): Promise<number> {
+    const targetProcessIds: number[] = []
+
     if (String(ignoreId) && ignoreId === 'all') {
-      this.sendToProcess(0, topic, data)
-      return 0
+      targetProcessIds.push(0)
+    } else if (String(ignoreId) && ignoreId === 'one' && id) {
+      targetProcessIds.push(id)
+    } else {
+      for (const [processId, pName] of this.pm2Ids) {
+        if (
+          pName === processName &&
+          ((ignoreId != null && processId !== ignoreId) ||
+            (processId !== 0 && ignoreId == null))
+        ) {
+          targetProcessIds.push(processId)
+        }
+      }
     }
 
-    if (String(ignoreId) && ignoreId === 'one' && id) {
-      this.sendToProcess(id, topic, data)
+    if (targetProcessIds.length === 0) {
       return 0
     }
 
-    for (const [processId, pName] of this.pm2Ids) {
-      if (
-        pName === processName &&
-        ((ignoreId && processId !== ignoreId) || (processId !== 0 && !ignoreId))
-      ) {
-        this.sendToProcess(processId, topic, data)
-      }
-    }
-
+    await this.sendToProcesses(targetProcessIds, topic, data)
     return 0
   }
 
-  private sendToProcess(processId: number, topic: string, data: any): void {
-    pm2.connect((err: unknown) => {
-      if (err) {
-        this.logger.error('Error connecting to PM2:', err)
-        return
-      }
-
-      pm2.sendDataToProcessId(
-        {
-          id: processId,
-          type: 'process:msg',
-          topic,
-          data,
-        },
-        (err: unknown) => {
-          if (err) {
-            this.logger.error(
-              `TOPIC - { ${topic} } | Error sending data to process ${processId}:`,
-              err,
-            )
-          } else {
-            this.logger.log(
-              `TOPIC - { ${topic} } | Data successfully sent to process ${processId}`,
-            )
+  private sendToProcesses(
+    processIds: number[],
+    topic: string,
+    data: any,
+  ): Promise<void> {
+    return new Promise((resolve) => {
+      pm2.connect((err: unknown) => {
+        if (err) {
+          this.logger.error('Error connecting to PM2:', err)
+          resolve()
+          return
+        }
+
+        let completed = 0
+        const total = processIds.length
+
+        const onComplete = () => {
+          completed += 1
+          if (completed === total) {
+            pm2.disconnect()
+            resolve()
           }
-        },
-      )
+        }
+
+        for (const processId of processIds) {
+          pm2.sendDataToProcessId(
+            {
+              id: processId,
+              type: 'process:msg',
+              topic,
+              data,
+            },
+            (sendErr: unknown) => {
+              if (sendErr) {
+                this.logger.error(
+                  `TOPIC - { ${topic} } | Error sending data to process ${processId}:`,
+                  sendErr,
+                )
+              } else {
+                this.logger.log(
+                  `TOPIC - { ${topic} } | Data successfully sent to process ${processId}`,
+                )
+              }
+              onComplete()
+            },
+          )
+        }
+      })
     })
   }