66 * found in the LICENSE file at https://angular.dev/license
77 */
88
9- import { BuildOutputFileType } from '@angular/build' ;
109import {
1110 ApplicationBuilderInternalOptions ,
1211 Result ,
@@ -15,21 +14,22 @@ import {
1514 buildApplicationInternal ,
1615 emitFilesToDisk ,
1716} from '@angular/build/private' ;
18- import { BuilderContext , BuilderOutput } from '@angular-devkit/architect' ;
17+ import type { BuilderContext , BuilderOutput } from '@angular-devkit/architect' ;
1918import glob from 'fast-glob' ;
20- import type { Config , ConfigOptions , FilePattern , InlinePluginDef } from 'karma' ;
19+ import type { Config , ConfigOptions , FilePattern , InlinePluginDef , Server } from 'karma' ;
2120import { randomUUID } from 'node:crypto' ;
2221import * as fs from 'node:fs/promises' ;
23- import { IncomingMessage , ServerResponse } from 'node:http' ;
22+ import type { IncomingMessage , ServerResponse } from 'node:http' ;
23+ import { createRequire } from 'node:module' ;
2424import * as path from 'node:path' ;
25- import { Observable , Subscriber , catchError , defaultIfEmpty , from , of , switchMap } from 'rxjs' ;
26- import { Configuration } from 'webpack' ;
27- import { ExecutionTransformer } from '../../transforms' ;
28- import { normalizeFileReplacements } from '../../utils' ;
29- import { OutputHashing } from '../browser-esbuild/schema' ;
25+ import { ReadableStreamController } from 'node:stream/web' ;
26+ import { BuildOutputFileType } from '../../tools/esbuild/bundler-context' ;
27+ import { OutputHashing } from '../application/schema' ;
3028import { findTests , getTestEntrypoints } from './find-tests' ;
3129import { Schema as KarmaBuilderOptions } from './schema' ;
3230
31+ const localResolve = createRequire ( __filename ) . resolve ;
32+
3333interface BuildOptions extends ApplicationBuilderInternalOptions {
3434 // We know that it's always a string since we set it.
3535 outputPath : string ;
@@ -171,7 +171,7 @@ function injectKarmaReporter(
171171 buildOptions : BuildOptions ,
172172 buildIterator : AsyncIterator < Result > ,
173173 karmaConfig : Config & ConfigOptions ,
174- subscriber : Subscriber < BuilderOutput > ,
174+ controller : ReadableStreamController < BuilderOutput > ,
175175) {
176176 const reporterName = 'angular-progress-notifier' ;
177177
@@ -205,7 +205,7 @@ function injectKarmaReporter(
205205 }
206206
207207 if ( buildOutput . kind === ResultKind . Failure ) {
208- subscriber . next ( { success : false , message : 'Build failed' } ) ;
208+ controller . enqueue ( { success : false , message : 'Build failed' } ) ;
209209 } else if (
210210 buildOutput . kind === ResultKind . Incremental ||
211211 buildOutput . kind === ResultKind . Full
@@ -227,9 +227,9 @@ function injectKarmaReporter(
227227
228228 onRunComplete = function ( _browsers : unknown , results : RunCompleteInfo ) {
229229 if ( results . exitCode === 0 ) {
230- subscriber . next ( { success : true } ) ;
230+ controller . enqueue ( { success : true } ) ;
231231 } else {
232- subscriber . next ( { success : false } ) ;
232+ controller . enqueue ( { success : false } ) ;
233233 }
234234 } ;
235235 }
@@ -255,44 +255,48 @@ export function execute(
255255 context : BuilderContext ,
256256 karmaOptions : ConfigOptions ,
257257 transforms : {
258- webpackConfiguration ?: ExecutionTransformer < Configuration > ;
259258 // The karma options transform cannot be async without a refactor of the builder implementation
260259 karmaOptions ?: ( options : ConfigOptions ) => ConfigOptions ;
261260 } = { } ,
262- ) : Observable < BuilderOutput > {
263- return from ( initializeApplication ( options , context , karmaOptions , transforms ) ) . pipe (
264- switchMap (
265- ( [ karma , karmaConfig , buildOptions , buildIterator ] ) =>
266- new Observable < BuilderOutput > ( ( subscriber ) => {
267- // If `--watch` is explicitly enabled or if we are keeping the Karma
268- // process running, we should hook Karma into the build.
269- if ( buildIterator ) {
270- injectKarmaReporter ( buildOptions , buildIterator , karmaConfig , subscriber ) ;
271- }
261+ ) : AsyncIterable < BuilderOutput > {
262+ let karmaServer : Server ;
263+
264+ return new ReadableStream ( {
265+ async start ( controller ) {
266+ let init ;
267+ try {
268+ init = await initializeApplication ( options , context , karmaOptions , transforms ) ;
269+ } catch ( err ) {
270+ if ( err instanceof ApplicationBuildError ) {
271+ controller . enqueue ( { success : false , message : err . message } ) ;
272+ controller . close ( ) ;
273+
274+ return ;
275+ }
272276
273- // Complete the observable once the Karma server returns.
274- const karmaServer = new karma . Server ( karmaConfig as Config , ( exitCode ) => {
275- subscriber . next ( { success : exitCode === 0 } ) ;
276- subscriber . complete ( ) ;
277- } ) ;
277+ throw err ;
278+ }
279+
280+ const [ karma , karmaConfig , buildOptions , buildIterator ] = init ;
278281
279- const karmaStart = karmaServer . start ( ) ;
280-
281- // Cleanup, signal Karma to exit.
282- return ( ) => {
283- void karmaStart . then ( ( ) => karmaServer . stop ( ) ) ;
284- } ;
285- } ) ,
286- ) ,
287- catchError ( ( err ) => {
288- if ( err instanceof ApplicationBuildError ) {
289- return of ( { success : false , message : err . message } ) ;
282+ // If `--watch` is explicitly enabled or if we are keeping the Karma
283+ // process running, we should hook Karma into the build.
284+ if ( buildIterator ) {
285+ injectKarmaReporter ( buildOptions , buildIterator , karmaConfig , controller ) ;
290286 }
291287
292- throw err ;
293- } ) ,
294- defaultIfEmpty ( { success : false } ) ,
295- ) ;
288+ // Close the stream once the Karma server returns.
289+ karmaServer = new karma . Server ( karmaConfig as Config , ( exitCode ) => {
290+ controller . enqueue ( { success : exitCode === 0 } ) ;
291+ controller . close ( ) ;
292+ } ) ;
293+
294+ await karmaServer . start ( ) ;
295+ } ,
296+ async cancel ( ) {
297+ await karmaServer ?. stop ( ) ;
298+ } ,
299+ } ) ;
296300}
297301
298302async function getProjectSourceRoot ( context : BuilderContext ) : Promise < string > {
@@ -315,10 +319,8 @@ function normalizePolyfills(polyfills: string | string[] | undefined): [string[]
315319 polyfills = [ ] ;
316320 }
317321
318- const jasmineGlobalEntryPoint =
319- '@angular-devkit/build-angular/src/builders/karma/jasmine_global.js' ;
320- const jasmineGlobalCleanupEntrypoint =
321- '@angular-devkit/build-angular/src/builders/karma/jasmine_global_cleanup.js' ;
322+ const jasmineGlobalEntryPoint = localResolve ( './polyfills/jasmine_global.js' ) ;
323+ const jasmineGlobalCleanupEntrypoint = localResolve ( './polyfills/jasmine_global_cleanup.js' ) ;
322324
323325 const zoneTestingEntryPoint = 'zone.js/testing' ;
324326 const polyfillsExludingZoneTesting = polyfills . filter ( ( p ) => p !== zoneTestingEntryPoint ) ;
@@ -352,18 +354,11 @@ async function initializeApplication(
352354 context : BuilderContext ,
353355 karmaOptions : ConfigOptions ,
354356 transforms : {
355- webpackConfiguration ?: ExecutionTransformer < Configuration > ;
356357 karmaOptions ?: ( options : ConfigOptions ) => ConfigOptions ;
357358 } = { } ,
358359) : Promise <
359360 [ typeof import ( 'karma' ) , Config & ConfigOptions , BuildOptions , AsyncIterator < Result > | null ]
360361> {
361- if ( transforms . webpackConfiguration ) {
362- context . logger . warn (
363- `This build is using the application builder but transforms.webpackConfiguration was provided. The transform will be ignored.` ,
364- ) ;
365- }
366-
367362 const outputPath = path . join ( context . workspaceRoot , 'dist/test-out' , randomUUID ( ) ) ;
368363 const projectSourceRoot = await getProjectSourceRoot ( context ) ;
369364
@@ -377,7 +372,7 @@ async function initializeApplication(
377372 if ( options . main ) {
378373 entryPoints . set ( mainName , options . main ) ;
379374 } else {
380- entryPoints . set ( mainName , '@angular-devkit/build-angular/src/builders/karma/ init_test_bed.js') ;
375+ entryPoints . set ( mainName , localResolve ( './polyfills/ init_test_bed.js') ) ;
381376 }
382377
383378 const instrumentForCoverage = options . codeCoverage
@@ -416,9 +411,10 @@ async function initializeApplication(
416411 watch : options . watch ?? ! karmaOptions . singleRun ,
417412 stylePreprocessorOptions : options . stylePreprocessorOptions ,
418413 inlineStyleLanguage : options . inlineStyleLanguage ,
419- fileReplacements : options . fileReplacements
420- ? normalizeFileReplacements ( options . fileReplacements , './' )
421- : undefined ,
414+ fileReplacements : options . fileReplacements ,
415+ define : options . define ,
416+ loader : options . loader ,
417+ externalDependencies : options . externalDependencies ,
422418 } ;
423419
424420 // Build tests with `application` builder, using test files as entry points.
0 commit comments