feat(api): add create_story/get_story/list_stories/accept_story to chatbot MCP

1 files changed, 82 insertions, 0 deletions

diff --git a/internal/api/chatbotmcp.go b/internal/api/chatbotmcp.go
index e14b522..7223bcc 100644
--- a/internal/api/chatbotmcp.go
+++ b/internal/api/chatbotmcp.go
@@ -8,9 +8,11 @@ import (
 	"strings"
 	"time"
 
+	"github.com/google/uuid"
 	"github.com/modelcontextprotocol/go-sdk/mcp"
 	"github.com/thepeterstone/claudomator/internal/event"
 	"github.com/thepeterstone/claudomator/internal/storage"
+	"github.com/thepeterstone/claudomator/internal/story"
 	"github.com/thepeterstone/claudomator/internal/task"
 )
 
@@ -53,6 +55,24 @@ type rejectTaskMCPInput struct {
 	Comment string `json:"comment,omitempty" jsonschema:"optional reason the work was rejected, fed back to the agent on retry"`
 }
 
+type createStoryMCPInput struct {
+	Name               string   `json:"name" jsonschema:"short human-readable story name"`
+	Spec               string   `json:"spec,omitempty" jsonschema:"prose description of the intent -- what a human is asking for and why"`
+	AcceptanceCriteria []string `json:"acceptance_criteria,omitempty" jsonschema:"optional list of concrete criteria the finished work must satisfy"`
+	EpicID             string   `json:"epic_id,omitempty" jsonschema:"optional epic ID to group this story under"`
+	ProjectID          string   `json:"project_id,omitempty" jsonschema:"optional loose-reference project ID; not yet used to automatically resolve a repository"`
+	Priority           string   `json:"priority,omitempty" jsonschema:"optional priority, e.g. high, normal, low"`
+}
+
+type listStoriesMCPInput struct {
+	Status string `json:"status,omitempty" jsonschema:"optional status filter, e.g. DISCOVERY, IN_PROGRESS, REVIEW_READY, DONE"`
+	EpicID string `json:"epic_id,omitempty" jsonschema:"optional epic ID filter"`
+}
+
+type storyIDInput struct {
+	StoryID string `json:"story_id" jsonschema:"the story ID"`
+}
+
 type compactTask struct {
 	ID      string     `json:"id"`
 	Name    string     `json:"name"`
@@ -196,6 +216,68 @@ func (s *Server) newChatbotServer() *mcp.Server {
 		return mcpText(msg), nil, nil
 	})
 
+	mcp.AddTool(srv, &mcp.Tool{
+		Name:        "create_story",
+		Description: "Create a story representing a piece of user intent -- a shippable slice of work realized by a tree of tasks. Use this instead of submit_task when the ask needs to be broken down rather than run as a single step. Returns the new story.",
+	}, func(_ context.Context, _ *mcp.CallToolRequest, in createStoryMCPInput) (*mcp.CallToolResult, any, error) {
+		if strings.TrimSpace(in.Name) == "" {
+			return nil, nil, badRequestf("name is required")
+		}
+		st := &story.Story{
+			ID:                 uuid.New().String(),
+			Name:               in.Name,
+			Status:             "DISCOVERY",
+			DiscoverySource:    "agent",
+			Spec:               in.Spec,
+			AcceptanceCriteria: in.AcceptanceCriteria,
+			EpicID:             in.EpicID,
+			ProjectID:          in.ProjectID,
+			Priority:           in.Priority,
+		}
+		if st.AcceptanceCriteria == nil {
+			st.AcceptanceCriteria = []string{}
+		}
+		if err := s.store.CreateStory(st); err != nil {
+			return nil, nil, err
+		}
+		return mcpJSON(st)
+	})
+
+	mcp.AddTool(srv, &mcp.Tool{
+		Name:        "get_story",
+		Description: "Get one story by ID.",
+	}, func(_ context.Context, _ *mcp.CallToolRequest, in storyIDInput) (*mcp.CallToolResult, any, error) {
+		st, err := s.store.GetStory(in.StoryID)
+		if err != nil {
+			return nil, nil, errStoryNotFound
+		}
+		return mcpJSON(st)
+	})
+
+	mcp.AddTool(srv, &mcp.Tool{
+		Name:        "list_stories",
+		Description: "List stories, optionally filtered by status and/or epic_id.",
+	}, func(_ context.Context, _ *mcp.CallToolRequest, in listStoriesMCPInput) (*mcp.CallToolResult, any, error) {
+		stories, err := s.store.ListStories(storage.StoryFilter{Status: in.Status, EpicID: in.EpicID})
+		if err != nil {
+			return nil, nil, err
+		}
+		if stories == nil {
+			stories = []*story.Story{}
+		}
+		return mcpJSON(stories)
+	})
+
+	mcp.AddTool(srv, &mcp.Tool{
+		Name:        "accept_story",
+		Description: "Accept a REVIEW_READY story, marking it DONE. This is the single human/chatbot touchpoint for a whole story's pipeline -- the underlying builder/evaluator/arbitration tasks are auto-accepted by the story orchestrator.",
+	}, func(_ context.Context, _ *mcp.CallToolRequest, in storyIDInput) (*mcp.CallToolResult, any, error) {
+		if err := s.acceptStory(in.StoryID, event.ActorChatbot); err != nil {
+			return nil, nil, err
+		}
+		return mcpText("Story accepted."), nil, nil
+	})
+
 	return srv
 }