qwen-code/packages/web-shell/client/utils/monitorTasks.ts

import type {
  DaemonSessionMonitorTaskStatus,
  DaemonSessionTaskStatus,
} from '@qwen-code/sdk/daemon';
import type { ACPToolCall } from '../adapters/types';

function monitorIdFromTool(tool: ACPToolCall): string | undefined {
  const text = [
    typeof tool.rawOutput === 'string' ? tool.rawOutput : '',
    tool.subContent ?? '',
    ...(tool.content ?? []).map((item) => item.content?.text ?? ''),
  ].join('\n');
  return text.match(/\bmon_[a-f0-9]{16}\b/i)?.[0];
}

export function findMonitorTaskForTool(
  tasks: readonly DaemonSessionTaskStatus[],
  tool: ACPToolCall,
): DaemonSessionMonitorTaskStatus | undefined {
  const monitors = tasks.filter(
    (task): task is DaemonSessionMonitorTaskStatus => task.kind === 'monitor',
  );
  const linked = monitors.find((task) => task.toolUseId === tool.callId);
  if (linked) return linked;

  const monitorId = monitorIdFromTool(tool);
  return monitorId
    ? monitors.find(
        (task) => task.id === monitorId && task.toolUseId === undefined,
      )
    : undefined;
}