// Copyright 2025 eat-pray-ai & OpenWaygate // SPDX-License-Identifier: Apache-2.0 package comment import ( "encoding/json/jsontext" "fmt" "io" cobramcp "github.com/eat-pray-ai/cobra-mcp" "github.com/eat-pray-ai/yutu/cmd" "github.com/eat-pray-ai/yutu/pkg" "github.com/eat-pray-ai/yutu/pkg/comment" "github.com/eat-pray-ai/yutu/pkg/utils" "github.com/google/jsonschema-go/jsonschema" "github.com/modelcontextprotocol/go-sdk/mcp" "github.com/spf13/cobra" ) const ( insertTool = "comment-insert" insertPidUsage = "ID of the parent comment" insertConfirm = "Create comment on parent: %s" insertShort = "Create a comment" insertLong = "Create a comment. Use this tool to create a comment on a video." insertExample = `# Reply to a comment yutu comment insert --channelId UC_x5X --videoId dQw4w9 --authorChannelId UA_x5X --parentId UgyXXX --textOriginal 'Hello' # Reply with rating enabled yutu comment insert --channelId UC_x5X --videoId dQw4w9 --authorChannelId UA_x5X --parentId UgyXXX --textOriginal 'Reply' --canRate` ) var insertInSchema = &jsonschema.Schema{ Type: "object", Required: []string{ "parent_id", "text_original", }, Properties: map[string]*jsonschema.Schema{ "author_channel_id": {Type: "string", Description: acidUsage}, "channel_id": {Type: "string", Description: cidUsage}, "can_rate": {Type: "boolean", Description: crUsage}, "parent_id": {Type: "string", Description: insertPidUsage}, "text_original": {Type: "string", Description: toUsage}, "video_id": {Type: "string", Description: vidUsage}, "output": { Type: "string", Enum: []any{"json", "yaml", "silent"}, Description: pkg.SilentUsage, Default: jsontext.Value(`"json"`), }, }, } func init() { mcp.AddTool( cmd.Server, &mcp.Tool{ Name: insertTool, Title: insertShort, Description: insertLong, InputSchema: insertInSchema, Annotations: &mcp.ToolAnnotations{ DestructiveHint: new(false), IdempotentHint: false, OpenWorldHint: new(true), ReadOnlyHint: false, }, }, cobramcp.GenToolHandlerWithMRTR( insertTool, cobramcp.ConfirmThen( func(input comment.Comment) string { return fmt.Sprintf(insertConfirm, input.ParentId) }, func(input comment.Comment, w io.Writer) error { return input.Insert(w) }, ), ), ) commentCmd.AddCommand(insertCmd) insertCmd.Flags().StringVarP( &authorChannelId, "authorChannelId", "a", "", acidUsage, ) insertCmd.Flags().StringVarP( &channelId, "channelId", "c", "", cidUsage, ) insertCmd.Flags().BoolVarP(canRate, "canRate", "R", false, crUsage) insertCmd.Flags().StringVarP( &parentId, "parentId", "P", "", insertPidUsage, ) insertCmd.Flags().StringVarP( &textOriginal, "textOriginal", "t", "", toUsage, ) insertCmd.Flags().StringVarP(&videoId, "videoId", "v", "", vidUsage) insertCmd.Flags().StringP("output", "o", "", pkg.SilentUsage) insertCmd.Flags().Bool("yes", false, pkg.ConfirmedUsage) _ = insertCmd.MarkFlagRequired("parentId") _ = insertCmd.MarkFlagRequired("textOriginal") } var insertCmd = &cobra.Command{ Use: "insert", Short: insertShort, Long: insertLong, Example: insertExample, PreRunE: func(c *cobra.Command, _ []string) error { return utils.ConfirmPreRun(c, fmt.Sprintf(insertConfirm, parentId)) }, Run: func(c *cobra.Command, _ []string) { output, _ := c.Flags().GetString("output") input := comment.NewComment( comment.WithAuthorChannelId(authorChannelId), comment.WithChannelId(channelId), comment.WithCanRate(canRate), comment.WithParentId(parentId), comment.WithTextOriginal(textOriginal), comment.WithVideoId(videoId), comment.WithOutput(output), ) utils.HandleCmdError(input.Insert(c.OutOrStdout()), c) }, }