Optimizely DXP MCP Server

/** * Content Tools Module * Handles content synchronization operations * Part of Jaxon Digital Optimizely DXP MCP Server */ import ResponseBuilder from '../response-builder'; import ErrorHandler from '../error-handler'; import Config from '../config'; import DXPRestClient from '../dxp-rest-client'; /** * Content copy arguments */ export interface ContentCopyArgs { apiKey?: string; apiSecret?: string; projectId?: string; projectName?: string; sourceEnvironment?: string; targetEnvironment?: string; isSelfHosted?: boolean; connectionString?: string; apiUrl?: string; } /** * Content copy structured data */ export interface ContentCopyData { deploymentId: string | null; sourceEnvironment: string; targetEnvironment: string; type: string; status: string; includesCode: boolean; includesDatabase: boolean; includesBlobs: boolean; } /** * Content copy result with data and message */ export interface ContentCopyResult { data: ContentCopyData; message: string; } /** * Project configuration for permission checking */ interface ProjectConfig { apiKey: string; apiSecret: string; projectId: string; id: string; name: string; } /** * Deployment API response */ interface DeploymentResponse { id?: string; status?: string; } class ContentTools { /** * Copy content between environments handler */ static async handleCopyContent(args: ContentCopyArgs): Promise<any> { // Check if this is a self-hosted project if (args.isSelfHosted || args.connectionString) { return ResponseBuilder.invalidParams('Content copy is not available for self-hosted projects. Self-hosted projects can only download existing backups and blobs.'); } // Validate parameters if (!args.apiKey || !args.apiSecret || !args.projectId || !args.sourceEnvironment || !args.targetEnvironment) { return ResponseBuilder.invalidParams('Missing required parameters for content copy'); } // Validate that source and target are different if (args.sourceEnvironment === args.targetEnvironment) { return ResponseBuilder.invalidParams('Source and target environments must be different'); } // Check permissions for both environments const PermissionChecker = require('./permission-checker'); const projectConfig: ProjectConfig = { apiKey: args.apiKey, apiSecret: args.apiSecret, projectId: args.projectId, id: args.projectId, name: args.projectName || 'Project' }; const permissions = await PermissionChecker.getOrCheckPermissionsSafe(projectConfig); // Check if user has access to both source and target const missingAccess: string[] = []; if (!permissions.accessible.includes(args.sourceEnvironment)) { missingAccess.push(args.sourceEnvironment); } if (!permissions.accessible.includes(args.targetEnvironment)) { missingAccess.push(args.targetEnvironment); } if (missingAccess.length > 0) { let response = `ℹ️ **Access Level Check**\n\n`; response += `Content copy requires access to both source and target environments.\n\n`; response += `**Requested:** ${args.sourceEnvironment} → ${args.targetEnvironment}\n`; response += `**Your access level:** ${permissions.accessible.join(', ')} environment${permissions.accessible.length > 1 ? 's' : ''}\n`; response += `**Additional access needed:** ${missingAccess.join(', ')}\n\n`; // Suggest alternatives based on what they have access to if (permissions.accessible.length >= 2) { response += `**Available Content Copy Options:**\n`; // Show valid copy directions based on their access const copyOptions = PermissionChecker.getContentCopyDefaults(permissions); if (copyOptions) { response += `• ${copyOptions.description}: \`copy_content sourceEnvironment: "${copyOptions.source}" targetEnvironment: "${copyOptions.target}"\`\n`; } response += `\n💡 **Tip:** Content typically flows from higher to lower environments (Prod→Pre→Int).`; } else if (permissions.accessible.length === 1) { response += `⚠️ You need access to at least 2 environments to copy content.\n`; response += `Your API key only has access to ${permissions.accessible[0]}.`; } return ResponseBuilder.success(response); } try { const result = await this.copyContent(args); // DXP-66: Check if result is structured response with data and message if (result && typeof result === 'object' && 'data' in result && 'message' in result) { return ResponseBuilder.successWithStructuredData(result.data, result.message); } // Fallback for legacy string responses return ResponseBuilder.success(result); } catch (error: any) { console.error('Content copy error:', error); return ResponseBuilder.internalError('Content copy failed', error.message); } } /** * Copy content implementation */ static async copyContent(args: ContentCopyArgs): Promise<ContentCopyResult> { const { apiKey, apiSecret, projectId, sourceEnvironment, targetEnvironment } = args; console.error(`Starting content copy from ${sourceEnvironment} to ${targetEnvironment}`); // DXP-101: Use REST API instead of PowerShell (3-10x faster, no PowerShell dependency) // Content copy is essentially a deployment with includeBlob=true and includeDB=true try { const deploymentParams = { sourceEnvironment: sourceEnvironment!, targetEnvironment: targetEnvironment!, includeBlob: true, // Include blob storage includeDB: true // Include database // Note: No sourceApps = content only (no code deployment) }; const options = args.apiUrl ? { apiUrl: args.apiUrl as string } : {}; const result: DeploymentResponse = await DXPRestClient.startDeployment( projectId!, apiKey!, apiSecret!, deploymentParams as any, options // Support custom API URLs ); // Format and return response if (result) { return this.formatContentCopyResponse(result, sourceEnvironment!, targetEnvironment!); } return { data: { deploymentId: null, sourceEnvironment: sourceEnvironment!, targetEnvironment: targetEnvironment!, type: 'content', status: 'InProgress', includesCode: false, includesDatabase: true, includesBlobs: true }, message: ResponseBuilder.addFooter( `Content copy initiated from ${sourceEnvironment} to ${targetEnvironment}.`, true ) }; } catch (error: any) { // Handle REST API errors const errorDetails = { operation: 'Content Copy', projectId, sourceEnvironment, targetEnvironment, error: error.message }; // Check if this is an access denied error if (error.statusCode === 401 || error.statusCode === 403) { return ErrorHandler.formatError({ type: 'ACCESS_DENIED', message: 'Access denied to deployment API' } as any, errorDetails) as any; } // Generic error handling throw new Error(`Content copy failed: ${error.message}`); } } /** * Format content copy response */ static formatContentCopyResponse(data: DeploymentResponse, sourceEnvironment: string, targetEnvironment: string): ContentCopyResult { const { FORMATTING: { STATUS_ICONS } } = Config; let response = `${STATUS_ICONS.SUCCESS} **Content Copy Started**\n\n`; if (data.id) { response += `**Deployment ID:** \`${data.id}\`\n`; } response += `**Source:** ${sourceEnvironment}\n`; response += `**Target:** ${targetEnvironment}\n`; response += `**Type:** Content Only\n`; if (data.status) { response += `**Status:** ${data.status}\n`; } const tips = [ 'Use get_deployment_status to monitor progress', 'Content sync typically takes 10-30 minutes', 'Only content and media will be copied (no code changes)' ]; response += '\n' + ResponseBuilder.formatTips(tips); // DXP-66: Return structured data and message const structuredData: ContentCopyData = { deploymentId: data.id || null, sourceEnvironment: sourceEnvironment, targetEnvironment: targetEnvironment, type: 'content', status: data.status || 'InProgress', includesCode: false, includesDatabase: true, includesBlobs: true }; return { data: structuredData, message: ResponseBuilder.addFooter(response, true) }; } } export default ContentTools;