Class BrowserTargetManager

src/targets/browser/browserTargetManager.ts:20–370

import { IBrowserProcess } from './spawn/browserProcess';

export class BrowserTargetManager implements IDisposable {
  private _connection: CdpConnection;
  private _targets: Map<Cdp.Target.SessionID, BrowserTarget> = new Map();
  protected readonly _browser: Cdp.Api;
  private readonly _detachedTargets = new Set();
  readonly frameModel = new FrameModel();
  readonly serviceWorkerModel = new ServiceWorkerModel(this.frameModel);
  private _lifecycleQueue = Promise.resolve();
  _sourcePathResolver: ISourcePathResolver;
  _targetOrigin: ITargetOrigin;
  _scriptSkipper?: ScriptSkipper;

  private _onTargetAddedEmitter = new EventEmitter<BrowserTarget>();
  private _onTargetRemovedEmitter = new EventEmitter<BrowserTarget>();
  readonly onTargetAdded = this._onTargetAddedEmitter.event;
  readonly onTargetRemoved = this._onTargetRemovedEmitter.event;

  static async connect(
    connection: CdpConnection,
    process: undefined | IBrowserProcess,
    sourcePathResolver: ISourcePathResolver,
    launchParams: AnyChromiumConfiguration,
    logger: ILogger,
    telemetry: ITelemetryReporter,
    targetOrigin: ITargetOrigin,
  ): Promise<BrowserTargetManager | undefined> {
    const rootSession = connection.rootSession();
    const result = await rootSession.Target.attachToBrowserTarget({});
    if (!result) return;
    const browserSession = connection.createSession(result.sessionId);
    return new this(
      connection,
      process,
      browserSession,
      sourcePathResolver,
      logger,
      telemetry,
      launchParams,
      targetOrigin,
    );
  }

  constructor(
    connection: CdpConnection,
    private process: IBrowserProcess | undefined,
    browserSession: Cdp.Api,
    sourcePathResolver: ISourcePathResolver,
    private readonly logger: ILogger,
    private readonly telemetry: ITelemetryReporter,
    protected readonly launchParams: AnyChromiumConfiguration,
    targetOrigin: ITargetOrigin,
  ) {
    this._connection = connection;
    this._sourcePathResolver = sourcePathResolver;
    this._browser = browserSession;
    this._targetOrigin = targetOrigin;
    this.serviceWorkerModel.onDidChange(() => {
      for (const target of this._targets.values()) {