feat: Update version to 0.1.0-beta.5; fix typos in interface names and descriptions; enhance workflow state management with step status tracking and progress formatting

Author: yaonyan

packages/core/deno.json

@@ -1,6 +1,6 @@
 {
     "name": "@mcpc/core",
-    "version": "0.1.0-beta.4",
+    "version": "0.1.0-beta.5",
     "tasks": {
         "server:compile": "echo \"no need to compile\""
     },

packages/core/src/compose.ts

@@ -13,7 +13,7 @@ import {
 } from "@modelcontextprotocol/sdk/server/index.js";
 import type z from "zod";
 import { composeMcpDepTools, parseTags } from "../mod.ts";
-import type { ComposeDefination } from "./set-up-mcp-compose.ts";
+import type { ComposeDefinition } from "./set-up-mcp-compose.ts";
 import { updateRefPaths } from "./utils/common/schema.ts";
 import type { ToolCallback, JSONSchema } from "./types.ts";
 import { registerAgenticTool } from "./workflow/agentic-tool-registrar.ts";
@@ -215,7 +215,7 @@ export class ComposableMCPServer extends Server {
     name: string,
     description: string,
     depsConfig: z.infer<typeof McpSettingsSchema> = { mcpServers: {} },
-    options: ComposeDefination["options"] = { mode: "agentic" }
+    options: ComposeDefinition["options"] = { mode: "agentic" }
   ) {
     const { tagToResults, $ } = parseTags(description, ["tool", "fn"]);
 

packages/core/src/controllers/core.controller.ts

@@ -10,7 +10,7 @@ export const coreHandler = (app: OpenAPIHono) => {
     info: {
       title: "tencentcloudapi openapi spec",
       version: "1.0.0",
-      description: "openapi defination of tencentcloudapi",
+      description: "openapi definition of tencentcloudapi",
     },
   });
 };

packages/core/src/prompts/index.ts

@@ -1,6 +1,6 @@
 /**
  * MCPC Prompt Management System
- * 
+ *
  * Centralized management for all prompts and templates used across MCPC.
  * Supports dynamic content replacement and template variables.
  */
@@ -25,7 +25,6 @@ export const SystemPrompts = {
 2. **Plan Next Action:** Anticipate the likely next step needed (if any)
 
 **⚡ Key Rules:**
-- Execute ONE action per iteration
 - Use structured protocol - no direct tool calls
 - Always analyze results before proceeding`,
 
@@ -44,7 +43,7 @@ export const SystemPrompts = {
 **⚡ SUBSEQUENT CALLS (Execution):**
 - Provide ONLY current step parameters
 - **ADVANCE STEP**: Set \`proceed: true\` to move to next step  
-- **RETRY STEP**: Set \`proceed: false\` (or omit) to retry current step
+- **RETRY STEP**: Set \`proceed: false\`
 - Use \`reasoning\` action for thinking/analysis
 
 **🚫 Do NOT include \`steps\` parameter during normal execution**
@@ -83,7 +82,7 @@ export const WorkflowPrompts = {
    */
   WORKFLOW_INIT: `Workflow initialized with {stepCount} steps. You MUST start the workflow with the first step to \`{currentStepDescription}\`. 
               
-## EXECUTE tool \`{toolName}\` with following new tool arguments
+## EXECUTE tool \`{toolName}\` with the following new parameter definition
 
 {schemaDefinition}
 
@@ -92,8 +91,9 @@ export const WorkflowPrompts = {
 - **Do NOT include 'steps' parameter during normal step execution**
 - **MUST Use the provided JSON schema definition above for parameter generation and validation**
 - **ADVANCE STEP: Set 'proceed' to true to advance to next step**
-- **RETRY STEP: Set 'proceed' to false or omit it to re-execute current step**
-- **⚠️ CRITICAL: When retrying failed steps, NEVER set 'proceed' to true**
+- **RETRY STEP: Set 'proceed' to false to re-execute current step**
+- **⚠️ CRITICAL: When retrying failed steps, MUST set 'proceed' to false**
+
 {workflowSteps}`,
 
   /**
@@ -112,16 +112,79 @@ export const WorkflowPrompts = {
    * Planning instructions for dynamic workflows
    */
   DYNAMIC_WORKFLOW_PLANNING: `- Set \`init: true\` and define complete \`steps\` array`,
+
+  /**
+   * Next step decision prompt
+   */
+  NEXT_STEP_DECISION: `**Next Step Decision Required**
+
+Previous step completed. Choose your action:
+
+**🔄 RETRY Current Step:** 
+- Call \`{toolName}\` with current parameters
+- ⚠️ CRITICAL: Set \`proceed: false\`
+
+**▶️ PROCEED to Next Step:** 
+- Call \`{toolName}\` with parameters below
+- Set \`proceed: true\`
+
+Next step: \`{nextStepDescription}\`
+
+{nextStepSchema}
+
+**Important:** Exclude \`steps\` key from your parameters`,
+
+  /**
+   * Final step completion prompt
+   */
+  FINAL_STEP_COMPLETION: `**Step Complete - Workflow Ending** {statusIcon}
+
+Current step executed {statusText}. Choose your next action:
+
+**1. ▶️ Complete Workflow:** Call \`{toolName}\` with \`proceed: true\` to finish
+**2. 🔄 Retry Final Step:** Call \`{toolName}\` with final step parameters  
+**3. 🆕 New Workflow:** Call \`{toolName}\` with \`init: true\`{newWorkflowInstructions}
+
+**Note:** Use \`proceed: true\` to officially complete the workflow.`,
+
+  /**
+   * Workflow completion success message
+   */
+  WORKFLOW_COMPLETED: `**Workflow Completed Successfully** ✅
+
+All workflow steps have been executed and the workflow is now complete.
+
+**Summary:**
+- Total steps: {totalSteps}
+- All steps executed successfully
+
+You can now start a new workflow if needed by calling \`{toolName}\` with \`init: true\`{newWorkflowInstructions}.`,
+
+  /**
+   * Error messages
+   */
+  ERRORS: {
+    NOT_INITIALIZED: {
+      WITH_PREDEFINED:
+        "Error: Workflow not initialized. Please provide 'init' parameter to start a new workflow.",
+      WITHOUT_PREDEFINED:
+        "Error: Workflow not initialized. Please provide 'init' and 'steps' parameter to start a new workflow.",
+    },
+    ALREADY_AT_FINAL:
+      "Error: Cannot proceed, you are already at the final step.",
+    NO_STEPS_PROVIDED: "Error: No steps provided",
+    NO_CURRENT_STEP: "Error: No current step to execute",
+  },
 };
 
 /**
  * Response templates for different scenarios
  */
 export const ResponseTemplates = {
   /**
-   * Success response for tool execution
+   * Success response for action execution
    */
-  TOOL_SUCCESS: `# You WILL call this tool(\`{toolName}\`) AGAIN using the \`{nextAction}\` action, after evaluating the result from previous action({currentAction}):`,
+  ACTION_SUCCESS: `# You WILL call this tool(\`{toolName}\`) AGAIN using the \`{nextAction}\` action, after evaluating the result from previous action({currentAction}):`,
 
   /**
    * Planning prompt when no next action is specified
@@ -131,12 +194,12 @@ export const ResponseTemplates = {
   /**
    * Error response template
    */
-  ERROR_RESPONSE: `Tool/Function argument validation failed: {errorMessage}`,
+  ERROR_RESPONSE: `Action/Function argument validation failed: {errorMessage}`,
 
   /**
    * Completion message
    */
-  COMPLETION_MESSAGE: `Completed, no dependent tools to execute`,
+  COMPLETION_MESSAGE: `Completed, no dependent actions to execute`,
 
   /**
    * Security validation messages
@@ -183,7 +246,10 @@ export const CompiledPrompts = {
   toolUsageInstructions: p(SystemPrompts.TOOL_USAGE_INSTRUCTIONS),
   workflowInit: p(WorkflowPrompts.WORKFLOW_INIT),
   workflowToolDescription: p(WorkflowPrompts.WORKFLOW_TOOL_DESCRIPTION),
-  toolSuccess: p(ResponseTemplates.TOOL_SUCCESS),
+  nextStepDecision: p(WorkflowPrompts.NEXT_STEP_DECISION),
+  finalStepCompletion: p(WorkflowPrompts.FINAL_STEP_COMPLETION),
+  workflowCompleted: p(WorkflowPrompts.WORKFLOW_COMPLETED),
+  actionSuccess: p(ResponseTemplates.ACTION_SUCCESS),
   planningPrompt: p(ResponseTemplates.PLANNING_PROMPT),
   errorResponse: p(ResponseTemplates.ERROR_RESPONSE),
   securityPassed: p(ResponseTemplates.SECURITY_VALIDATION.PASSED),
@@ -199,36 +265,77 @@ export const PromptUtils = {
   /**
    * Generate tool list for descriptions
    */
-  generateToolList: (tools: Array<{ name: string; description?: string; hide?: boolean }>) => {
+  generateToolList: (
+    tools: Array<{ name: string; description?: string; hide?: boolean }>
+  ) => {
     return tools
-      .filter(tool => !tool.hide)
-      .map(tool => `<tool name="${tool.name}"${tool.description ? ` description="${tool.description}"` : ''}/>`)
-      .join('\n');
+      .filter((tool) => !tool.hide)
+      .map(
+        (tool) =>
+          `<tool name="${tool.name}"${
+            tool.description ? ` description="${tool.description}"` : ""
+          }/>`
+      )
+      .join("\n");
   },
 
   /**
    * Generate hidden tool list for descriptions
    */
   generateHiddenToolList: (tools: Array<{ name: string; hide?: boolean }>) => {
     return tools
-      .filter(tool => tool.hide)
-      .map(tool => `<tool name="${tool.name}" hide/>`)
-      .join('\n');
+      .filter((tool) => tool.hide)
+      .map((tool) => `<tool name="${tool.name}" hide/>`)
+      .join("\n");
   },
 
   /**
    * Format workflow steps for display
    */
-  formatWorkflowSteps: (steps: Array<{ description: string; actions: string[] }>) => {
-    if (!steps.length) return '';
+  formatWorkflowSteps: (
+    steps: Array<{ description: string; actions: string[] }>
+  ) => {
+    if (!steps.length) return "";
     return `## Workflow Steps\n${JSON.stringify(steps, null, 2)}`;
   },
 
+  /**
+   * Format workflow progress display with status icons
+   */
+  formatWorkflowProgress: (progressData: {
+    steps: Array<{ description: string; actions: string[] }>;
+    statuses: Array<string>;
+    currentStepIndex: number;
+  }) => {
+    const statusIcons = {
+      pending: "⏳",
+      running: "🔄",
+      completed: "✅",
+      failed: "❌",
+    };
+
+    return progressData.steps
+      .map((step, index) => {
+        const status = progressData.statuses[index] || "pending";
+        const icon = statusIcons[status as keyof typeof statusIcons] || "⏳";
+        const current =
+          index === progressData.currentStepIndex ? " **[CURRENT]**" : "";
+        const actions =
+          step.actions.length > 0
+            ? ` | Action: ${step.actions.join(", ")}`
+            : "";
+        return `${icon} **Step ${index + 1}:** ${
+          step.description
+        }${actions}${current}`;
+      })
+      .join("\n");
+  },
+
   /**
    * Generate user info for audit logs
    */
   formatUserInfo: (user?: string) => {
-    return user ? ` by ${user}` : '';
+    return user ? ` by ${user}` : "";
   },
 
   /**
@@ -237,6 +344,20 @@ export const PromptUtils = {
   formatTimestamp: () => {
     return new Date().toISOString();
   },
+
+  /**
+   * Extract and format text content from CallToolResult
+   */
+  extractActionResultText: (actionResult: {
+    content?: Array<{ type: string; text?: string }>;
+  }) => {
+    return (
+      actionResult.content
+        ?.filter((item) => item.type === "text")
+        ?.map((item) => item.text)
+        ?.join("\n") || "No text content"
+    );
+  },
 };
 
 /**

packages/core/src/set-up-mcp-compose.ts

@@ -6,7 +6,7 @@ import { MCPSetting } from "./service/tools.ts";
 
 export const INCOMING_MSG_ROUTE_PATH = "/core/messages";
 
-export interface ComposeDefination {
+export interface ComposeDefinition {
   name: string;
   description: string;
   deps?: MCPSetting;
@@ -31,12 +31,12 @@ export interface ComposeDefination {
 }
 
 export interface ComposibleMCPConfig {
-  [key: string]: ComposeDefination[];
+  [key: string]: ComposeDefinition[];
 }
 
 export function parseMcpcConfigs(
-  conf?: ComposeDefination[]
-): ComposeDefination[] {
+  conf?: ComposeDefinition[]
+): ComposeDefinition[] {
   const mcpcConfigRaw =
     minimist(process.argv.slice(2))?.["mcpc-config"] ?? process.env.MCPC_CONFIG;
   const mcpcConfigs = conf ?? JSON.parse(mcpcConfigRaw);
@@ -61,7 +61,7 @@ export function parseMcpcConfigs(
 
 export async function mcpc(
   serverConf: ConstructorParameters<typeof ComposableMCPServer>,
-  composeConf?: ComposeDefination[],
+  composeConf?: ComposeDefinition[],
   setupCallback?: (server: ComposableMCPServer) => void | Promise<void>
 ): Promise<InstanceType<typeof ComposableMCPServer>> {
   const server = new ComposableMCPServer(...serverConf);

packages/core/src/utils/common/ai.ts

@@ -151,8 +151,8 @@ export async function composeMcpDepTools(
   const allTools: Record<string, any> = {};
 
   // Process each MCP definition sequentially
-  for (const [name, defination] of Object.entries(mcpConfig.mcpServers)) {
-    const def = defination as z.infer<typeof ServerConfigSchema>;
+  for (const [name, definition] of Object.entries(mcpConfig.mcpServers)) {
+    const def = definition as z.infer<typeof ServerConfigSchema>;
 
     if (def.disabled) {
       continue;