Nx MCP Server

import { NxWorkspace } from '@nx-console/shared-types'; import { getPackageManagerCommand } from '@nx-console/shared-npm'; import { getNxWorkspace } from '@nx-console/vscode-nx-workspace'; import { getShellExecutionForConfig } from '@nx-console/vscode-utils'; import type { PackageManagerCommands } from 'nx/src/utils/package-manager'; import { join } from 'path'; import { Task, TaskScope } from 'vscode'; import { CliTaskDefinition } from './cli-task-definition'; import { noProvenanceError, nxLatestProvenanceCheck, } from '@nx-console/shared-utils'; import { getTelemetry } from '@nx-console/vscode-telemetry'; import { vscodeLogger } from '@nx-console/vscode-output-channels'; export class CliTask extends Task { /** * workspace & packageManagerCommands can be passed in to increase performance when creating multiple tasks * if you don't pass them in, they will fetched for you */ static async create( definition: CliTaskDefinition, workspace?: NxWorkspace, packageManagerCommands?: PackageManagerCommands, ): Promise<CliTask | undefined> { // Using `run [project]:[command]` is more backwards compatible in case different // versions of CLI does not handle `[command] [project]` args. const args = getArgs(definition); const nxWorkspace = workspace ?? (await getNxWorkspace()); if (!nxWorkspace) { return; } const { isEncapsulatedNx, workspacePath } = nxWorkspace; if (definition.useLatestNxVersion) { const provenanceResult = await nxLatestProvenanceCheck(workspacePath); if (provenanceResult !== true) { getTelemetry().logUsage('misc.nx-latest-no-provenance'); vscodeLogger.log(provenanceResult); throw new Error(noProvenanceError); } } const displayCommand = `${definition.useLatestNxVersion ? 'nx@latest' : 'nx'} ${args.join(' ')}`; const task = new CliTask( { ...definition, type: 'nx' }, // definition TaskScope.Workspace, // scope displayCommand, // name 'nx', // execution await getShellExecutionForConfig( { displayCommand, cwd: definition.cwd ? join(workspacePath, definition.cwd) : workspacePath, encapsulatedNx: isEncapsulatedNx, workspacePath, env: definition.env, }, packageManagerCommands, ), ); return task; } static async batchCreate( definitions: CliTaskDefinition[], workspace?: NxWorkspace, ): Promise<CliTask[]> { const w = workspace ?? (await getNxWorkspace()); if (!w) { return []; } const packageManagerCommands = await getPackageManagerCommand( w.workspacePath, ); const tasks = await Promise.all( definitions.map((definition) => this.create(definition, w, packageManagerCommands), ), ); return tasks.filter((task) => task !== undefined) as CliTask[]; } } function getArgs(definition: CliTaskDefinition) { const { positional, command, flags } = definition; const args = [command, positional, ...flags]; return args.filter((v) => v !== undefined && v !== null); }