AEM MCP Server

import { Server } from '@modelcontextprotocol/sdk/server/index.js'; import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js'; import { CallToolRequestSchema, ListToolsRequestSchema } from '@modelcontextprotocol/sdk/types.js'; import { AEMConnector } from './aem-connector.js'; import dotenv from 'dotenv'; dotenv.config(); const aemConnector = new AEMConnector(); const server = new Server({ name: 'aem-mcp-agent', version: '1.0.0', }, { capabilities: { resources: {}, tools: {}, prompts: {}, }, }); type ToolDefinition = { name: string; description?: string; inputSchema: object; }; const tools: ToolDefinition[] = [ { name: 'validateComponent', description: 'Validate component changes before applying them', inputSchema: { type: 'object', properties: { locale: { type: 'string' }, pagePath: { type: 'string' }, component: { type: 'string' }, props: { type: 'object' }, }, required: ['locale', 'pagePath', 'component', 'props'], }, }, { name: 'updateComponent', description: 'Update component properties in AEM', inputSchema: { type: 'object', properties: { componentPath: { type: 'string' }, properties: { type: 'object' }, }, required: ['componentPath', 'properties'], }, }, { name: 'undoChanges', description: 'Undo the last component changes', inputSchema: { type: 'object', properties: { jobId: { type: 'string' }, }, required: ['jobId'], }, }, { name: 'scanPageComponents', description: 'Scan a page to discover all components and their properties', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' }, }, required: ['pagePath'], }, }, { name: 'fetchSites', description: 'Get all available sites in AEM', inputSchema: { type: 'object', properties: {} }, }, { name: 'fetchLanguageMasters', description: 'Get language masters for a specific site', inputSchema: { type: 'object', properties: { site: { type: 'string' } }, required: ['site'], }, }, { name: 'fetchAvailableLocales', description: 'Get available locales for a site and language master', inputSchema: { type: 'object', properties: { site: { type: 'string' }, languageMasterPath: { type: 'string' }, }, required: ['site', 'languageMasterPath'], }, }, { name: 'replicateAndPublish', description: 'Replicate and publish content to selected locales', inputSchema: { type: 'object', properties: { selectedLocales: { type: 'array', items: { type: 'string' } }, componentData: { type: 'object' }, localizedOverrides: { type: 'object' }, }, required: ['selectedLocales', 'componentData'], }, }, { name: 'getAllTextContent', description: 'Get all text content from a page including titles, text components, and descriptions', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' } }, required: ['pagePath'], }, }, { name: 'getPageTextContent', description: 'Get text content from a specific page', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' } }, required: ['pagePath'], }, }, { name: 'getPageImages', description: 'Get all images from a page, including those within Experience Fragments', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' } }, required: ['pagePath'], }, }, { name: 'updateImagePath', description: 'Update the image path for an image component and verify the update', inputSchema: { type: 'object', properties: { componentPath: { type: 'string' }, newImagePath: { type: 'string' }, }, required: ['componentPath', 'newImagePath'], }, }, { name: 'getPageContent', description: 'Get all content from a page including Experience Fragments and Content Fragments', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' } }, required: ['pagePath'], }, }, { name: 'listPages', description: 'List all pages under a site root', inputSchema: { type: 'object', properties: { siteRoot: { type: 'string' }, depth: { type: 'number' }, limit: { type: 'number' }, }, }, }, { name: 'getNodeContent', description: 'Legacy: Get JCR node content', inputSchema: { type: 'object', properties: { path: { type: 'string' }, depth: { type: 'number' }, }, required: ['path'], }, }, { name: 'listChildren', description: 'Legacy: List child nodes', inputSchema: { type: 'object', properties: { path: { type: 'string' } }, required: ['path'], }, }, { name: 'getPageProperties', description: 'Get page properties', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' } }, required: ['pagePath'], }, }, { name: 'searchContent', description: 'Search content using Query Builder', inputSchema: { type: 'object', properties: { type: { type: 'string' }, fulltext: { type: 'string' }, path: { type: 'string' }, limit: { type: 'number' }, }, }, }, { name: 'executeJCRQuery', description: 'Execute JCR query', inputSchema: { type: 'object', properties: { query: { type: 'string' }, limit: { type: 'number' }, }, required: ['query'], }, }, { name: 'getAssetMetadata', description: 'Get asset metadata', inputSchema: { type: 'object', properties: { assetPath: { type: 'string' } }, required: ['assetPath'], }, }, { name: 'getStatus', description: 'Get workflow status by ID', inputSchema: { type: 'object', properties: { workflowId: { type: 'string' } }, required: ['workflowId'], }, }, { name: 'listMethods', description: 'Get list of available MCP methods', inputSchema: { type: 'object', properties: {} }, }, { name: 'enhancedPageSearch', description: 'Intelligent page search with comprehensive fallback strategies and cross-section search', inputSchema: { type: 'object', properties: { searchTerm: { type: 'string' }, basePath: { type: 'string' }, includeAlternateLocales: { type: 'boolean' }, }, required: ['searchTerm', 'basePath'], }, }, { name: 'createPage', description: 'Create a new page in AEM', inputSchema: { type: 'object', properties: { parentPath: { type: 'string' }, title: { type: 'string' }, template: { type: 'string' }, name: { type: 'string' }, properties: { type: 'object' }, }, required: ['parentPath', 'title', 'template'], }, }, { name: 'deletePage', description: 'Delete a page from AEM', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' }, force: { type: 'boolean' }, }, required: ['pagePath'], }, }, { name: 'createComponent', description: 'Create a new component on a page', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' }, componentType: { type: 'string' }, resourceType: { type: 'string' }, properties: { type: 'object' }, name: { type: 'string' }, }, required: ['pagePath', 'componentType', 'resourceType'], }, }, { name: 'deleteComponent', description: 'Delete a component from AEM', inputSchema: { type: 'object', properties: { componentPath: { type: 'string' }, force: { type: 'boolean' }, }, required: ['componentPath'], }, }, { name: 'unpublishContent', description: 'Unpublish content from the publish environment', inputSchema: { type: 'object', properties: { contentPaths: { type: 'array', items: { type: 'string' } }, unpublishTree: { type: 'boolean' }, }, required: ['contentPaths'], }, }, { name: 'activatePage', description: 'Activate (publish) a single page', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' }, activateTree: { type: 'boolean' }, }, required: ['pagePath'], }, }, { name: 'deactivatePage', description: 'Deactivate (unpublish) a single page', inputSchema: { type: 'object', properties: { pagePath: { type: 'string' }, deactivateTree: { type: 'boolean' }, }, required: ['pagePath'], }, }, { name: 'uploadAsset', description: 'Upload a new asset to AEM DAM', inputSchema: { type: 'object', properties: { parentPath: { type: 'string' }, fileName: { type: 'string' }, fileContent: { type: 'string' }, mimeType: { type: 'string' }, metadata: { type: 'object' }, }, required: ['parentPath', 'fileName', 'fileContent'], }, }, { name: 'updateAsset', description: 'Update an existing asset in AEM DAM', inputSchema: { type: 'object', properties: { assetPath: { type: 'string' }, metadata: { type: 'object' }, fileContent: { type: 'string' }, mimeType: { type: 'string' }, }, required: ['assetPath'], }, }, { name: 'deleteAsset', description: 'Delete an asset from AEM DAM', inputSchema: { type: 'object', properties: { assetPath: { type: 'string' }, force: { type: 'boolean' }, }, required: ['assetPath'], }, }, { name: 'getTemplates', description: 'Get available page templates', inputSchema: { type: 'object', properties: { sitePath: { type: 'string' } }, }, }, { name: 'getTemplateStructure', description: 'Get detailed structure of a specific template', inputSchema: { type: 'object', properties: { templatePath: { type: 'string' } }, required: ['templatePath'], }, }, { name: 'bulkUpdateComponents', description: 'Update multiple components in a single operation with validation and rollback support', inputSchema: { type: 'object', properties: { updates: { type: 'array', items: { type: 'object', properties: { componentPath: { type: 'string' }, properties: { type: 'object' } }, required: ['componentPath', 'properties'] } }, validateFirst: { type: 'boolean' }, continueOnError: { type: 'boolean' } }, required: ['updates'], }, }, { name: 'startWorkflow', description: 'Start a new workflow instance', inputSchema: { type: 'object', properties: { model: { type: 'string' }, payloadPath: { type: 'string' }, title: { type: 'string' }, comment: { type: 'string' } }, required: ['model', 'payloadPath'], }, }, { name: 'listActiveWorkflows', description: 'List all currently running workflow instances', inputSchema: { type: 'object', properties: { limit: { type: 'number' } } }, }, { name: 'completeWorkflowStep', description: 'Complete a workflow step', inputSchema: { type: 'object', properties: { workflowId: { type: 'string' }, stepName: { type: 'string' }, comment: { type: 'string' } }, required: ['workflowId', 'stepName'], }, }, { name: 'cancelWorkflow', description: 'Cancel a workflow instance', inputSchema: { type: 'object', properties: { workflowId: { type: 'string' }, reason: { type: 'string' } }, required: ['workflowId'], }, }, { name: 'suspendWorkflow', description: 'Suspend a workflow instance', inputSchema: { type: 'object', properties: { workflowId: { type: 'string' }, reason: { type: 'string' } }, required: ['workflowId'], }, }, { name: 'resumeWorkflow', description: 'Resume a suspended workflow instance', inputSchema: { type: 'object', properties: { workflowId: { type: 'string' } }, required: ['workflowId'], }, }, { name: 'getWorkflowModels', description: 'Get all available workflow models', inputSchema: { type: 'object', properties: {} }, }, { name: 'getVersionHistory', description: 'Get version history for a content path', inputSchema: { type: 'object', properties: { path: { type: 'string' } }, required: ['path'], }, }, { name: 'createVersion', description: 'Create a new version of content', inputSchema: { type: 'object', properties: { path: { type: 'string' }, label: { type: 'string' }, comment: { type: 'string' } }, required: ['path'], }, }, { name: 'restoreVersion', description: 'Restore content to a specific version', inputSchema: { type: 'object', properties: { path: { type: 'string' }, versionName: { type: 'string' } }, required: ['path', 'versionName'], }, }, { name: 'compareVersions', description: 'Compare two versions of content', inputSchema: { type: 'object', properties: { path: { type: 'string' }, version1: { type: 'string' }, version2: { type: 'string' } }, required: ['path', 'version1', 'version2'], }, }, { name: 'deleteVersion', description: 'Delete a specific version', inputSchema: { type: 'object', properties: { path: { type: 'string' }, versionName: { type: 'string' } }, required: ['path', 'versionName'], }, }, ]; server.setRequestHandler(ListToolsRequestSchema, async () => { return { tools }; }); server.setRequestHandler(CallToolRequestSchema, async (request: any) => { const { name, arguments: args } = request.params; if (!args) { return { content: [ { type: 'text', text: 'Error: No arguments provided' }, ], isError: true, }; } try { switch (name) { case 'validateComponent': { const result = await aemConnector.validateComponent({ locale: args.locale, page_path: args.pagePath, component: args.component, props: args.props, }); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'updateComponent': { const result = await aemConnector.updateComponent(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'undoChanges': { const result = await aemConnector.undoChanges(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'scanPageComponents': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.scanPageComponents(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'fetchSites': { const result = await aemConnector.fetchSites(); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'fetchLanguageMasters': { const site = (args as { site: string }).site; const result = await aemConnector.fetchLanguageMasters(site); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'fetchAvailableLocales': { const { site, languageMasterPath } = args as { site: string; languageMasterPath: string }; const result = await aemConnector.fetchAvailableLocales(site, languageMasterPath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'replicateAndPublish': { const result = await aemConnector.replicateAndPublish(args.selectedLocales, args.componentData, args.localizedOverrides); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getAllTextContent': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.getAllTextContent(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getPageTextContent': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.getPageTextContent(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getPageImages': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.getPageImages(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'updateImagePath': { const { componentPath, newImagePath } = args as { componentPath: string; newImagePath: string }; const result = await aemConnector.updateImagePath(componentPath, newImagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getPageContent': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.getPageContent(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'listPages': { const { siteRoot, depth, limit } = args as { siteRoot: string; depth: number; limit: number }; const result = await aemConnector.listPages(siteRoot, depth, limit); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getNodeContent': { const { path, depth } = args as { path: string; depth: number }; const result = await aemConnector.getNodeContent(path, depth); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'listChildren': { const path = (args as { path: string }).path; const children = await aemConnector.listChildren(path); return { content: [{ type: 'text', text: JSON.stringify({ children }, null, 2) }] }; } case 'getPageProperties': { const pagePath = (args as { pagePath: string }).pagePath; const result = await aemConnector.getPageProperties(pagePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'searchContent': { const result = await aemConnector.searchContent(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'executeJCRQuery': { const { query, limit } = args as { query: string; limit: number }; const result = await aemConnector.executeJCRQuery(query, limit); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getAssetMetadata': { const assetPath = (args as { assetPath: string }).assetPath; const result = await aemConnector.getAssetMetadata(assetPath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getStatus': { const result = await aemConnector.getWorkflowStatus(args.workflowId); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'listMethods': { const result = tools; return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'enhancedPageSearch': { const result = await aemConnector.enhancedPageSearch(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'createPage': { const result = await aemConnector.createPage(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'deletePage': { const result = await aemConnector.deletePage(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'createComponent': { const result = await aemConnector.createComponent(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'deleteComponent': { const result = await aemConnector.deleteComponent(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'unpublishContent': { const result = await aemConnector.unpublishContent(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'activatePage': { const result = await aemConnector.activatePage(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'deactivatePage': { const result = await aemConnector.deactivatePage(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'uploadAsset': { const result = await aemConnector.uploadAsset(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'updateAsset': { const result = await aemConnector.updateAsset(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'deleteAsset': { const result = await aemConnector.deleteAsset(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getTemplates': { const sitePath = (args as { sitePath: string }).sitePath; const result = await aemConnector.getTemplates(sitePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getTemplateStructure': { const templatePath = (args as { templatePath: string }).templatePath; const result = await aemConnector.getTemplateStructure(templatePath); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'bulkUpdateComponents': { const result = await aemConnector.bulkUpdateComponents(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'startWorkflow': { const result = await aemConnector.startWorkflow(args); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'listActiveWorkflows': { const limit = (args as { limit?: number }).limit; const result = await aemConnector.listActiveWorkflows(limit); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'completeWorkflowStep': { const { workflowId, stepName, comment } = args as { workflowId: string; stepName: string; comment?: string }; const result = await aemConnector.completeWorkflowStep(workflowId, stepName, comment); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'cancelWorkflow': { const { workflowId, reason } = args as { workflowId: string; reason?: string }; const result = await aemConnector.cancelWorkflow(workflowId, reason); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'suspendWorkflow': { const { workflowId, reason } = args as { workflowId: string; reason?: string }; const result = await aemConnector.suspendWorkflow(workflowId, reason); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'resumeWorkflow': { const workflowId = (args as { workflowId: string }).workflowId; const result = await aemConnector.resumeWorkflow(workflowId); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getWorkflowModels': { const result = await aemConnector.getWorkflowModels(); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'getVersionHistory': { const path = (args as { path: string }).path; const result = await aemConnector.getVersionHistory(path); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'createVersion': { const { path, label, comment } = args as { path: string; label?: string; comment?: string }; const result = await aemConnector.createVersion(path, label, comment); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'restoreVersion': { const { path, versionName } = args as { path: string; versionName: string }; const result = await aemConnector.restoreVersion(path, versionName); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'compareVersions': { const { path, version1, version2 } = args as { path: string; version1: string; version2: string }; const result = await aemConnector.compareVersions(path, version1, version2); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } case 'deleteVersion': { const { path, versionName } = args as { path: string; versionName: string }; const result = await aemConnector.deleteVersion(path, versionName); return { content: [{ type: 'text', text: JSON.stringify(result, null, 2) }] }; } default: throw new Error(`Unknown tool: ${name}`); } } catch (error: any) { return { content: [{ type: 'text', text: `Error: ${error.message}` }], isError: true, }; } }); async function main() { const transport = new StdioServerTransport(); await server.connect(transport); // eslint-disable-next-line no-console console.error('AEM MCP Server running as a standard MCP handler (stdio transport)'); } main().catch((error) => { // eslint-disable-next-line no-console console.error('Fatal error:', error); process.exit(1); });