/** * Atomic projects.json read/write operations. * All state mutations go through this module to prevent corruption. */ import fs from "node:fs/promises"; import path from "node:path"; import { homedir } from "node:os"; export type WorkerState = { active: boolean; issueId: string | null; startTime: string | null; tier: string | null; sessions: Record; }; export type Project = { name: string; repo: string; groupName: string; deployUrl: string; baseBranch: string; deployBranch: string; /** Messaging channel for this project's group (e.g. "telegram", "whatsapp", "discord", "slack"). Stored at registration time. */ channel?: string; /** Project-level role execution: parallel (DEV+QA can run simultaneously) or sequential (only one role at a time). Default: parallel */ roleExecution?: "parallel" | "sequential"; maxDevWorkers?: number; maxQaWorkers?: number; dev: WorkerState; qa: WorkerState; }; export type ProjectsData = { projects: Record; }; function parseWorkerState(worker: Record): WorkerState { return { active: worker.active as boolean, issueId: worker.issueId as string | null, startTime: worker.startTime as string | null, tier: worker.tier as string | null, sessions: (worker.sessions as Record) ?? {}, }; } /** * Create a blank WorkerState with null sessions for given tier names. */ export function emptyWorkerState(tiers: string[]): WorkerState { const sessions: Record = {}; for (const t of tiers) { sessions[t] = null; } return { active: false, issueId: null, startTime: null, tier: null, sessions, }; } /** * Get session key for a specific tier from a worker's sessions map. */ export function getSessionForTier( worker: WorkerState, tier: string, ): string | null { return worker.sessions[tier] ?? null; } function projectsPath(workspaceDir: string): string { return path.join(workspaceDir, "projects", "projects.json"); } export async function readProjects(workspaceDir: string): Promise { const raw = await fs.readFile(projectsPath(workspaceDir), "utf-8"); const data = JSON.parse(raw) as ProjectsData; for (const project of Object.values(data.projects)) { project.dev = project.dev ? parseWorkerState(project.dev as unknown as Record) : emptyWorkerState([]); project.qa = project.qa ? parseWorkerState(project.qa as unknown as Record) : emptyWorkerState([]); if (!project.channel) { project.channel = "telegram"; } } return data; } export async function writeProjects( workspaceDir: string, data: ProjectsData, ): Promise { const filePath = projectsPath(workspaceDir); const tmpPath = filePath + ".tmp"; await fs.writeFile(tmpPath, JSON.stringify(data, null, 2) + "\n", "utf-8"); await fs.rename(tmpPath, filePath); } export function getProject( data: ProjectsData, groupId: string, ): Project | undefined { return data.projects[groupId]; } export function getWorker( project: Project, role: "dev" | "qa", ): WorkerState { return project[role]; } /** * Update worker state for a project. Only provided fields are updated. * Sessions are merged (not replaced) when both existing and new sessions are present. */ export async function updateWorker( workspaceDir: string, groupId: string, role: "dev" | "qa", updates: Partial, ): Promise { const data = await readProjects(workspaceDir); const project = data.projects[groupId]; if (!project) { throw new Error(`Project not found for groupId: ${groupId}`); } const worker = project[role]; if (updates.sessions && worker.sessions) { updates.sessions = { ...worker.sessions, ...updates.sessions }; } project[role] = { ...worker, ...updates }; await writeProjects(workspaceDir, data); return data; } /** * Mark a worker as active with a new task. * Stores session key in sessions[tier] when a new session is spawned. */ export async function activateWorker( workspaceDir: string, groupId: string, role: "dev" | "qa", params: { issueId: string; tier: string; sessionKey?: string; startTime?: string; }, ): Promise { const updates: Partial = { active: true, issueId: params.issueId, tier: params.tier, }; if (params.sessionKey !== undefined) { updates.sessions = { [params.tier]: params.sessionKey }; } if (params.startTime !== undefined) { updates.startTime = params.startTime; } return updateWorker(workspaceDir, groupId, role, updates); } /** * Mark a worker as inactive after task completion. * Preserves sessions map and tier for reuse via updateWorker's spread. * Clears startTime to prevent stale timestamps on inactive workers. */ export async function deactivateWorker( workspaceDir: string, groupId: string, role: "dev" | "qa", ): Promise { return updateWorker(workspaceDir, groupId, role, { active: false, issueId: null, startTime: null, }); } /** * Resolve repo path from projects.json repo field (handles ~/ expansion). */ export function resolveRepoPath(repoField: string): string { if (repoField.startsWith("~/")) { return repoField.replace("~", homedir()); } return repoField; }