fix(apme): route adapter-emitted task_boundary spans to closeTask

The collector's task_boundary span case handled only signal='clear'
(splitRun) and silently dropped every other signal with a comment claiming
they were "handled automatically elsewhere". That contract broke when the
new adapter hooks landed: OpenClaw emits 'manual' on chat.aborted and
'idle_gap' on its idle-gap timer; OpenCode emits 'todo_complete' on its
TodoWrite all-completed detection. None of those signals reach the
Claude-Code-only auto-detection paths the comment relied on, so the active
task stayed open until session_end — task_judge never fired and the
upserted Timeline task_end row never received score/outcome.

Fix routes signal in {todo_complete, manual, idle_gap} to
`closeTask(sessionId, signal)`. session_end stays out of the route because
closeRun fires that transition directly and a duplicate would re-emit
onTaskClosed. Unknown signals log + drop (failure surfaces in test) rather
than silently disappear.

Added test coverage in apme-telemetry-envelope.test.ts for each of the
three signals and for the unknown-signal drop. Existing /clear test
preserved. Full suite: 1267/1267 (up from 1263, +4).

TaskBoundarySignal type widened to include 'idle_gap' (already referenced
unchecked in index.ts label switch).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: puritysb

bridge/src/__tests__/apme-telemetry-envelope.test.ts

@@ -406,6 +406,46 @@ describe('ApmeCollector.ingestSpan dispatch', () => {
     expect(afterRunId).not.toBe(beforeRunId);
   });
 
+  it.each(['manual', 'idle_gap', 'todo_complete'] as const)(
+    'task_boundary span with signal=%s closes the active task',
+    (signal) => {
+      // Seed a turn so a task is opened (closeTask drops empty tasks otherwise).
+      for (const s of claudeHookToSpans(ctx(), 'UserPromptSubmit', { message: { content: 'work' } })) {
+        collector.ingestSpan('S', s);
+      }
+      const taskId = collector.getActiveTaskId('S');
+      expect(taskId).not.toBeNull();
+
+      let closedSignal: string | null = null;
+      collector.onTaskClosed = ({ boundarySignal }) => { closedSignal = boundarySignal; };
+
+      collector.ingestSpan('S', {
+        traceId: 'T', spanId: 'b', name: spanNameForKind('task_boundary'),
+        kind: 'task_boundary', ts: Date.now(),
+        attributes: { 'agentdeck.boundary_signal': signal },
+      });
+
+      expect(collector.getActiveTaskId('S')).toBeNull();
+      expect(closedSignal).toBe(signal);
+    },
+  );
+
+  it('task_boundary span with an unknown signal is dropped (no task close, no throw)', () => {
+    for (const s of claudeHookToSpans(ctx(), 'UserPromptSubmit', { message: { content: 'work' } })) {
+      collector.ingestSpan('S', s);
+    }
+    const taskBefore = collector.getActiveTaskId('S');
+    expect(taskBefore).not.toBeNull();
+
+    collector.ingestSpan('S', {
+      traceId: 'T', spanId: 'b', name: spanNameForKind('task_boundary'),
+      kind: 'task_boundary', ts: Date.now(),
+      attributes: { 'agentdeck.boundary_signal': 'made_up_value' },
+    });
+
+    expect(collector.getActiveTaskId('S')).toBe(taskBefore);
+  });
+
   it('raw_step span inserts a steps row without lifecycle effects', () => {
     for (const s of claudeHookToSpans(ctx(), 'UserPromptSubmit', { message: { content: 'q' } })) {
       collector.ingestSpan('S', s);

bridge/src/apme/collector.ts

@@ -58,7 +58,7 @@ interface ActiveTask {
   lastTurnIndex: number | null;
 }
 
-export type TaskBoundarySignal = 'todo_complete' | 'clear' | 'session_end' | 'manual';
+export type TaskBoundarySignal = 'todo_complete' | 'clear' | 'session_end' | 'manual' | 'idle_gap';
 
 /** Callback fired after a task is closed in DB. Used to enqueue task-level eval
  *  without creating a direct dependency from collector → runner. */
@@ -505,11 +505,20 @@ export class ApmeCollector {
           this.splitRun(sessionId, (a['agentdeck.cwd'] as string | undefined));
           return;
         }
-        // Other boundary signals (todo_complete, session_end) are handled
-        // automatically: tool_result detects todo_complete, closeRun closes
-        // the current task with session_end. Adapters that emit those
-        // spans explicitly are no-ops here by design — preserving the
-        // single-source-of-truth for those transitions.
+        // Adapter-emitted boundaries (OpenClaw chat.aborted → 'manual',
+        // OpenClaw idle-gap timer → 'idle_gap', OpenCode TodoWrite
+        // all-completed → 'todo_complete') must close the active task.
+        // Without this route those spans were silently swallowed and the
+        // task only closed on session_end, breaking task_judge enqueue
+        // and Timeline task_end emission.
+        //
+        // `session_end` is intentionally excluded: closeRun fires that
+        // path itself, and a duplicate here would double-emit onTaskClosed.
+        if (signal === 'todo_complete' || signal === 'manual' || signal === 'idle_gap') {
+          this.closeTask(sessionId, signal);
+          return;
+        }
+        debug('APME', `task_boundary span dropped: unknown signal=${signal ?? '<none>'}`);
         return;
       }
       case 'session_meta': {