Add direct Rush reporter demo path

apps/rush/src/MinimalRushConfiguration.ts

@@ -3,10 +3,14 @@
 
 import * as path from 'node:path';
 
-import { FileSystem, JsonFile } from '@rushstack/node-core-library';
+import { FileSystem, JsonFile, PackageJsonLookup } from '@rushstack/node-core-library';
 import { RushConfiguration } from '@microsoft/rush-lib';
+import { EnvironmentConfiguration } from '@microsoft/rush-lib/lib/api/EnvironmentConfiguration';
 import { RushConstants } from '@microsoft/rush-lib/lib/logic/RushConstants';
 import { RushCommandLineParser } from '@microsoft/rush-lib/lib/cli/RushCommandLineParser';
+import { isSupportedReporterName, type ReporterName } from '@rushstack/rush-reporter';
+
+import { getRushPreviewVersion } from './RushPreviewVersion';
 
 interface IMinimalRushConfigurationJson {
   rushMinimumVersion: string;
@@ -52,14 +56,37 @@ export class MinimalRushConfiguration {
   }
 
   public static loadFromDefaultLocation(): MinimalRushConfiguration | undefined {
+    const showVerbose: boolean = !RushCommandLineParser.shouldRestrictConsoleOutput();
     const rushJsonLocation: string | undefined = RushConfiguration.tryFindRushJsonLocation({
-      showVerbose: !RushCommandLineParser.shouldRestrictConsoleOutput()
+      showVerbose: false
     });
     if (rushJsonLocation) {
       const minimalRushConfigurationJson: IMinimalRushConfigurationJson | undefined =
         _loadConfigurationJson(rushJsonLocation);
       if (minimalRushConfigurationJson) {
-        return new MinimalRushConfiguration(minimalRushConfigurationJson, rushJsonLocation);
+        const configuration: MinimalRushConfiguration = new MinimalRushConfiguration(
+          minimalRushConfigurationJson,
+          rushJsonLocation
+        );
+        const explicitReporter: ReporterName | undefined = _getExplicitReporter(process.argv.slice(2));
+        const currentPackageVersion: string = PackageJsonLookup.loadOwnPackageJson(__dirname).version;
+        const effectiveRushVersion: string = getRushPreviewVersion() ?? configuration.rushVersion;
+        const legacyFallbackRequested: boolean =
+          explicitReporter === 'legacy' ||
+          process.env.RUSH_REPORTER?.trim().toLowerCase() === 'legacy' ||
+          _hasHelpControl(process.argv.slice(2)) ||
+          effectiveRushVersion !== currentPackageVersion;
+        if (
+          showVerbose &&
+          (legacyFallbackRequested ||
+            (!configuration.useRushReporter &&
+              (explicitReporter === undefined || explicitReporter === 'legacy')))
+        ) {
+          // Preserve the legacy discovery message exactly when the reporter path is not taking ownership.
+          console.log('Found configuration in ' + rushJsonLocation);
+          console.log('');
+        }
+        return configuration;
       }
       return undefined;
     } else {
@@ -94,6 +121,53 @@ export class MinimalRushConfiguration {
   public get useRushReporter(): boolean {
     return this._useRushReporter;
   }
+
+  /**
+   * The repository's common temp folder, used for invocation-scoped reporter logs.
+   */
+  public get commonTempFolder(): string {
+    return (
+      EnvironmentConfiguration._getRushTempFolderOverride(process.env) ??
+      path.resolve(this._commonRushConfigFolder, '..', '..', 'temp')
+    );
+  }
+}
+
+function _getExplicitReporter(argv: readonly string[]): ReporterName | undefined {
+  for (let index: number = 0; index < argv.length; index++) {
+    const argument: string = argv[index];
+    if (argument === '--') {
+      break;
+    }
+    let value: string | undefined;
+    if (argument === '--reporter') {
+      const nextArgument: string | undefined = argv[index + 1];
+      if (!nextArgument || nextArgument.startsWith('-')) {
+        continue;
+      }
+      value = nextArgument;
+      index++;
+    } else if (argument.startsWith('--reporter=')) {
+      value = argument.slice('--reporter='.length);
+    }
+    if (value !== undefined) {
+      const normalizedValue: string = value.trim().toLowerCase();
+      return isSupportedReporterName(normalizedValue) ? normalizedValue : undefined;
+    }
+  }
+  return undefined;
+}
+
+function _hasHelpControl(argv: readonly string[]): boolean {
+  for (const argument of argv) {
+    if (argument === '--') {
+      return false;
+    }
+    if (argument === '--help' || argument === '-h') {
+      return true;
+    }
+  }
+  return false;
 }
 
 function _loadConfigurationJson(rushJsonFilename: string): IMinimalRushConfigurationJson | undefined {

apps/rush/src/RushFrontend.ts

@@ -4,7 +4,7 @@
 import { randomUUID } from 'node:crypto';
 
 import type { ILaunchOptions } from '@microsoft/rush-lib';
-import { DEFAULT_SIGNAL_FLUSH_TIMEOUT_MS } from '@rushstack/rush-reporter';
+import { DEFAULT_SIGNAL_FLUSH_TIMEOUT_MS, REPORTER_PROTOCOL_VERSION } from '@rushstack/rush-reporter';
 
 import {
   initializeRushReporterHostAsync,
@@ -139,10 +139,14 @@ export async function launchRushFrontendAsync(options: IRushFrontendOptions): Pr
     processLifecycle = createProcessLifecycle()
   } = options;
 
+  const engineArgv: string[] = stripReporterValueControls(process.argv.slice(2));
+  const actionName: string | undefined = engineArgv.find((argument: string) => !argument.startsWith('-'));
   const reporterHost: IInitializedRushReporterHost = await initializeReporterHostAsync({
     repositoryOptIn: configuration?.useRushReporter,
     forceLegacy: rushVersionToLoad !== undefined && rushVersionToLoad !== currentPackageVersion,
-    selectedRushVersion: rushVersionToLoad
+    selectedRushVersion: rushVersionToLoad,
+    commonTempFolder: actionName === 'purge' ? undefined : configuration?.commonTempFolder,
+    actionName
   });
   const reporterLifecycle: RushFrontendReporterLifecycle | undefined = reporterHost.selection.enabled
     ? new RushFrontendReporterLifecycle(reporterHost, processLifecycle)
@@ -153,10 +157,27 @@ export async function launchRushFrontendAsync(options: IRushFrontendOptions): Pr
       process.argv,
       new Set(reporterHost.selection.reporterValueFlagsToStrip)
     );
+    delete process.env.RUSH_REPORTER;
+    delete process.env.RUSH_LOG_LEVEL;
   }
   const reporterCloseAsync: () => Promise<void> = () =>
     reporterLifecycle?.closeAsync() ?? reporterHost.closeAsync();
   const sessionId: string = createSessionId();
+  if (reporterHost.selection.enabled && reporterHost.logArtifact?.path) {
+    reporterHost.sink.emit({
+      protocolVersion: REPORTER_PROTOCOL_VERSION,
+      sessionId,
+      source: { packageName: '@microsoft/rush', packageVersion: currentPackageVersion },
+      privacy: 'local-sensitive',
+      type: 'artifactAvailable',
+      payload: {
+        role: 'log',
+        path: reporterHost.logArtifact.path,
+        format: 'plaintext',
+        complete: false
+      }
+    });
+  }
   const reporterLaunchOptions: IRushFrontendLaunchOptions = {
     ...launchOptions,
     reporter: {

apps/rush/src/RushPreviewVersion.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.
+
+import { EnvironmentVariableNames } from '@microsoft/rush-lib/lib/api/EnvironmentConfiguration';
+
+export function getRushPreviewVersion(
+  env: Record<string, string | undefined> = process.env
+): string | undefined {
+  return env[EnvironmentVariableNames.RUSH_PREVIEW_VERSION] || undefined;
+}