Nx MCP Server

import { Logger, httpRequest, HttpError } from '@nx-console/shared-utils'; import { isNxCloudUsed } from './is-nx-cloud-used'; import { getNxCloudUrl } from './cloud-ids'; import { nxCloudAuthHeaders } from './nx-cloud-auth-headers'; export interface FailedTaskAttemptSummary { startTimeMs: number; endTimeMs: number; durationMs: number; status: string; runId: string; } export interface MTaskMeta { // Define based on your actual MTaskMeta type [key: string]: any; } export interface TaskDetails { taskId: string; runId?: string; projectName: string; target: string; startTimeMs: number; endTimeMs: number; durationMs: number; status: string; cacheStatus: string; isCacheable: boolean; hash: string; targetGroupName?: string; params: string; artifactId?: string; priorAttempts: FailedTaskAttemptSummary[]; terminalOutputUploadedToFileStorage: boolean; parallelism: boolean; meta?: MTaskMeta; continuous: boolean; batchId?: string; associatedBatches: string[]; uploadedToStorage?: boolean; hashScope?: string; } export interface TaskDetailsError { type: 'authentication' | 'network' | 'not_found' | 'other'; message: string; } export async function getTaskDetails( workspacePath: string, logger: Logger, runId: string, encodedTaskId: string, ): Promise<{ data?: TaskDetails; error?: TaskDetailsError; }> { if (!(await isNxCloudUsed(workspacePath, logger))) { return { error: { type: 'other', message: 'Nx Cloud is not used in this workspace', }, }; } const nxCloudUrl = await getNxCloudUrl(workspacePath); const url = `${nxCloudUrl}/nx-cloud/mcp-context/runs/${runId}/tasks/${encodedTaskId}`; const headers: any = { 'Content-Type': 'application/json', ...(await nxCloudAuthHeaders(workspacePath)), }; logger.log( `Making task details request for run ID: ${runId}, task ID: ${encodedTaskId}`, ); try { const response = await httpRequest({ type: 'POST', url, headers, timeout: 10000, }); const responseData = JSON.parse(response.responseText) as TaskDetails; return { data: responseData, }; } catch (e) { if (e instanceof HttpError && e.status === 401) { logger.log(`Authentication error: ${e.responseText}`); return { error: { type: 'authentication', message: e.responseText, }, }; } if (e instanceof HttpError && e.status === 404) { logger.log(`Task not found: ${e.responseText}`); const decodedTaskId = decodeURIComponent(encodedTaskId); return { error: { type: 'not_found', message: `Task with ID ${decodedTaskId} not found in run ${runId}`, }, }; } logger.log(`Error: ${JSON.stringify(e)}`); return { error: { type: 'other', message: e instanceof HttpError ? e.responseText : (e as Error).message, }, }; } } export function formatTaskDetailsContent(task: TaskDetails): string[] { const content: string[] = []; let taskDetailsText = `Task Details for ID: ${task.taskId}\n`; taskDetailsText += `Project: ${task.projectName}, Target: ${task.target}\n`; taskDetailsText += `Status: ${task.status}, Cache Status: ${task.cacheStatus}\n`; taskDetailsText += `Duration: ${Math.round(task.durationMs / 1000)}s\n`; taskDetailsText += `Hash: ${task.hash}\n`; taskDetailsText += `Cacheable: ${task.isCacheable}`; if (task.params) { taskDetailsText += `\nParameters: ${task.params}`; } if (task.priorAttempts && task.priorAttempts.length > 0) { taskDetailsText += `\nPrior Attempts: ${task.priorAttempts.length}`; } content.push(taskDetailsText); return content; }