Skip to content

Ean Schuessler / mo-mcp

Go to a project
Toggle navigation
Toggle navigation pinning
df9e7244 by Ean Schuessler
Options

Continuing to flesh out MCP connectivity

1 parent 7abaf27f
Inline Side-by-side
Showing 3 changed files with 114 additions and 25 deletions
......@@ -30,6 +30,21 @@
<set field="locale" from="ec.user?.locale ?: 'en_US'"/>
</actions>
<transition name="fixConfig">
<actions>
<script><![CDATA[
ec.entity.find("moqui.mcp.agent.ProductStoreAiConfig")
.condition("productStoreId", "POPC_DEFAULT")
.condition("aiConfigId", "DEFAULT")
.one()
.set("modelName", "devstral")
.update()
]]></script>
<set field="message" value="Config updated successfully to devstral"/>
</actions>
<default-response type="screen-last"/>
</transition>
<widgets>
<container style="mcp-test-screen">
<container style="text-center">
......
......@@ -193,7 +193,9 @@
def internalToolMappings = [
"moqui_search_screens": "McpServices.mcp#SearchScreens",
"moqui_get_screen_details": "McpServices.mcp#GetScreenDetails",
"moqui_get_help": "McpServices.mcp#GetHelp"
"moqui_get_help": "McpServices.mcp#GetHelp",
"moqui_prompts_list": "McpServices.mcp#PromptsList",
"moqui_prompts_get": "McpServices.mcp#PromptsGet"
// "moqui_batch_operations": "McpServices.mcp#BatchOperations" - hidden until fixed
]
......@@ -655,15 +657,15 @@ def getWikiInstructions = { lookupPath ->
if (!wikiSpace) continue
// Build the resource location for the page
// rootPageLocation is dbresource://WikiSpace/MCP_PROMPTS.md
// Need to construct: dbresource://WikiSpace/MCP_PROMPTS/get-started.md
// TEST - adding marker
def pageLocation = wikiSpace.rootPageLocation
if (!pageLocation.endsWith('/')) {
pageLocation += '/'
// Replace .md with /pagePath.md
if (pageLocation.endsWith('.md')) {
pageLocation = pageLocation.substring(0, pageLocation.length() - 3) + '/' + wikiPage.pagePath + '.md'
}
pageLocation += wikiPage.pagePath + '.md'
// Get the resource reference and text content
def pageRef = ec.resource.getLocationReference(pageLocation)
def wikiText = pageRef?.getText()
ec.logger.error("MCP PromptsGet: TEST MARKER - Using location: ${pageLocation}")
if (wikiText) {
if (tryPath != normalizedPath) {
......@@ -2107,20 +2109,25 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
.list()
for (def wp in wikiPageList) {
// Try to load argument schema from attachment
// Try to load argument schema from DbResource
def arguments = []
try {
def attachment = ec.entity.find("moqui.resource.wiki.WikiPageAttachment")
.condition("wikiPageId", wp.wikiPageId)
.condition("filename", "arguments.json")
// Build resourceId for arguments file (e.g., WIKI_MCP_GET_STARTED_ARGS)
def argsResourceId = "WIKI_MCP_${wp.pagePath.toUpperCase().replace('-', '_')}_ARGS"
def dbResource = ec.entity.find("moqui.resource.DbResource")
.condition("resourceId", argsResourceId)
.one()
if (attachment) {
def attachmentRef = ec.resource.getLocationReference(attachment.getLocation())
def jsonText = attachmentRef?.getText()
if (dbResource) {
def dbResourceFile = ec.entity.find("moqui.resource.DbResourceFile")
.condition("resourceId", argsResourceId)
.one()
if (dbResourceFile) {
def jsonText = dbResourceFile.fileData?.getText()
if (jsonText) {
arguments = new JsonSlurper().parseText(jsonText) ?: []
}
}
}
} catch (Exception e) {
ec.logger.debug("Could not parse arguments for ${wp.pagePath}: ${e.message}")
}
......@@ -2156,13 +2163,22 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
ExecutionContext ec = context.ec
ec.logger.info("MCP PromptsGet: Retrieving prompt '${name}' from wiki space MCP_PROMPTS")
ec.logger.info("MCP PromptsGet: START v2.0 - Retrieving prompt '${name}' from wiki space MCP_PROMPTS")
// Debug: Check what wiki pages exist in MCP_PROMPTS space
def allPages = ec.entity.find("moqui.resource.wiki.WikiPage")
.condition("wikiSpaceId", "MCP_PROMPTS")
.useCache(true)
.list()
ec.logger.info("MCP PromptsGet: All pages in MCP_PROMPTS space: ${allPages.collect { [pageId: it.wikiPageId, pagePath: it.pagePath] }}")
// Get the wiki page for this prompt
def wikiPage = ec.entity.find("moqui.resource.wiki.WikiPage")
.condition("wikiSpaceId", "MCP_PROMPTS")
.condition("pagePath", name)
.useCache(true)
.one()
ec.logger.info("MCP PromptsGet: Looking for pagePath='${name}', found: ${wikiPage?.wikiPageId}")
if (!wikiPage) {
throw new Exception("Prompt not found: ${name}")
......@@ -2171,27 +2187,57 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
// Get the wiki space to build the page location
def wikiSpace = ec.entity.find("moqui.resource.wiki.WikiSpace")
.condition("wikiSpaceId", "MCP_PROMPTS")
.useCache(true)
.one()
if (!wikiSpace) {
throw new Exception("MCP Prompts wiki space not found")
}
// Build the resource location for the page (root + page path + .md)
def pageLocation = wikiSpace.rootPageLocation
if (!pageLocation.endsWith('/')) {
pageLocation += '/'
// Build resource location using framework's findChildFile pattern
// Note: pagePath is "get-started" but file is "get-started.md"
ec.logger.info("MCP PromptsGet: rootPageLocation=${wikiSpace.rootPageLocation}, pagePath=${wikiPage.pagePath}")
def rootPageRef = ec.resource.getLocationReference(wikiSpace.rootPageLocation)
ec.logger.info("MCP PromptsGet: rootPageRef.location=${rootPageRef?.location}")
// Try with .md extension first, then without
def pageRef = rootPageRef.findChildFile(wikiPage.pagePath + '.md')
if (!pageRef) {
pageRef = rootPageRef.findChildFile(wikiPage.pagePath)
}
pageLocation += name + '.md'
ec.logger.info("MCP PromptsGet: pageRef.location=${pageRef?.location}")
// Get the resource reference and text content
def pageRef = ec.resource.getLocationReference(pageLocation)
def templateText = pageRef?.getText()
ec.logger.info("MCP PromptsGet: templateText.length=${templateText?.length() ?: 'null'}")
if (!templateText) {
throw new Exception("Prompt template not found: ${name}")
}
// Load arguments schema from DbResource for prompt metadata
def promptArguments = []
try {
def argsResourceId = "WIKI_MCP_${name.toUpperCase().replace('-', '_')}_ARGS"
def dbResource = ec.entity.find("moqui.resource.DbResource")
.condition("resourceId", argsResourceId)
.useCache(true)
.one()
if (dbResource) {
def dbResourceFile = ec.entity.find("moqui.resource.DbResourceFile")
.condition("resourceId", argsResourceId)
.useCache(true)
.one()
if (dbResourceFile) {
def jsonText = dbResourceFile.fileData?.getText()
if (jsonText) {
promptArguments = new JsonSlurper().parseText(jsonText) ?: []
}
}
}
} catch (Exception e) {
ec.logger.debug("Could not parse arguments for ${name}: ${e.message}")
}
// Render template using Groovy GString engine
def templateEngine = new GStringTemplateEngine()
def template = templateEngine.createTemplate(templateText)
......@@ -2202,6 +2248,7 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
result = [
description: "MCP prompt template",
arguments: promptArguments,
messages: [[
role: "user",
content: [type: "text", text: rendered]
......@@ -3011,7 +3058,7 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
// moqui_batch_operations - hidden until fixed
//
[
name: "prompts_list",
name: "moqui_prompts_list",
title: "List Prompts",
description: "List available MCP prompt templates.",
inputSchema: [
......@@ -3020,7 +3067,7 @@ def wikiInstructions = getWikiInstructions(inputScreenPath)
]
],
[
name: "prompts_get",
name: "moqui_prompts_get",
title: "Get Prompt",
description: "Retrieve and render a specific MCP prompt template.",
inputSchema: [
......
<?xml version="1.0" encoding="UTF-8"?>
<services xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="http://moqui.org/xsd/service-definition-3.xsd">
<service verb="update" noun="ModelName" authenticate="false">
<description>Update modelName in ProductStoreAiConfig</description>
<actions>
<script><![CDATA[
def config = ec.entity.find("moqui.mcp.agent.ProductStoreAiConfig")
.condition("productStoreId", "POPC_DEFAULT")
.condition("aiConfigId", "DEFAULT")
.one()
if (config) {
ec.logger.info("UPDATE MODEL NAME: Current=${config.modelName}")
config.modelName = "devstral"
config.update()
ec.logger.info("UPDATE MODEL NAME: Updated to=${config.modelName}")
return "Updated modelName to devstral"
} else {
ec.logger.warn("UPDATE MODEL NAME: Config not found")
return "Config not found"
}
]]></script>
</actions>
</service>
</services>