feat(core): retrieve file data from the daemon

packages/nx/src/command-line/affected/affected.ts

@@ -21,8 +21,8 @@ import { TargetDependencyConfig } from '../../config/workspace-json-project-json
 import { readNxJson } from '../../config/configuration';
 import { workspaceConfigurationCheck } from '../../utils/workspace-configuration-check';
 import { findMatchingProjects } from '../../utils/find-matching-projects';
-import { fileHasher } from '../../hasher/impl';
 import { generateGraph } from '../graph/graph';
+import { allFileData } from '../../utils/all-file-data';
 
 export async function affected(
   command: 'graph' | 'print-affected' | 'affected',
@@ -125,14 +125,13 @@ async function projectsToRun(
   nxArgs: NxArgs,
   projectGraph: ProjectGraph
 ): Promise<ProjectGraphProjectNode[]> {
-  fileHasher.ensureInitialized();
   let affectedGraph = nxArgs.all
     ? projectGraph
     : await filterAffected(
         projectGraph,
         calculateFileChanges(
           parseFiles(nxArgs).files,
-          fileHasher.allFileData(),
+          await allFileData(),
           nxArgs
         )
       );

packages/nx/src/command-line/format/format.ts

@@ -21,7 +21,7 @@ import { filterAffected } from '../../project-graph/affected/affected-project-gr
 import { readNxJson } from '../../config/configuration';
 import { ProjectGraph } from '../../config/project-graph';
 import { chunkify } from '../../utils/chunkify';
-import { fileHasher } from '../../hasher/impl';
+import { allFileData } from '../../utils/all-file-data';
 
 const PRETTIER_PATH = require.resolve('prettier/bin-prettier');
 
@@ -93,7 +93,7 @@ async function getPatterns(
     );
 
     return args.libsAndApps
-      ? await getPatternsFromApps(patterns, fileHasher.allFileData(), graph)
+      ? await getPatternsFromApps(patterns, await allFileData(), graph)
       : patterns;
   } catch {
     return allFilesPattern;

packages/nx/src/command-line/show/show.ts

@@ -15,12 +15,8 @@ import {
   ProjectGraphProjectNode,
 } from '../../config/project-graph';
 import { findMatchingProjects } from '../../utils/find-matching-projects';
-import { fileHasher } from '../../hasher/impl';
-import {
-  NxShowArgs,
-  ShowProjectsOptions,
-  ShowProjectOptions,
-} from './command-object';
+import { ShowProjectOptions, ShowProjectsOptions } from './command-object';
+import { allFileData } from '../../utils/all-file-data';
 
 export async function showProjectsHandler(
   args: ShowProjectsOptions
@@ -137,18 +133,14 @@ function getGraphNodesMatchingPatterns(
   return nodes;
 }
 
-function getAffectedGraph(
+async function getAffectedGraph(
   nxArgs: NxArgs,
   nxJson: NxJsonConfiguration<'*' | string[]>,
   graph: ProjectGraph
 ) {
   return filterAffected(
     graph,
-    calculateFileChanges(
-      parseFiles(nxArgs).files,
-      fileHasher.allFileData(),
-      nxArgs
-    ),
+    calculateFileChanges(parseFiles(nxArgs).files, await allFileData(), nxArgs),
     nxJson
   );
 }

packages/nx/src/daemon/client/client.ts

@@ -14,7 +14,7 @@ import {
   isDaemonDisabled,
   removeSocketDir,
 } from '../tmp-dir';
-import { ProjectGraph } from '../../config/project-graph';
+import { FileData, ProjectGraph } from '../../config/project-graph';
 import { isCI } from '../../utils/is-ci';
 import { NxJsonConfiguration } from '../../config/nx-json';
 import { readNxJson } from '../../config/configuration';
@@ -116,6 +116,10 @@ export class DaemonClient {
       .projectGraph;
   }
 
+  async getAllFileData(): Promise<FileData[]> {
+    return await this.sendToDaemonViaQueue({ type: 'REQUEST_FILE_DATA' });
+  }
+
   hashTasks(runnerOptions: any, tasks: Task[]): Promise<Hash[]> {
     return this.sendToDaemonViaQueue({
       type: 'HASH_TASKS',

packages/nx/src/daemon/server/handle-request-file-data.ts

@@ -0,0 +1,9 @@
+import { fileHasher } from '../../hasher/impl';
+
+export async function handleRequestFileData() {
+  const response = JSON.stringify(fileHasher.allFileData());
+  return {
+    response,
+    description: 'handleRequestFileData',
+  };
+}

packages/nx/src/daemon/server/server.ts

@@ -51,6 +51,7 @@ import { PackageJson } from '../../utils/package-json';
 import { getDaemonProcessIdSync, writeDaemonJsonProcessCache } from '../cache';
 import { handleHashTasks } from './handle-hash-tasks';
 import { fileHasher, hashArray } from '../../hasher/impl';
+import { handleRequestFileData } from './handle-request-file-data';
 
 let performanceObserver: PerformanceObserver | undefined;
 let workspaceWatcherError: Error | undefined;
@@ -141,6 +142,8 @@ async function handleMessage(socket, data: string) {
     await handleResult(socket, await handleRequestProjectGraph());
   } else if (payload.type === 'HASH_TASKS') {
     await handleResult(socket, await handleHashTasks(payload));
+  } else if (payload.type === 'REQUEST_FILE_DATA') {
+    await handleResult(socket, await handleRequestFileData());
   } else if (payload.type === 'PROCESS_IN_BACKGROUND') {
     await handleResult(socket, await handleProcessInBackground(payload));
   } else if (payload.type === 'RECORD_OUTPUTS_HASH') {

packages/nx/src/utils/all-file-data.ts

@@ -0,0 +1,12 @@
+import { FileData } from '../config/project-graph';
+import { daemonClient } from '../daemon/client/client';
+import { fileHasher } from '../hasher/impl';
+
+export function allFileData(): Promise<FileData[]> {
+  if (daemonClient.enabled()) {
+    return daemonClient.getAllFileData();
+  } else {
+    fileHasher.ensureInitialized();
+    return Promise.resolve(fileHasher.allFileData());
+  }
+}