chore(shared-ini-file-loder): use Promises in slurpFile hash

Author: trivikr

packages/shared-ini-file-loader/src/slurpFile.spec.ts

@@ -8,16 +8,17 @@ describe("slurpFile", () => {
   const getMockFileContents = (path: string, options = UTF8) => JSON.stringify({ path, options });
 
   beforeEach(() => {
-    (promises.readFile as jest.Mock).mockImplementation((path, options) =>
-      Promise.resolve(getMockFileContents(path, options))
-    );
+    (promises.readFile as jest.Mock).mockImplementation(async (path, options) => {
+      await new Promise((resolve) => setTimeout(resolve, 100));
+      return getMockFileContents(path, options);
+    });
   });
 
   afterEach(() => {
     jest.clearAllMocks();
   });
 
-  it("makes one readFile call for a filepath irrepsective of slurpFile calls", (done) => {
+  it("makes one readFile call for a filepath irrespective of slurpFile calls", (done) => {
     jest.isolateModules(async () => {
       const { slurpFile } = require("./slurpFile");
       const mockPath = "/mock/path";

packages/shared-ini-file-loader/src/slurpFile.ts

@@ -3,45 +3,19 @@ import { promises as fsPromises } from "fs";
 
 const { readFile } = fsPromises;
 
-type callbacks = { resolve: Function; reject: Function };
-type FileStatus = {
-  contents: string;
-  isReading: boolean;
-  requestQueue: callbacks[];
-};
-
-const fileStatusHash: { [key: string]: FileStatus } = {};
+const filePromisesHash: { [key: string]: Promise<string> } = {};
 
-export const slurpFile = (path: string) =>
-  new Promise<string>((resolve, reject) => {
-    if (!fileStatusHash[path]) {
-      // File not read yet, set file isReading to true and read file.
-      fileStatusHash[path] = { isReading: true, contents: "", requestQueue: [] };
-      fileStatusHash[path].requestQueue.push({ resolve, reject });
+export const slurpFile = (path: string) => {
+  if (!filePromisesHash[path]) {
+    filePromisesHash[path] = new Promise((resolve, reject) => {
       readFile(path, "utf8")
         .then((data) => {
-          // File read successful
-          fileStatusHash[path].isReading = false;
-          fileStatusHash[path].contents = data;
-          const { requestQueue } = fileStatusHash[path];
-          while (requestQueue.length) {
-            const { resolve } = requestQueue.pop()!;
-            resolve(data);
-          }
+          resolve(data);
         })
         .catch((err) => {
-          // File read failed;
-          fileStatusHash[path].isReading = false;
-          const { requestQueue } = fileStatusHash[path];
-          while (requestQueue.length) {
-            const { reject } = requestQueue.pop()!;
-            reject(err);
-          }
+          reject(err);
         });
-    } else if (fileStatusHash[path].isReading) {
-      // File currently being read. Add callbacks to the request queue.
-      fileStatusHash[path].requestQueue.push({ resolve, reject });
-    } else {
-      resolve(fileStatusHash[path].contents);
-    }
-  });
+    });
+  }
+  return filePromisesHash[path];
+};