Method handleChange

backend/api/mcp/tool_change.go:157–288

(ctx context.Context, req *mcp.CallToolRequest, input ChangeInput)

}

func (s *Server) handleChange(ctx context.Context, req *mcp.CallToolRequest, input ChangeInput) (*mcp.CallToolResult, any, error) {
	// Step 1: Validate input.
	if input.Database == "" {
		return nil, nil, errors.New("database is required")
	}
	if input.SQL == "" {
		return nil, nil, errors.New("sql is required")
	}
	if input.Title == "" {
		return nil, nil, errors.New("title is required")
	}

	changeType := input.ChangeType
	if changeType == "" {
		changeType = changeTypeMigrate
	}
	if changeType != changeTypeMigrate && changeType != changeTypeSDL {
		return formatToolError(&toolError{
			Code:       "INVALID_ARGUMENT",
			Message:    fmt.Sprintf("invalid changeType %q", changeType),
			Suggestion: "allowed values: MIGRATE, SDL",
		}), nil, nil
	}

	var warnings []string
	reason := input.Reason
	runes := []rune(reason)
	if len(runes) > reasonMaxLen {
		reason = string(runes[:reasonMaxLen-3]) + "..."
		warnings = append(warnings, "reason truncated to 1000 chars")
	}

	// Step 2: Resolve database.
	resolved, resolveResult := s.resolveChangeTarget(ctx, req, input)
	if resolveResult != nil {
		return resolveResult, nil, nil
	}

	// Step 3: Use project from resolved database.
	// When input.Project is set, the resolver already filtered by it.
	project := resolved.project

	// Step 4: Create sheet.
	sheetName, err := s.createSheet(ctx, project, input.SQL)
	if err != nil {
		return formatChangeStepError(err, "SHEET_CREATE_FAILED", "bb.sheets.create", nil), nil, nil
	}

	// Step 5: Create plan.
	planName, err := s.createPlan(ctx, project, input.Title, resolved.resourceName, sheetName)
	if err != nil {
		return formatChangeStepError(err, "PLAN_CREATE_FAILED", "bb.plans.create", map[string]string{"sheet": sheetName}), nil, nil
	}

	// Step 6: Run plan checks (hybrid async, 10s budget).
	planChecks := s.runPlanChecks(ctx, planName)

	// Step 7: Create issue.