Diseñar subagentes

from dataclasses import dataclass
import anthropic

MODEL = "claude-sonnet-5-5"
client = anthropic.AsyncAnthropic()

@dataclass
class Brief:
    objetivo: str
    para_que: str
    limites: str
    contexto: str
    parada: str
    max_pasos: int = 12

ENTREGAR = {
    "name": "entregar",
    "description": "Entrega el resultado final. Llámala una sola vez, al terminar.",
    "strict": True,
    "input_schema": {
        "type": "object",
        "properties": {
            "hallazgos": {"type": "array", "items": {
                "type": "object",
                "properties": {"afirmacion": {"type": "string"},
                               "evidencia": {"type": "string"},
                               "fuente": {"type": "string"}},
                "required": ["afirmacion", "evidencia", "fuente"],
                "additionalProperties": False}},
            "lagunas": {"type": "string", "description": "Qué no pudiste verificar"},
        },
        "required": ["hallazgos", "lagunas"],
        "additionalProperties": False,
    },
}

def system_de(b: Brief) -> str:
    return (f"Eres un subagente de investigación.\n<objetivo>{b.objetivo}</objetivo>\n"
            f"<para_que>{b.para_que}</para_que>\n<limites>{b.limites}</limites>\n"
            f"<contexto>{b.contexto}</contexto>\n<parada>{b.parada}</parada>\n"
            "Termina siempre llamando a la herramienta entregar. No incluyas nada fuera de tus límites.")

async def ejecutar_subagente(b: Brief, tools: list[dict], handlers: dict) -> dict:
    messages = [{"role": "user", "content": "Empieza."}]
    for paso in range(b.max_pasos):
        ultimo = paso == b.max_pasos - 1
        resp = await client.messages.create(
            model=MODEL, max_tokens=4096, system=system_de(b), messages=messages,
            tools=tools + [ENTREGAR],
            # en el último paso, obligamos a entregar lo que tenga
            tool_choice={"type": "tool", "name": "entregar"} if ultimo else {"type": "auto"})
        messages.append({"role": "assistant", "content": resp.content})
        usos = [x for x in resp.content if x.type == "tool_use"]
        for u in usos:
            if u.name == "entregar":
                return u.input
        if resp.stop_reason == "pause_turn":
            continue
        if resp.stop_reason != "tool_use":
            messages.append({"role": "user", "content": "Llama a entregar con lo que tengas."})
            continue
        resultados = []
        for u in usos:
            try:
                salida, err = await handlers[u.name](**u.input), False
            except Exception as e:
                salida, err = f"Error: {e}", True
            resultados.append({"type": "tool_result", "tool_use_id": u.id,
                               "content": salida, "is_error": err})
        messages.append({"role": "user", "content": resultados})
    raise RuntimeError("El subagente no entregó.")

import Anthropic from "@anthropic-ai/sdk";

const MODEL = "claude-sonnet-5-5";
const client = new Anthropic();

export interface Brief {
  objetivo: string; paraQue: string; limites: string; contexto: string; parada: string; maxPasos: number;
}
type Handler = (input: any) => Promise<string>;
declare const ENTREGAR: Anthropic.Tool; // mismo esquema estricto que en Python

export async function ejecutarSubagente(b: Brief, tools: Anthropic.Tool[], handlers: Record<string, Handler>) {
  const system = `Eres un subagente de investigación.\n<objetivo>${b.objetivo}</objetivo>\n` +
    `<para_que>${b.paraQue}</para_que>\n<limites>${b.limites}</limites>\n` +
    `<contexto>${b.contexto}</contexto>\n<parada>${b.parada}</parada>\nTermina llamando a entregar.`;
  const messages: Anthropic.MessageParam[] = [{ role: "user", content: "Empieza." }];
  for (let paso = 0; paso < b.maxPasos; paso++) {
    const ultimo = paso === b.maxPasos - 1;
    const resp = await client.messages.create({
      model: MODEL, max_tokens: 4096, system, messages, tools: [...tools, ENTREGAR],
      tool_choice: ultimo ? { type: "tool", name: "entregar" } : { type: "auto" },
    });
    messages.push({ role: "assistant", content: resp.content });
    const usos = resp.content.filter((x): x is Anthropic.ToolUseBlock => x.type === "tool_use");
    const entrega = usos.find((u) => u.name === "entregar");
    if (entrega) return entrega.input;
    if (resp.stop_reason === "pause_turn") continue;
    if (resp.stop_reason !== "tool_use") {
      messages.push({ role: "user", content: "Llama a entregar con lo que tengas." });
      continue;
    }
    const resultados: Anthropic.ToolResultBlockParam[] = [];
    for (const u of usos) {
      try {
        resultados.push({ type: "tool_result", tool_use_id: u.id, content: await handlers[u.name](u.input) });
      } catch (e) {
        resultados.push({ type: "tool_result", tool_use_id: u.id, content: `Error: ${e}`, is_error: true });
      }
    }
    messages.push({ role: "user", content: resultados });
  }
  throw new Error("El subagente no entregó.");
}