add tool create command

Signed-off-by: Akihiko Kuroda <[email protected]>

Author: akihikokuroda

internal/commands/create.go

@@ -146,18 +146,64 @@ func (c *CreateCommand) createAgentsFromYAML(agentsYaml []common.YAMLDocument) e
 }
 
 // createMCPToolsFromYAML creates MCP tools from the YAML configuration
-func (c *CreateCommand) createMCPToolsFromYAML(agentsYaml []common.YAMLDocument) error {
-	// In the Python implementation, this calls create_mcptools from maestro.mcptool
-	// We'll need to implement the equivalent functionality in Go
-
+func (c *CreateCommand) createMCPToolsFromYAML(toolsYaml []common.YAMLDocument) error {
 	// For now, we'll just print a message
 	c.Console().Ok("Creating MCP tools from YAML configuration")
 
-	// TODO: Implement the actual MCP tool creation logic
-	// This would involve:
-	// 1. Parsing the tool definitions
-	// 2. Creating the tool instances
-	// 3. Registering them with the system
+	// Get MCP server URI
+	serverURI, err := common.GetMCPServerURI("")
+	// serverURI, err := common.GetMaestroMCPServerURI(c.mcpServerURI)
+	if err != nil {
+		if common.Progress != nil {
+			common.Progress.StopWithError("Failed to get MCP server URI")
+		}
+		return err
+	}
+
+	if common.Verbose {
+		fmt.Printf("Connecting to MCP server at: %s\n", serverURI)
+	}
+
+	// Create MCP client
+	client, _ := common.NewMCPClient(serverURI)
+	if err != nil {
+		if common.Progress != nil {
+			common.Progress.StopWithError("Failed to create MCP client")
+		}
+		return err
+	}
+	defer client.Close()
+
+	if common.Progress != nil {
+		common.Progress.Update("Executing create tools...")
+	}
+
+	// Call the run_workflow tool
+	tool_strings, err := common.YamlToString(toolsYaml)
+	if err != nil {
+		fmt.Println("tool file error")
+	}
+
+	params := map[string]interface{}{
+		"tools": tool_strings,
+	}
+
+	result, err := client.CallMCPServer("create_tools", params)
+	if err != nil {
+		if common.Progress != nil {
+			common.Progress.StopWithError("Create tool failed")
+		}
+		return err
+	}
+
+	if common.Progress != nil {
+		common.Progress.Stop("Create tools completed successfully")
+	}
+
+	if !common.Silent {
+		fmt.Println("OK")
+	}
+	fmt.Println(result)
 
 	return nil
 }

src/commands.go

@@ -352,8 +352,8 @@ var agentCmd = &cobra.Command{
 	Short:   "Manage agents",
 	Long:    `Manage agent including creating, and serving.`,
 	Aliases: []string{"agent"},
-	Example: `  maestro create agents.yaml
-  maestro agent create agents.yaml`,
+	Example: `  maestro agent create agents.yaml
+  maestro agent serve agents.yaml`,
 }
 
 // Workflow commands - run, serve, deploy
@@ -367,6 +367,15 @@ var workflowCmd = &cobra.Command{
   maestro workflow deploy agents.yaml workflow.yaml`,
 }
 
+// Tool commands - create
+var toolCmd = &cobra.Command{
+	Use:     "tool",
+	Short:   "Manage tools",
+	Long:    `Manage tool including creating.`,
+	Aliases: []string{"tool"},
+	Example: `  maestro tool create tools.yaml`,
+}
+
 // CustomResource commands - create
 var customResourceCmd = &cobra.Command{
 	Use:     "customresource",

src/main.go

@@ -124,6 +124,7 @@ A command-line interface for working with Maestro configurations.`,
 	)
 	rootCmd.AddCommand(agentCmd)
 	rootCmd.AddCommand(workflowCmd)
+	rootCmd.AddCommand(toolCmd)
 	rootCmd.AddCommand(customResourceCmd)
 	rootCmd.AddCommand(metaAgentCmd)
 	rootCmd.AddCommand(vdbCmd)
@@ -163,6 +164,8 @@ A command-line interface for working with Maestro configurations.`,
 	workflowCmd.AddCommand(commands.NewRunCommand())
 	workflowCmd.AddCommand(commands.NewDeployCommand())
 
+	toolCmd.AddCommand(commands.NewCreateCommand())
+
 	customResourceCmd.AddCommand(commands.NewCreateCrCommand())
 
 	// Chunking