[rushd] Wire layer: protocol, transport & presentation (WS1) (#5922)

* [rushd] Wire layer: protocol, transport & presentation (WS1, #5896)

Add the engine-agnostic rushd wire layer as three new 0.x packages plus
additive rush-lib engine instrumentation:

- @rushstack/rush-daemon-protocol: frame taxonomy (0x01 control-json,
  0x02/0x03 log-stdout/stderr, 0x04 stdin, 0x05 event), length-prefixed
  binary codec, DAEMON_PROTOCOL_VERSION, hello/version negotiation with
  typed mismatch errors, and per-subscription verbosity filtering at
  serialization. Event envelope mirrors the @rushstack/reporter contract
  as a placeholder pending its merge (#5858).
- @rushstack/rush-daemon-transport: workspace-key hashing, per-user
  runtime-dir socket/pipe paths, net listener/connector with
  backpressure, and PID/lockfile stale-socket reclaim.
- @rushstack/rush-terminal-renderer: client reporter host with
  StreamCollator-backed per-op collation (byte-parity with legacy),
  per-client verbosity, and FORCE_COLOR/COLUMNS child-env threading.
- rush-lib: optional internal IOperationGraphEventSink dual-emit
  (structured status/activity/header events + per-op raw output tap)
  with byte-identical legacy output.
- build-tests/rushd-wire-e2e-test: cross-layer conformance suite
  (golden parity over a real socket, raw-stream integrity, verbosity
  isolation, failure propagation).
- rigs: shared strict-codegen ESLint mixin for the new packages, with
  inline suppression disabled (noInlineConfig).

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Address WS1 review: protocol hardening, performance, and safety

Review pass over the wire-layer packages (#5922):

Protocol (@rushstack/rush-daemon-protocol):
- kind/payload naming throughout (frames + control messages); control
  messages are a uniform { kind, payload } discriminated union so kind
  reads stay monomorphic.
- Uint8Array wire payloads instead of Buffer, so the protocol is
  platform-agnostic and drops the @types/node peer dependency.
- FrameDecoder uses ECMAScript private fields and accumulates received
  bytes in a SegmentBuffer (no per-push Buffer.concat); payloads copy out
  once per completed frame.
- encodeDaemonFrames returns a Uint8Array[] (no batch concat); the
  transport writes parts sequentially.
- Containment checks use numeric ranges/Sets; the event-type list is
  as-const with the union derived from it (list and type cannot drift).
- Error codes are a plain string union; DaemonProtocolError accepts
  { cause } per the standard Error convention.
- decodeDaemonEventFrame structurally validates envelopes (typed error
  instead of routing malformed input); new isDaemonEventEnvelope guard.
- Envelope optional fields moved to the end of the layout; log chunk
  encoding measures the id once and allocates the payload once; TS target
  ES2022.

Transport (@rushstack/rush-daemon-transport):
- Decoder/handler failures in the socket callback now fail the connection
  closed instead of crashing the daemon (new ConnectionRobustness test).
- Reclaim is serialized through a dedicated .reclaim mutex (wx create,
  dead-PID steal) so a concurrent starter cannot unlink a socket another
  process just bound; the daemon lockfile is written after bind so a
  stale record never reads as a live owner.

Renderer/e2e: track the renames and Uint8Array decode boundary.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Fix CI: annotate literal lists to clear typedef warnings

rush retest runs with warnings-as-failures; the reviewer-requested
as-const literal lists tripped the friendly-locals @typescript-eslint/typedef
rule (variableDeclaration). Annotate DAEMON_EVENT_TYPES and
DAEMON_CONTROL_MESSAGE_KINDS with explicit literal-tuple types and derive the
unions from them, preserving the single-source-of-truth invariant (adding a
member requires updating the tuple annotation, which the compiler enforces via
the derived union) with zero lint warnings.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* chore: regenerate README package table (repo-toolbox readme)

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Fix e2e golden comparison on Windows (OS newline normalization)

The renderer pipeline normalizes newlines to the OS default (CRLF on
Windows) via colorsNewlinesTransform, but the e2e test sink compared the
raw LF-carrying chunks, so the byte-parity assertions failed only on
Windows. Normalize the captured golden to the OS newline before
comparing so the test is platform-correct.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Fix e2e golden newline normalization to not double-apply CRLF

The previous OS-newline normalization mapped every LF to CRLF, producing
CRCRLF on Windows for text that already carried CRLF. Normalize only
lone-LF newlines (leave existing CRLF intact) so the golden comparison is
correct on both platforms.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Make e2e golden newline normalization idempotent

Collapse existing CRLF to LF before re-applying the OS newline, so the
golden comparison is correct on Windows (no CRCRLF) and a no-op on POSIX.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

* [rushd] Emit OS newline for renderer global activity lines

The legacy collated pipeline normalizes to OS newlines via
TextRewriterTransform(OsDefault), but the renderer wrote global
activityChanged lines with a raw LF, producing mixed LF/CRLF output on
Windows. Write the client OS newline instead so global status lines and
collated blocks are byte-consistent.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

---------

Co-authored-by: TheLarkInn <TheLarkInn@users.noreply.github.com>
Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>
Copilot-Session: 47388e8f-8d41-4ca4-819b-688ea6c510a2

Author: TheLarkInn

README.md

@@ -97,11 +97,14 @@ These GitHub repositories provide supplementary resources for Rush Stack:
 | [/libraries/package-extractor](./libraries/package-extractor/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Fpackage-extractor.svg)](https://badge.fury.io/js/%40rushstack%2Fpackage-extractor) | [changelog](./libraries/package-extractor/CHANGELOG.md) | [@rushstack/package-extractor](https://www.npmjs.com/package/@rushstack/package-extractor) |
 | [/libraries/problem-matcher](./libraries/problem-matcher/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Fproblem-matcher.svg)](https://badge.fury.io/js/%40rushstack%2Fproblem-matcher) | [changelog](./libraries/problem-matcher/CHANGELOG.md) | [@rushstack/problem-matcher](https://www.npmjs.com/package/@rushstack/problem-matcher) |
 | [/libraries/rig-package](./libraries/rig-package/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frig-package.svg)](https://badge.fury.io/js/%40rushstack%2Frig-package) | [changelog](./libraries/rig-package/CHANGELOG.md) | [@rushstack/rig-package](https://www.npmjs.com/package/@rushstack/rig-package) |
+| [/libraries/rush-daemon-protocol](./libraries/rush-daemon-protocol/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-daemon-protocol.svg)](https://badge.fury.io/js/%40rushstack%2Frush-daemon-protocol) | [changelog](./libraries/rush-daemon-protocol/CHANGELOG.md) | [@rushstack/rush-daemon-protocol](https://www.npmjs.com/package/@rushstack/rush-daemon-protocol) |
+| [/libraries/rush-daemon-transport](./libraries/rush-daemon-transport/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-daemon-transport.svg)](https://badge.fury.io/js/%40rushstack%2Frush-daemon-transport) | [changelog](./libraries/rush-daemon-transport/CHANGELOG.md) | [@rushstack/rush-daemon-transport](https://www.npmjs.com/package/@rushstack/rush-daemon-transport) |
 | [/libraries/rush-lib](./libraries/rush-lib/) | [![npm version](https://badge.fury.io/js/%40microsoft%2Frush-lib.svg)](https://badge.fury.io/js/%40microsoft%2Frush-lib) | | [@microsoft/rush-lib](https://www.npmjs.com/package/@microsoft/rush-lib) |
 | [/libraries/rush-pnpm-kit-v10](./libraries/rush-pnpm-kit-v10/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v10.svg)](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v10) | [changelog](./libraries/rush-pnpm-kit-v10/CHANGELOG.md) | [@rushstack/rush-pnpm-kit-v10](https://www.npmjs.com/package/@rushstack/rush-pnpm-kit-v10) |
 | [/libraries/rush-pnpm-kit-v8](./libraries/rush-pnpm-kit-v8/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v8.svg)](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v8) | [changelog](./libraries/rush-pnpm-kit-v8/CHANGELOG.md) | [@rushstack/rush-pnpm-kit-v8](https://www.npmjs.com/package/@rushstack/rush-pnpm-kit-v8) |
 | [/libraries/rush-pnpm-kit-v9](./libraries/rush-pnpm-kit-v9/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v9.svg)](https://badge.fury.io/js/%40rushstack%2Frush-pnpm-kit-v9) | [changelog](./libraries/rush-pnpm-kit-v9/CHANGELOG.md) | [@rushstack/rush-pnpm-kit-v9](https://www.npmjs.com/package/@rushstack/rush-pnpm-kit-v9) |
 | [/libraries/rush-sdk](./libraries/rush-sdk/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-sdk.svg)](https://badge.fury.io/js/%40rushstack%2Frush-sdk) | | [@rushstack/rush-sdk](https://www.npmjs.com/package/@rushstack/rush-sdk) |
+| [/libraries/rush-terminal-renderer](./libraries/rush-terminal-renderer/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Frush-terminal-renderer.svg)](https://badge.fury.io/js/%40rushstack%2Frush-terminal-renderer) | [changelog](./libraries/rush-terminal-renderer/CHANGELOG.md) | [@rushstack/rush-terminal-renderer](https://www.npmjs.com/package/@rushstack/rush-terminal-renderer) |
 | [/libraries/stream-collator](./libraries/stream-collator/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Fstream-collator.svg)](https://badge.fury.io/js/%40rushstack%2Fstream-collator) | [changelog](./libraries/stream-collator/CHANGELOG.md) | [@rushstack/stream-collator](https://www.npmjs.com/package/@rushstack/stream-collator) |
 | [/libraries/terminal](./libraries/terminal/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Fterminal.svg)](https://badge.fury.io/js/%40rushstack%2Fterminal) | [changelog](./libraries/terminal/CHANGELOG.md) | [@rushstack/terminal](https://www.npmjs.com/package/@rushstack/terminal) |
 | [/libraries/tree-pattern](./libraries/tree-pattern/) | [![npm version](https://badge.fury.io/js/%40rushstack%2Ftree-pattern.svg)](https://badge.fury.io/js/%40rushstack%2Ftree-pattern) | [changelog](./libraries/tree-pattern/CHANGELOG.md) | [@rushstack/tree-pattern](https://www.npmjs.com/package/@rushstack/tree-pattern) |
@@ -226,6 +229,7 @@ These GitHub repositories provide supplementary resources for Rush Stack:
 | [/build-tests/rush-package-manager-integration-test](./build-tests/rush-package-manager-integration-test/) | Integration tests for non-pnpm package managers in Rush. |
 | [/build-tests/rush-project-change-analyzer-test](./build-tests/rush-project-change-analyzer-test/) | This is an example project that uses rush-lib's ProjectChangeAnalyzer to  |
 | [/build-tests/rush-redis-cobuild-plugin-integration-test](./build-tests/rush-redis-cobuild-plugin-integration-test/) | Tests connecting to an redis server |
+| [/build-tests/rushd-wire-e2e-test](./build-tests/rushd-wire-e2e-test/) | End-to-end conformance tests for the rushd wire layer (protocol + transport + renderer against the rush-lib engine) |
 | [/build-tests/set-webpack-public-path-plugin-test](./build-tests/set-webpack-public-path-plugin-test/) | Building this project tests the set-webpack-public-path-plugin |
 | [/build-tests/webpack-local-version-test](./build-tests/webpack-local-version-test/) | Building this project tests the rig loading for the local version of webpack |
 | [/eslint/local-eslint-config](./eslint/local-eslint-config/) | An ESLint configuration consumed projects inside the rushstack repo. |

build-tests/rushd-wire-e2e-test/AGENTS.md

@@ -0,0 +1,51 @@
+# Agent coding contract — `rushd-wire-e2e-test`
+
+This package is governed by an **ultra-strict lint policy** for generated code. All of the
+rules below are enabled to `error` in `eslint.config.js` via the shared
+`local-node-rig/profiles/default/includes/eslint/flat/mixins/strict-codegen.js` mixin.
+They apply to **all** TypeScript in this package, **including tests** (`src/**/*.test.ts`).
+
+## Enforced rules (do not attempt to bypass)
+
+| Rule | Setting |
+| ---- | ------- |
+| `complexity` | `['error', 3]` |
+| `max-depth` | `['error', 3]` |
+| `max-lines-per-function` | `['error', 30]` |
+| `max-lines` | `['error', 100]` — every file, including this means: keep files small; split modules |
+| `max-params` | `['error', 4]` — use options objects |
+| `@typescript-eslint/no-magic-numbers` | `'error'` — every numeric literal must be a named constant |
+| `@typescript-eslint/prefer-nullish-coalescing` | `'error'` — use `??`, not `\|\|` or nullish-guard ternaries |
+| `import/enforce-node-protocol-usage` | `['error', 'always']` — write `node:crypto`, never `crypto` |
+| `import/order` | `['error', { alphabetize: asc, grouped, newlines-between: always }]` |
+| `sort-imports` | `['error', { ignoreDeclarationSort: true }]` — sort named members |
+| `@typescript-eslint/consistent-type-imports` | `['error', { fixStyle: 'separate-type-imports' }]` — `import type { X }`, never inline `type` specifiers |
+| `import/no-relative-parent-imports` | `'error'` for non-test source — no `../` imports outside tests |
+| `no-eval`, `@typescript-eslint/no-implied-eval` | `'error'` |
+
+## Suppression is forbidden — mechanically enforced
+
+- `linterOptions.noInlineConfig: true` makes **every** `eslint-disable*` comment a lint error.
+- `reportUnusedDisableDirectives: 'error'` flags stale suppressions.
+- Therefore, as an agent working in this package you MUST NOT:
+  - add `eslint-disable`, `eslint-disable-next-line`, `eslint-env`, or inline `/* eslint ... */` config comments;
+  - add entries to any `.eslint-bulk-suppressions.json`;
+  - add `eslintIgnore` keys to `package.json`;
+  - add `@ts-nocheck` or `@ts-ignore` comments;
+  - weaken, reorder, or remove the `strict-codegen` mixin in `eslint.config.js`.
+- If a rule fires, **fix the code** (extract a constant, split the function/module, restructure) — never silence it.
+
+## Deferred rules (do not emulate with hacks)
+
+The following intended rules have no existing implementation in this repository's ESLint
+toolchain and are **not yet enabled** (the user will wire them up later):
+`no-magic-strings`, `no-object-mutation`, `no-array-mutation`,
+`no-placeholder-implementation`, and the custom zero-tolerance import rules
+(`no-re-export`, `require-clean-barrel`, `require-barrel-relative-exports`,
+`no-export-alias`, `no-dynamic-import`, `no-hardcoded-secrets`,
+`no-parent-internal-access`). Write code that would already satisfy them: prefer immutable
+update patterns and named string constants, and never land stubs or `TODO` implementations.
+
+## Design notes for this package
+
+- Test-only project: adapts the rush-lib engine's dual-emit into wire frames and proves conformance (golden parity, raw streams, verbosity isolation, backpressure) through the real protocol and transport packages.

build-tests/rushd-wire-e2e-test/config/jest.config.json

@@ -0,0 +1,3 @@
+{
+  "extends": "local-node-rig/profiles/default/config/jest.config.json"
+}

build-tests/rushd-wire-e2e-test/config/rig.json

@@ -0,0 +1,7 @@
+{
+  // The "rig.json" file directs tools to look for their config files in an external package.
+  // Documentation for this system: https://www.npmjs.com/package/@rushstack/rig-package
+  "$schema": "https://developer.microsoft.com/json-schemas/rig-package/rig.schema.json",
+
+  "rigPackageName": "local-node-rig"
+}

build-tests/rushd-wire-e2e-test/eslint.config.js

@@ -0,0 +1,23 @@
+// Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
+// See LICENSE in the project root for license information.
+
+const nodeProfile = require('local-node-rig/profiles/default/includes/eslint/flat/profile/node');
+const friendlyLocalsMixin = require('local-node-rig/profiles/default/includes/eslint/flat/mixins/friendly-locals');
+const tsdocMixin = require('local-node-rig/profiles/default/includes/eslint/flat/mixins/tsdoc');
+const strictCodegenMixin = require('local-node-rig/profiles/default/includes/eslint/flat/mixins/strict-codegen');
+
+module.exports = [
+  ...nodeProfile,
+  ...friendlyLocalsMixin,
+  ...tsdocMixin,
+  // IMPORTANT: The strict-codegen mixin must remain last so its rules win conflicts.
+  ...strictCodegenMixin,
+  {
+    files: ['**/*.ts', '**/*.tsx'],
+    languageOptions: {
+      parserOptions: {
+        tsconfigRootDir: __dirname
+      }
+    }
+  }
+];

build-tests/rushd-wire-e2e-test/package.json

@@ -0,0 +1,23 @@
+{
+  "name": "rushd-wire-e2e-test",
+  "description": "End-to-end conformance tests for the rushd wire layer (protocol + transport + renderer against the rush-lib engine)",
+  "version": "1.0.0",
+  "private": true,
+  "license": "MIT",
+  "scripts": {
+    "build": "heft build --clean",
+    "_phase:build": "heft run --only build -- --clean",
+    "_phase:test": "heft run --only test -- --clean"
+  },
+  "devDependencies": {
+    "@microsoft/rush-lib": "workspace:*",
+    "@rushstack/heft": "workspace:*",
+    "@rushstack/node-core-library": "workspace:*",
+    "@rushstack/rush-daemon-protocol": "workspace:*",
+    "@rushstack/rush-daemon-transport": "workspace:*",
+    "@rushstack/rush-terminal-renderer": "workspace:*",
+    "@rushstack/terminal": "workspace:*",
+    "eslint": "~9.37.0",
+    "local-node-rig": "workspace:*"
+  }
+}

build-tests/rushd-wire-e2e-test/src/index.ts

@@ -0,0 +1,10 @@
+// Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
+// See LICENSE in the project root for license information.
+
+/**
+ * End-to-end conformance tests for the rushd wire layer. See `src/test/`.
+ *
+ * @packageDocumentation
+ */
+
+export {};

build-tests/rushd-wire-e2e-test/src/test/EngineRunners.ts

@@ -0,0 +1,57 @@
+// Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
+// See LICENSE in the project root for license information.
+
+// Inline operation runners that use runWithTerminalAsync, matching the
+// production runners (ShellOperationRunner, IPCOperationRunner).
+
+import * as os from 'node:os';
+
+import type { RushConfigurationProject } from '@microsoft/rush-lib/lib/api/RushConfigurationProject';
+import type {
+  IOperationRunner,
+  IOperationRunnerContext
+} from '@microsoft/rush-lib/lib/logic/operations/IOperationRunner';
+import { Operation } from '@microsoft/rush-lib/lib/logic/operations/Operation';
+import type { OperationStatus } from '@microsoft/rush-lib/lib/logic/operations/OperationStatus';
+
+function createRunner(name: string, status: OperationStatus): IOperationRunner {
+  return {
+    name,
+    reportTiming: true,
+    silent: false,
+    cacheable: false,
+    warningsAreAllowed: false,
+    isNoOp: false,
+    executeAsync: async (context: IOperationRunnerContext) =>
+      await context.runWithTerminalAsync(
+        async (terminal) => {
+          terminal.writeLine(`${name}-out ünïcode ✓`);
+          terminal.writeErrorLine(`${name}-err`);
+          return status;
+        },
+        { createLogFile: false, logFileSuffix: '' }
+      ),
+    getConfigHash: () => 'e2e'
+  };
+}
+
+/** Creates a fixture operation writing deterministic unicode output. */
+export function createScenarioOperation(name: string, status: OperationStatus): Operation {
+  return new Operation({
+    runner: createRunner(name, status),
+    logFilenameIdentifier: name,
+    phase: {
+      name: 'phase',
+      allowWarningsOnSuccess: false,
+      associatedParameters: new Set(),
+      dependencies: { self: new Set(), upstream: new Set() },
+      isSynthetic: false,
+      logFilenameIdentifier: 'phase',
+      missingScriptBehavior: 'silent'
+    },
+    project: {
+      packageName: name,
+      projectFolder: os.tmpdir()
+    } as unknown as RushConfigurationProject
+  });
+}

build-tests/rushd-wire-e2e-test/src/test/EngineScenario.ts

@@ -0,0 +1,60 @@
+// Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
+// See LICENSE in the project root for license information.
+
+// Builds and runs a small rush-lib operation graph with the dual-emit sink
+// attached, capturing both the legacy terminal output and the wire frames.
+
+import { OperationGraph } from '@microsoft/rush-lib/lib/logic/operations/OperationGraph';
+import type { IOperationGraphOptions } from '@microsoft/rush-lib/lib/logic/operations/OperationGraph';
+import { OperationStatus } from '@microsoft/rush-lib/lib/logic/operations/OperationStatus';
+
+import { createScenarioOperation } from './EngineRunners';
+import { TestWritable } from './TestWritable';
+import { WireAdapter } from './WireAdapter';
+
+const PARALLELISM: number = 1;
+
+/** Options for {@link runEngineScenarioAsync}. */
+export interface IEngineScenarioOptions {
+  /** Run the engine in quiet mode (stdout discarded from the collated terminal). */
+  readonly quiet: boolean;
+  /** Make the `beta` operation fail. */
+  readonly failing?: boolean;
+}
+
+/** The captured result of one engine run. */
+export interface IEngineScenarioResult {
+  /** The legacy terminal output (golden reference). */
+  readonly writable: TestWritable;
+  /** The wire frames produced by the dual-emit sink. */
+  readonly adapter: WireAdapter;
+}
+
+/** Runs the fixture graph to completion with the wire adapter attached. */
+export async function runEngineScenarioAsync(
+  options: IEngineScenarioOptions
+): Promise<IEngineScenarioResult> {
+  const writable: TestWritable = new TestWritable();
+  const adapter: WireAdapter = new WireAdapter();
+  const graphOptions: IOperationGraphOptions = {
+    quietMode: options.quiet,
+    debugMode: false,
+    parallelism: PARALLELISM,
+    allowOversubscription: true,
+    destinations: [writable],
+    abortController: new AbortController()
+  };
+  const graph: OperationGraph = new OperationGraph(
+    new Set([
+      createScenarioOperation('alpha', OperationStatus.Success),
+      createScenarioOperation(
+        'beta',
+        options.failing ? OperationStatus.Failure : OperationStatus.Success
+      )
+    ]),
+    graphOptions
+  );
+  graph.eventSink = adapter;
+  await graph.executeAsync({});
+  return { writable, adapter };
+}

build-tests/rushd-wire-e2e-test/src/test/FrameDispatch.ts

@@ -0,0 +1,43 @@
+// Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT license.
+// See LICENSE in the project root for license information.
+
+// Shared client-side frame dispatch: decoded frames into a renderer host.
+
+import { DaemonFrameType, decodeDaemonEventFrame, decodeDaemonLogChunk } from '@rushstack/rush-daemon-protocol';
+import type { IDaemonFrame, IDaemonLogChunk } from '@rushstack/rush-daemon-protocol';
+import type { DaemonRendererHost } from '@rushstack/rush-terminal-renderer';
+
+const WIRE_DECODER: InstanceType<typeof TextDecoder> = new TextDecoder();
+
+/** Returns true for `0x02`/`0x03` log frames. */
+export function isLogFrame(frame: IDaemonFrame): boolean {
+  return frame.kind === DaemonFrameType.logStdout || frame.kind === DaemonFrameType.logStderr;
+}
+
+/** Maps a log frame type to its stream name. */
+export function toStream(frame: IDaemonFrame): 'stdout' | 'stderr' {
+  return frame.kind === DaemonFrameType.logStderr ? 'stderr' : 'stdout';
+}
+
+/** Routes one decoded frame into the renderer host. */
+export function dispatchFrame(host: DaemonRendererHost, frame: IDaemonFrame): void {
+  if (frame.kind === DaemonFrameType.event) {
+    host.handleEvent(decodeDaemonEventFrame(frame.payload));
+    return;
+  }
+  if (isLogFrame(frame)) {
+    const log: IDaemonLogChunk = decodeDaemonLogChunk(frame.payload);
+    host.handleLogChunk(log.operationId, toStream(frame), log.chunk);
+  }
+}
+
+/** Collects log frame payloads into per-operation ordered text chunks. */
+export function collectLogChunk(perOperation: Map<string, string[]>, frame: IDaemonFrame): void {
+  if (!isLogFrame(frame)) {
+    return;
+  }
+  const log: IDaemonLogChunk = decodeDaemonLogChunk(frame.payload);
+  const chunks: string[] = perOperation.get(log.operationId) ?? [];
+  chunks.push(WIRE_DECODER.decode(log.chunk));
+  perOperation.set(log.operationId, chunks);
+}