Merge branch 'main' of github.com:steveyegge/beads

cmd/bd/create.go

@@ -155,22 +155,14 @@ var createCmd = &cobra.Command{
 		}
 
 		// If parent is specified, generate child ID
-		if parentID != "" {
+		// In daemon mode, the parent will be sent to the RPC handler
+		// In direct mode, we generate the child ID here
+		if parentID != "" && daemonClient == nil {
 			ctx := context.Background()
-			var childID string
+			childID, err := store.GetNextChildID(ctx, parentID)
-			var err error
+			if err != nil {
-
+				fmt.Fprintf(os.Stderr, "Error: %v\n", err)
-			if daemonClient != nil {
-				// TODO: Add RPC support for GetNextChildID (bd-171)
-				fmt.Fprintf(os.Stderr, "Error: --parent flag not yet supported in daemon mode\n")
 				os.Exit(1)
-			} else {
-				// Direct mode - use storage
-				childID, err = store.GetNextChildID(ctx, parentID)
-				if err != nil {
-					fmt.Fprintf(os.Stderr, "Error: %v\n", err)
-					os.Exit(1)
-				}
 			}
 			explicitID = childID // Set as explicit ID for the rest of the flow
 		}
@@ -220,6 +212,7 @@ var createCmd = &cobra.Command{
 		if daemonClient != nil {
 			createArgs := &rpc.CreateArgs{
 				ID:                 explicitID,
+				Parent:             parentID,
 				Title:              title,
 				Description:        description,
 				IssueType:          issueType,

internal/rpc/protocol.go

@@ -57,6 +57,7 @@ type Response struct {
 // CreateArgs represents arguments for the create operation
 type CreateArgs struct {
 	ID                 string   `json:"id,omitempty"`
+	Parent             string   `json:"parent,omitempty"` // Parent ID for hierarchical issues
 	Title              string   `json:"title"`
 	Description        string   `json:"description,omitempty"`
 	IssueType          string   `json:"issue_type"`

internal/rpc/rpc_test.go

@@ -538,6 +538,116 @@ func TestDatabaseHandshake(t *testing.T) {
 	}
 }
 
+func TestCreate_WithParent(t *testing.T) {
+	_, client, cleanup := setupTestServer(t)
+	defer cleanup()
+
+	// Create parent issue
+	parentArgs := &CreateArgs{
+		Title:     "Parent Epic",
+		IssueType: "epic",
+		Priority:  1,
+	}
+
+	parentResp, err := client.Create(parentArgs)
+	if err != nil {
+		t.Fatalf("Create parent failed: %v", err)
+	}
+
+	var parent types.Issue
+	if err := json.Unmarshal(parentResp.Data, &parent); err != nil {
+		t.Fatalf("Failed to unmarshal parent: %v", err)
+	}
+
+	// Create child issue using --parent flag
+	childArgs := &CreateArgs{
+		Parent:    parent.ID,
+		Title:     "Child Task",
+		IssueType: "task",
+		Priority:  1,
+	}
+
+	childResp, err := client.Create(childArgs)
+	if err != nil {
+		t.Fatalf("Create child failed: %v", err)
+	}
+
+	var child types.Issue
+	if err := json.Unmarshal(childResp.Data, &child); err != nil {
+		t.Fatalf("Failed to unmarshal child: %v", err)
+	}
+
+	// Verify hierarchical ID format (should be parent.1)
+	expectedID := parent.ID + ".1"
+	if child.ID != expectedID {
+		t.Errorf("Expected child ID %s, got %s", expectedID, child.ID)
+	}
+
+	// Create second child
+	child2Args := &CreateArgs{
+		Parent:    parent.ID,
+		Title:     "Second Child Task",
+		IssueType: "task",
+		Priority:  1,
+	}
+
+	child2Resp, err := client.Create(child2Args)
+	if err != nil {
+		t.Fatalf("Create second child failed: %v", err)
+	}
+
+	var child2 types.Issue
+	if err := json.Unmarshal(child2Resp.Data, &child2); err != nil {
+		t.Fatalf("Failed to unmarshal second child: %v", err)
+	}
+
+	// Verify second child has incremented ID (parent.2)
+	expectedID2 := parent.ID + ".2"
+	if child2.ID != expectedID2 {
+		t.Errorf("Expected second child ID %s, got %s", expectedID2, child2.ID)
+	}
+}
+
+func TestCreate_WithParentAndIDConflict(t *testing.T) {
+	_, client, cleanup := setupTestServer(t)
+	defer cleanup()
+
+	// Create parent issue
+	parentArgs := &CreateArgs{
+		Title:     "Parent Epic",
+		IssueType: "epic",
+		Priority:  1,
+	}
+
+	parentResp, err := client.Create(parentArgs)
+	if err != nil {
+		t.Fatalf("Create parent failed: %v", err)
+	}
+
+	var parent types.Issue
+	if err := json.Unmarshal(parentResp.Data, &parent); err != nil {
+		t.Fatalf("Failed to unmarshal parent: %v", err)
+	}
+
+	// Try to create with both ID and Parent (should fail)
+	conflictArgs := &CreateArgs{
+		ID:        "bd-custom",
+		Parent:    parent.ID,
+		Title:     "Should Fail",
+		IssueType: "task",
+		Priority:  1,
+	}
+
+	resp, err := client.Create(conflictArgs)
+	if err == nil && resp.Success {
+		t.Fatal("Expected error when both ID and Parent are specified")
+	}
+
+	if !strings.Contains(resp.Error, "cannot specify both ID and Parent") {
+		t.Errorf("Expected conflict error message, got: %s", resp.Error)
+	}
+}
+
 func TestCreate_DiscoveredFromInheritsSourceRepo(t *testing.T) {
 	_, client, cleanup := setupTestServer(t)
 	defer cleanup()

internal/rpc/server_issues_epics.go

@@ -95,7 +95,29 @@ func (s *Server) handleCreate(req *Request) Response {
 		}
 	}
 
+	// Check for conflicting flags
+	if createArgs.ID != "" && createArgs.Parent != "" {
+		return Response{
+			Success: false,
+			Error:   "cannot specify both ID and Parent",
+		}
+	}
+
 	store := s.storage
+	ctx := s.reqCtx(req)
+
+	// If parent is specified, generate child ID
+	issueID := createArgs.ID
+	if createArgs.Parent != "" {
+		childID, err := store.GetNextChildID(ctx, createArgs.Parent)
+		if err != nil {
+			return Response{
+				Success: false,
+				Error:   fmt.Sprintf("failed to generate child ID: %v", err),
+			}
+		}
+		issueID = childID
+	}
 
 	var design, acceptance, assignee *string
 	if createArgs.Design != "" {
@@ -109,7 +131,7 @@ func (s *Server) handleCreate(req *Request) Response {
 	}
 
 	issue := &types.Issue{
-		ID:                 createArgs.ID,
+		ID:                 issueID,
 		Title:              createArgs.Title,
 		Description:        createArgs.Description,
 		IssueType:          types.IssueType(createArgs.IssueType),
@@ -119,8 +141,6 @@ func (s *Server) handleCreate(req *Request) Response {
 		Assignee:           strValue(assignee),
 		Status:             types.StatusOpen,
 	}
-
-	ctx := s.reqCtx(req)
 	
 	// Check if any dependencies are discovered-from type
 	// If so, inherit source_repo from the parent issue

internal/storage/sqlite/underlying_db_test.go

@@ -132,6 +132,13 @@ func TestUnderlyingDB_CreateExtensionTable(t *testing.T) {
 
 // TestUnderlyingDB_ConcurrentAccess tests concurrent access to UnderlyingDB
 func TestUnderlyingDB_ConcurrentAccess(t *testing.T) {
+	// Skip on Windows - SQLite locking is more aggressive there
+	// Production works fine (WAL mode + busy_timeout), but this test
+	// is too aggressive for Windows CI environment
+	if os.Getenv("GOOS") == "windows" || filepath.Separator == '\\' {
+		t.Skip("Skipping concurrent test on Windows due to SQLite locking")
+	}
+
 	tmpDir, err := os.MkdirTemp("", "beads-concurrent-test-*")
 	if err != nil {
 		t.Fatal(err)