DevOps AI Toolkit

/** * Deploy Manifests Tool - Apply Kubernetes manifests or execute Helm installations * Supports both capability-based solutions (kubectl apply) and Helm-based solutions (helm install) */ import { z } from 'zod'; import { ErrorHandler } from '../core/error-handling'; import { DeployOperation } from '../core/deploy-operation'; import { DotAI } from '../core/index'; import { Logger } from '../core/error-handling'; import { ensureClusterConnection } from '../core/cluster-utils'; import { GenericSessionManager } from '../core/generic-session-manager'; import type { SolutionData } from './recommend'; import { extractUserAnswers } from '../core/solution-utils'; import { deployHelmRelease, getHelmValuesPath, helmValuesExist } from '../core/helm-utils'; import { HelmChartInfo } from '../core/helm-types'; // Tool metadata for direct MCP registration export const DEPLOYMANIFESTS_TOOL_NAME = 'deployManifests'; export const DEPLOYMANIFESTS_TOOL_DESCRIPTION = 'Deploy Kubernetes manifests from generated solution with kubectl apply --wait'; // Zod schema for MCP registration export const DEPLOYMANIFESTS_TOOL_INPUT_SCHEMA = { solutionId: z.string().regex(/^sol-\d+-[a-f0-9]{8}$/).describe('Solution ID to deploy (e.g., sol-1762983784617-9ddae2b8)'), timeout: z.number().min(1).max(600).optional().describe('Deployment timeout in seconds (default: 30)') }; /** * Direct MCP tool handler for deployManifests functionality */ export async function handleDeployManifestsTool( args: { solutionId: string; timeout?: number }, dotAI: DotAI, logger: Logger, requestId: string ): Promise<{ content: { type: 'text'; text: string }[] }> { return await ErrorHandler.withErrorHandling( async () => { logger.debug('Handling deployManifests request', { requestId, solutionId: args?.solutionId, timeout: args?.timeout }); // Input validation is handled automatically by MCP SDK with Zod schema // args are already validated and typed when we reach this point // Ensure cluster connectivity before proceeding await ensureClusterConnection(dotAI, logger, requestId, 'DeployManifestsTool'); // Load solution session to determine solution type const sessionManager = new GenericSessionManager<SolutionData>('sol'); const session = sessionManager.getSession(args.solutionId); if (!session) { throw new Error(`Solution not found: ${args.solutionId}`); } const solution = session.data; const timeout = args.timeout || 30; logger.debug('Solution loaded successfully', { solutionId: args.solutionId, solutionType: solution.type }); // Branch based on solution type if (solution.type === 'helm') { logger.info('Detected Helm solution, using Helm deployment flow', { solutionId: args.solutionId, chart: solution.chart ? `${solution.chart.repositoryName}/${solution.chart.chartName}` : 'unknown' }); if (!solution.chart) { throw new Error('Helm solution missing chart information'); } const chart: HelmChartInfo = solution.chart; const userAnswers = extractUserAnswers(solution); const releaseName = userAnswers.name; const namespace = userAnswers.namespace || 'default'; if (!releaseName) { throw new Error('Release name (name) is required for Helm deployment'); } // Get values path if values file exists const valuesPath = helmValuesExist(args.solutionId) ? getHelmValuesPath(args.solutionId) : undefined; logger.info('Starting Helm deployment', { solutionId: args.solutionId, chart: `${chart.repositoryName}/${chart.chartName}`, releaseName, namespace, hasValuesFile: !!valuesPath, timeout, requestId }); const result = await deployHelmRelease( chart, releaseName, namespace, valuesPath, timeout ); logger.info('Helm deployment completed', { success: result.success, solutionId: args.solutionId, releaseName, namespace, requestId }); const response = { success: result.success, solutionId: args.solutionId, solutionType: 'helm', releaseName, namespace, chart: { repository: chart.repository, repositoryName: chart.repositoryName, chartName: chart.chartName, version: chart.version }, message: result.success ? `Helm release "${releaseName}" deployed successfully to namespace "${namespace}"` : `Helm deployment failed: ${result.error}`, helmOutput: result.output || result.error, deploymentComplete: result.success, timestamp: new Date().toISOString() }; return { content: [{ type: 'text' as const, text: JSON.stringify(response, null, 2) }] }; } // Capability-based solution: Use existing DeployOperation logger.info('Using capability-based deployment flow', { solutionId: args.solutionId }); const deployOp = new DeployOperation(); const deployOptions = { solutionId: args.solutionId, timeout }; logger.info('Starting deployment operation', { solutionId: args.solutionId, timeout: deployOptions.timeout, requestId }); const result = await deployOp.deploy(deployOptions); logger.info('Deployment operation completed', { success: result.success, solutionId: result.solutionId, manifestPath: result.manifestPath, readinessTimeout: result.readinessTimeout, requestId }); // Prepare response with deployment status const response = { success: result.success, solutionId: result.solutionId, solutionType: 'capability', manifestPath: result.manifestPath, readinessTimeout: result.readinessTimeout, message: result.message, kubectlOutput: result.kubectlOutput, // Additional deployment status info deploymentComplete: result.success && !result.readinessTimeout, requiresStatusCheck: result.success && result.readinessTimeout, timestamp: new Date().toISOString() }; return { content: [{ type: 'text' as const, text: JSON.stringify(response, null, 2) }] }; }, { operation: 'deploy_manifests', component: 'DeployManifestsTool', requestId, input: args } ); }