Skip to content

Add dry-run mode and task status dashboard #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
mikkel wants to merge 6 commits into
base: master
Choose a base branch
from
Open

Add dry-run mode and task status dashboard #2

Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
1d6f26e
task/453: Add dry-run mode and task status dashboard
Feb 16, 2026
111f73d
Fix dry-run preflight and status error handling
Feb 16, 2026
89cfaf1
fix: address Codex review — Move dry-run branch before Claude preflight
Feb 16, 2026
e9558cf
fix: address Codex review — Move dry-run branch before Claude preflight
Feb 16, 2026
0d616b5
fix: address Codex review — Do not report ATS query failures as zero …
Feb 16, 2026
2e2d69b
fix: address review — Move dry-run branch before Claude preflight
Mar 22, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
153 changes: 151 additions & 2 deletions index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -503,8 +503,10 @@ async function runAllAttempts(task, project, projectName, attempts, modeOverride
}

// === Preflight ===
function preflight() {
for (const check of [{ name: 'ats', bin: ATS_BIN }, { name: 'claude', bin: CLAUDE_BIN }]) {
function preflight({ skipClaude = false } = {}) {
const checks = [{ name: 'ats', bin: ATS_BIN }];
if (!skipClaude) checks.push({ name: 'claude', bin: CLAUDE_BIN });
for (const check of checks) {
try {
const version = execSync(`'${check.bin}' --version`, {
encoding: 'utf-8', timeout: 10000, stdio: ['pipe', 'pipe', 'pipe'],
Expand Down Expand Up @@ -796,6 +798,111 @@ function handleWatchEvent(event, projectName, channel, project) {
});
}

// === Dry-run preview ===
function dryRunPreview(task, project, projectName, attempts, modeOverride) {
const origTaskId = task.id || task.uuid;
const title = task.title || 'Untitled';
const description = task.description || '';

// Detect mode
let mode, iterations;
if (modeOverride) {
mode = modeOverride.mode;
iterations = modeOverride.iterations || (mode === 'oneshot' ? 1 : 8);
iterations = Math.min(iterations, project.max_iterations || 15);
} else {
({ mode, iterations } = detectMode(title, description, project));
}

// Build branch name
const branchName = `task/${origTaskId}-${slugify(title)}`;

// Build first-iteration prompt
const prompt = `You are working on the project at ${project.repo}. Execute this task:\n\n${title}\n${description}\n\nMake progress on this task. Do NOT commit, push, or create PRs.`;

const separator = '─'.repeat(60);

console.log(`\n${separator}`);
console.log(` DRY RUN — nothing will be executed`);
console.log(separator);
console.log(` Project: ${projectName}`);
console.log(` Channel: ${project.channel}`);
console.log(` Repo: ${project.repo}`);
console.log(` GitHub: ${project.github}`);
console.log(` Task ID: ${origTaskId}`);
console.log(` Title: ${title}`);
console.log(` Mode: ${mode}${modeOverride ? ' (override)' : ' (auto-detected)'}`);
console.log(` Iterations: ${iterations}`);
console.log(` Attempts: ${attempts}`);
console.log(` Branch: ${branchName}`);
if (attempts > 1) {
console.log(` Run branches: ${branchName}, ${branchName}-run2`);
if (attempts > 2) console.log(` ... through ${branchName}-run${attempts}`);
}
console.log(separator);
console.log(` Claude prompt preview (first 500 chars):`);
console.log();
console.log(` ${prompt.slice(0, 500).split('\n').join('\n ')}`);
if (prompt.length > 500) console.log(` ... (${prompt.length - 500} more chars)`);
console.log(`\n${separator}`);
console.log(` Would create: ATS run task on channel "${project.channel}:run-1"`);
console.log(` Would run: Claude Code (${mode}, up to ${iterations} iteration${iterations > 1 ? 's' : ''})`);
console.log(` Would open: PR on ${project.github} from ${branchName}`);
console.log(separator + '\n');
}

// === Status command ===
function statusCommand() {
const projects = Object.entries(PROJECTS);

if (projects.length === 0) {
console.log('No projects configured.');
return;
}

// Table header
const col = { name: 20, channel: 22, repo: 45, github: 35, pending: 9 };
const pad = (s, w) => String(s).padEnd(w).slice(0, w);
const separator = '─'.repeat(col.name + col.channel + col.repo + col.github + col.pending + 8);

console.log(`\nats-project-runner v${VERSION} — Project Status\n`);
console.log(
` ${pad('Project', col.name)} ${pad('Channel', col.channel)} ${pad('Repo Path', col.repo)} ${pad('GitHub', col.github)} ${pad('Pending', col.pending)}`
);
console.log(` ${separator}`);

let hasErrors = false;
for (const [name, proj] of projects) {
let pendingCount = '?';
try {
const raw = ats('list', '--channel', proj.channel, '--status', 'pending', '-f', 'json');
// Try to parse as JSON array or count objects
const match = raw.match(/\[[\s\S]*\]/);
if (match) {
const tasks = JSON.parse(match[0]);
pendingCount = String(tasks.length);
} else {
// Count individual task JSON objects
const taskMatches = raw.match(/\{[\s\S]*?\}/g);
pendingCount = taskMatches ? String(taskMatches.length) : '0';
}
} catch (err) {
log('warn', 'Failed to query pending tasks', { project: name, channel: proj.channel, error: err.message });
pendingCount = 'ERR';
hasErrors = true;
}

console.log(
` ${pad(name, col.name)} ${pad(proj.channel, col.channel)} ${pad(proj.repo, col.repo)} ${pad(proj.github, col.github)} ${pad(pendingCount, col.pending)}`
);
}
console.log();
if (hasErrors) {
console.error('Warning: one or more channels could not be queried (see ERR above).');
process.exit(1);
}
}

// === CLI ===
function usage() {
console.error(`Usage:
Expand All @@ -804,7 +911,9 @@ function usage() {
node index.js run <task-id> --mode oneshot Force one-shot mode
node index.js run <task-id> --mode iterative Force iterative mode
node index.js run <task-id> --iterations 12 Set max iterations (implies iterative)
node index.js run <task-id> --dry-run Preview what would happen without executing
node index.js watch Watch all configured channels for new tasks
node index.js status Show all projects and pending task counts
`);
process.exit(1);
}
Expand All @@ -820,6 +929,11 @@ async function main() {
return;
}

if (command === 'status') {
statusCommand();
return;
}

if (command !== 'run') usage();

const taskIdArg = args[1];
Expand All @@ -840,10 +954,13 @@ async function main() {
attempts: { type: 'string', short: 'a' },
mode: { type: 'string', short: 'm' },
iterations: { type: 'string', short: 'i' },
'dry-run': { type: 'boolean' },
},
strict: false,
});

const dryRun = values['dry-run'] || false;

if (values.attempts) {
attempts = parseInt(values.attempts, 10);
if (isNaN(attempts) || attempts < 1) {
Expand Down Expand Up @@ -873,6 +990,38 @@ async function main() {
projects: Object.keys(PROJECTS),
});

// Dry-run mode: only validate ATS connectivity, fetch task, and preview
if (dryRun) {
preflight({ skipClaude: true });

let task;
try {
task = getTask(taskId);
} catch (err) {
log('error', 'Failed to fetch task', { taskId, error: err.message });
process.exit(1);
}
if (!task) {
log('error', 'Task not found', { taskId });
process.exit(1);
}

log('info', 'Fetched original task', { taskId, title: task.title, channel: task.channel, status: task.status });

const match = findProjectByChannel(task.channel);
if (!match) {
log('error', 'Task channel not found in config', { taskId, channel: task.channel, configured: Object.values(PROJECTS).map(p => p.channel) });
process.exit(1);
}

const { name: projectName, project } = match;
log('info', 'Matched project', { projectName, repo: project.repo, github: project.github });

dryRunPreview(task, project, projectName, attempts, modeOverride);
return;
}

// Full preflight (includes Claude binary validation)
preflight();

// Fetch the original task (read-only)
Expand Down
Loading