Work on the worker path fix

package.json

@@ -1,7 +1,7 @@
 {
   "name": "denomo-cli",
   "private": false,
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "Denomo is a CLI utility that deletes nested 'node_modules' directories",
   "author": {
     "name": "Peter Dyumin",
@@ -16,7 +16,7 @@
     "lint": "eslint",
     "prepublishOnly": "npm run build",
     "pretest": "npm run build",
-    "test": "mocha \"build/tests/*.spec.js\""
+    "test": "cross-env TESTING=true mocha \"build/tests/*.spec.js\""
   },
   "homepage": "https://github.com/julyskies/denomo-cli",
   "license": "MIT",
@@ -42,6 +42,7 @@
     "@typescript-eslint/eslint-plugin": "^5.9.0",
     "@typescript-eslint/parser": "^5.9.0",
     "chai": "^4.3.4",
+    "cross-env": "^7.0.3",
     "eslint": "^8.6.0",
     "eslint-config-airbnb-base": "^15.0.0",
     "eslint-plugin-import": "^2.25.4",

src/constants.ts

@@ -1,4 +1,5 @@
 export const ERROR_MESSAGES = {
+  couldNotAccessTheModule: 'Could not access the module!',
   couldNotAccessTheProvidedPath: 'Could not access the provided path!',
   pathIsRequired: 'Path is required!',
   pleaseProvideThePath: 'Please provide the path!',

src/main.ts

@@ -1,15 +1,19 @@
-import { ChildProcess, fork } from 'child_process';
+import { ChildProcess, exec, fork } from 'child_process';
 import { cpus } from 'os';
+import { promisify } from 'util';
 import { stat } from 'fs/promises';
 
 import { ERROR_MESSAGES, HANDLER_TYPES } from './constants';
 import logger from './logger';
 import { MessageToParent, NodeError } from './types';
 
+const execPromise = promisify(exec);
+
 const DIRECTORIES: string[] = [];
 const MAX_WORKERS: number = cpus().length;
 
 let START_TIME: number;
+let WORKER_PATH: string;
 let WORKERS: ChildProcess[] = [];
 
 /**
@@ -34,7 +38,7 @@ function handler(type: string, payload: ChildProcess | string[]): never | void {
 
     // eslint-disable-next-line
     for (const path of paths) {
-      const newWorker = fork(`${process.cwd()}/build/worker.js`);
+      const newWorker = fork(WORKER_PATH);
       newWorker.send({ path });
       newWorker.on(
         HANDLER_TYPES.close,
@@ -64,6 +68,18 @@ function handler(type: string, payload: ChildProcess | string[]): never | void {
 export default async function main(): Promise<Error | void> {
   START_TIME = Date.now();
 
+  try {
+    const { stdout = '', stderr = '' } = await execPromise('npm root -g');
+    if (stderr || !stdout) {
+      throw new Error(ERROR_MESSAGES.couldNotAccessTheModule);
+    }
+    WORKER_PATH = process.env.TESTING
+      ? `${process.cwd()}/build/worker.js`
+      : `${stdout.trim()}/denomo-cli/build/worker.js`;
+  } catch {
+    throw new Error(ERROR_MESSAGES.couldNotAccessTheModule);
+  }
+
   const [, , entryPoint = ''] = process.argv;
   if (!entryPoint) {
     throw new Error(ERROR_MESSAGES.pleaseProvideThePath);
@@ -90,7 +106,7 @@ export default async function main(): Promise<Error | void> {
   }
 
   if (DIRECTORIES.length > 0) {
-    const entryWorker = fork(`${process.cwd()}/build/worker.js`);
+    const entryWorker = fork(WORKER_PATH);
     entryWorker.send({ path: DIRECTORIES[0] });
     DIRECTORIES.splice(0);
     entryWorker.on(