refactor(data): retire legacy TaskStatus values and backfill existing rows

Slice 6 of the worker state and queue consolidation refactor.

* Drop Manual, Planning, Planned, Draft, Waiting from the TaskStatus enum
  and from the EF value converter; only the lifecycle values remain
  (Idle, Queued, Running, Done, Failed, Cancelled).
* Add migration RetireLegacyTaskStatus that rewrites existing rows:
  manual/draft -> idle, planning -> idle+planning_phase=active,
  planned -> idle+planning_phase=finalized, waiting -> queued+blocked_by
  derived from sort_order via a CTE with LAG().
* Reroute every call site that compared/set legacy values to the new
  three-field model (Status + PlanningPhase + BlockedByTaskId), including
  the planning repo helpers, MCP services, the planning chain coordinator,
  and the UI view-models. TaskRowViewModel now exposes PlanningPhase to
  drive the planning badge.
* Refresh Worker/CLAUDE.md and Data/CLAUDE.md, the docs/plan.md status
  section, and the planning verification notes in docs/open.md.
This commit is contained in:
Mika Kuns
2026-04-27 15:28:55 +02:00
parent ff7c239959
commit dc3fc443b4
37 changed files with 306 additions and 229 deletions

View File

@@ -219,10 +219,11 @@ Requires Plan B (worker hub endpoints) merged. Until then, only the UI structure
3. Ask Claude to create two child tasks via `mcp__claudedo__create_child_task`. 3. Ask Claude to create two child tasks via `mcp__claudedo__create_child_task`.
4. Watch the UI: drafts appear indented under the parent, italic, reduced opacity, with a `DRAFT` badge. 4. Watch the UI: drafts appear indented under the parent, italic, reduced opacity, with a `DRAFT` badge.
5. The parent shows a `PLANNING` badge. Click the chevron → children collapse; click again → children expand. 5. The parent shows a `PLANNING` badge. Click the chevron → children collapse; click again → children expand.
6. Ask Claude to `finalize` — drafts flip to Manual/Queued children; parent flips to `PLANNED` badge. 6. Ask Claude to `finalize` — children move to `Queued` (first) and `Queued + BlockedBy` (rest); parent's `PlanningPhase` flips from `Active` to `Finalized` (`PLANNED` badge). The first child must reach `Running` automatically — no manual `WakeQueue` needed (regression-tested in `PlanningEndToEndTests`).
7. In a new planning task, close the terminal without finalize. Right-click the Planning task → the unfinished-session modal opens with Resume / Finalize now / Discard. 7. In a new planning task, close the terminal without finalize. Right-click the Planning task → the unfinished-session modal opens with Resume / Finalize now / Discard.
8. Attempt to delete a parent with children via the details panel — confirm the friendly error dialog appears and the task is NOT deleted. 8. Attempt to delete a parent with children via the details panel — confirm the friendly error dialog appears and the task is NOT deleted.
**Known followups (non-blocking):** **Known followups (non-blocking):**
- `Border.badge.planned` style (blue) is defined in `IslandStyles.axaml` but never applied — `TaskRowView` keeps the `planning` class for both Planning and Planned, so Planned gets the amber badge. Either make the view swap `Classes.planned` when status is Planned, or remove the unused style + brush. - `Border.badge.planned` style (blue) is defined in `IslandStyles.axaml` but never applied — `TaskRowView` keeps the `planning` class for both `PlanningPhase=Active` and `Finalized`, so a finalized parent gets the amber badge. Either make the view swap `Classes.planned` when `PlanningPhase` is `Finalized`, or remove the unused style + brush.
- Dead `Instance` statics on `BoolToItalicConverter` and `BoolToDraftOpacityConverter` — App.axaml registers instances via the resource dictionary; the static members can be removed. - Dead `Instance` statics on `BoolToItalicConverter` and `BoolToDraftOpacityConverter` — App.axaml registers instances via the resource dictionary; the static members can be removed.
- `Ui.Tests` `IWorkerClient` fakes (`DetailsIslandPlanningTests`, `PlanningDiffViewModelTests`, `ConflictResolutionViewModelTests`) miss `OpenInteractiveTerminalAsync` and `QueuePlanningSubtasksAsync` — pre-existing constructor-drift; rebase fakes onto a shared abstract base.

View File

@@ -49,7 +49,9 @@ Schema in 3NF. Keine Mehrwert-Felder (z.B. JSON-Arrays), keine transitiven Abhä
- `list_id` TEXT NOT NULL REFERENCES `lists(id)` ON DELETE CASCADE - `list_id` TEXT NOT NULL REFERENCES `lists(id)` ON DELETE CASCADE
- `title` TEXT NOT NULL - `title` TEXT NOT NULL
- `description` TEXT NULL - `description` TEXT NULL
- `status` TEXT NOT NULL — `manual` | `queued` | `running` | `done` | `failed` (`running` bleibt persistiert für Crash-Recovery: stale `running`-Tasks werden beim Worker-Start auf `failed` gesetzt) - `status` TEXT NOT NULL — Lifecycle-only: `idle` | `queued` | `running` | `done` | `failed` | `cancelled` (`running` bleibt persistiert für Crash-Recovery: stale `running`-Tasks werden beim Worker-Start auf `failed` gesetzt). Planungs-Hierarchie und Chain-Blocking laufen über zwei separate Felder.
- `planning_phase` TEXT NOT NULL DEFAULT `'none'` — Parent-only Marker: `none` | `active` (Planung läuft) | `finalized` (Plan committed, Children existieren). Ein Parent kann `status='idle'` sein und gleichzeitig `planning_phase='finalized'` (für Re-Runs).
- `blocked_by_task_id` TEXT NULL REFERENCES `tasks(id)` ON DELETE SET NULL — Vorgänger in einem sequenziellen Subtask-Chain. Ein `queued`-Row mit `blocked_by_task_id IS NOT NULL` wird vom Picker übersprungen.
- `scheduled_for` TIMESTAMP NULL — "nicht vor" - `scheduled_for` TIMESTAMP NULL — "nicht vor"
- `result` TEXT NULL (Markdown) - `result` TEXT NULL (Markdown)
- `log_path` TEXT NULL — Pfad zur ndjson-Log-Datei - `log_path` TEXT NULL — Pfad zur ndjson-Log-Datei

View File

@@ -4,7 +4,7 @@ Shared data layer: models, repositories, SQLite infrastructure, and git operatio
## Models ## Models
- **TaskEntity** — Id, ListId, Title, Description, Status (Manual|Queued|Running|Done|Failed), ScheduledFor, Result, LogPath, timestamps, CommitType, Model / SystemPrompt / AgentPath (nullable overrides), IsStarred, IsMyDay, Notes - **TaskEntity** — Id, ListId, Title, Description, Status (`Idle|Queued|Running|Done|Failed|Cancelled`), PlanningPhase (`None|Active|Finalized` — parent-only), BlockedByTaskId (nullable FK to predecessor in a chain), ScheduledFor, Result, LogPath, timestamps, CommitType, Model / SystemPrompt / AgentPath (nullable overrides), IsStarred, IsMyDay, Notes, ParentTaskId, PlanningSessionId, PlanningSessionToken, PlanningFinalizedAt, CreatedBy. Legacy values `Manual`/`Planning`/`Planned`/`Draft`/`Waiting` were retired; existing rows backfill automatically via the `RetireLegacyTaskStatus` migration.
- **ListEntity** — Id, Name, WorkingDir, DefaultCommitType, CreatedAt - **ListEntity** — Id, Name, WorkingDir, DefaultCommitType, CreatedAt
- **ListConfigEntity** — ListId (PK, 1:1 with list), Model, SystemPrompt, AgentPath (all nullable) - **ListConfigEntity** — ListId (PK, 1:1 with list), Model, SystemPrompt, AgentPath (all nullable)
- **TagEntity** — Id (autoincrement), Name (unique) - **TagEntity** — Id (autoincrement), Name (unique)
@@ -16,7 +16,7 @@ Shared data layer: models, repositories, SQLite infrastructure, and git operatio
All repositories use EF Core LINQ queries via `ClaudeDoDbContext`. Exception: `TaskRepository.GetNextQueuedAgentTaskAsync` uses `FromSqlRaw` for atomic queue claim. All repositories use EF Core LINQ queries via `ClaudeDoDbContext`. Exception: `TaskRepository.GetNextQueuedAgentTaskAsync` uses `FromSqlRaw` for atomic queue claim.
- **TaskRepository** — CRUD, status transitions (`MarkRunningAsync`, `MarkDoneAsync`, `MarkFailedAsync`), `GetNextQueuedAgentTaskAsync` (queue polling), `GetEffectiveTagsAsync` (union of task + list tags), `FlipAllRunningToFailedAsync`, `UpdateAgentSettingsAsync` (model / system-prompt / agent-path overrides) - **TaskRepository** — CRUD, planning helpers (`CreateChildAsync`, `SetPlanningStartedAsync`, `DiscardPlanningAsync`, `TryCompleteParentAsync`, `UpdateChildAsync`), tag management (`GetEffectiveTagsAsync` union of task + list tags), `UpdateAgentSettingsAsync` (model / system-prompt / agent-path overrides). Status-mutation primitives `MarkRunningAsync` / `MarkDoneAsync` / `MarkFailedAsync` / `FlipAllRunningToFailedAsync` are `internal` and called only by `TaskStateService` in the worker. `CreateChildAsync` produces children with `Status=Idle, PlanningPhase=None`; once their parent's `PlanningPhase` becomes `Finalized`, the chain coordinator queues them.
- **ListRepository** — CRUD, tag junction management, `GetConfigAsync` / `SetConfigAsync` (upsert) / `DeleteConfigAsync` for `list_config` - **ListRepository** — CRUD, tag junction management, `GetConfigAsync` / `SetConfigAsync` (upsert) / `DeleteConfigAsync` for `list_config`
- **TagRepository** — `GetOrCreateAsync` (idempotent) - **TagRepository** — `GetOrCreateAsync` (idempotent)
- **WorktreeRepository** — CRUD, `UpdateHeadAsync`, `SetStateAsync` - **WorktreeRepository** — CRUD, `UpdateHeadAsync`, `SetStateAsync`
@@ -35,7 +35,7 @@ All repositories use EF Core LINQ queries via `ClaudeDoDbContext`. Exception: `T
## Schema ## Schema
Tables: `lists`, `tasks`, `tags`, `list_tags`, `task_tags`, `worktrees`, `list_config`, `task_runs`, `subtasks`, `app_settings`. Managed by EF Core migrations in the `Migrations/` folder. Seed data: tags "agent" and "manual". Tables: `lists`, `tasks`, `tags`, `list_tags`, `task_tags`, `worktrees`, `list_config`, `task_runs`, `subtasks`, `app_settings`. Managed by EF Core migrations in the `Migrations/` folder. Seed data: tags "agent" and "manual". The `tasks` table holds `status`, `planning_phase` (default `none`), and `blocked_by_task_id` (FK to `tasks.id`, `ON DELETE SET NULL`).
## Conventions ## Conventions

View File

@@ -17,12 +17,6 @@ public class TaskEntityConfiguration : IEntityTypeConfiguration<TaskEntity>
TaskStatus.Done => "done", TaskStatus.Done => "done",
TaskStatus.Failed => "failed", TaskStatus.Failed => "failed",
TaskStatus.Cancelled => "cancelled", TaskStatus.Cancelled => "cancelled",
// Legacy values — kept for compat until slice 6 retires them.
TaskStatus.Manual => "manual",
TaskStatus.Planning => "planning",
TaskStatus.Planned => "planned",
TaskStatus.Draft => "draft",
TaskStatus.Waiting => "waiting",
_ => throw new ArgumentOutOfRangeException(nameof(v)), _ => throw new ArgumentOutOfRangeException(nameof(v)),
}; };
@@ -35,12 +29,6 @@ public class TaskEntityConfiguration : IEntityTypeConfiguration<TaskEntity>
"done" => TaskStatus.Done, "done" => TaskStatus.Done,
"failed" => TaskStatus.Failed, "failed" => TaskStatus.Failed,
"cancelled" => TaskStatus.Cancelled, "cancelled" => TaskStatus.Cancelled,
// Legacy values — kept for compat until slice 6 retires them.
"manual" => TaskStatus.Manual,
"planning" => TaskStatus.Planning,
"planned" => TaskStatus.Planned,
"draft" => TaskStatus.Draft,
"waiting" => TaskStatus.Waiting,
_ => throw new ArgumentOutOfRangeException(nameof(v)), _ => throw new ArgumentOutOfRangeException(nameof(v)),
}; };

View File

@@ -0,0 +1,51 @@
using Microsoft.EntityFrameworkCore.Migrations;
#nullable disable
namespace ClaudeDo.Data.Migrations
{
/// <inheritdoc />
public partial class RetireLegacyTaskStatus : Migration
{
/// <inheritdoc />
protected override void Up(MigrationBuilder migrationBuilder)
{
// manual / draft -> idle
migrationBuilder.Sql("UPDATE tasks SET status = 'idle' WHERE status IN ('manual', 'draft');");
// planning -> idle + planning_phase=active
migrationBuilder.Sql("UPDATE tasks SET status = 'idle', planning_phase = 'active' WHERE status = 'planning';");
// planned -> idle + planning_phase=finalized
migrationBuilder.Sql("UPDATE tasks SET status = 'idle', planning_phase = 'finalized' WHERE status = 'planned';");
// waiting -> queued + blocked_by_task_id derived from sort_order chain.
// SQLite 3.25+ supports window functions (LAG).
migrationBuilder.Sql(@"
WITH ordered AS (
SELECT id,
LAG(id) OVER (PARTITION BY parent_task_id ORDER BY sort_order, created_at) AS prev_id
FROM tasks
WHERE status = 'waiting'
)
UPDATE tasks
SET status = 'queued',
blocked_by_task_id = (SELECT prev_id FROM ordered WHERE ordered.id = tasks.id)
WHERE id IN (SELECT id FROM ordered);");
}
/// <inheritdoc />
protected override void Down(MigrationBuilder migrationBuilder)
{
// Best-effort and lossy: cancelled is folded back into failed,
// (idle, finalized) -> planned, (idle, active) -> planning,
// queued + blocked_by_task_id != null -> waiting.
// Manual/Draft distinction is unrecoverable — anything previously
// 'manual' or 'draft' stays 'idle' on the way back.
migrationBuilder.Sql("UPDATE tasks SET status = 'failed' WHERE status = 'cancelled';");
migrationBuilder.Sql("UPDATE tasks SET status = 'planned' WHERE status = 'idle' AND planning_phase = 'finalized';");
migrationBuilder.Sql("UPDATE tasks SET status = 'planning' WHERE status = 'idle' AND planning_phase = 'active';");
migrationBuilder.Sql("UPDATE tasks SET status = 'waiting', blocked_by_task_id = NULL WHERE status = 'queued' AND blocked_by_task_id IS NOT NULL;");
}
}
}

View File

@@ -2,22 +2,12 @@ namespace ClaudeDo.Data.Models;
public enum TaskStatus public enum TaskStatus
{ {
// Lifecycle (canonical values).
Idle, Idle,
Queued, Queued,
Running, Running,
Done, Done,
Failed, Failed,
Cancelled, Cancelled,
// Legacy values — kept for backwards compatibility while the worker
// layer is migrated to (Status, PlanningPhase, BlockedByTaskId).
// Removed in slice 6 of the worker-state-and-queue-consolidation refactor.
Manual,
Planning,
Planned,
Draft,
Waiting,
} }
public enum PlanningPhase public enum PlanningPhase
@@ -33,7 +23,7 @@ public sealed class TaskEntity
public required string ListId { get; init; } public required string ListId { get; init; }
public required string Title { get; set; } public required string Title { get; set; }
public string? Description { get; set; } public string? Description { get; set; }
public TaskStatus Status { get; set; } = TaskStatus.Manual; public TaskStatus Status { get; set; } = TaskStatus.Idle;
public PlanningPhase PlanningPhase { get; set; } = PlanningPhase.None; public PlanningPhase PlanningPhase { get; set; } = PlanningPhase.None;
public string? BlockedByTaskId { get; set; } public string? BlockedByTaskId { get; set; }
public DateTime? ScheduledFor { get; set; } public DateTime? ScheduledFor { get; set; }

View File

@@ -141,7 +141,7 @@ public sealed class TaskRepository
await _context.Tasks await _context.Tasks
.Where(t => t.Id == taskId) .Where(t => t.Id == taskId)
.ExecuteUpdateAsync(s => s .ExecuteUpdateAsync(s => s
.SetProperty(t => t.Status, TaskStatus.Manual) .SetProperty(t => t.Status, TaskStatus.Idle)
.SetProperty(t => t.StartedAt, (DateTime?)null) .SetProperty(t => t.StartedAt, (DateTime?)null)
.SetProperty(t => t.FinishedAt, (DateTime?)null) .SetProperty(t => t.FinishedAt, (DateTime?)null)
.SetProperty(t => t.Result, (string?)null), ct); .SetProperty(t => t.Result, (string?)null), ct);
@@ -270,7 +270,7 @@ public sealed class TaskRepository
ListId = parent.ListId, ListId = parent.ListId,
Title = title, Title = title,
Description = description, Description = description,
Status = TaskStatus.Draft, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = string.IsNullOrEmpty(commitType) ? parent.CommitType : commitType, CommitType = string.IsNullOrEmpty(commitType) ? parent.CommitType : commitType,
ParentTaskId = parentId, ParentTaskId = parentId,
@@ -355,9 +355,10 @@ public sealed class TaskRepository
CancellationToken ct = default) CancellationToken ct = default)
{ {
var affected = await _context.Tasks var affected = await _context.Tasks
.Where(t => t.Id == taskId && t.Status == TaskStatus.Manual) .Where(t => t.Id == taskId
&& t.Status == TaskStatus.Idle
&& t.PlanningPhase == PlanningPhase.None)
.ExecuteUpdateAsync(s => s .ExecuteUpdateAsync(s => s
.SetProperty(t => t.Status, TaskStatus.Planning)
.SetProperty(t => t.PlanningPhase, PlanningPhase.Active) .SetProperty(t => t.PlanningPhase, PlanningPhase.Active)
.SetProperty(t => t.PlanningSessionToken, sessionToken), ct); .SetProperty(t => t.PlanningSessionToken, sessionToken), ct);
@@ -406,20 +407,23 @@ public sealed class TaskRepository
var parent = await _context.Tasks var parent = await _context.Tasks
.AsNoTracking() .AsNoTracking()
.FirstOrDefaultAsync(t => t.Id == parentId, ct); .FirstOrDefaultAsync(t => t.Id == parentId, ct);
if (parent is null || parent.Status != TaskStatus.Planning) if (parent is null || parent.PlanningPhase != PlanningPhase.Active)
{ {
await tx.RollbackAsync(ct); await tx.RollbackAsync(ct);
return false; return false;
} }
// Children created during the planning session are Status=Idle, PlanningPhase=None.
await _context.Tasks await _context.Tasks
.Where(t => t.ParentTaskId == parentId && t.Status == TaskStatus.Draft) .Where(t => t.ParentTaskId == parentId
&& t.Status == TaskStatus.Idle
&& t.PlanningPhase == PlanningPhase.None)
.ExecuteDeleteAsync(ct); .ExecuteDeleteAsync(ct);
await _context.Tasks await _context.Tasks
.Where(t => t.Id == parentId) .Where(t => t.Id == parentId)
.ExecuteUpdateAsync(s => s .ExecuteUpdateAsync(s => s
.SetProperty(t => t.Status, TaskStatus.Manual) .SetProperty(t => t.Status, TaskStatus.Idle)
.SetProperty(t => t.PlanningPhase, PlanningPhase.None) .SetProperty(t => t.PlanningPhase, PlanningPhase.None)
.SetProperty(t => t.PlanningSessionId, (string?)null) .SetProperty(t => t.PlanningSessionId, (string?)null)
.SetProperty(t => t.PlanningSessionToken, (string?)null) .SetProperty(t => t.PlanningSessionToken, (string?)null)
@@ -434,7 +438,7 @@ public sealed class TaskRepository
CancellationToken ct = default) CancellationToken ct = default)
{ {
var parent = await _context.Tasks.AsNoTracking().FirstOrDefaultAsync(t => t.Id == parentId, ct); var parent = await _context.Tasks.AsNoTracking().FirstOrDefaultAsync(t => t.Id == parentId, ct);
if (parent is null || parent.Status != TaskStatus.Planned) return; if (parent is null || parent.PlanningPhase != PlanningPhase.Finalized) return;
var children = await _context.Tasks var children = await _context.Tasks
.Where(t => t.ParentTaskId == parentId) .Where(t => t.ParentTaskId == parentId)

View File

@@ -474,8 +474,7 @@ public sealed partial class DetailsIslandViewModel : ViewModelBase
foreach (var s in subs) foreach (var s in subs)
Subtasks.Add(new SubtaskRowViewModel { Id = s.Id, Title = s.Title, Done = s.Completed }); Subtasks.Add(new SubtaskRowViewModel { Id = s.Id, Title = s.Title, Done = s.Completed });
if (entity.Status == ClaudeDo.Data.Models.TaskStatus.Planning || if (entity.PlanningPhase != ClaudeDo.Data.Models.PlanningPhase.None)
entity.Status == ClaudeDo.Data.Models.TaskStatus.Planned)
{ {
await LoadPlanningChildrenAsync(row.Id, ct); await LoadPlanningChildrenAsync(row.Id, ct);
} }

View File

@@ -15,6 +15,7 @@ public sealed partial class TaskRowViewModel : ViewModelBase
[ObservableProperty] private bool _isMyDay; [ObservableProperty] private bool _isMyDay;
[ObservableProperty] private bool _isSelected; [ObservableProperty] private bool _isSelected;
[ObservableProperty] private TaskStatus _status; [ObservableProperty] private TaskStatus _status;
[ObservableProperty] private PlanningPhase _planningPhase;
[ObservableProperty] private string? _branch; [ObservableProperty] private string? _branch;
[ObservableProperty] private string? _diffStat; [ObservableProperty] private string? _diffStat;
[ObservableProperty] private string? _liveTail; [ObservableProperty] private string? _liveTail;
@@ -37,18 +38,19 @@ public sealed partial class TaskRowViewModel : ViewModelBase
public int StepsCompleted { get; init; } public int StepsCompleted { get; init; }
public bool IsChild => !string.IsNullOrEmpty(ParentTaskId); public bool IsChild => !string.IsNullOrEmpty(ParentTaskId);
public bool IsPlanningParent => Status == TaskStatus.Planning public bool IsPlanningParent => PlanningPhase != PlanningPhase.None
|| Status == TaskStatus.Planned
|| HasPlanningChildren; || HasPlanningChildren;
public bool IsDraft => Status == TaskStatus.Draft; public bool IsDraft => IsChild && Status == TaskStatus.Idle;
public bool CanOpenPlanningSession => Status == TaskStatus.Manual && !IsChild; public bool CanOpenPlanningSession => Status == TaskStatus.Idle
public bool CanResumeOrDiscardPlanning => Status == TaskStatus.Planning; && PlanningPhase == PlanningPhase.None
&& !IsChild;
public bool CanResumeOrDiscardPlanning => PlanningPhase == PlanningPhase.Active;
public string? PlanningBadge => Status switch public string? PlanningBadge => PlanningPhase switch
{ {
TaskStatus.Planning => "PLANNING", PlanningPhase.Active => "PLANNING",
TaskStatus.Planned => "PLANNED", PlanningPhase.Finalized => "PLANNED",
_ => null, _ => null,
}; };
@@ -59,8 +61,7 @@ public sealed partial class TaskRowViewModel : ViewModelBase
public bool IsOverdue => ScheduledFor is { } d && d.Date < DateTime.Today && !Done; public bool IsOverdue => ScheduledFor is { } d && d.Date < DateTime.Today && !Done;
public bool IsRunning => Status == TaskStatus.Running; public bool IsRunning => Status == TaskStatus.Running;
public bool IsQueued => Status == TaskStatus.Queued && string.IsNullOrEmpty(BlockedByTaskId); public bool IsQueued => Status == TaskStatus.Queued && string.IsNullOrEmpty(BlockedByTaskId);
public bool IsWaiting => (Status == TaskStatus.Queued && !string.IsNullOrEmpty(BlockedByTaskId)) public bool IsWaiting => Status == TaskStatus.Queued && !string.IsNullOrEmpty(BlockedByTaskId);
|| Status == TaskStatus.Waiting;
public bool CanRemoveFromQueue => IsQueued || HasQueuedSubtasks; public bool CanRemoveFromQueue => IsQueued || HasQueuedSubtasks;
public bool HasSchedule => ScheduledFor.HasValue; public bool HasSchedule => ScheduledFor.HasValue;
public bool HasLiveTail => IsRunning && !string.IsNullOrEmpty(LiveTail); public bool HasLiveTail => IsRunning && !string.IsNullOrEmpty(LiveTail);
@@ -76,7 +77,6 @@ public sealed partial class TaskRowViewModel : ViewModelBase
(TaskStatus.Done, _) => "review", (TaskStatus.Done, _) => "review",
(TaskStatus.Queued, true) => "waiting", (TaskStatus.Queued, true) => "waiting",
(TaskStatus.Queued, false) => "queued", (TaskStatus.Queued, false) => "queued",
(TaskStatus.Waiting, _) => "waiting",
_ => "idle", _ => "idle",
}; };
@@ -87,14 +87,19 @@ public sealed partial class TaskRowViewModel : ViewModelBase
OnPropertyChanged(nameof(IsQueued)); OnPropertyChanged(nameof(IsQueued));
OnPropertyChanged(nameof(IsWaiting)); OnPropertyChanged(nameof(IsWaiting));
OnPropertyChanged(nameof(HasLiveTail)); OnPropertyChanged(nameof(HasLiveTail));
OnPropertyChanged(nameof(IsPlanningParent));
OnPropertyChanged(nameof(PlanningBadge));
OnPropertyChanged(nameof(IsDraft)); OnPropertyChanged(nameof(IsDraft));
OnPropertyChanged(nameof(CanOpenPlanningSession)); OnPropertyChanged(nameof(CanOpenPlanningSession));
OnPropertyChanged(nameof(CanResumeOrDiscardPlanning));
OnPropertyChanged(nameof(CanRemoveFromQueue)); OnPropertyChanged(nameof(CanRemoveFromQueue));
} }
partial void OnPlanningPhaseChanged(PlanningPhase value)
{
OnPropertyChanged(nameof(IsPlanningParent));
OnPropertyChanged(nameof(PlanningBadge));
OnPropertyChanged(nameof(CanOpenPlanningSession));
OnPropertyChanged(nameof(CanResumeOrDiscardPlanning));
}
partial void OnHasQueuedSubtasksChanged(bool value) partial void OnHasQueuedSubtasksChanged(bool value)
=> OnPropertyChanged(nameof(CanRemoveFromQueue)); => OnPropertyChanged(nameof(CanRemoveFromQueue));
@@ -141,6 +146,7 @@ public sealed partial class TaskRowViewModel : ViewModelBase
IsStarred = t.IsStarred; IsStarred = t.IsStarred;
IsMyDay = t.IsMyDay; IsMyDay = t.IsMyDay;
Status = t.Status; Status = t.Status;
PlanningPhase = t.PlanningPhase;
Branch = t.Worktree?.BranchName; Branch = t.Worktree?.BranchName;
DiffStat = t.Worktree?.DiffStat; DiffStat = t.Worktree?.DiffStat;
ScheduledFor = t.ScheduledFor; ScheduledFor = t.ScheduledFor;

View File

@@ -176,7 +176,7 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
ct.ThrowIfCancellationRequested(); ct.ThrowIfCancellationRequested();
static bool IsPlanningStatus(TaskStatus s) => s == TaskStatus.Planning || s == TaskStatus.Planned; static bool IsPlanningParent(TaskEntity t) => t.PlanningPhase != PlanningPhase.None;
IEnumerable<TaskEntity> filtered = list.Kind switch IEnumerable<TaskEntity> filtered = list.Kind switch
{ {
@@ -185,10 +185,10 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
ListKind.Smart when list.Id == "smart:planned" => all.Where(t => t.ScheduledFor != null), ListKind.Smart when list.Id == "smart:planned" => all.Where(t => t.ScheduledFor != null),
ListKind.Virtual when list.Id == "virtual:queued" => all.Where(t => ListKind.Virtual when list.Id == "virtual:queued" => all.Where(t =>
(t.Status == TaskStatus.Queued && t.ParentTaskId == null) || (t.Status == TaskStatus.Queued && t.ParentTaskId == null) ||
(IsPlanningStatus(t.Status) && all.Any(c => c.ParentTaskId == t.Id && (c.Status == TaskStatus.Queued || c.Status == TaskStatus.Waiting)))), (IsPlanningParent(t) && all.Any(c => c.ParentTaskId == t.Id && c.Status == TaskStatus.Queued))),
ListKind.Virtual when list.Id == "virtual:running" => all.Where(t => ListKind.Virtual when list.Id == "virtual:running" => all.Where(t =>
(t.Status == TaskStatus.Running && t.ParentTaskId == null) || (t.Status == TaskStatus.Running && t.ParentTaskId == null) ||
(IsPlanningStatus(t.Status) && all.Any(c => c.ParentTaskId == t.Id && c.Status == TaskStatus.Running))), (IsPlanningParent(t) && all.Any(c => c.ParentTaskId == t.Id && c.Status == TaskStatus.Running))),
ListKind.Virtual when list.Id == "virtual:review" => all.Where(t => t.Status == TaskStatus.Done && t.Worktree?.State == WorktreeState.Active && t.ParentTaskId == null), ListKind.Virtual when list.Id == "virtual:review" => all.Where(t => t.Status == TaskStatus.Done && t.Worktree?.State == WorktreeState.Active && t.ParentTaskId == null),
ListKind.User => all.Where(t => $"user:{t.ListId}" == list.Id), ListKind.User => all.Where(t => $"user:{t.ListId}" == list.Id),
_ => Enumerable.Empty<TaskEntity>(), _ => Enumerable.Empty<TaskEntity>(),
@@ -437,7 +437,7 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
var entity = await db.Tasks.FirstOrDefaultAsync(t => t.Id == row.Id); var entity = await db.Tasks.FirstOrDefaultAsync(t => t.Id == row.Id);
if (entity != null) if (entity != null)
{ {
entity.Status = row.Done ? TaskStatus.Done : TaskStatus.Manual; entity.Status = row.Done ? TaskStatus.Done : TaskStatus.Idle;
row.Status = entity.Status; row.Status = entity.Status;
await db.SaveChangesAsync(); await db.SaveChangesAsync();
} }
@@ -493,18 +493,16 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
var entity = await db.Tasks.FirstOrDefaultAsync(t => t.Id == row.Id); var entity = await db.Tasks.FirstOrDefaultAsync(t => t.Id == row.Id);
if (entity is null) return; if (entity is null) return;
// For a planning parent the dequeue button targets queued/waiting children, // For a planning parent the dequeue button targets queued children
// not the parent itself (whose Status is Planning/Planned). // (chain-blocked or not), not the parent itself.
if (entity.Status == TaskStatus.Planning || entity.Status == TaskStatus.Planned if (entity.PlanningPhase != PlanningPhase.None)
|| entity.PlanningPhase != PlanningPhase.None)
{ {
var children = await db.Tasks var children = await db.Tasks
.Where(t => t.ParentTaskId == row.Id .Where(t => t.ParentTaskId == row.Id && t.Status == TaskStatus.Queued)
&& (t.Status == TaskStatus.Queued || t.Status == TaskStatus.Waiting))
.ToListAsync(); .ToListAsync();
foreach (var c in children) foreach (var c in children)
{ {
c.Status = TaskStatus.Manual; c.Status = TaskStatus.Idle;
c.BlockedByTaskId = null; c.BlockedByTaskId = null;
} }
await db.SaveChangesAsync(); await db.SaveChangesAsync();
@@ -513,7 +511,7 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
var childRow = Items.FirstOrDefault(r => r.Id == c.Id); var childRow = Items.FirstOrDefault(r => r.Id == c.Id);
if (childRow is not null) if (childRow is not null)
{ {
childRow.Status = TaskStatus.Manual; childRow.Status = TaskStatus.Idle;
childRow.BlockedByTaskId = null; childRow.BlockedByTaskId = null;
} }
} }
@@ -521,9 +519,9 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
} }
else else
{ {
entity.Status = TaskStatus.Manual; entity.Status = TaskStatus.Idle;
await db.SaveChangesAsync(); await db.SaveChangesAsync();
row.Status = TaskStatus.Manual; row.Status = TaskStatus.Idle;
} }
Regroup(); Regroup();
UpdateSubtitle(); UpdateSubtitle();
@@ -565,7 +563,8 @@ public sealed partial class TasksIslandViewModel : ViewModelBase
[RelayCommand] [RelayCommand]
private async Task OpenPlanningSessionAsync(TaskRowViewModel? row) private async Task OpenPlanningSessionAsync(TaskRowViewModel? row)
{ {
if (row is null || row.Status != TaskStatus.Manual) return; if (row is null) return;
if (row.Status != TaskStatus.Idle || row.PlanningPhase != PlanningPhase.None) return;
ForegroundHelper.AllowAny(); ForegroundHelper.AllowAny();
try { await _worker!.StartPlanningSessionAsync(row.Id); } try { await _worker!.StartPlanningSessionAsync(row.Id); }
catch { } catch { }

View File

@@ -2,15 +2,60 @@
ASP.NET Core hosted service that executes tasks via Claude CLI in isolated environments. ASP.NET Core hosted service that executes tasks via Claude CLI in isolated environments.
## Folder Layout
```
Worker/
State/ — TaskStateService + TransitionResult (sole owner of Status/PlanningPhase/BlockedBy writes)
Queue/ — IQueueWaker, IQueuePicker, QueueService (BackgroundService), OverrideSlotService
Lifecycle/ — StaleTaskRecovery, TaskResetService, TaskMergeService
Worktrees/ — WorktreeMaintenanceService
Agents/ — AgentFileService, DefaultAgentSeeder
Runner/ — TaskRunner + Claude CLI integration
Planning/ — PlanningSessionManager, PlanningChainCoordinator, PlanningMcpService
External/ — ExternalMcpService
Hub/ — WorkerHub, HubBroadcaster
```
## Architecture ## Architecture
- **Program.cs** — loads config, inits schema, registers DI, configures SignalR on `/hub`, binds to `127.0.0.1:47821` - **Program.cs** — loads config, inits schema, registers DI, configures SignalR on `/hub`, binds to `127.0.0.1:47821`
- **QueueService** — `BackgroundService` with two execution slots: - **TaskStateService** — only component that writes `Status`, `PlanningPhase`, `BlockedByTaskId`. All transitions return a `TransitionResult` (no exceptions on invalid moves). Wakes the queue and broadcasts `TaskUpdated` automatically; advances the planning chain on child terminal transitions.
- Queue slot: FIFO sequential processing of "agent"-tagged queued tasks - **IQueueWaker / IQueuePicker / QueueService** — waker is a singleton `SemaphoreSlim`; picker performs the atomic `Queued → Running` claim filtered by `BlockedByTaskId IS NULL`, schedule, and the `agent` tag; QueueService is a thin `BackgroundService` that loops on the waker and dispatches via `TaskRunner`.
- Override slot: immediate execution via `RunNow(taskId)` - **OverrideSlotService** — owns `RunNow` / `ContinueTask`; goes through `TaskStateService.StartRunningAsync` (caller-driven, serialized by slot lock).
- Wake signaling via `SemaphoreSlim`, backstop timer (30s default) - **StaleTaskRecovery** — startup-only service; calls `TaskStateService.RecoverStaleRunningAsync` to flip orphaned `Running` rows to `Failed`.
- **StaleTaskRecovery** — startup-only service, flips orphaned "running" tasks to "failed" - **External/ExternalMcpService** — always-on MCP tools for general Claude sessions: `ListTaskLists`, `ListTasks`, `GetTask`, `AddTask` (with tags), `UpdateTask`, `UpdateTaskStatus` (`Idle` / `Queued`), `SetTaskTags`, `ListTags`, `DeleteTask`, `RunTaskNow`, `CancelTask`. Auth via optional `X-ClaudeDo-Key` header.
- **External/ExternalMcpService** — always-on MCP tools for general Claude sessions: `ListTaskLists`, `ListTasks`, `GetTask`, `AddTask` (with tags), `UpdateTask`, `UpdateTaskStatus`, `SetTaskTags`, `ListTags`, `DeleteTask`, `RunTaskNow`, `CancelTask`. Auth via optional `X-ClaudeDo-Key` header.
## Status Model
`TaskEntity` carries three orthogonal fields. Lifecycle, planning hierarchy, and chain blocking are no longer conflated.
| Field | Values | Meaning |
|---|---|---|
| `Status` | `Idle`, `Queued`, `Running`, `Done`, `Failed`, `Cancelled` | Lifecycle only. |
| `PlanningPhase` | `None`, `Active`, `Finalized` | Parent-only marker. `Active` ≈ legacy `Planning`; `Finalized` ≈ legacy `Planned`. |
| `BlockedByTaskId` | nullable FK | Replaces legacy `Waiting`. A queued row with `BlockedByTaskId != NULL` is skipped by the picker. |
Allowed transitions (enforced by `TaskStateService`):
```
Idle → Queued | Running (RunNow)
Queued → Running | Cancelled | Idle
Running → Done | Failed | Cancelled
Done → Idle (re-run)
Failed → Idle | Queued
Cancelled → Idle | Queued
```
## Planning Flow
`PlanningSessionManager.FinalizeAsync` is the single path:
1. `_state.FinalizePlanningAsync(parent)` flips parent `PlanningPhase` to `Finalized`.
2. `PlanningChainCoordinator.SetupChainAsync` attaches the `agent` tag to every child, enqueues child[0], and `BlockOn`s child[i] → child[i-1].
3. The first child is woken automatically; successors unblock as their predecessor reaches a terminal state via `OnChildFinishedAsync`.
`TaskRepository.FinalizePlanningAsync` no longer exists. The `Mark*Async` repository helpers are `internal` — only `TaskStateService` calls them.
## Task Execution Pipeline ## Task Execution Pipeline
@@ -28,7 +73,7 @@ ASP.NET Core hosted service that executes tasks via Claude CLI in isolated envir
- **ClaudeProcess** — spawns `claude -p --output-format stream-json --verbose --permission-mode auto` (or whatever permission mode the app settings specify). Writes prompt to stdin, reads NDJSON from stdout. Supports CancellationToken (kills process tree). - **ClaudeProcess** — spawns `claude -p --output-format stream-json --verbose --permission-mode auto` (or whatever permission mode the app settings specify). Writes prompt to stdin, reads NDJSON from stdout. Supports CancellationToken (kills process tree).
- **ClaudeArgsBuilder** — dynamically constructs CLI args; supports `--model`, `--append-system-prompt`, `--agents`, `--json-schema`, `--resume` - **ClaudeArgsBuilder** — dynamically constructs CLI args; supports `--model`, `--append-system-prompt`, `--agents`, `--json-schema`, `--resume`
- **StreamAnalyzer** — parses rich NDJSON output; extracts session_id, token counts, turn counts, result text, structured output. Replaces MessageParser. - **StreamAnalyzer** — parses rich NDJSON output; extracts session_id, token counts, turn counts, result text, structured output. Replaces MessageParser.
- **TaskResetService** — discards a failed task's worktree and resets the task row to Manual; preserves run history. - **TaskResetService** — discards a failed task's worktree and resets the task row to Idle; preserves run history.
- **WorktreeManager** — creates worktrees at `claudedo/{taskId[:8]}` branches, commits changes with semantic messages, updates DB with head commit and diff stats - **WorktreeManager** — creates worktrees at `claudedo/{taskId[:8]}` branches, commits changes with semantic messages, updates DB with head commit and diff stats
- **CommitMessageBuilder** — formats `{commitType}(slug): title\n\ndescription\n\nClaudeDo-Task: taskId` - **CommitMessageBuilder** — formats `{commitType}(slug): title\n\ndescription\n\nClaudeDo-Task: taskId`
- **AgentFileService** — manages `~/.todo-app/agents/*.md` agent definition files; exposes list/refresh via SignalR - **AgentFileService** — manages `~/.todo-app/agents/*.md` agent definition files; exposes list/refresh via SignalR

View File

@@ -117,7 +117,7 @@ public sealed class ExternalMcpService
ListId = listId, ListId = listId,
Title = title, Title = title,
Description = description, Description = description,
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = list.DefaultCommitType, CommitType = list.DefaultCommitType,
CreatedBy = createdBy, CreatedBy = createdBy,
@@ -167,7 +167,7 @@ public sealed class ExternalMcpService
return ToDto(reload); return ToDto(reload);
} }
[McpServerTool, Description("Update a task's status. Only 'Manual' and 'Queued' are permitted — use RunTaskNow or CancelTask for execution control.")] [McpServerTool, Description("Update a task's status. Only 'Idle' and 'Queued' are permitted — use RunTaskNow or CancelTask for execution control.")]
public async Task<TaskDto> UpdateTaskStatus( public async Task<TaskDto> UpdateTaskStatus(
string taskId, string taskId,
string status, string status,
@@ -181,7 +181,7 @@ public sealed class ExternalMcpService
switch (target) switch (target)
{ {
case TaskStatus.Manual: case TaskStatus.Idle:
await _tasks.ResetToManualAsync(taskId, cancellationToken); await _tasks.ResetToManualAsync(taskId, cancellationToken);
await _broadcaster.TaskUpdated(taskId); await _broadcaster.TaskUpdated(taskId);
break; break;

View File

@@ -39,16 +39,10 @@ public sealed class PlanningChainCoordinator
if (children.Count == 0) if (children.Count == 0)
throw new InvalidOperationException("Parent has no subtasks."); throw new InvalidOperationException("Parent has no subtasks.");
// Eligibility: new layout uses Status=Idle. Tolerate legacy Manual/Planned/Draft var bad = children.FirstOrDefault(c => c.Status != TaskStatus.Idle);
// values during this slice — they will be migrated away in slice 6.
var bad = children.FirstOrDefault(c =>
c.Status != TaskStatus.Idle &&
c.Status != TaskStatus.Manual &&
c.Status != TaskStatus.Planned &&
c.Status != TaskStatus.Draft);
if (bad is not null) if (bad is not null)
throw new InvalidOperationException( throw new InvalidOperationException(
$"Child {bad.Id} is in status {bad.Status}; expected Idle (or legacy Manual/Planned/Draft)."); $"Child {bad.Id} is in status {bad.Status}; expected Idle.");
// Worker queue picker requires the "agent" tag — attach it so children are pickable. // Worker queue picker requires the "agent" tag — attach it so children are pickable.
var agentTag = await ctx.Tags.FirstOrDefaultAsync(t => t.Name == "agent", ct); var agentTag = await ctx.Tags.FirstOrDefaultAsync(t => t.Name == "agent", ct);

View File

@@ -49,7 +49,7 @@ public sealed class PlanningMcpService
var child = await _tasks.CreateChildAsync(ctx.ParentTaskId, title, description, tags, commitType, cancellationToken); var child = await _tasks.CreateChildAsync(ctx.ParentTaskId, title, description, tags, commitType, cancellationToken);
await BroadcastTaskUpdatedAsync(child.Id, cancellationToken); await BroadcastTaskUpdatedAsync(child.Id, cancellationToken);
await BroadcastTaskUpdatedAsync(ctx.ParentTaskId, cancellationToken); await BroadcastTaskUpdatedAsync(ctx.ParentTaskId, cancellationToken);
return new CreatedChildDto(child.Id, "Draft"); return new CreatedChildDto(child.Id, child.Status.ToString());
} }
[McpServerTool, Description("List all child tasks under the current planning session's parent task.")] [McpServerTool, Description("List all child tasks under the current planning session's parent task.")]
@@ -68,9 +68,9 @@ public sealed class PlanningMcpService
} }
private static readonly TaskStatus[] EditableStatuses = private static readonly TaskStatus[] EditableStatuses =
{ TaskStatus.Draft, TaskStatus.Idle, TaskStatus.Manual, TaskStatus.Queued }; { TaskStatus.Idle, TaskStatus.Queued };
[McpServerTool, Description("Update a child task in the active planning session. Can change title, description, tags (replaces the full set), commit type, and status. Status must be one of: Draft, Idle, Manual, Queued.")] [McpServerTool, Description("Update a child task in the active planning session. Can change title, description, tags (replaces the full set), commit type, and status. Status must be one of: Idle, Queued.")]
public async Task<ChildTaskDto> UpdateChildTask( public async Task<ChildTaskDto> UpdateChildTask(
string taskId, string taskId,
string? title, string? title,
@@ -97,7 +97,7 @@ public sealed class PlanningMcpService
if (!Enum.TryParse<TaskStatus>(status, ignoreCase: true, out var parsed)) if (!Enum.TryParse<TaskStatus>(status, ignoreCase: true, out var parsed))
throw new InvalidOperationException($"Unknown status '{status}'."); throw new InvalidOperationException($"Unknown status '{status}'.");
if (!EditableStatuses.Contains(parsed)) if (!EditableStatuses.Contains(parsed))
throw new InvalidOperationException($"Status '{parsed}' cannot be set via MCP. Allowed: Draft, Idle, Manual, Queued."); throw new InvalidOperationException($"Status '{parsed}' cannot be set via MCP. Allowed: Idle, Queued.");
newStatus = parsed; newStatus = parsed;
} }

View File

@@ -81,8 +81,9 @@ public sealed class PlanningSessionManager
?? throw new InvalidOperationException($"Task {taskId} not found."); ?? throw new InvalidOperationException($"Task {taskId} not found.");
if (task.ParentTaskId is not null) if (task.ParentTaskId is not null)
throw new InvalidOperationException("Cannot start a planning session on a child task."); throw new InvalidOperationException("Cannot start a planning session on a child task.");
if (task.Status != TaskStatus.Manual) if (task.Status != TaskStatus.Idle || task.PlanningPhase != PlanningPhase.None)
throw new InvalidOperationException($"Task is in status {task.Status}; only Manual can start planning."); throw new InvalidOperationException(
$"Task is in status {task.Status}/{task.PlanningPhase}; only Idle+None can start planning.");
var list = await lists.GetByIdAsync(task.ListId, ct) var list = await lists.GetByIdAsync(task.ListId, ct)
?? throw new InvalidOperationException($"List {task.ListId} not found."); ?? throw new InvalidOperationException($"List {task.ListId} not found.");
@@ -232,7 +233,7 @@ public sealed class PlanningSessionManager
var (tasks, _, settings, ctx) = CreateRepos(); var (tasks, _, settings, ctx) = CreateRepos();
await using var __ = ctx; await using var __ = ctx;
var children = await tasks.GetChildrenAsync(taskId, ct); var children = await tasks.GetChildrenAsync(taskId, ct);
return children.Count(c => c.Status == TaskStatus.Draft); return children.Count(c => c.Status == TaskStatus.Idle);
} }
public async Task DiscardAsync(string taskId, CancellationToken ct) public async Task DiscardAsync(string taskId, CancellationToken ct)
@@ -261,8 +262,9 @@ public sealed class PlanningSessionManager
var task = await tasks.GetByIdAsync(taskId, ct) var task = await tasks.GetByIdAsync(taskId, ct)
?? throw new InvalidOperationException($"Task {taskId} not found."); ?? throw new InvalidOperationException($"Task {taskId} not found.");
if (task.Status != TaskStatus.Planning) if (task.PlanningPhase != PlanningPhase.Active)
throw new InvalidOperationException($"Task is in status {task.Status}; resume requires Planning."); throw new InvalidOperationException(
$"Task planning phase is {task.PlanningPhase}; resume requires Active planning.");
if (string.IsNullOrEmpty(task.PlanningSessionId)) if (string.IsNullOrEmpty(task.PlanningSessionId))
throw new InvalidOperationException("No Claude session ID captured yet; cannot resume."); throw new InvalidOperationException("No Claude session ID captured yet; cannot resume.");

View File

@@ -27,7 +27,7 @@ public sealed class PlanningTokenAuthMiddleware
var token = auth.Substring("Bearer ".Length).Trim(); var token = auth.Substring("Bearer ".Length).Trim();
var parent = await tasks.FindByPlanningTokenAsync(token, ctx.RequestAborted); var parent = await tasks.FindByPlanningTokenAsync(token, ctx.RequestAborted);
if (parent is null || parent.Status != ClaudeDo.Data.Models.TaskStatus.Planning) if (parent is null || parent.PlanningPhase != ClaudeDo.Data.Models.PlanningPhase.Active)
{ {
ctx.Response.StatusCode = 401; ctx.Response.StatusCode = 401;
await ctx.Response.WriteAsync("Invalid or expired planning token"); await ctx.Response.WriteAsync("Invalid or expired planning token");

View File

@@ -144,10 +144,10 @@ public sealed class TaskStateService : ITaskStateService
{ {
await using var ctx = await _dbFactory.CreateDbContextAsync(ct); await using var ctx = await _dbFactory.CreateDbContextAsync(ct);
var affected = await ctx.Tasks var affected = await ctx.Tasks
.Where(t => t.Id == parentId && .Where(t => t.Id == parentId
(t.Status == TaskStatus.Manual || t.Status == TaskStatus.Idle)) && t.Status == TaskStatus.Idle
&& t.PlanningPhase == PlanningPhase.None)
.ExecuteUpdateAsync(s => s .ExecuteUpdateAsync(s => s
.SetProperty(t => t.Status, TaskStatus.Planning)
.SetProperty(t => t.PlanningPhase, PlanningPhase.Active), ct); .SetProperty(t => t.PlanningPhase, PlanningPhase.Active), ct);
if (affected == 0) if (affected == 0)
@@ -198,13 +198,6 @@ public sealed class TaskStateService : ITaskStateService
if (affected == 0) if (affected == 0)
return new TransitionResult(false, "Task not found."); return new TransitionResult(false, "Task not found.");
// Bridge to legacy chain layout: a Waiting predecessor-blocked sibling becomes Queued
// when its predecessor finishes. New layout (post-Slice 4) stores siblings as
// Status=Queued + BlockedByTaskId set, so this is a no-op for them.
await ctx.Tasks
.Where(t => t.Id == taskId && t.Status == TaskStatus.Waiting)
.ExecuteUpdateAsync(s => s.SetProperty(t => t.Status, TaskStatus.Queued), ct);
_waker.Wake(); _waker.Wake();
await _broadcaster.TaskUpdated(taskId); await _broadcaster.TaskUpdated(taskId);
return new TransitionResult(true, null); return new TransitionResult(true, null);

View File

@@ -175,7 +175,8 @@ public class DetailsIslandPlanningTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "Parent", Id = parentId, ListId = listId, Title = "Parent",
Status = TaskStatus.Planning, CreatedAt = DateTime.UtcNow, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Active,
CreatedAt = DateTime.UtcNow,
}); });
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
@@ -199,7 +200,8 @@ public class DetailsIslandPlanningTests : IDisposable
// Bind triggers BindAsync → LoadPlanningChildrenAsync → GetMergeTargetsAsync // Bind triggers BindAsync → LoadPlanningChildrenAsync → GetMergeTargetsAsync
var parentRow = new TaskRowViewModel { Id = parentId }; var parentRow = new TaskRowViewModel { Id = parentId };
parentRow.Status = TaskStatus.Planning; parentRow.Status = TaskStatus.Idle;
parentRow.PlanningPhase = PlanningPhase.Active;
vm.Bind(parentRow); vm.Bind(parentRow);
// Wait for the background load to settle // Wait for the background load to settle

View File

@@ -49,7 +49,8 @@ public class TasksIslandRegroupTests : IDisposable
TaskStatus parentStatus, TaskStatus parentStatus,
TaskStatus childStatus, TaskStatus childStatus,
string parentId = "p1", string parentId = "p1",
string childId = "c1") string childId = "c1",
PlanningPhase parentPhase = PlanningPhase.None)
{ {
await using var db = NewContext(); await using var db = NewContext();
var list = new ListEntity var list = new ListEntity
@@ -67,6 +68,7 @@ public class TasksIslandRegroupTests : IDisposable
Title = "Parent", Title = "Parent",
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
Status = parentStatus, Status = parentStatus,
PlanningPhase = parentPhase,
SortOrder = 0, SortOrder = 0,
}); });
db.Tasks.Add(new TaskEntity db.Tasks.Add(new TaskEntity
@@ -110,7 +112,7 @@ public class TasksIslandRegroupTests : IDisposable
public async Task VirtualQueued_QueuedChildOfPlanningParent_IsNotStandaloneRow() public async Task VirtualQueued_QueuedChildOfPlanningParent_IsNotStandaloneRow()
{ {
await SeedPlanningWithChildAsync( await SeedPlanningWithChildAsync(
parentStatus: TaskStatus.Planning, parentStatus: TaskStatus.Idle, parentPhase: PlanningPhase.Active,
childStatus: TaskStatus.Queued, childStatus: TaskStatus.Queued,
parentId: "p1", parentId: "p1",
childId: "c1"); childId: "c1");
@@ -126,7 +128,7 @@ public class TasksIslandRegroupTests : IDisposable
public async Task VirtualQueued_PlannedParentWithQueuedChild_ParentIsStandaloneRow_ChildIsNot() public async Task VirtualQueued_PlannedParentWithQueuedChild_ParentIsStandaloneRow_ChildIsNot()
{ {
await SeedPlanningWithChildAsync( await SeedPlanningWithChildAsync(
parentStatus: TaskStatus.Planned, parentStatus: TaskStatus.Idle, parentPhase: PlanningPhase.Finalized,
childStatus: TaskStatus.Queued, childStatus: TaskStatus.Queued,
parentId: "p1", parentId: "p1",
childId: "c1"); childId: "c1");
@@ -142,7 +144,7 @@ public class TasksIslandRegroupTests : IDisposable
public async Task VirtualRunning_RunningChildOfPlanningParent_IsNotStandaloneRow() public async Task VirtualRunning_RunningChildOfPlanningParent_IsNotStandaloneRow()
{ {
await SeedPlanningWithChildAsync( await SeedPlanningWithChildAsync(
parentStatus: TaskStatus.Planning, parentStatus: TaskStatus.Idle, parentPhase: PlanningPhase.Active,
childStatus: TaskStatus.Running, childStatus: TaskStatus.Running,
parentId: "p1", parentId: "p1",
childId: "c1"); childId: "c1");
@@ -158,7 +160,7 @@ public class TasksIslandRegroupTests : IDisposable
public async Task Done_ChildOfOpenPlanningParent_StaysNestedUnderParent() public async Task Done_ChildOfOpenPlanningParent_StaysNestedUnderParent()
{ {
await SeedPlanningWithChildAsync( await SeedPlanningWithChildAsync(
parentStatus: TaskStatus.Planning, parentStatus: TaskStatus.Idle, parentPhase: PlanningPhase.Active,
childStatus: TaskStatus.Done, childStatus: TaskStatus.Done,
parentId: "p1", parentId: "p1",
childId: "c1"); childId: "c1");

View File

@@ -74,7 +74,7 @@ public sealed class ExternalMcpServiceTests : IDisposable
return id; return id;
} }
private async Task<TaskEntity> SeedTaskAsync(string listId, string title = "t", TaskStatus status = TaskStatus.Manual) private async Task<TaskEntity> SeedTaskAsync(string listId, string title = "t", TaskStatus status = TaskStatus.Idle)
{ {
var task = new TaskEntity var task = new TaskEntity
{ {

View File

@@ -75,7 +75,7 @@ public sealed class PlanningHubTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "Do something", Title = "Do something",
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "feat", CommitType = "feat",
}; };
@@ -96,7 +96,8 @@ public sealed class PlanningHubTests : IDisposable
Assert.Equal(0, _launcher.LaunchResumeCalls); Assert.Equal(0, _launcher.LaunchResumeCalls);
var loaded = await _tasks.GetByIdAsync(taskId); var loaded = await _tasks.GetByIdAsync(taskId);
Assert.Equal(TaskStatus.Planning, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.Active, loaded.PlanningPhase);
Assert.Contains(_proxy.Sent, m => m.method == "TaskUpdated"); Assert.Contains(_proxy.Sent, m => m.method == "TaskUpdated");
} }
@@ -112,7 +113,8 @@ public sealed class PlanningHubTests : IDisposable
hub.StartPlanningSessionAsync(taskId)); hub.StartPlanningSessionAsync(taskId));
var loaded = await _tasks.GetByIdAsync(taskId); var loaded = await _tasks.GetByIdAsync(taskId);
Assert.Equal(TaskStatus.Manual, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.None, loaded.PlanningPhase);
var sessionDir = Path.Combine(_rootDir, taskId); var sessionDir = Path.Combine(_rootDir, taskId);
Assert.False(Directory.Exists(sessionDir)); Assert.False(Directory.Exists(sessionDir));
@@ -130,7 +132,8 @@ public sealed class PlanningHubTests : IDisposable
await hub.DiscardPlanningSessionAsync(taskId); await hub.DiscardPlanningSessionAsync(taskId);
var loaded = await _tasks.GetByIdAsync(taskId); var loaded = await _tasks.GetByIdAsync(taskId);
Assert.Equal(TaskStatus.Manual, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.None, loaded.PlanningPhase);
Assert.Contains(_proxy.Sent, m => m.method == "TaskUpdated"); Assert.Contains(_proxy.Sent, m => m.method == "TaskUpdated");
} }

View File

@@ -67,7 +67,7 @@ public class PlanningAggregatorTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow, Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planning, SortOrder = 0, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Active, SortOrder = 0,
}); });
// Two children (sorted A then B). // Two children (sorted A then B).
@@ -171,7 +171,7 @@ public class PlanningAggregatorTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow, Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planning, SortOrder = 0, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Active, SortOrder = 0,
}); });
var subA = Guid.NewGuid().ToString(); var subA = Guid.NewGuid().ToString();
var subB = Guid.NewGuid().ToString(); var subB = Guid.NewGuid().ToString();

View File

@@ -32,7 +32,7 @@ public sealed class PlanningChainCoordinatorTests : IDisposable
public void Dispose() => _db.Dispose(); public void Dispose() => _db.Dispose();
private async Task SeedPlanningFamilyAsync(string parentId, int childCount, TaskStatus childStatus = TaskStatus.Manual) private async Task SeedPlanningFamilyAsync(string parentId, int childCount, TaskStatus childStatus = TaskStatus.Idle)
{ {
await using var ctx = _factory.CreateDbContext(); await using var ctx = _factory.CreateDbContext();
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
@@ -41,7 +41,8 @@ public sealed class PlanningChainCoordinatorTests : IDisposable
ListId = _listId, ListId = _listId,
Title = "Parent", Title = "Parent",
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planned, Status = TaskStatus.Idle,
PlanningPhase = PlanningPhase.Finalized,
}); });
for (int i = 0; i < childCount; i++) for (int i = 0; i < childCount; i++)
{ {
@@ -108,16 +109,6 @@ public sealed class PlanningChainCoordinatorTests : IDisposable
Assert.Equal(2, count); Assert.Equal(2, count);
} }
[Fact]
public async Task SetupChain_AcceptsDraftChildren()
{
await SeedPlanningFamilyAsync("P", 2, childStatus: TaskStatus.Draft);
var count = await _sut.SetupChainAsync("P", default);
Assert.Equal(2, count);
}
[Fact] [Fact]
public async Task OnChildDone_UnblocksTheSuccessor() public async Task OnChildDone_UnblocksTheSuccessor()
{ {

View File

@@ -99,7 +99,7 @@ public sealed class PlanningEndToEndTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "Big Task", Title = "Big Task",
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "chore", CommitType = "chore",
}; };
@@ -145,7 +145,7 @@ public sealed class PlanningEndToEndTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "Parent", Title = "Parent",
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "chore", CommitType = "chore",
}; };

View File

@@ -93,7 +93,7 @@ public sealed class PlanningMcpServiceTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "p", Title = "p",
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "chore", CommitType = "chore",
}; };
@@ -110,10 +110,10 @@ public sealed class PlanningMcpServiceTests : IDisposable
var result = await sut.CreateChildTask("My child", "desc", null, null, CancellationToken.None); var result = await sut.CreateChildTask("My child", "desc", null, null, CancellationToken.None);
Assert.Equal("Draft", result.Status); Assert.Equal("Idle", result.Status);
var child = await _tasks.GetByIdAsync(result.TaskId); var child = await _tasks.GetByIdAsync(result.TaskId);
Assert.Equal("My child", child!.Title); Assert.Equal("My child", child!.Title);
Assert.Equal(TaskStatus.Draft, child.Status); Assert.Equal(TaskStatus.Idle, child.Status);
} }
[Fact] [Fact]

View File

@@ -101,7 +101,7 @@ public sealed class PlanningMergeOrchestratorTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow, Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planned, SortOrder = 0, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Finalized, SortOrder = 0,
}); });
var subA = Guid.NewGuid().ToString(); var subA = Guid.NewGuid().ToString();
@@ -169,7 +169,7 @@ public sealed class PlanningMergeOrchestratorTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow, Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planned, SortOrder = 0, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Finalized, SortOrder = 0,
}); });
var subA = Guid.NewGuid().ToString(); var subA = Guid.NewGuid().ToString();
var subB = Guid.NewGuid().ToString(); var subB = Guid.NewGuid().ToString();
@@ -232,7 +232,7 @@ public sealed class PlanningMergeOrchestratorTests : IDisposable
using var ctx = db.CreateContext(); using var ctx = db.CreateContext();
// Planning stays in Planned — NOT flipped to Done. // Planning stays in Planned — NOT flipped to Done.
Assert.Equal(TaskStatus.Planned, ctx.Tasks.Single(t => t.Id == parentId).Status); Assert.Equal(PlanningPhase.Finalized, ctx.Tasks.Single(t => t.Id == parentId).PlanningPhase);
// Earlier successful merge stays merged. // Earlier successful merge stays merged.
Assert.Equal(WorktreeState.Merged, ctx.Worktrees.Single(w => w.TaskId == subA).State); Assert.Equal(WorktreeState.Merged, ctx.Worktrees.Single(w => w.TaskId == subA).State);
// Conflicted subtask's worktree stays Active (abort doesn't flip it). // Conflicted subtask's worktree stays Active (abort doesn't flip it).
@@ -280,7 +280,7 @@ public sealed class PlanningMergeOrchestratorTests : IDisposable
Assert.Contains(runningSub, ex.Message); Assert.Contains(runningSub, ex.Message);
using var ctx = db.CreateContext(); using var ctx = db.CreateContext();
Assert.Equal(TaskStatus.Planned, ctx.Tasks.Single(t => t.Id == parentId).Status); Assert.Equal(PlanningPhase.Finalized, ctx.Tasks.Single(t => t.Id == parentId).PlanningPhase);
Assert.Empty(spy); Assert.Empty(spy);
} }
@@ -337,7 +337,7 @@ public sealed class PlanningMergeOrchestratorTests : IDisposable
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity
{ {
Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow, Id = parentId, ListId = listId, Title = "plan", CreatedAt = DateTime.UtcNow,
Status = TaskStatus.Planned, SortOrder = 0, Status = TaskStatus.Idle, PlanningPhase = PlanningPhase.Finalized, SortOrder = 0,
}); });
var running = Guid.NewGuid().ToString(); var running = Guid.NewGuid().ToString();
ctx.Tasks.Add(new TaskEntity ctx.Tasks.Add(new TaskEntity

View File

@@ -67,7 +67,7 @@ public sealed class PlanningSessionManagerTests : IDisposable
ListId = listId, ListId = listId,
Title = "Brainstorm auth", Title = "Brainstorm auth",
Description = "- review tokens\n- plan rollout", Description = "- review tokens\n- plan rollout",
Status = TaskStatus.Manual, Status = TaskStatus.Idle,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "feat", CommitType = "feat",
}; };
@@ -101,7 +101,8 @@ public sealed class PlanningSessionManagerTests : IDisposable
Assert.Contains("review tokens", initial); Assert.Contains("review tokens", initial);
var loaded = await _tasks.GetByIdAsync(parent.Id); var loaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Planning, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.Active, loaded.PlanningPhase);
Assert.NotNull(loaded.PlanningSessionToken); Assert.NotNull(loaded.PlanningSessionToken);
} }
@@ -220,7 +221,8 @@ public sealed class PlanningSessionManagerTests : IDisposable
Assert.False(Directory.Exists(startCtx.Files.SessionDirectory)); Assert.False(Directory.Exists(startCtx.Files.SessionDirectory));
var loaded = await _tasks.GetByIdAsync(parent.Id); var loaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Manual, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.None, loaded.PlanningPhase);
Assert.Null(loaded.PlanningSessionToken); Assert.Null(loaded.PlanningSessionToken);
} }

View File

@@ -127,11 +127,6 @@ public sealed class QueuePickerTests : IDisposable
await SeedAsync(listId, status: TaskStatus.Done); await SeedAsync(listId, status: TaskStatus.Done);
await SeedAsync(listId, status: TaskStatus.Failed); await SeedAsync(listId, status: TaskStatus.Failed);
await SeedAsync(listId, status: TaskStatus.Cancelled); await SeedAsync(listId, status: TaskStatus.Cancelled);
await SeedAsync(listId, status: TaskStatus.Manual);
await SeedAsync(listId, status: TaskStatus.Draft);
await SeedAsync(listId, status: TaskStatus.Planning);
await SeedAsync(listId, status: TaskStatus.Planned);
await SeedAsync(listId, status: TaskStatus.Waiting);
var picked = await _picker.ClaimNextAsync(DateTime.UtcNow, CancellationToken.None); var picked = await _picker.ClaimNextAsync(DateTime.UtcNow, CancellationToken.None);
Assert.Null(picked); Assert.Null(picked);

View File

@@ -37,7 +37,8 @@ public sealed class TaskRepositoryParentCompletionTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "p", Title = "p",
Status = TaskStatus.Planned, Status = TaskStatus.Idle,
PlanningPhase = PlanningPhase.Finalized,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "chore", CommitType = "chore",
}; };
@@ -102,35 +103,37 @@ public sealed class TaskRepositoryParentCompletionTests : IDisposable
await _tasks.TryCompleteParentAsync(parent.Id); await _tasks.TryCompleteParentAsync(parent.Id);
var loaded = await _tasks.GetByIdAsync(parent.Id); var loaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Planned, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
Assert.Equal(PlanningPhase.Finalized, loaded.PlanningPhase);
Assert.Null(loaded.FinishedAt); Assert.Null(loaded.FinishedAt);
} }
[Fact] [Fact]
public async Task TryCompleteParentAsync_ChildStillDraft_ParentStaysPlanned() public async Task TryCompleteParentAsync_ChildStillIdle_ParentStaysFinalized()
{ {
var listId = await ListAsync(); var listId = await ListAsync();
var parent = await PlannedParentAsync(listId); var parent = await PlannedParentAsync(listId);
await ChildAsync(listId, parent.Id, TaskStatus.Done); await ChildAsync(listId, parent.Id, TaskStatus.Done);
await ChildAsync(listId, parent.Id, TaskStatus.Draft); await ChildAsync(listId, parent.Id, TaskStatus.Idle);
await _tasks.TryCompleteParentAsync(parent.Id); await _tasks.TryCompleteParentAsync(parent.Id);
var loaded = await _tasks.GetByIdAsync(parent.Id); var loaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Planned, loaded!.Status); Assert.Equal(PlanningPhase.Finalized, loaded!.PlanningPhase);
} }
[Fact] [Fact]
public async Task TryCompleteParentAsync_ParentIsNotPlanned_NoChange() public async Task TryCompleteParentAsync_ParentIsNotFinalized_NoChange()
{ {
var listId = await ListAsync(); var listId = await ListAsync();
var parent = await PlannedParentAsync(listId); var parent = await PlannedParentAsync(listId);
await _ctx.Database.ExecuteSqlRawAsync("UPDATE tasks SET status = 'planning' WHERE id = {0}", parent.Id); await _ctx.Database.ExecuteSqlRawAsync(
"UPDATE tasks SET planning_phase = 'active' WHERE id = {0}", parent.Id);
await ChildAsync(listId, parent.Id, TaskStatus.Done); await ChildAsync(listId, parent.Id, TaskStatus.Done);
await _tasks.TryCompleteParentAsync(parent.Id); await _tasks.TryCompleteParentAsync(parent.Id);
var loaded = await _tasks.GetByIdAsync(parent.Id); var loaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Planning, loaded!.Status); Assert.Equal(PlanningPhase.Active, loaded!.PlanningPhase);
} }
} }

View File

@@ -40,12 +40,17 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
return listId; return listId;
} }
private TaskEntity MakeTask(string listId, TaskStatus status = TaskStatus.Manual, string? parentId = null) => new() private TaskEntity MakeTask(
string listId,
TaskStatus status = TaskStatus.Idle,
string? parentId = null,
PlanningPhase phase = PlanningPhase.None) => new()
{ {
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "t", Title = "t",
Status = status, Status = status,
PlanningPhase = phase,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "feat", CommitType = "feat",
ParentTaskId = parentId, ParentTaskId = parentId,
@@ -55,23 +60,23 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task GetChildrenAsync_ReturnsOnlyDirectChildren_Sorted() public async Task GetChildrenAsync_ReturnsOnlyDirectChildren_Sorted()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var parent = MakeTask(listId, TaskStatus.Planning); var parent = MakeTask(listId, phase: PlanningPhase.Active);
parent.Title = "parent"; parent.Title = "parent";
await _tasks.AddAsync(parent); await _tasks.AddAsync(parent);
var childA = MakeTask(listId, TaskStatus.Draft, parentId: parent.Id); var childA = MakeTask(listId, parentId: parent.Id);
childA.Title = "a"; childA.Title = "a";
await _tasks.AddAsync(childA); await _tasks.AddAsync(childA);
childA.SortOrder = 1; childA.SortOrder = 1;
await _tasks.UpdateAsync(childA); await _tasks.UpdateAsync(childA);
var childB = MakeTask(listId, TaskStatus.Draft, parentId: parent.Id); var childB = MakeTask(listId, parentId: parent.Id);
childB.Title = "b"; childB.Title = "b";
await _tasks.AddAsync(childB); await _tasks.AddAsync(childB);
childB.SortOrder = 0; childB.SortOrder = 0;
await _tasks.UpdateAsync(childB); await _tasks.UpdateAsync(childB);
var unrelated = MakeTask(listId, TaskStatus.Manual); var unrelated = MakeTask(listId);
await _tasks.AddAsync(unrelated); await _tasks.AddAsync(unrelated);
var children = await _tasks.GetChildrenAsync(parent.Id); var children = await _tasks.GetChildrenAsync(parent.Id);
@@ -82,10 +87,10 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
} }
[Fact] [Fact]
public async Task CreateChildAsync_CreatesDraftUnderParent() public async Task CreateChildAsync_CreatesIdleChildUnderParent()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var parent = MakeTask(listId, TaskStatus.Planning); var parent = MakeTask(listId, phase: PlanningPhase.Active);
await _tasks.AddAsync(parent); await _tasks.AddAsync(parent);
var child = await _tasks.CreateChildAsync( var child = await _tasks.CreateChildAsync(
@@ -95,7 +100,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
tagNames: new[] { "agent" }, tagNames: new[] { "agent" },
commitType: "feat"); commitType: "feat");
Assert.Equal(TaskStatus.Draft, child.Status); Assert.Equal(TaskStatus.Idle, child.Status);
Assert.Equal(parent.Id, child.ParentTaskId); Assert.Equal(parent.Id, child.ParentTaskId);
Assert.Equal(listId, child.ListId); Assert.Equal(listId, child.ListId);
Assert.Equal("child title", child.Title); Assert.Equal("child title", child.Title);
@@ -104,7 +109,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
var loaded = await _tasks.GetByIdAsync(child.Id); var loaded = await _tasks.GetByIdAsync(child.Id);
Assert.NotNull(loaded); Assert.NotNull(loaded);
Assert.Equal(TaskStatus.Draft, loaded!.Status); Assert.Equal(TaskStatus.Idle, loaded!.Status);
var tags = await _tasks.GetTagsAsync(child.Id); var tags = await _tasks.GetTagsAsync(child.Id);
Assert.Contains(tags, t => t.Name == "agent"); Assert.Contains(tags, t => t.Name == "agent");
@@ -114,32 +119,33 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task CreateChildAsync_ThrowsIfParentNotFound() public async Task CreateChildAsync_ThrowsIfParentNotFound()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
_ = listId; // just to create the DB _ = listId;
await Assert.ThrowsAsync<InvalidOperationException>(() => await Assert.ThrowsAsync<InvalidOperationException>(() =>
_tasks.CreateChildAsync("nonexistent-parent-id", "t", null, null, null)); _tasks.CreateChildAsync("nonexistent-parent-id", "t", null, null, null));
} }
[Fact] [Fact]
public async Task SetPlanningStartedAsync_ManualTask_TransitionsToPlanning() public async Task SetPlanningStartedAsync_IdleTask_TransitionsToActivePhase()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var task = MakeTask(listId, TaskStatus.Manual); var task = MakeTask(listId);
await _tasks.AddAsync(task); await _tasks.AddAsync(task);
var result = await _tasks.SetPlanningStartedAsync(task.Id, "tok-abc"); var result = await _tasks.SetPlanningStartedAsync(task.Id, "tok-abc");
Assert.NotNull(result); Assert.NotNull(result);
Assert.Equal(TaskStatus.Planning, result!.Status); Assert.Equal(TaskStatus.Idle, result!.Status);
Assert.Equal(PlanningPhase.Active, result.PlanningPhase);
Assert.Equal("tok-abc", result.PlanningSessionToken); Assert.Equal("tok-abc", result.PlanningSessionToken);
var loaded = await _tasks.GetByIdAsync(task.Id); var loaded = await _tasks.GetByIdAsync(task.Id);
Assert.Equal(TaskStatus.Planning, loaded!.Status); Assert.Equal(PlanningPhase.Active, loaded!.PlanningPhase);
Assert.Equal("tok-abc", loaded.PlanningSessionToken); Assert.Equal("tok-abc", loaded.PlanningSessionToken);
} }
[Fact] [Fact]
public async Task SetPlanningStartedAsync_NonManualTask_ReturnsNull() public async Task SetPlanningStartedAsync_NonIdleTask_ReturnsNull()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var task = MakeTask(listId, TaskStatus.Queued); var task = MakeTask(listId, TaskStatus.Queued);
@@ -157,7 +163,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task UpdatePlanningSessionIdAsync_StoresClaudeSessionId() public async Task UpdatePlanningSessionIdAsync_StoresClaudeSessionId()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var task = MakeTask(listId, TaskStatus.Manual); var task = MakeTask(listId);
await _tasks.AddAsync(task); await _tasks.AddAsync(task);
await _tasks.SetPlanningStartedAsync(task.Id, "tok"); await _tasks.SetPlanningStartedAsync(task.Id, "tok");
@@ -171,7 +177,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task FindByPlanningTokenAsync_ReturnsTask_WhenTokenMatches() public async Task FindByPlanningTokenAsync_ReturnsTask_WhenTokenMatches()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var task = MakeTask(listId, TaskStatus.Manual); var task = MakeTask(listId);
await _tasks.AddAsync(task); await _tasks.AddAsync(task);
await _tasks.SetPlanningStartedAsync(task.Id, "unique-token-123"); await _tasks.SetPlanningStartedAsync(task.Id, "unique-token-123");
@@ -192,7 +198,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task DiscardPlanningAsync_DeletesDraftsAndResetsParent() public async Task DiscardPlanningAsync_DeletesDraftsAndResetsParent()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var parent = MakeTask(listId, TaskStatus.Manual); var parent = MakeTask(listId);
await _tasks.AddAsync(parent); await _tasks.AddAsync(parent);
await _tasks.SetPlanningStartedAsync(parent.Id, "tok"); await _tasks.SetPlanningStartedAsync(parent.Id, "tok");
await _tasks.UpdatePlanningSessionIdAsync(parent.Id, "claude-42"); await _tasks.UpdatePlanningSessionIdAsync(parent.Id, "claude-42");
@@ -206,7 +212,8 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
Assert.Null(await _tasks.GetByIdAsync(c2.Id)); Assert.Null(await _tasks.GetByIdAsync(c2.Id));
var parentLoaded = await _tasks.GetByIdAsync(parent.Id); var parentLoaded = await _tasks.GetByIdAsync(parent.Id);
Assert.Equal(TaskStatus.Manual, parentLoaded!.Status); Assert.Equal(TaskStatus.Idle, parentLoaded!.Status);
Assert.Equal(PlanningPhase.None, parentLoaded.PlanningPhase);
Assert.Null(parentLoaded.PlanningSessionId); Assert.Null(parentLoaded.PlanningSessionId);
Assert.Null(parentLoaded.PlanningSessionToken); Assert.Null(parentLoaded.PlanningSessionToken);
Assert.Null(parentLoaded.PlanningFinalizedAt); Assert.Null(parentLoaded.PlanningFinalizedAt);
@@ -216,7 +223,7 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task DiscardPlanningAsync_OnNonPlanningTask_ReturnsFalse() public async Task DiscardPlanningAsync_OnNonPlanningTask_ReturnsFalse()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var task = MakeTask(listId, TaskStatus.Manual); var task = MakeTask(listId);
await _tasks.AddAsync(task); await _tasks.AddAsync(task);
var ok = await _tasks.DiscardPlanningAsync(task.Id); var ok = await _tasks.DiscardPlanningAsync(task.Id);
@@ -228,12 +235,10 @@ public sealed class TaskRepositoryPlanningTests : IDisposable
public async Task DeleteAsync_ParentWithChildren_ThrowsOrDoesNotDelete() public async Task DeleteAsync_ParentWithChildren_ThrowsOrDoesNotDelete()
{ {
var listId = await CreateListAsync(); var listId = await CreateListAsync();
var parent = MakeTask(listId, TaskStatus.Planning); var parent = MakeTask(listId, phase: PlanningPhase.Active);
await _tasks.AddAsync(parent); await _tasks.AddAsync(parent);
await _tasks.CreateChildAsync(parent.Id, "c", null, null, null); await _tasks.CreateChildAsync(parent.Id, "c", null, null, null);
// ExecuteDelete bypasses EF change tracking, so SQLite's FK enforcement
// (foreign_keys = ON, set by ClaudeDoDbContext) throws SqliteException directly.
await Assert.ThrowsAsync<Microsoft.Data.Sqlite.SqliteException>(async () => await Assert.ThrowsAsync<Microsoft.Data.Sqlite.SqliteException>(async () =>
{ {
await _tasks.DeleteAsync(parent.Id); await _tasks.DeleteAsync(parent.Id);

View File

@@ -163,7 +163,7 @@ public sealed class TaskRepositoryTests : IDisposable
using var readCtx = _db.CreateContext(); using var readCtx = _db.CreateContext();
var after = await new TaskRepository(readCtx).GetByIdAsync(task.Id); var after = await new TaskRepository(readCtx).GetByIdAsync(task.Id);
Assert.NotNull(after); Assert.NotNull(after);
Assert.Equal(TaskStatus.Manual, after!.Status); Assert.Equal(TaskStatus.Idle, after!.Status);
Assert.Null(after.StartedAt); Assert.Null(after.StartedAt);
Assert.Null(after.FinishedAt); Assert.Null(after.FinishedAt);
Assert.Null(after.Result); Assert.Null(after.Result);

View File

@@ -33,7 +33,8 @@ public sealed class TaskRunnerParentCompletionTests : IDisposable
Id = Guid.NewGuid().ToString(), Id = Guid.NewGuid().ToString(),
ListId = listId, ListId = listId,
Title = "p", Title = "p",
Status = TaskStatus.Planned, Status = TaskStatus.Idle,
PlanningPhase = PlanningPhase.Finalized,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
CommitType = "chore", CommitType = "chore",
}; };

View File

@@ -161,7 +161,7 @@ public class WorktreeMaintenanceServiceTests : IDisposable
var db = NewDb(); var db = NewDb();
var (list, t1) = MakeEntities(repo.RepoDir, status: ClaudeDo.Data.Models.TaskStatus.Done); var (list, t1) = MakeEntities(repo.RepoDir, status: ClaudeDo.Data.Models.TaskStatus.Done);
var t2 = MakeTaskForList(list.Id, ClaudeDo.Data.Models.TaskStatus.Manual); var t2 = MakeTaskForList(list.Id, ClaudeDo.Data.Models.TaskStatus.Idle);
var wt1 = await CreateWorktreeAsync(git, repo.RepoDir, t1.Id); var wt1 = await CreateWorktreeAsync(git, repo.RepoDir, t1.Id);
var wt2 = await CreateWorktreeAsync(git, repo.RepoDir, t2.Id); var wt2 = await CreateWorktreeAsync(git, repo.RepoDir, t2.Id);

View File

@@ -40,7 +40,8 @@ public sealed class TaskStateServiceTests : IDisposable
TaskStatus status, TaskStatus status,
string? parentId = null, string? parentId = null,
int sortOrder = 0, int sortOrder = 0,
string? blockedBy = null) string? blockedBy = null,
PlanningPhase phase = PlanningPhase.None)
{ {
var id = Guid.NewGuid().ToString(); var id = Guid.NewGuid().ToString();
await using var ctx = _factory.CreateDbContext(); await using var ctx = _factory.CreateDbContext();
@@ -50,6 +51,7 @@ public sealed class TaskStateServiceTests : IDisposable
ListId = _listId, ListId = _listId,
Title = "task", Title = "task",
Status = status, Status = status,
PlanningPhase = phase,
CreatedAt = DateTime.UtcNow, CreatedAt = DateTime.UtcNow,
ParentTaskId = parentId, ParentTaskId = parentId,
SortOrder = sortOrder, SortOrder = sortOrder,
@@ -256,15 +258,15 @@ public sealed class TaskStateServiceTests : IDisposable
// ─── StartPlanningAsync ─────────────────────────────────────────────── // ─── StartPlanningAsync ───────────────────────────────────────────────
[Fact] [Fact]
public async Task StartPlanningAsync_FromManual_FlipsStatus_AndPlanningPhase() public async Task StartPlanningAsync_FromIdle_SetsPlanningPhase()
{ {
var id = await SeedTaskAsync(TaskStatus.Manual); var id = await SeedTaskAsync(TaskStatus.Idle);
var result = await _sut.StartPlanningAsync(id, default); var result = await _sut.StartPlanningAsync(id, default);
Assert.True(result.Ok); Assert.True(result.Ok);
var t = await GetTaskAsync(id); var t = await GetTaskAsync(id);
Assert.Equal(TaskStatus.Planning, t.Status); Assert.Equal(TaskStatus.Idle, t.Status);
Assert.Equal(PlanningPhase.Active, t.PlanningPhase); Assert.Equal(PlanningPhase.Active, t.PlanningPhase);
} }
@@ -283,7 +285,7 @@ public sealed class TaskStateServiceTests : IDisposable
[Fact] [Fact]
public async Task FinalizePlanningAsync_OnActivePhase_TransitionsToFinalized() public async Task FinalizePlanningAsync_OnActivePhase_TransitionsToFinalized()
{ {
var id = await SeedTaskAsync(TaskStatus.Manual); var id = await SeedTaskAsync(TaskStatus.Idle);
await _sut.StartPlanningAsync(id, default); await _sut.StartPlanningAsync(id, default);
var result = await _sut.FinalizePlanningAsync(id, default); var result = await _sut.FinalizePlanningAsync(id, default);
@@ -297,7 +299,7 @@ public sealed class TaskStateServiceTests : IDisposable
[Fact] [Fact]
public async Task FinalizePlanningAsync_OnNonePhase_Rejects() public async Task FinalizePlanningAsync_OnNonePhase_Rejects()
{ {
var id = await SeedTaskAsync(TaskStatus.Manual); var id = await SeedTaskAsync(TaskStatus.Idle);
var result = await _sut.FinalizePlanningAsync(id, default); var result = await _sut.FinalizePlanningAsync(id, default);
@@ -335,18 +337,6 @@ public sealed class TaskStateServiceTests : IDisposable
Assert.True(_built.WakeCount() > wakesBefore); Assert.True(_built.WakeCount() > wakesBefore);
} }
[Fact]
public async Task UnblockAsync_OnWaitingTask_FlipsToQueued()
{
// Bridge to legacy chain layout: a Status=Waiting sibling becomes Queued on unblock.
var task = await SeedTaskAsync(TaskStatus.Waiting);
var result = await _sut.UnblockAsync(task, default);
Assert.True(result.Ok);
Assert.Equal(TaskStatus.Queued, await GetStatusAsync(task));
}
// ─── RecoverStaleRunningAsync ───────────────────────────────────────── // ─── RecoverStaleRunningAsync ─────────────────────────────────────────
[Fact] [Fact]
@@ -371,7 +361,7 @@ public sealed class TaskStateServiceTests : IDisposable
[Fact] [Fact]
public async Task CompleteAsync_OnChild_AdvancesNextBlockedSibling() public async Task CompleteAsync_OnChild_AdvancesNextBlockedSibling()
{ {
var parent = await SeedTaskAsync(TaskStatus.Planned); var parent = await SeedTaskAsync(TaskStatus.Idle, phase: PlanningPhase.Finalized);
var c0 = await SeedTaskAsync(TaskStatus.Running, parentId: parent, sortOrder: 0); var c0 = await SeedTaskAsync(TaskStatus.Running, parentId: parent, sortOrder: 0);
var c1 = await SeedTaskAsync(TaskStatus.Queued, parentId: parent, sortOrder: 1, blockedBy: c0); var c1 = await SeedTaskAsync(TaskStatus.Queued, parentId: parent, sortOrder: 1, blockedBy: c0);
var c2 = await SeedTaskAsync(TaskStatus.Queued, parentId: parent, sortOrder: 2, blockedBy: c1); var c2 = await SeedTaskAsync(TaskStatus.Queued, parentId: parent, sortOrder: 2, blockedBy: c1);

View File

@@ -7,38 +7,42 @@ namespace ClaudeDo.Worker.Tests.UiVm;
public class TaskRowViewModelPlanningTests public class TaskRowViewModelPlanningTests
{ {
private static TaskRowViewModel MakeRow(TaskStatus status, string? parentTaskId = null) private static TaskRowViewModel MakeRow(
=> new TaskRowViewModel { Id = "t", Status = status, ParentTaskId = parentTaskId }; TaskStatus status,
string? parentTaskId = null,
PlanningPhase phase = PlanningPhase.None)
=> new TaskRowViewModel { Id = "t", Status = status, ParentTaskId = parentTaskId, PlanningPhase = phase };
[Fact] [Fact]
public void Draft_Status_SetsIsChildFlag_WhenParentIdIsNotNull() public void IdleChild_IsDraft_WhenParentIdIsNotNull()
{ {
var vm = MakeRow(TaskStatus.Draft, "parent-id"); var vm = MakeRow(TaskStatus.Idle, parentTaskId: "parent-id");
Assert.True(vm.IsChild); Assert.True(vm.IsChild);
Assert.True(vm.IsDraft);
Assert.False(vm.IsPlanningParent); Assert.False(vm.IsPlanningParent);
} }
[Fact] [Fact]
public void Planning_Status_SetsIsPlanningParent() public void ActivePlanning_SetsIsPlanningParent()
{ {
var vm = MakeRow(TaskStatus.Planning); var vm = MakeRow(TaskStatus.Idle, phase: PlanningPhase.Active);
Assert.True(vm.IsPlanningParent); Assert.True(vm.IsPlanningParent);
Assert.False(vm.IsChild); Assert.False(vm.IsChild);
Assert.Equal("PLANNING", vm.PlanningBadge); Assert.Equal("PLANNING", vm.PlanningBadge);
} }
[Fact] [Fact]
public void Planned_Status_ShowsPlannedBadge() public void FinalizedPlanning_ShowsPlannedBadge()
{ {
var vm = MakeRow(TaskStatus.Planned); var vm = MakeRow(TaskStatus.Idle, phase: PlanningPhase.Finalized);
Assert.True(vm.IsPlanningParent); Assert.True(vm.IsPlanningParent);
Assert.Equal("PLANNED", vm.PlanningBadge); Assert.Equal("PLANNED", vm.PlanningBadge);
} }
[Fact] [Fact]
public void NonPlanningStatus_NoBadge() public void PlainIdle_NoBadge()
{ {
var vm = MakeRow(TaskStatus.Manual); var vm = MakeRow(TaskStatus.Idle);
Assert.False(vm.IsPlanningParent); Assert.False(vm.IsPlanningParent);
Assert.Null(vm.PlanningBadge); Assert.Null(vm.PlanningBadge);
} }

View File

@@ -12,7 +12,7 @@ public class TaskRowViewModelTests
[InlineData(TaskStatus.Failed, "error")] [InlineData(TaskStatus.Failed, "error")]
[InlineData(TaskStatus.Done, "review")] [InlineData(TaskStatus.Done, "review")]
[InlineData(TaskStatus.Queued, "queued")] [InlineData(TaskStatus.Queued, "queued")]
[InlineData(TaskStatus.Manual, "idle")] [InlineData(TaskStatus.Idle, "idle")]
public void StatusChipClass_Maps_Correctly(TaskStatus s, string expected) public void StatusChipClass_Maps_Correctly(TaskStatus s, string expected)
{ {
var vm = new TaskRowViewModel { Id = "t" }; var vm = new TaskRowViewModel { Id = "t" };

View File

@@ -96,15 +96,20 @@ file static class VmFactory
public class TasksIslandViewModelPlanningTests public class TasksIslandViewModelPlanningTests
{ {
private static TaskRowViewModel MakeRow(string id, TaskStatus status, string? parentId = null, int sortOrder = 0) private static TaskRowViewModel MakeRow(
=> new TaskRowViewModel { Id = id, Status = status, ParentTaskId = parentId }; string id,
TaskStatus status,
string? parentId = null,
int sortOrder = 0,
PlanningPhase phase = PlanningPhase.None)
=> new TaskRowViewModel { Id = id, Status = status, ParentTaskId = parentId, PlanningPhase = phase };
[Fact] [Fact]
public void ToggleExpand_CollapsesChildrenOfPlanningParent() public void ToggleExpand_CollapsesChildrenOfPlanningParent()
{ {
var parent = MakeRow("p1", TaskStatus.Planning); var parent = MakeRow("p1", TaskStatus.Idle, phase: PlanningPhase.Active);
var child1 = MakeRow("c1", TaskStatus.Draft, "p1"); var child1 = MakeRow("c1", TaskStatus.Idle, "p1");
var child2 = MakeRow("c2", TaskStatus.Draft, "p1"); var child2 = MakeRow("c2", TaskStatus.Idle, "p1");
var (vm, _) = VmFactory.Create([parent, child1, child2]); var (vm, _) = VmFactory.Create([parent, child1, child2]);
@@ -123,7 +128,7 @@ public class TasksIslandViewModelPlanningTests
} }
[Fact] [Fact]
public async Task OpenPlanningSession_IgnoresNonManualRow() public async Task OpenPlanningSession_IgnoresNonIdleRow()
{ {
var row = MakeRow("t1", TaskStatus.Queued); var row = MakeRow("t1", TaskStatus.Queued);
var (vm, worker) = VmFactory.Create([row]); var (vm, worker) = VmFactory.Create([row]);
@@ -134,9 +139,9 @@ public class TasksIslandViewModelPlanningTests
} }
[Fact] [Fact]
public async Task OpenPlanningSession_CallsWorkerForManualRow() public async Task OpenPlanningSession_CallsWorkerForIdleRow()
{ {
var row = MakeRow("t1", TaskStatus.Manual); var row = MakeRow("t1", TaskStatus.Idle);
var (vm, worker) = VmFactory.Create([row]); var (vm, worker) = VmFactory.Create([row]);
await ((IAsyncRelayCommand<TaskRowViewModel?>)vm.OpenPlanningSessionCommand).ExecuteAsync(row); await ((IAsyncRelayCommand<TaskRowViewModel?>)vm.OpenPlanningSessionCommand).ExecuteAsync(row);
@@ -147,8 +152,8 @@ public class TasksIslandViewModelPlanningTests
[Fact] [Fact]
public void ToggleExpand_ExpandsCollapsedParentAgain() public void ToggleExpand_ExpandsCollapsedParentAgain()
{ {
var parent = MakeRow("p1", TaskStatus.Planned); var parent = MakeRow("p1", TaskStatus.Idle, phase: PlanningPhase.Finalized);
var child = MakeRow("c1", TaskStatus.Draft, "p1"); var child = MakeRow("c1", TaskStatus.Idle, "p1");
var (vm, _) = VmFactory.Create([parent, child]); var (vm, _) = VmFactory.Create([parent, child]);