@@ -89,7 +89,7 @@ const loadPluginFingerprints = async (
8989} ;
9090
9191/** Resolves the portable cache identity before work is dispatched. */
92- const createFmtFileRunTask = ( file : FmtFileRequest , cache ?: RunCache ) : FmtFileRunTask => {
92+ const createRunTask = ( file : FmtFileRequest , cache ?: RunCache ) : FmtFileRunTask => {
9393 let key : string | undefined ;
9494 let fileCache : FmtFileCache | undefined ;
9595
@@ -160,7 +160,7 @@ const runFmtFile = async (
160160} ;
161161
162162/** Starts slower Markdown parsers first while preserving order within both priority groups. */
163- const runPriorityFmtFiles = async (
163+ const runPriorityTasks = async (
164164 tasks : FmtFileRunTask [ ] ,
165165 shouldWrite : boolean ,
166166 formatFile : FormatFile ,
@@ -184,13 +184,13 @@ const runPriorityFmtFiles = async (
184184} ;
185185
186186/** Processes files in a worker pool while preserving input order. */
187- const runFmtFilesInWorkerPool = async (
187+ const runWithWorkers = async (
188188 files : FmtFileRequest [ ] ,
189189 shouldWrite : boolean ,
190190 maxWorkers ?: number ,
191191 cache ?: RunCache ,
192192) : Promise < FmtWorkerPoolResult > => {
193- const tasks = files . map ( ( file ) => createFmtFileRunTask ( file , cache ) ) ;
193+ const tasks = files . map ( ( file ) => createRunTask ( file , cache ) ) ;
194194 const pendingFileCount = tasks . reduce (
195195 ( count , task ) => count + ( isCachedUnsupported ( task ) ? 0 : 1 ) ,
196196 0 ,
@@ -199,13 +199,13 @@ const runFmtFilesInWorkerPool = async (
199199 return { files : [ ] , processedFileCount : 0 } ;
200200 }
201201
202- const { createFmtWorkerPool } = await import ( './workerPool.ts' ) ;
203- const workerPool = await createFmtWorkerPool ( pendingFileCount , maxWorkers ) ;
202+ const { createWorkerPool } = await import ( './workerPool.ts' ) ;
203+ const workerPool = await createWorkerPool ( pendingFileCount , maxWorkers ) ;
204204
205205 try {
206206 const results =
207207 workerPool . workerCount >= minPriorityWorkers
208- ? await runPriorityFmtFiles ( tasks , shouldWrite , workerPool . formatFile )
208+ ? await runPriorityTasks ( tasks , shouldWrite , workerPool . formatFile )
209209 : await Promise . all (
210210 tasks . map ( ( task ) => runFmtFile ( task , shouldWrite , workerPool . formatFile ) ) ,
211211 ) ;
@@ -233,7 +233,7 @@ const runFmtFilesInWorkerPool = async (
233233} ;
234234
235235/** Maps file results to the Prettier-compatible CLI exit code. */
236- const getFmtExitCode = ( files : FmtFileResult [ ] ) : FmtExitCode => {
236+ const getExitCode = ( files : FmtFileResult [ ] ) : FmtExitCode => {
237237 let exitCode : FmtExitCode = 0 ;
238238
239239 for ( const file of files ) {
@@ -272,13 +272,12 @@ const runFmtFiles = async ({
272272 const result =
273273 files . length === 0
274274 ? { files : [ ] , processedFileCount : 0 }
275- : await runFmtFilesInWorkerPool ( files , shouldWrite , maxWorkers , runCache ) ;
275+ : await runWithWorkers ( files , shouldWrite , maxWorkers , runCache ) ;
276276 await runCache ?. store . save ( ) . catch ( ( ) => false ) ;
277277
278278 return {
279279 ...result ,
280- exitCode :
281- files . length > 0 && result . processedFileCount === 0 ? 2 : getFmtExitCode ( result . files ) ,
280+ exitCode : files . length > 0 && result . processedFileCount === 0 ? 2 : getExitCode ( result . files ) ,
282281 } ;
283282} ;
284283
0 commit comments