rea/src/browser/ElectronCaptureCleanup.ts

import type { _electron as electron } from "playwright-core";
import {
  AnalysisCleanupLease,
  AnalysisCleanupLeaseGroup,
} from "../artifacts/AnalysisCleanupLease.js";
import { ArtifactReaderFailure } from "../artifacts/ArtifactReader.js";
import type { ArtifactResourceScope } from "../artifacts/ArtifactResourceScope.js";
import type { AnalysisError } from "../domain/analysisErrorBase.js";
import { observeOwnedProcessLineage } from "../process/ProcessOwnershipObservation.js";
import type {
  OwnedProcessGroup,
  ProcessCleanupResult,
  ProcessLineageObservation,
} from "../process/ProcessOwnership.js";
import { runWithExecutionLimits } from "./PlaywrightElectronActiveActions.js";
import { cleanupElectronProcesses } from "./ElectronProcessCleanup.js";

type ElectronApplication = Awaited<ReturnType<typeof electron.launch>>;

/** Transport acknowledgement and process-family release are independent facts. */
export class ElectronCaptureCleanup {
  readonly #transport: AnalysisCleanupLease;
  readonly #processes: AnalysisCleanupLease;
  #closeOperation: Promise<void> | undefined;
  #lineage: ProcessLineageObservation | undefined;
  #processResult: ProcessCleanupResult | undefined;

  constructor(
    application: Pick<ElectronApplication, "close">,
    ownership: OwnedProcessGroup | undefined,
    lineage: ProcessLineageObservation | undefined,
  ) {
    this.#lineage = lineage;
    this.#transport = new AnalysisCleanupLease(async () => {
      // A deadline stops this wait, not the underlying Playwright close. Reuse
      // a still-running/fulfilled close; only a physical rejection permits retry.
      if (this.#closeOperation === undefined) {
        const closing = Promise.resolve().then(() => application.close());
        this.#closeOperation = closing;
        void closing.catch(() => {
          if (this.#closeOperation === closing)
            this.#closeOperation = undefined;
        });
      }
      await runWithExecutionLimits(
        this.#closeOperation,
        undefined,
        performance.now() + 5_000,
      );
    }, ["browser_transport"]);
    const resources =
      ownership === undefined
        ? ["owned_process_group"]
        : [
            "owned_process_group",
            `run:${ownership.runId}`,
            `process-group:${String(ownership.processGroupId)}`,
          ];
    this.#processes = new AnalysisCleanupLease(async () => {
      const cleanup =
        ownership === undefined
          ? {
              cleaned: false as const,
              reason: "owned Electron process identity was unavailable",
            }
          : await this.#cleanupProcesses(ownership);
      this.#processResult = cleanup;
      if (!cleanup.cleaned)
        throw new ArtifactReaderFailure("unavailable", cleanup.reason, {
          cleanup: { reason: cleanup.reason, resources },
        });
    }, resources);
  }

  get processResult(): ProcessCleanupResult | undefined {
    return this.#processResult;
  }
  get pendingResources(): readonly string[] {
    return this.#pending.flatMap((lease) => lease.cleanupResources ?? []);
  }
  get #pending(): AnalysisCleanupLease[] {
    return [this.#transport, this.#processes].filter(
      (lease) => !lease.released,
    );
  }

  async release(scope: ArtifactResourceScope) {
    const transport = await scope.release({
      kind: "lease",
      resource: "browser_transport",
      lease: this.#transport,
    });
    const processes = await scope.release({
      kind: "lease",
      resource: "owned_process_group",
      lease: this.#processes,
    });
    return { transport, processes };
  }

  bind(error: AnalysisError): void {
    new AnalysisCleanupLeaseGroup(error, this.#pending);
  }

  async #cleanupProcesses(
    ownership: OwnedProcessGroup,
  ): Promise<ProcessCleanupResult> {
    const current = await observeOwnedProcessLineage(ownership);
    if (current.status === "verified") this.#lineage = current;
    // Cached POSIX group IDs are candidates only; the shared primitive checks
    // current tokens/start identities. Windows requires this attempt's lineage.
    return cleanupElectronProcesses(
      ownership,
      process.platform === "win32" ? current : (this.#lineage ?? current),
    );
  }
}