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",
     "yaml": "^2.7.0"
   },
   "repository": {

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 {
+  withConcurrencyLimit,
+  getConcurrencyThreshold,
+} from "xml-disassembler";
 
 export async function deleteReassembledXML(
   disassembledPath: string,

src/service/transform2YAML.ts

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

src/service/xml2yamlDisassembler.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 {
+  withConcurrencyLimit,
+  getConcurrencyThreshold,
+} from "xml-disassembler";
 
 import { logger } from "@src/index";
 import { disassembleHandler } from "@src/service/disassembleHandler";
 import { transform2YAML } from "@src/service/transform2YAML";
-import { withConcurrencyLimit } from "./withConcurrencyLimit";
-import { getConcurrencyThreshold } from "./getConcurrencyThreshold";
 
 export class XmlToYamlDisassembler {
   async disassemble(xmlAttributes: {

src/service/yaml2xmlReassembler.ts

@@ -2,13 +2,15 @@
 
 import { stat, readdir } from "node:fs/promises";
 import { join } from "node:path/posix";
+import {
+  withConcurrencyLimit,
+  getConcurrencyThreshold,
+} 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 YamlToXmlReassembler {
   async reassemble(xmlAttributes: {

test/main.spec.ts

@@ -30,7 +30,6 @@ describe("main function", () => {
 
   afterEach(async () => {
     jest.restoreAllMocks();
-    jest.resetModules();
   });
 
   afterAll(async () => {
@@ -120,33 +119,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);