Revert "Test adding limited concurrency"

This reverts commit 267c8e4.

packages/core/package.json

@@ -49,7 +49,6 @@
     "jiti": "2.3.3",
     "js-yaml": "^4.1.0",
     "neotraverse": "^0.6.18",
-    "p-all": "^5.0.0",
     "path-to-regexp": "6.3.0",
     "picomatch": "^4.0.2",
     "simple-git": "^3.26.0",

packages/core/src/index.ts

@@ -19,7 +19,6 @@ import {
 	externalSafePath,
 	md5,
 } from './utils/utils.js';
-import pAll from 'p-all';
 
 export type { LunariaIntegration } from './integrations/types.js';
 export type * from './files/types.js';
@@ -92,27 +91,17 @@ class Lunaria {
 				);
 			}
 
-			const entries: LunariaStatus = new Array(sourceFilePaths.length);
-
-			await pAll(
-				sourceFilePaths.map((path) => {
-					return async () => {
-						const entry = await this.getFileStatus(path);
-						if (entry) entries.push(entry);
-					};
-				}),
-				{
-					concurrency: 5,
-				},
-			);
-
-			// We sort the entries by source path to make the resulting status consistent.
-			// That is, entries will be laid out by precedence in the `files` array, and then
-			// sorted internally.
-			const sortedEntries = entries.sort((a, b) => a.source.path.localeCompare(b.source.path));
-
-			for (const entry of sortedEntries) {
-				status.push(entry);
+			/** We use `Promise.all` to allow the promises to run in parallel, increasing the performance considerably. */
+			const entries = (
+				await Promise.all(
+					sourceFilePaths.map(async (path) => {
+						return await this.#getFileStatus(path, false);
+					}),
+				)
+			).sort((a, b) => (a?.source.path ?? '').localeCompare(b?.source.path ?? ''));
+
+			for (const entry of entries) {
+				if (entry) status.push(entry);
 			}
 		}
 
@@ -181,19 +170,23 @@ class Lunaria {
 			await cache.write(this.#git.cache);
 		}
 
-		const localizations: StatusLocalizationEntry[] = new Array(this.config.locales.length);
-
-		const tasks = this.config.locales.map(({ lang }) => {
-			return async () => {
-				{
+		return {
+			...file,
+			source: {
+				lang: this.config.sourceLocale.lang,
+				path: sourcePath,
+				git: latestSourceChanges,
+			},
+			localizations: await Promise.all(
+				this.config.locales.map(async ({ lang }): Promise<StatusLocalizationEntry> => {
 					const localizedPath = toPath(sourcePath, lang);
 
 					if (!(await exists(resolve(externalSafePath(external, this.#cwd, localizedPath))))) {
-						localizations.push({
+						return {
 							lang: lang,
 							path: localizedPath,
 							status: 'missing',
-						});
+						};
 					}
 
 					const latestLocaleChanges = await this.#git.getFileLatestChanges(localizedPath);
@@ -228,27 +221,15 @@ class Lunaria {
 						return {};
 					};
 
-					localizations.push({
+					return {
 						lang: lang,
 						path: localizedPath,
 						git: latestLocaleChanges,
 						status: isOutdated ? 'outdated' : 'up-to-date',
 						...(await entryTypeData()),
-					});
-				}
-			};
-		});
-
-		await pAll(tasks, { concurrency: 5 });
-
-		return {
-			...file,
-			source: {
-				lang: this.config.sourceLocale.lang,
-				path: sourcePath,
-				git: latestSourceChanges,
-			},
-			localizations,
+					};
+				}),
+			),
 		};
 	}