fix(cue): scan watched file on manual task.pending trigger

[scriptease]

A manual maestro-cli cue trigger of a task.pending subscription built a bare event with no task payload, so the prompt's {{CUE_TASK_COUNT}} and {{CUE_TASK_LIST}} fell back to "0"/"" and the run saw no work. Only the polling scanner populated those fields, so the documented manual fallback was broken.

Extract buildTaskPendingPayload and add scanTaskFilesOnce in the task scanner (hash-free live scan), and have CueEngine.triggerSubscription scan the sub's watch glob against the owner's projectRoot before dispatch, merging the first matching file's task fields into the event payload.

Summary by CodeRabbit

• New Features
  • Manual task triggering now performs a one-time scan of the watched project files for pending tasks and enriches the event payload with task metadata (count, list, path) when available.
  • When no pending tasks are found, the event payload is still dispatched with the manual indicator, omitting task metadata.
• Bug Fixes
  • If the scan fails, manual triggers still dispatch the bare manual payload and log a warning instead of breaking the workflow.

[coderabbitai]

No actionable comments were generated in the recent review. 🎉

ℹ️ Recent review info

⚙️ Run configuration

Configuration used: Path: .coderabbit.yaml

Review profile: CHILL

Plan: Pro

Run ID: b0d35477-6b7b-4883-af71-53d18e5b15a6

📥 Commits

Reviewing files that changed from the base of the PR and between de8d00e and bd4c2cc.

📒 Files selected for processing (2)

• src/__tests__/main/cue/cue-engine.test.ts
• src/main/cue/cue-engine.ts

🚧 Files skipped from review as they are similar to previous changes (1)

• src/main/cue/cue-engine.ts

---

📝 Walkthrough

Walkthrough

cue-task-scanner.ts gains two new exports: buildTaskPendingPayload (extracts pending markdown tasks from file content into a payload object or null) and scanTaskFilesOnce (single-pass glob walk returning payloads for files with pending tasks). The existing doScan is refactored to use buildTaskPendingPayload. CueEngine.triggerSubscription now calls scanTaskFilesOnce when manually dispatching a task.pending subscription that has a watch, merging scanned data into the event payload. Test coverage includes successful scan results, empty scans, and error handling with logged warnings.

Changes

Manual task.pending trigger with scanned payload

Layer / File(s)	Summary
Task scanner helpers and doScan refactor src/main/cue/cue-task-scanner.ts	Adds buildTaskPendingPayload to produce a standardized payload or null from file content, adds scanTaskFilesOnce to walk matching files and return payloads for files with pending tasks, and refactors doScan to use buildTaskPendingPayload instead of inline extraction.
Engine manual trigger integration src/main/cue/cue-engine.ts	Imports scanTaskFilesOnce and updates triggerSubscription to resolve projectRoot, run a one-shot scan for task.pending subscriptions with a watch, log scan outcomes and match counts, handle scan failures via warning logs and exception capture, and merge the scanned task payload with { manual: true } into the Cue event.
Test setup and manual trigger test cases src/__tests__/main/cue/cue-engine.test.ts	Adds mockScanTaskFilesOnce to the module mock and provides test cases asserting correct payload shape when scan returns pending tasks, when scan returns empty results, and when scan throws an exception with logged warnings.

Estimated code review effort

🎯 2 (Simple) | ⏱️ ~10 minutes

Suggested labels

ready to merge

Poem

🐇 A rabbit hops through markdown files,
Scanning tasks across the miles,
pending tasks found in one pass,
Manual triggers now amass!
No more empty payloads — hooray,
Scanned data joins the cue today! 🎉

🚥 Pre-merge checks | ✅ 5

✅ Passed checks (5 passed)

Check name	Status	Explanation
Description Check	✅ Passed	Check skipped - CodeRabbit’s high-level summary is enabled.
Title check	✅ Passed	The title accurately captures the main change: scanning watched files during manual task.pending subscription triggers, which is the core fix addressing the documented bug.
Docstring Coverage	✅ Passed	Docstring coverage is 80.00% which is sufficient. The required threshold is 80.00%.
Linked Issues check	✅ Passed	Check skipped because no linked issues were found for this pull request.
Out of Scope Changes check	✅ Passed	Check skipped because no linked issues were found for this pull request.

_{✏️ Tip: You can configure your own custom pre-merge checks in the settings.}

✨ Finishing Touches

🧪 Generate unit tests (beta)

• Create PR with unit tests

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

[coderabbitai]

Actionable comments posted: 1

🤖 Prompt for all review comments with AI agents

Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.

Inline comments:
In `@src/main/cue/cue-engine.ts`:
- Around line 1161-1181: The scanTaskFilesOnce() call in the task.pending event
handler can throw on filesystem access failures without a guard, causing
triggerSubscription to abort before dispatching a run. Wrap the
scanTaskFilesOnce(sub.watch, projectRoot) call in a try-catch block within the
projectRoot check. In the catch block, log the error context using
this.deps.onLog(), call captureException() from src/utils/sentry.ts to report
the error, and continue with a default { manual: true } payload instead of
letting the exception propagate. This ensures manual triggers are resilient to
filesystem errors.

🪄 Autofix (Beta)

Fix all unresolved CodeRabbit comments on this PR:

• Push a commit to this branch (recommended)
• Create a new PR with the fixes

---

ℹ️ Review info

⚙️ Run configuration

Configuration used: Path: .coderabbit.yaml

Review profile: CHILL

Plan: Pro

Run ID: 867d2b16-31e7-4796-b1c9-a5564ee7e747

📥 Commits

Reviewing files that changed from the base of the PR and between cb36a25 and de8d00e.

📒 Files selected for processing (3)

• src/__tests__/main/cue/cue-engine.test.ts
• src/main/cue/cue-engine.ts
• src/main/cue/cue-task-scanner.ts

[greptile-apps]

Greptile Summary

This PR fixes the broken manual cue trigger flow for task.pending subscriptions by scanning the watched file(s) synchronously at dispatch time and merging the first matching file's task fields into the event payload, so {{CUE_TASK_COUNT}} and {{CUE_TASK_LIST}} resolve correctly without a polling cycle.

• Refactoring (cue-task-scanner.ts): Extracts buildTaskPendingPayload from the inline code in createCueTaskScanner and adds scanTaskFilesOnce for a hash-free, one-shot walk — both are now shared by the polling and manual paths, keeping payloads identical.
• Engine change (cue-engine.ts): triggerSubscription calls scanTaskFilesOnce before building the event for any task.pending sub that has a watch glob, using the first matching file's payload and logging a warning when more than one file matches.
• Tests (cue-engine.test.ts): Two new cases verify payload population on a successful scan and clean dispatch when no pending tasks are found.

Confidence Score: 3/5

The manual trigger can throw out of the dispatch loop when the project root is inaccessible, instead of gracefully degrading; review this before merging.

The core fix is correct and well-tested, but scanTaskFilesOnce is not guarded with a try/catch at the call site in triggerSubscription. An inaccessible projectRoot causes walkDir to re-throw, escaping the dispatch loop instead of returning false cleanly. The polling scanner handles the same failure by catching and logging. Additionally, a broad glob silently drops all but the first matching file's tasks, diverging from the polling scanner's one-event-per-file behavior.

src/main/cue/cue-engine.ts — the scanTaskFilesOnce call inside triggerSubscription needs error handling; src/main/cue/cue-task-scanner.ts is otherwise clean.

Important Files Changed

Filename	Overview
src/main/cue/cue-task-scanner.ts	Extracts buildTaskPendingPayload for reuse and adds scanTaskFilesOnce for live, hash-free scanning. Refactoring is clean and the polling scanner behavior is unchanged. scanTaskFilesOnce lacks a top-level try/catch, which can cause exceptions to escape callers that don't guard against it.
src/main/cue/cue-engine.ts	Integrates scanTaskFilesOnce into triggerSubscription for task.pending subs. The call is not guarded with try/catch — an inaccessible projectRoot throws out of the dispatch loop, and only the first matching file's tasks are dispatched even when multiple files match the glob.
src/tests/main/cue/cue-engine.test.ts	Adds scanTaskFilesOnce mock and two new tests covering the happy path (payload populated) and empty-scan (no task fields). Tests are clear and align with the new behavior. No error-path test for a failing scan.

Sequence Diagram

%%{init: {'theme': 'neutral'}}%%
sequenceDiagram
    participant CLI as maestro-cli cue trigger
    participant CE as CueEngine.triggerSubscription
    participant STO as scanTaskFilesOnce
    participant FS as File System
    participant DS as dispatchService

    CLI->>CE: triggerSubscription("task-queue")
    CE->>CE: "resolve anchor sub (event=task.pending, watch=tasks/**/*.md)"
    CE->>STO: scanTaskFilesOnce(watch, projectRoot)
    STO->>FS: walkDir(projectRoot)
    FS-->>STO: [relPaths...]
    STO->>FS: readFileSync(absPath) per match
    FS-->>STO: file content
    STO->>STO: buildTaskPendingPayload(absPath, relPath, content)
    STO-->>CE: "[{path, taskCount, taskList, tasks, ...}]"
    CE->>CE: "merge payloads[0] into event payload {manual:true, ...taskPayload}"
    CE->>DS: dispatchSubscription(ownerSessionId, sub, event, "manual")
    DS-->>CE: dispatched count
    CE-->>CLI: true

Loading

%%{init: {'theme': 'base', 'themeVariables': {"darkMode": true, "background": "#0d1117", "primaryColor": "#21262d", "primaryTextColor": "#e6edf3", "primaryBorderColor": "#8b949e", "lineColor": "#8b949e", "textColor": "#e6edf3", "edgeLabelBackground": "#161b22", "actorBkg": "#21262d", "actorBorder": "#8b949e", "actorTextColor": "#e6edf3", "actorLineColor": "#8b949e", "signalColor": "#8b949e", "signalTextColor": "#e6edf3", "noteBkgColor": "#373320", "noteBorderColor": "#d4a72c", "noteTextColor": "#f0e6c0", "labelBoxBkgColor": "#21262d", "labelBoxBorderColor": "#8b949e", "labelTextColor": "#e6edf3", "loopTextColor": "#e6edf3", "activationBkgColor": "#30363d", "activationBorderColor": "#8b949e"}}}%%
sequenceDiagram
    participant CLI as maestro-cli cue trigger
    participant CE as CueEngine.triggerSubscription
    participant STO as scanTaskFilesOnce
    participant FS as File System
    participant DS as dispatchService

    CLI->>CE: triggerSubscription("task-queue")
    CE->>CE: "resolve anchor sub (event=task.pending, watch=tasks/**/*.md)"
    CE->>STO: scanTaskFilesOnce(watch, projectRoot)
    STO->>FS: walkDir(projectRoot)
    FS-->>STO: [relPaths...]
    STO->>FS: readFileSync(absPath) per match
    FS-->>STO: file content
    STO->>STO: buildTaskPendingPayload(absPath, relPath, content)
    STO-->>CE: "[{path, taskCount, taskList, tasks, ...}]"
    CE->>CE: "merge payloads[0] into event payload {manual:true, ...taskPayload}"
    CE->>DS: dispatchSubscription(ownerSessionId, sub, event, "manual")
    DS-->>CE: dispatched count
    CE-->>CLI: true

Loading

_{Reviews (1): Last reviewed commit: "fix(cue): scan watched file on manual ta..." | Re-trigger Greptile}

[pedramamini]

Thanks for the fix, @scriptease! Great catch on the broken manual cue trigger fallback for task.pending, and extracting buildTaskPendingPayload so the polling and manual paths produce identical payloads is a clean way to keep them in sync. The two new tests (populated payload + empty-scan) cover the behavior well.

One change before this is good to merge:

Guard the one-shot scan in triggerSubscription (src/main/cue/cue-engine.ts)

scanTaskFilesOnce calls walkDir(projectRoot, projectRoot), and walkDir deliberately re-throws when the root itself is unreadable (if (dir === root) throw err). The new call inside the dispatch loop isn't wrapped, and triggerSubscription has no surrounding try/catch, so if a session's projectRoot is deleted, unmounted, or hits a permission change, the exception escapes the whole method: every remaining sub in the dispatch group is skipped and the trigger throws instead of returning cleanly.

The polling scanner already handles this exact case gracefully - doScan wraps its walkDir call in try/catch and logs - so the manual path should degrade the same way. captureException is already imported in this file (and used a few lines down), so the fix matches existing usage:

try {
	const payloads = scanTaskFilesOnce(sub.watch, projectRoot);
	// ...existing payload handling...
} catch (err) {
	this.deps.onLog(
		'warn',
		`[CUE] "${sub.name}" manual trigger scan failed: ${err instanceof Error ? err.message : String(err)}`
	);
	void captureException(err, {
		operation: 'cue.triggerSubscription.scanTaskFilesOnce',
		subscriptionName: sub.name,
		ownerSessionId,
	});
}
// taskPayload stays {} so dispatch continues with { manual: true }

This also lines up with our error-handling guideline of handling expected/recoverable errors explicitly rather than letting them abort the flow. Both Greptile and CodeRabbit flagged the same thing, and I confirmed it against the code.

Minor, your call

For a broad glob like tasks/**/*.md that matches several files, the manual trigger dispatches a single event from payloads[0], whereas the poller fires one event per file. You already log a warning when more than one file matches, which is a reasonable choice for a one-shot trigger, but I'm flagging the asymmetry in case you'd rather fan out to match the poller. Not a blocker.

Once the scan is guarded I'm happy to approve. Thanks again for the contribution!