Skip to content

Commit

Permalink
refactor: remove _onCrawlEnd (#18207)
Browse files Browse the repository at this point in the history
  • Loading branch information
sapphi-red authored Sep 27, 2024
1 parent 768a50f commit bea0272
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 27 deletions.
2 changes: 1 addition & 1 deletion packages/vite/src/node/optimizer/optimizer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ export function createDepsOptimizer(
cachedMetadata || initDepsOptimizerMetadata(environment, sessionTimestamp)

if (!cachedMetadata) {
environment._onCrawlEnd(onCrawlEnd)
environment.waitForRequestsIdle().then(onCrawlEnd)
waitingForCrawlEnd = true

// Enter processing state until crawl of static imports ends
Expand Down
29 changes: 3 additions & 26 deletions packages/vite/src/node/server/environment.ts
Original file line number Diff line number Diff line change
Expand Up @@ -78,10 +78,6 @@ export class DevEnvironment extends BaseEnvironment {
abort: () => void
}
>
/**
* @internal
*/
_onCrawlEndCallbacks: (() => void)[]
/**
* @internal
*/
Expand Down Expand Up @@ -118,10 +114,7 @@ export class DevEnvironment extends BaseEnvironment {

this.hot = context.hot || createNoopHotChannel()

this._onCrawlEndCallbacks = []
this._crawlEndFinder = setupOnCrawlEnd(() => {
this._onCrawlEndCallbacks.forEach((cb) => cb())
})
this._crawlEndFinder = setupOnCrawlEnd()

this._ssrRunnerOptions = context.runner ?? {}
context.runner?.transport?.register(this)
Expand Down Expand Up @@ -243,13 +236,6 @@ export class DevEnvironment extends BaseEnvironment {
_registerRequestProcessing(id: string, done: () => Promise<unknown>): void {
this._crawlEndFinder.registerRequestProcessing(id, done)
}
/**
* @internal
* TODO: use waitForRequestsIdle in the optimizer instead of this function
*/
_onCrawlEnd(cb: () => void): void {
this._onCrawlEndCallbacks.push(cb)
}
}

function invalidateModule(
Expand Down Expand Up @@ -292,7 +278,7 @@ interface CrawlEndFinder {
cancel: () => void
}

function setupOnCrawlEnd(onCrawlEnd: () => void): CrawlEndFinder {
function setupOnCrawlEnd(): CrawlEndFinder {
const registeredIds = new Set<string>()
const seenIds = new Set<string>()
const onCrawlEndPromiseWithResolvers = promiseWithResolvers<void>()
Expand All @@ -304,15 +290,6 @@ function setupOnCrawlEnd(onCrawlEnd: () => void): CrawlEndFinder {
cancelled = true
}

let crawlEndCalled = false
function callOnCrawlEnd() {
if (!cancelled && !crawlEndCalled) {
crawlEndCalled = true
onCrawlEnd()
}
onCrawlEndPromiseWithResolvers.resolve()
}

function registerRequestProcessing(
id: string,
done: () => Promise<any>,
Expand Down Expand Up @@ -352,7 +329,7 @@ function setupOnCrawlEnd(onCrawlEnd: () => void): CrawlEndFinder {
}
async function callOnCrawlEndWhenIdle() {
if (cancelled || registeredIds.size > 0) return
callOnCrawlEnd()
onCrawlEndPromiseWithResolvers.resolve()
}

return {
Expand Down

0 comments on commit bea0272

Please sign in to comment.