Method execute

src/tools/builtin/gather.ts:104–142

(args: z.infer<typeof GatherArgs>, ctx: ToolContext)

  argsSchema = GatherArgs;

  async execute(args: z.infer<typeof GatherArgs>, ctx: ToolContext): Promise<ToolResult> {
    const runner = getSubAgentRunner();
    if (!runner) {
      return {
        content: '[SUBAGENT_DISABLED] gather needs sub-agents enabled. Run `qx setup` and pick a sub-agent mode, ' +
          'or set subagents.mode: sequential in ~/.qodex/config.yaml.',
        isError: true,
      };
    }

    const probes = args.probes;
    const maxConc = args.max_concurrency ?? 3;
    const maxIter = args.max_iterations_each ?? 6;
    ctx.emit({ type: 'progress', message: `Gathering: dispatching ${probes.length} scout(s), up to ${maxConc} at once…` });
    logger.info('gather: dispatching scouts', { count: probes.length, maxConc, maxIter });

    const start = Date.now();
    const results = await runWithConcurrency(probes, maxConc, async (probe, i) => {
      ctx.emit({ type: 'progress', message: `Scout ${i + 1}/${probes.length}: ${probe.focus.slice(0, 60)}` });
      try {
        const r = await runner(buildScoutPrompt(probe.focus, probe.hint), {
          maxIterations: maxIter,
          signal: ctx.signal,
          sessionId: `${ctx.sessionId}/scout-${i}-${Date.now()}`,
          role: 'scout',
        });
        return { focus: probe.focus, ok: r.ok, findings: r.finalText, error: r.error };
      } catch (e: any) {
        return { focus: probe.focus, ok: false, findings: '', error: e?.message ?? String(e) };
      }
    });

    const elapsedSec = Math.round((Date.now() - start) / 1000);
    const okCount = results.filter(r => r.ok).length;
    return {
      content: consolidateFindings(results),
      metadata: { scouts: probes.length, succeeded: okCount, elapsedSec },
    };
  }
}