fix: import concurrency functions from xml-disassembler

package.json

@@ -45,7 +45,7 @@
   },
   "dependencies": {
     "tslib": "^2.6.2",
-    "xml-disassembler": "^1.3.9"
+    "xml-disassembler": "^1.3.10"
   },
   "repository": {
     "type": "git",

src/service/deleteReassembledXML.ts

@@ -2,8 +2,10 @@
 
 import { readdir, rm } from "node:fs/promises";
 import { join } from "node:path/posix";
-import { getConcurrencyThreshold } from "./getConcurrencyThreshold";
-import { withConcurrencyLimit } from "./withConcurrencyLimit";
+import {
+  getConcurrencyThreshold,
+  withConcurrencyLimit,
+} from "xml-disassembler";
 
 export async function deleteReassembledXML(
   disassembledPath: string,

src/service/json2xmlReassembler.ts

@@ -2,13 +2,15 @@
 
 import { stat, readdir } from "node:fs/promises";
 import { join } from "node:path/posix";
+import {
+  getConcurrencyThreshold,
+  withConcurrencyLimit,
+} from "xml-disassembler";
 
 import { logger } from "@src/index";
 import { reassembleHandler } from "@src/service/reassembleHandler";
 import { transform2XML } from "@src/service/transform2XML";
 import { deleteReassembledXML } from "@src/service/deleteReassembledXML";
-import { withConcurrencyLimit } from "./withConcurrencyLimit";
-import { getConcurrencyThreshold } from "./getConcurrencyThreshold";
 
 export class JsonToXmlReassembler {
   async reassemble(xmlAttributes: {

src/service/transform2JSON.ts

@@ -2,11 +2,13 @@
 
 import { readdir, rm, writeFile } from "node:fs/promises";
 import { join } from "node:path/posix";
-import { parseXML } from "xml-disassembler";
+import {
+  parseXML,
+  getConcurrencyThreshold,
+  withConcurrencyLimit,
+} from "xml-disassembler";
 
 import { logger } from "@src/index";
-import { withConcurrencyLimit } from "./withConcurrencyLimit";
-import { getConcurrencyThreshold } from "./getConcurrencyThreshold";
 
 export async function transform2JSON(xmlPath: string): Promise<void> {
   const tasks: (() => Promise<void>)[] = [];

src/service/xml2jsonDisassembler.ts

@@ -3,12 +3,14 @@
 import { existsSync } from "node:fs";
 import { stat, readdir } from "node:fs/promises";
 import { resolve, join, basename, dirname, extname } from "node:path/posix";
+import {
+  getConcurrencyThreshold,
+  withConcurrencyLimit,
+} from "xml-disassembler";
 
 import { logger } from "@src/index";
 import { disassembleHandler } from "@src/service/disassembleHandler";
 import { transform2JSON } from "@src/service/transform2JSON";
-import { withConcurrencyLimit } from "./withConcurrencyLimit";
-import { getConcurrencyThreshold } from "./getConcurrencyThreshold";
 
 export class XmlToJsonDisassembler {
   async disassemble(xmlAttributes: {

test/main.spec.ts

@@ -30,7 +30,6 @@ describe("main function", () => {
 
   afterEach(async () => {
     jest.restoreAllMocks();
-    jest.resetModules();
   });
 
   afterAll(async () => {
@@ -121,33 +120,6 @@ describe("main function", () => {
     await rm(fakeFile);
     expect(logger.error).toHaveBeenCalled();
   });
-  it("should return the minimum of available parallelism and 6", () => {
-    jest.mock("node:os", () => ({
-      availableParallelism: jest.fn(() => 4), // Mock availableParallelism to return 4
-    }));
-    const {
-      getConcurrencyThreshold,
-    } = require("../src/service/getConcurrencyThreshold");
-    expect(getConcurrencyThreshold()).toBe(4);
-  });
-  it("should return 6 if availableParallelism returns a higher value", () => {
-    jest.mock("node:os", () => ({
-      availableParallelism: jest.fn(() => 10), // Mock availableParallelism to return 10
-    }));
-    const {
-      getConcurrencyThreshold,
-    } = require("../src/service/getConcurrencyThreshold");
-    expect(getConcurrencyThreshold()).toBe(6);
-  });
-  it("should return 6 if availableParallelism is undefined", () => {
-    jest.mock("node:os", () => ({
-      availableParallelism: undefined, // Simulate unavailable function
-    }));
-    const {
-      getConcurrencyThreshold,
-    } = require("../src/service/getConcurrencyThreshold");
-    expect(getConcurrencyThreshold()).toBe(6);
-  });
   // This should always be the final test
   it("should compare the files created in the mock directory against the baselines to confirm no changes.", async () => {
     await compareDirectories(baselineDir, mockDir);