سیستم‌های چندایجنت

def run_swarm(start_agent: Agent, user_messages: list[str]) -> list[Msg]:
    history: list[Msg] = []
    active = start_agent                     # نگهدارنده‌ی چت
    for user in user_messages:
        history.append(Msg(role="user", content=user))
        out = scripted_router(active, user)  # جایگزین LLM
        if isinstance(out, Agent):           # ابزاری که یک ایجنت برگرداند
            history.append(
                Msg(role="assistant", content=f"(handoff to {out.name})", sender=active.name)
            )
            active = out                     # تعویض ایجنت فعال
            out = scripted_router(active, user)
        history.append(Msg(role="assistant", content=str(out), sender=active.name))
    return history                           # چیزی ذخیره نمی‌شود

def cp_wbft(votes: list[Vote], threshold: float = 0.5):
    weights: dict[str, float] = {}
    rep: dict[str, str] = {}
    for v in votes:
        key = v.canonical()   # خوشه‌بندی پاسخ‌های یکسان
        weights[key] = weights.get(key, 0.0) + v.confidence
        rep.setdefault(key, v.answer)
    total = sum(weights.values()) or 1.0
    winner_key = max(weights, key=weights.get)
    if weights[winner_key] / total < threshold:
        return None, weights  # بسیار ضعیف: تلاش مجدد یا ارجاع به بالاتر
    return rep[winner_key], weights