root/fusion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(HAI-001): add status read/write support to TaskStore

Browse Source
This commit is contained in:
Dustin Byrne
2026-03-25 18:50:58 -04:00
parent f26c3561dc
commit e85d8ad743
1 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
packages/core/src/store.ts
View File

@@ -3,7 +3,7 @@ import { execSync } from "node:child_process";
import { mkdir, readFile, writeFile, readdir } from "node:fs/promises"; import { mkdir, readFile, writeFile, readdir } from "node:fs/promises";
import { join } from "node:path"; import { join } from "node:path";
import { existsSync } from "node:fs"; import { existsSync } from "node:fs";
import type { Task, TaskDetail, TaskCreateInput, BoardConfig, Column, MergeResult } from "./types.js"; import type { Task, TaskDetail, TaskCreateInput, BoardConfig, Column, MergeResult, TaskStatus } from "./types.js";
import { VALID_TRANSITIONS } from "./types.js"; import { VALID_TRANSITIONS } from "./types.js";
export interface TaskStoreEvents { export interface TaskStoreEvents {
@@ -63,6 +63,7 @@ export class TaskStore extends EventEmitter<TaskStoreEvents> {
description: input.description || "", description: input.description || "",
column: input.column || "triage", column: input.column || "triage",
dependencies: input.dependencies || [], dependencies: input.dependencies || [],
status: "idle",
createdAt: now, createdAt: now,
updatedAt: now, updatedAt: now,
}; };
@@ -134,6 +135,15 @@ export class TaskStore extends EventEmitter<TaskStoreEvents> {
task.column = toColumn; task.column = toColumn;
task.updatedAt = new Date().toISOString(); task.updatedAt = new Date().toISOString();
// Auto-set status based on target column
if (toColumn === "in-review" || toColumn === "done") {
task.status = "complete";
} else if (toColumn === "in-progress") {
task.status = "executing";
} else if (toColumn === "todo") {
task.status = "idle";
}
await writeFile(join(dir, "task.json"), JSON.stringify(task, null, 2)); await writeFile(join(dir, "task.json"), JSON.stringify(task, null, 2));
this.emit("task:moved", { task, from: fromColumn, to: toColumn }); this.emit("task:moved", { task, from: fromColumn, to: toColumn });
@@ -163,6 +173,20 @@ export class TaskStore extends EventEmitter<TaskStoreEvents> {
return task; return task;
} }
async setStatus(id: string, status: TaskStatus): Promise<Task> {
const dir = this.taskDir(id);
const data = await readFile(join(dir, "task.json"), "utf-8");
const task = JSON.parse(data) as Task;
task.status = status;
task.updatedAt = new Date().toISOString();
await writeFile(join(dir, "task.json"), JSON.stringify(task, null, 2));
this.emit("task:updated", task);
return task;
}
async deleteTask(id: string): Promise<Task> { async deleteTask(id: string): Promise<Task> {
const dir = this.taskDir(id); const dir = this.taskDir(id);
const data = await readFile(join(dir, "task.json"), "utf-8"); const data = await readFile(join(dir, "task.json"), "utf-8");
@@ -280,6 +304,7 @@ export class TaskStore extends EventEmitter<TaskStoreEvents> {
private async moveToDone(task: Task, dir: string): Promise<void> { private async moveToDone(task: Task, dir: string): Promise<void> {
task.column = "done"; task.column = "done";
task.status = "complete";
task.worktree = undefined; task.worktree = undefined;
task.updatedAt = new Date().toISOString(); task.updatedAt = new Date().toISOString();
await writeFile(join(dir, "task.json"), JSON.stringify(task, null, 2)); await writeFile(join(dir, "task.json"), JSON.stringify(task, null, 2));