feat(core): add pre and post run apis

docs/generated/devkit/NxPlugin.md

@@ -2,4 +2,4 @@
 
 Ƭ **NxPlugin**: [`NxPluginV2`](../../devkit/documents/NxPluginV2)
 
-A plugin for Nx
+A plugin which enhances the behavior of Nx

docs/generated/devkit/NxPluginV2.md

@@ -2,7 +2,7 @@
 
 Ƭ **NxPluginV2**\<`TOptions`\>: `Object`
 
-A plugin for Nx which creates nodes and dependencies for the [ProjectGraph](../../devkit/documents/ProjectGraph)
+A plugin which enhances the behavior of Nx
 
 #### Type parameters
 
@@ -19,3 +19,5 @@ A plugin for Nx which creates nodes and dependencies for the [ProjectGraph](../.
 | `createNodes?`        | [`CreateNodes`](../../devkit/documents/CreateNodes)\<`TOptions`\>               | Provides a file pattern and function that retrieves configuration info from those files. e.g. { '**/\*.csproj': buildProjectsFromCsProjFile } **`Deprecated`\*\* Use createNodesV2 instead. In Nx 21 support for calling createNodes with a single file for the first argument will be removed. |
 | `createNodesV2?`      | [`CreateNodesV2`](../../devkit/documents/CreateNodesV2)\<`TOptions`\>           | Provides a file pattern and function that retrieves configuration info from those files. e.g. { '\*_/_.csproj': buildProjectsFromCsProjFiles } In Nx 21 createNodes will be replaced with this property. In Nx 22, this property will be removed.                                               |
 | `name`                | `string`                                                                        | -                                                                                                                                                                                                                                                                                               |
+| `postTasksExecution?` | [`PostTasksExecution`](../../devkit/documents/PostTasksExecution)\<`TOptions`\> | Provides a function to run after the Nx runs tasks                                                                                                                                                                                                                                              |
+| `preTasksExecution?`  | [`PreTasksExecution`](../../devkit/documents/PreTasksExecution)\<`TOptions`\>   | Provides a function to run before the Nx runs tasks                                                                                                                                                                                                                                             |

docs/generated/devkit/PostTasksExecution.md

@@ -0,0 +1,24 @@
+# Type alias: PostTasksExecution\<TOptions\>
+
+Ƭ **PostTasksExecution**\<`TOptions`\>: (`options`: `TOptions` \| `undefined`, `context`: [`PostTasksExecutionContext`](../../devkit/documents/PostTasksExecutionContext)) => `void` \| `Promise`\<`void`\>
+
+#### Type parameters
+
+| Name       | Type      |
+| :--------- | :-------- |
+| `TOptions` | `unknown` |
+
+#### Type declaration
+
+▸ (`options`, `context`): `void` \| `Promise`\<`void`\>
+
+##### Parameters
+
+| Name      | Type                                                                            |
+| :-------- | :------------------------------------------------------------------------------ |
+| `options` | `TOptions` \| `undefined`                                                       |
+| `context` | [`PostTasksExecutionContext`](../../devkit/documents/PostTasksExecutionContext) |
+
+##### Returns
+
+`void` \| `Promise`\<`void`\>

docs/generated/devkit/PostTasksExecutionContext.md

@@ -0,0 +1,11 @@
+# Type alias: PostTasksExecutionContext
+
+Ƭ **PostTasksExecutionContext**: `Object`
+
+#### Type declaration
+
+| Name                  | Type                                                                |
+| :-------------------- | :------------------------------------------------------------------ |
+| `nxJsonConfiguration` | [`NxJsonConfiguration`](../../devkit/documents/NxJsonConfiguration) |
+| `taskResults`         | [`TaskResults`](../../devkit/documents/TaskResults)                 |
+| `workspaceRoot`       | `string`                                                            |

docs/generated/devkit/PreTasksExecution.md

@@ -0,0 +1,24 @@
+# Type alias: PreTasksExecution\<TOptions\>
+
+Ƭ **PreTasksExecution**\<`TOptions`\>: (`options`: `TOptions` \| `undefined`, `context`: [`PreTasksExecutionContext`](../../devkit/documents/PreTasksExecutionContext)) => `void` \| `Promise`\<`void`\>
+
+#### Type parameters
+
+| Name       | Type      |
+| :--------- | :-------- |
+| `TOptions` | `unknown` |
+
+#### Type declaration
+
+▸ (`options`, `context`): `void` \| `Promise`\<`void`\>
+
+##### Parameters
+
+| Name      | Type                                                                          |
+| :-------- | :---------------------------------------------------------------------------- |
+| `options` | `TOptions` \| `undefined`                                                     |
+| `context` | [`PreTasksExecutionContext`](../../devkit/documents/PreTasksExecutionContext) |
+
+##### Returns
+
+`void` \| `Promise`\<`void`\>

docs/generated/devkit/PreTasksExecutionContext.md

@@ -0,0 +1,10 @@
+# Type alias: PreTasksExecutionContext
+
+Ƭ **PreTasksExecutionContext**: `Object`
+
+#### Type declaration
+
+| Name                  | Type                                                                |
+| :-------------------- | :------------------------------------------------------------------ |
+| `nxJsonConfiguration` | [`NxJsonConfiguration`](../../devkit/documents/NxJsonConfiguration) |
+| `workspaceRoot`       | `string`                                                            |

docs/generated/devkit/README.md

@@ -59,6 +59,7 @@ It only uses language primitives and immutable objects
 - [Task](../../devkit/documents/Task)
 - [TaskGraph](../../devkit/documents/TaskGraph)
 - [TaskHasher](../../devkit/documents/TaskHasher)
+- [TaskResult](../../devkit/documents/TaskResult)
 - [Tree](../../devkit/documents/Tree)
 - [Workspace](../../devkit/documents/Workspace)
 
@@ -86,6 +87,10 @@ It only uses language primitives and immutable objects
 - [NxPluginV2](../../devkit/documents/NxPluginV2)
 - [PackageManager](../../devkit/documents/PackageManager)
 - [PluginConfiguration](../../devkit/documents/PluginConfiguration)
+- [PostTasksExecution](../../devkit/documents/PostTasksExecution)
+- [PostTasksExecutionContext](../../devkit/documents/PostTasksExecutionContext)
+- [PreTasksExecution](../../devkit/documents/PreTasksExecution)
+- [PreTasksExecutionContext](../../devkit/documents/PreTasksExecutionContext)
 - [ProjectType](../../devkit/documents/ProjectType)
 - [ProjectsMetadata](../../devkit/documents/ProjectsMetadata)
 - [PromiseExecutor](../../devkit/documents/PromiseExecutor)
@@ -94,6 +99,7 @@ It only uses language primitives and immutable objects
 - [StringChange](../../devkit/documents/StringChange)
 - [TargetDefaults](../../devkit/documents/TargetDefaults)
 - [TaskGraphExecutor](../../devkit/documents/TaskGraphExecutor)
+- [TaskResults](../../devkit/documents/TaskResults)
 - [ToJSOptions](../../devkit/documents/ToJSOptions)
 - [WorkspaceJsonConfiguration](../../devkit/documents/WorkspaceJsonConfiguration)
 

docs/generated/devkit/TaskResult.md

@@ -0,0 +1,36 @@
+# Interface: TaskResult
+
+The result of a completed [Task](../../devkit/documents/Task)
+
+## Table of contents
+
+### Properties
+
+- [code](../../devkit/documents/TaskResult#code): number
+- [status](../../devkit/documents/TaskResult#status): TaskStatus
+- [task](../../devkit/documents/TaskResult#task): Task
+- [terminalOutput](../../devkit/documents/TaskResult#terminaloutput): string
+
+## Properties
+
+### code
+
+• **code**: `number`
+
+---
+
+### status
+
+• **status**: `TaskStatus`
+
+---
+
+### task
+
+• **task**: [`Task`](../../devkit/documents/Task)
+
+---
+
+### terminalOutput
+
+• `Optional` **terminalOutput**: `string`

docs/generated/devkit/TaskResults.md

@@ -0,0 +1,5 @@
+# Type alias: TaskResults
+
+Ƭ **TaskResults**: `Record`\<`string`, [`TaskResult`](../../devkit/documents/TaskResult)\>
+
+A map of [TaskResult](../../devkit/documents/TaskResult) keyed by the ID of the completed [Task](../../devkit/documents/Task)s

docs/generated/packages/devkit/documents/nx_devkit.md

@@ -59,6 +59,7 @@ It only uses language primitives and immutable objects
 - [Task](../../devkit/documents/Task)
 - [TaskGraph](../../devkit/documents/TaskGraph)
 - [TaskHasher](../../devkit/documents/TaskHasher)
+- [TaskResult](../../devkit/documents/TaskResult)
 - [Tree](../../devkit/documents/Tree)
 - [Workspace](../../devkit/documents/Workspace)
 
@@ -86,6 +87,10 @@ It only uses language primitives and immutable objects
 - [NxPluginV2](../../devkit/documents/NxPluginV2)
 - [PackageManager](../../devkit/documents/PackageManager)
 - [PluginConfiguration](../../devkit/documents/PluginConfiguration)
+- [PostTasksExecution](../../devkit/documents/PostTasksExecution)
+- [PostTasksExecutionContext](../../devkit/documents/PostTasksExecutionContext)
+- [PreTasksExecution](../../devkit/documents/PreTasksExecution)
+- [PreTasksExecutionContext](../../devkit/documents/PreTasksExecutionContext)
 - [ProjectType](../../devkit/documents/ProjectType)
 - [ProjectsMetadata](../../devkit/documents/ProjectsMetadata)
 - [PromiseExecutor](../../devkit/documents/PromiseExecutor)
@@ -94,6 +99,7 @@ It only uses language primitives and immutable objects
 - [StringChange](../../devkit/documents/StringChange)
 - [TargetDefaults](../../devkit/documents/TargetDefaults)
 - [TaskGraphExecutor](../../devkit/documents/TaskGraphExecutor)
+- [TaskResults](../../devkit/documents/TaskResults)
 - [ToJSOptions](../../devkit/documents/ToJSOptions)
 - [WorkspaceJsonConfiguration](../../devkit/documents/WorkspaceJsonConfiguration)
 

e2e/jest/src/jest.test.ts

@@ -14,6 +14,7 @@ import {
 describe('Jest', () => {
   beforeAll(() => {
     newProject({ name: uniq('proj-jest'), packages: ['@nx/js', '@nx/node'] });
+    process.env.NX_E2E_VERBOSE_LOGGING = 'true';
   });
 
   afterAll(() => cleanupProject());

packages/devkit/src/utils/convert-nx-executor.spec.ts

@@ -29,7 +29,7 @@ describe('Convert Nx Executor', () => {
 
     const registry = new schema.CoreSchemaRegistry();
     registry.addPostTransform(schema.transforms.addUndefinedDefaults);
-    const testArchitectHost = new TestingArchitectHost();
+    const testArchitectHost = new TestingArchitectHost(fs.tempDir, fs.tempDir);
     testArchitectHost.workspaceRoot = fs.tempDir;
     const architect = new Architect(testArchitectHost, registry);
 

packages/nx/src/command-line/release/publish.ts

@@ -26,6 +26,11 @@ import {
 import { deepMergeJson } from './config/deep-merge-json';
 import { filterReleaseGroups } from './config/filter-release-groups';
 import { printConfigAndExit } from './utils/print-config';
+import { workspaceRoot } from '../../utils/workspace-root';
+import {
+  runPostTasksExecution,
+  runPreTasksExecution,
+} from '../../project-graph/plugins/tasks-execution-hooks';
 
 export interface PublishProjectsResult {
   [projectName: string]: {
@@ -249,6 +254,10 @@ async function runPublishOnProjects(
       ].join('\n')}\n`
     );
   }
+  await runPreTasksExecution({
+    workspaceRoot,
+    nxJsonConfiguration: nxJson,
+  });
 
   /**
    * Run the relevant nx-release-publish executor on each of the selected projects.
@@ -276,6 +285,11 @@ async function runPublishOnProjects(
       code: taskData.code,
     };
   }
+  await runPostTasksExecution({
+    taskResults: commandResults,
+    workspaceRoot,
+    nxJsonConfiguration: nxJson,
+  });
 
   return publishProjectsResult;
 }

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

@@ -78,6 +78,16 @@ import {
   type HandleFlushSyncGeneratorChangesToDiskMessage,
 } from '../message-types/flush-sync-generator-changes-to-disk';
 import { DelayedSpinner } from '../../utils/delayed-spinner';
+import {
+  PostTasksExecutionContext,
+  PreTasksExecutionContext,
+} from '../../project-graph/plugins/public-api';
+import {
+  HandlePostTasksExecutionMessage,
+  HandlePreTasksExecutionMessage,
+  POST_TASKS_EXECUTION,
+  PRE_TASKS_EXECUTION,
+} from '../message-types/run-tasks-execution-hooks';
 
 const DAEMON_ENV_SETTINGS = {
   NX_PROJECT_GLOB_CACHE: 'false',
@@ -435,6 +445,26 @@ export class DaemonClient {
     return this.sendToDaemonViaQueue(message);
   }
 
+  async runPreTasksExecution(
+    context: PreTasksExecutionContext
+  ): Promise<NodeJS.ProcessEnv[]> {
+    const message: HandlePreTasksExecutionMessage = {
+      type: PRE_TASKS_EXECUTION,
+      context,
+    };
+    return this.sendToDaemonViaQueue(message);
+  }
+
+  async runPostTasksExecution(
+    context: PostTasksExecutionContext
+  ): Promise<void> {
+    const message: HandlePostTasksExecutionMessage = {
+      type: POST_TASKS_EXECUTION,
+      context,
+    };
+    return this.sendToDaemonViaQueue(message);
+  }
+
   async isServerAvailable(): Promise<boolean> {
     return new Promise((resolve) => {
       try {

packages/nx/src/daemon/message-types/run-tasks-execution-hooks.ts

@@ -0,0 +1,38 @@
+import type {
+  PostTasksExecutionContext,
+  PreTasksExecutionContext,
+} from '../../project-graph/plugins';
+
+export const PRE_TASKS_EXECUTION = 'PRE_TASKS_EXECUTION' as const;
+export const POST_TASKS_EXECUTION = 'POST_TASKS_EXECUTION' as const;
+
+export type HandlePreTasksExecutionMessage = {
+  type: typeof PRE_TASKS_EXECUTION;
+  context: PreTasksExecutionContext;
+};
+export type HandlePostTasksExecutionMessage = {
+  type: typeof POST_TASKS_EXECUTION;
+  context: PostTasksExecutionContext;
+};
+
+export function isHandlePreTasksExecutionMessage(
+  message: unknown
+): message is HandlePreTasksExecutionMessage {
+  return (
+    typeof message === 'object' &&
+    message !== null &&
+    'type' in message &&
+    message['type'] === PRE_TASKS_EXECUTION
+  );
+}
+
+export function isHandlePostTasksExecutionMessage(
+  message: unknown
+): message is HandlePostTasksExecutionMessage {
+  return (
+    typeof message === 'object' &&
+    message !== null &&
+    'type' in message &&
+    message['type'] === POST_TASKS_EXECUTION
+  );
+}

packages/nx/src/daemon/server/handle-tasks-execution-hooks.ts

@@ -0,0 +1,41 @@
+import type {
+  PostTasksExecutionContext,
+  PreTasksExecutionContext,
+} from '../../project-graph/plugins/public-api';
+import {
+  runPostTasksExecution,
+  runPreTasksExecution,
+} from '../../project-graph/plugins/tasks-execution-hooks';
+
+export async function handleRunPreTasksExecution(
+  context: PreTasksExecutionContext
+) {
+  try {
+    const envs = await runPreTasksExecution(context);
+    return {
+      response: JSON.stringify(envs),
+      description: 'handleRunPreTasksExecution',
+    };
+  } catch (e) {
+    return {
+      error: e,
+      description: `Error when running preTasksExecution.`,
+    };
+  }
+}
+export async function handleRunPostTasksExecution(
+  context: PostTasksExecutionContext
+) {
+  try {
+    await runPostTasksExecution(context);
+    return {
+      response: 'true',
+      description: 'handleRunPostTasksExecution',
+    };
+  } catch (e) {
+    return {
+      error: e,
+      description: `Error when running postTasksExecution.`,
+    };
+  }
+}

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

@@ -110,6 +110,16 @@ import {
   isHandleFlushSyncGeneratorChangesToDiskMessage,
 } from '../message-types/flush-sync-generator-changes-to-disk';
 import { handleFlushSyncGeneratorChangesToDisk } from './handle-flush-sync-generator-changes-to-disk';
+import {
+  isHandlePostTasksExecutionMessage,
+  isHandlePreTasksExecutionMessage,
+  POST_TASKS_EXECUTION,
+  PRE_TASKS_EXECUTION,
+} from '../message-types/run-tasks-execution-hooks';
+import {
+  handleRunPostTasksExecution,
+  handleRunPreTasksExecution,
+} from './handle-tasks-execution-hooks';
 
 let performanceObserver: PerformanceObserver | undefined;
 let workspaceWatcherError: Error | undefined;
@@ -281,6 +291,14 @@ async function handleMessage(socket, data: string) {
         payload.deletedFiles
       )
     );
+  } else if (isHandlePreTasksExecutionMessage(payload)) {
+    await handleResult(socket, PRE_TASKS_EXECUTION, () =>
+      handleRunPreTasksExecution(payload.context)
+    );
+  } else if (isHandlePostTasksExecutionMessage(payload)) {
+    await handleResult(socket, POST_TASKS_EXECUTION, () =>
+      handleRunPostTasksExecution(payload.context)
+    );
   } else {
     await respondWithErrorAndExit(
       socket,