2FastLabs/agent-squad

#   This is especially recommended for binary packages to ensure reproducibility, and is more #   commonly ignored for libraries. #   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control

#   commonly ignored for libraries. #   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control #poetry.lock

#   https://python-poetry.org/docs/basic-usage/#commit-your-poetrylock-file-to-version-control

#   pdm stores project-wide configurations in .pdm.toml, but it is recommended to not include it #   in version control. #   https://pdm.fming.dev/#use-with-ide

#   in version control. #   https://pdm.fming.dev/#use-with-ide .pdm.toml

#   https://pdm.fming.dev/#use-with-ide

[Credential-related source omitted]

# PyCharm #  JetBrains specific template is maintained in a separate JetBrains.gitignore that can #  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore

#  JetBrains specific template is maintained in a separate JetBrains.gitignore that can #  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore #  and can be added to the global gitignore or merged into this 

#  be found at https://github.com/github/gitignore/blob/main/Global/JetBrains.gitignore

#### Installation Options: - Windows: [Python Official Website](https://www.python.org/downloads/windows/)

- Windows: [Python Official Website](https://www.python.org/downloads/windows/)

- macOS:   - [Python Official Website](https://www.python.org/downloads/macos/)   - Homebrew: `brew install python@3.11`

- [Python Official Website](https://www.python.org/downloads/macos/)

sudo add-apt-repository ppa:deadsnakes/ppa

sudo apt update

sudo apt install python3.11 python3.11-venv python3.11-dev

git clone https://github.com/YOUR_USERNAME/REPOSITORY_NAME.git

rm -rf .venv

Executable file

<p align="center">   <a href="https://github.com/2fastlabs/agent-squad"><img alt="GitHub Repo" src="https://img.shields.io/badge/GitHub-Repo-green.svg" /></a>

<a href="https://github.com/2fastlabs/agent-squad"><img alt="GitHub Repo" src="https://img.shields.io/badge/GitHub-Repo-green.svg" /></a>

<a href="https://pypi.org/project/agent-squad/"><img alt="PyPI" src="https://img.shields.io/pypi/v/agent-squad.svg?style=flat-square"></a>

<a href="https://2fastlabs.github.io/agent-squad/"><img alt="Documentation" src="https://img.shields.io/badge/docs-book-blue.svg?style=flat-square"></a>

<p align="center">   <!-- GitHub Stats -->   <img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">

<!-- GitHub Stats -->   <img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">   <img src="https://img.shields.io/github/forks/2fastlabs/agent-squad?style=social" alt="GitHub forks">

<img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">

<img src="https://img.shields.io/github/forks/2fastlabs/agent-squad?style=social" alt="GitHub forks">

<img src="https://img.shields.io/github/watchers/2fastlabs/agent-squad?style=social" alt="GitHub watchers">

<p align="center">   <!-- Repository Info -->   <img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">

<!-- Repository Info -->   <img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">   <img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">

<img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">   <img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">   <img src="https://img.shields.io/github/issues-pr/2fastlab

<img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">   <img src="https://img.shields.io/github/issues-pr/2fastlabs/agent-squad" alt="Pull Requests"> </p>

<img src="https://img.shields.io/github/issues-pr/2fastlabs/agent-squad" alt="Pull Requests">

<p align="center">   <!-- Package Stats -->   <a href="https://pypi.org/project/agent-squad/"><img src="https://img.shields.io/pypi/dm/agent-squad?label=pypi%20downloads" alt="PyPI Monthly Downloads"></a>

<!-- Package Stats -->   <a href="https://pypi.org/project/agent-squad/"><img src="https://img.shields.io/pypi/dm/agent-squad?label=pypi%20downloads" alt="PyPI Monthly Downloads"></a>   <img src="https://img.shields.io/static/v1?label=pytho

<a href="https://pypi.org/project/agent-squad/"><img src="https://img.shields.io/pypi/dm/agent-squad?label=pypi%20downloads" alt="PyPI Monthly Downloads"></a>

<img src="https://img.shields.io/static/v1?label=python&message=%203.11|%203.12|%203.13&color=blue?style=flat-square&logo=python" alt="Python versions">

Route requests with [Jev](https://docs.typesafe.ai/introduction), TypeSafe AI's decision model, instead of an LLM. Your agents become a typed `choice` question, and Jev returns the chosen agent plus a calibrated confidence. There's no outpu

[Credential-related source omitted]

[JevClassifier docs](https://2fastlabs.github.io/agent-squad/classifiers/built-in/jev-classifier) · [demos](https://github.com/2fastlabs/agent-squad/tree/main/examples/jev-demo/python)

![High-level architecture flow diagram](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/img/flow.jpg)

To quickly get a feel for the Agent Squad, we've provided a Demo App with a few basic agents. This interactive demo showcases the orchestrator's capabilities in a user-friendly interface. To learn more about setting up and running the demo 

Click on the image below to see a screen recording of the demo app on the GitHub repository of the project: <a href="https://github.com/2fastlabs/agent-squad" target="_blank">

<a href="https://github.com/2fastlabs/agent-squad" target="_blank">

<img src="https://raw.githubusercontent.com/2fastlabs/agent-squad/main/img/demo-app.jpg" alt="Demo App Screen Recording" style="max-width: 100%; height: auto;">

Check out our [documentation](https://2fastlabs.github.io/agent-squad/) for comprehensive guides on setting up and using the Agent Squad!

- Clean the `dist` directory before rebuilding if you encounter issues: `rm -rf python/dist/*`

We welcome contributions! Please see our [Contributing Guide](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/CONTRIBUTING.md) for more details.

This project is licensed under the Apache 2.0 licence - see the [LICENSE](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/LICENSE) file for details.

## 📄 Font License This project uses the JetBrainsMono NF font, licensed under the SIL Open Font License 1.1. For full license details, see [FONT-LICENSE.md](https://github.com/JetBrains/JetBrainsMono/blob/master/OFL.txt).

For full license details, see [FONT-LICENSE.md](https://github.com/JetBrains/JetBrainsMono/blob/master/OFL.txt).

[Credential-related source omitted]

provider = await MCPToolProvider.create([     MCPServerConfig(type="stdio", command="uvx", args=["my-mcp-server"]),     MCPServerConfig(type="sse", url="http://localhost:3000/sse"),

MCPServerConfig(type="stdio", command="uvx", args=["my-mcp-server"]),     MCPServerConfig(type="sse", url="http://localhost:3000/sse"), ])

MCPServerConfig(type="sse", url="http://localhost:3000/sse"),

# Enable rules. lint.select = [     "A",   # flake8-builtins - https://docs.astral.sh/ruff/rules/#flake8-builtins-a

lint.select = [     "A",   # flake8-builtins - https://docs.astral.sh/ruff/rules/#flake8-builtins-a     "B",   # flake8-bugbear-b - https://docs.astral.sh/ruff/rules/#flake8-bugbear-b

"A",   # flake8-builtins - https://docs.astral.sh/ruff/rules/#flake8-builtins-a

"B",   # flake8-bugbear-b - https://docs.astral.sh/ruff/rules/#flake8-bugbear-b

#"C4",  # flake8-comprehensions - https://docs.astral.sh/ruff/rules/#flake8-comprehensions-c4

#"C90", # mccabe - https://docs.astral.sh/ruff/rules/#mccabe-c90

#"COM", # flak8-commas - https://docs.astral.sh/ruff/rules/#flake8-commas-com

#"D", # pydocstyle - https://docs.astral.sh/ruff/rules/#pydocstyle-d

#"E",   # pycodestyle error - https://docs.astral.sh/ruff/rules/#error-e

#"ERA", # flake8-eradicate - https://docs.astral.sh/ruff/rules/#eradicate-era

#"FA",  # flake8-future-annotations - https://docs.astral.sh/ruff/rules/#flake8-future-annotations-fa

#"FIX", # flake8-fixme - https://docs.astral.sh/ruff/rules/#flake8-fixme-fix

#"F",   # pyflakes - https://docs.astral.sh/ruff/rules/#pyflakes-f

#"I",   # isort - https://docs.astral.sh/ruff/rules/#isort-i

#"ICN", # flake8-import-conventions - https://docs.astral.sh/ruff/rules/#flake8-import-conventions-icn

#"ISC", # flake8-implicit-str-concat - https://docs.astral.sh/ruff/rules/#flake8-implicit-str-concat-isc

#"PLE", # pylint error - https://docs.astral.sh/ruff/rules/#error-ple

#"PLC", # pylint convention - https://docs.astral.sh/ruff/rules/#convention-plc

#"PLR", # pylint refactoring - https://docs.astral.sh/ruff/rules/#refactor-plr

#"PLW", # pylint warning - https://docs.astral.sh/ruff/rules/#warning-plw

#"PL",  # pylint - https://docs.astral.sh/ruff/rules/#pylint-pl

#"PYI", # flake8-pyi - https://docs.astral.sh/ruff/rules/#flake8-pyi-pyi

#"Q",   # flake8-quotes - https://docs.astral.sh/ruff/rules/#flake8-quotes-q

#"PTH", # flake8-use-pathlib - https://docs.astral.sh/ruff/rules/#flake8-use-pathlib-pth

#"T10", # flake8-debugger https://docs.astral.sh/ruff/rules/#flake8-debugger-t10

#"TCH", # flake8-type-checking - https://docs.astral.sh/ruff/rules/#flake8-type-checking-tch

#"TD",  # flake8-todo - https://docs.astral.sh/ruff/rules/#flake8-todos-td

#"UP",  # pyupgrade - https://docs.astral.sh/ruff/rules/#pyupgrade-up

#"W",   # pycodestyle warning - https://docs.astral.sh/ruff/rules/#warning-w

# Ignore specific rules lint.ignore = [     #"W291",    # https://docs.astral.sh/ruff/rules/trailing-whitespace/

lint.ignore = [     #"W291",    # https://docs.astral.sh/ruff/rules/trailing-whitespace/     #"PLR0913", # https://docs.astral.sh/ruff/rules/too-many-arguments/

#"W291",    # https://docs.astral.sh/ruff/rules/trailing-whitespace/

#"PLR0913", # https://docs.astral.sh/ruff/rules/too-many-arguments/

#"PLR2004", #https://docs.astral.sh/ruff/rules/magic-value-comparison/

#"PLW0603", #https://docs.astral.sh/ruff/rules/global-statement/

#"PYI024",     #"A005",     #"TC006" # https://docs.astral.sh/ruff/rules/runtime-cast-value/

#"A005",     #"TC006" # https://docs.astral.sh/ruff/rules/runtime-cast-value/ ]

#"TC006" # https://docs.astral.sh/ruff/rules/runtime-cast-value/

license = Apache License 2.0 license_files = LICENSE url = https://github.com/2fastlabs/agent-squad

license_files = LICENSE url = https://github.com/2fastlabs/agent-squad classifiers =

url = https://github.com/2fastlabs/agent-squad

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

Executable file

Executable file

Executable file

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

# ToolChoice is only supported by Anthropic Claude 3 models and by Mistral AI Mistral Large.         # https://docs.aws.amazon.com/bedrock/latest/APIReference/API_runtime_ToolChoice.html

# https://docs.aws.amazon.com/bedrock/latest/APIReference/API_runtime_ToolChoice.html

Executable file

Executable file

# Official TypeSafe System One endpoint: https://docs.typesafe.ai/api

JEV_API_URL = "https://api.typesafe.ai/v1/systemone"

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

def _post(self, request: urllib.request.Request) -> Any:

try:             with urllib.request.urlopen(request, timeout=self.timeout) as response:

with urllib.request.urlopen(request, timeout=self.timeout) as response:

async def _send(self, request_body: dict[str, Any]) -> Any:         request = urllib.request.Request(

request = urllib.request.Request(

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

url: Base URL of the Dakera server. Falls back to the ``DAKERA_URL`             environment variable and finally to ``http://localhost:3000``.

environment variable and finally to ``http://localhost:3000``.

[Credential-related source omitted]

"""Retriever backed by a self-hosted `Dakera <https://dakera.ai>`_ memory server.

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

url = self.options.url or os.getenv("DAKERA_URL") or "http://localhost:3000"

[Credential-related source omitted]

Executable file

Executable file

Executable file

[Credential-related source omitted]

"""     This function is used to add an extra header for the User-Agent in the Botocore session,     as described in the pull request: https://github.com/boto/botocore/pull/2682

as described in the pull request: https://github.com/boto/botocore/pull/2682

# Customize botocore session to inject Boto3 header         # See: https://github.com/boto/botocore/pull/2682

# See: https://github.com/boto/botocore/pull/2682

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

provider = await MCPToolProvider.create([         MCPServerConfig(type="stdio", command="uvx", args=["my-mcp-server"]),         MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),

MCPServerConfig(type="stdio", command="uvx", args=["my-mcp-server"]),         MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),         MCPServerConfig(type="sse", url="http://localhost:3000/sse"),

MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),

MCPServerConfig(type="sse", url="http://localhost:3000/sse"),

provider = await MCPToolProvider.create([             MCPServerConfig(type="stdio", command="uvx", args=["my-server"]),             MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),

MCPServerConfig(type="stdio", command="uvx", args=["my-server"]),             MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),         ])

MCPServerConfig(type="streamable-http", url="http://localhost:3000/mcp"),

"""Fetch (and cache) a UI template resource by URI. Returns ``(mime_type, body)`` or ``None``.

body = base64.b64decode(blob).decode("utf-8")

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

ConversationMessage(                 role=ParticipantRole.USER.value,                 content=[{"text": "Hello"}, {"image_url": "http://example.com/image.jpg"}]

role=ParticipantRole.USER.value,                 content=[{"text": "Hello"}, {"image_url": "http://example.com/image.jpg"}]             )

content=[{"text": "Hello"}, {"image_url": "http://example.com/image.jpg"}]

assert len(result[0]["content"]) == 2         assert result[0]["content"][0] == {"text": "Hello"}         assert result[0]["content"][1] == {"image_url": "http://example.com/image.jpg"}

assert result[0]["content"][1] == {"image_url": "http://example.com/image.jpg"}

content=[                     {"text": "Hello"},                     {"image_url": "http://example.com/image.jpg"},

{"text": "Hello"},                     {"image_url": "http://example.com/image.jpg"},                     {"tool_call": {"name": "weather", "parameters": {"location": "Seattle"}}}

{"image_url": "http://example.com/image.jpg"},

assert len(result[0]["content"]) == 3         assert result[0]["content"][0] == {"text": "Hello"}         assert result[0]["content"][1] == {"image_url": "http://example.com/image.jpg"}

assert result[0]["content"][0] == {"text": "Hello"}         assert result[0]["content"][1] == {"image_url": "http://example.com/image.jpg"}         assert result[0]["content"][2] == {"tool_call": {"name": "weather", "parameters": {"location

assert result[0]["content"][1] == {"image_url": "http://example.com/image.jpg"}

"content": [                 {"text": "Here's an image: "},                 {"image_url": "http://example.com/image.jpg"},

{"text": "Here's an image: "},                 {"image_url": "http://example.com/image.jpg"},                 {"text": " And some more text."}

{"image_url": "http://example.com/image.jpg"},

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

"""Context-manager mock mimicking urllib.request.urlopen's response."""

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

base_url='https://gateway.example.com/v1/systemone',

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

assert options.base_url == 'https://gateway.example.com/v1/systemone'

[Credential-related source omitted]

def test_defaults_to_official_endpoint(self):         assert JEV_API_URL == 'https://api.typesafe.ai/v1/systemone'

assert JEV_API_URL == 'https://api.typesafe.ai/v1/systemone'

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

async def _sent_state(self, classifier):         classifier.set_agents(mock_agents())         with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

classifier.set_agents(mock_agents())         with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \                 as mock_urlopen:

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

with patch('urllib.request.urlopen') as mock_urlopen:

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)):

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)):

with patch('urllib.request.urlopen', return_value=ok_response(payload)):

@pytest.mark.asyncio     async def test_no_agents_registered_raises_before_network_call(self):         with patch('urllib.request.urlopen') as mock_urlopen:

async def test_no_agents_registered_raises_before_network_call(self):         with patch('urllib.request.urlopen') as mock_urlopen:             with pytest.raises(ValueError, match="No agents registered"):

with patch('urllib.request.urlopen') as mock_urlopen:

with patch('urllib.request.urlopen', return_value=ok_response(payload)):

with patch('urllib.request.urlopen',

with patch('urllib.request.urlopen', side_effect=[

with patch('urllib.request.urlopen', side_effect=[

with patch('urllib.request.urlopen',

with patch('urllib.request.urlopen', side_effect=[

with patch('urllib.request.urlopen',

with patch('urllib.request.urlopen',

with patch('urllib.request.urlopen', side_effect=TimeoutError('timed out')):

with patch('urllib.request.urlopen',

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

base_url='https://gateway.example.com/v1/systemone',

with patch('urllib.request.urlopen', return_value=ok_response(CHOICE_PAYLOAD)) \

request = mock_urlopen.call_args[0][0]         assert request.full_url == 'https://gateway.example.com/v1/systemone'

assert request.full_url == 'https://gateway.example.com/v1/systemone'

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

module, _ = dakera_client     monkeypatch.setenv("DAKERA_API_KEY", "dk-env")     monkeypatch.setenv("DAKERA_URL", "http://env-host:9999")

[Credential-related source omitted]

[Credential-related source omitted]

monkeypatch.setenv("DAKERA_URL", "http://env-host:9999")

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

cfg = MCPServerConfig(type="stdio", command="uvx", args=["my-server"])     else:         cfg = MCPServerConfig(type="sse", url="http://localhost:3000/sse")

cfg = MCPServerConfig(type="sse", url="http://localhost:3000/sse")

provider = MCPToolProvider(         [MCPServerConfig(type="sse", url="http://localhost:9000/sse")]

[MCPServerConfig(type="sse", url="http://localhost:9000/sse")]

assert "search" in provider._tool_map     mock_mcp_modules["sse_client"].assert_called_once_with(         "http://localhost:9000/sse", headers={}

mock_mcp_modules["sse_client"].assert_called_once_with(         "http://localhost:9000/sse", headers={}     )

"http://localhost:9000/sse", headers={}

[MCPServerConfig(             type="streamable-http",             url="http://localhost:9000/mcp",

[Credential-related source omitted]

url="http://localhost:9000/mcp",

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

provider = MCPToolProvider(         [MCPServerConfig(type="streamable-http", url="http://localhost:9000/mcp")]

[MCPServerConfig(type="streamable-http", url="http://localhost:9000/mcp")]

tool = _make_mcp_tool_v2("search", "Search")     provider = MCPToolProvider([         MCPServerConfig(type="streamable-http", url="http://h/mcp", headers={"x-k": "v"})

provider = MCPToolProvider([         MCPServerConfig(type="streamable-http", url="http://h/mcp", headers={"x-k": "v"})     ])

MCPServerConfig(type="streamable-http", url="http://h/mcp", headers={"x-k": "v"})

http_client = mock_mcp_v2_modules["create_mcp_http_client"].return_value     mock_mcp_v2_modules["streamable_http_client"].assert_called_once_with(         "http://h/mcp", http_client=http_client

mock_mcp_v2_modules["streamable_http_client"].assert_called_once_with(         "http://h/mcp", http_client=http_client     )

"http://h/mcp", http_client=http_client

provider = MCPToolProvider([         MCPServerConfig(type="streamable-http", url="http://h/mcp", headers={"x-k": "v"})

MCPServerConfig(type="streamable-http", url="http://h/mcp", headers={"x-k": "v"})

Executable file

Executable file

Executable file

<p align="center">   <img alt="Swift" src="https://img.shields.io/badge/Swift-6.2%2B-orange.svg?style=flat-square">

<img alt="Swift" src="https://img.shields.io/badge/Swift-6.2%2B-orange.svg?style=flat-square">

<img alt="Platforms" src="https://img.shields.io/badge/platforms-iOS%2016%20%C2%B7%20macOS%2014-blue.svg?style=flat-square">

<img alt="Status" src="https://img.shields.io/badge/status-WIP-yellow.svg?style=flat-square">

platforms: [.macOS(.v14)],     dependencies: [         .package(url: "https://github.com/2FastLabs/agent-squad", branch: "main")

dependencies: [         .package(url: "https://github.com/2FastLabs/agent-squad", branch: "main")     ],

.package(url: "https://github.com/2FastLabs/agent-squad", branch: "main")

[Credential-related source omitted]

[Credential-related source omitted]

|---|---|---|---| | **`AgentSquad`** (core) | `import AgentSquad` | **nothing external** | protocols, agents, orchestrator, native tools (`ToolKit`, `Tool.local`/`.http`, `HTTPToolGroup`, `AggregateToolProvider`), `DakeraRetriever` (Dakera 

| **`AgentSquad`** (core) | `import AgentSquad` | **nothing external** | protocols, agents, orchestrator, native tools (`ToolKit`, `Tool.local`/`.http`, `HTTPToolGroup`, `AggregateToolProvider`), `DakeraRetriever` (Dakera memory retriever),

| **`AgentSquadMCP`** | `import AgentSquadMCP` | the official [MCP Swift SDK](https://github.com/modelcontextprotocol/swift-sdk) | `MCPServer` (alias of `MCPToolProvider`) — connect any MCP server with `MCPServer(url:)`, with MCP Apps UI su

SwiftPM: `.package(url: "https://github.com/2FastLabs/agent-squad", branch: "main")`.

config once, then one line per endpoint; **`MCPServer(url:)`** connects an MCP server; and   **`AggregateToolProvider`** composes any mix behind one seam; **`DakeraRetriever(namespace:…)`** is a   `ToolProvider` backed by a self-hosted [Dak

**`AggregateToolProvider`** composes any mix behind one seam; **`DakeraRetriever(namespace:…)`** is a   `ToolProvider` backed by a self-hosted [Dakera](https://dakera.ai) memory server — it exposes a   `search_memory` tool for grounding (an

`ToolProvider` backed by a self-hosted [Dakera](https://dakera.ai) memory server — it exposes a

public init(         baseURL: URL = URL(string: "https://api.openai.com/v1")!,

baseURL: URL = URL(string: "https://api.openai.com/v1")!,

/// A persistent store must pin a stable `JSONEncoder.dateEncodingStrategy` (see `ConversationMessage.timestamp`). public protocol ChatStorage: Sendable {     func fetch(

public protocol ChatStorage: Sendable {     func fetch(         userId: String,

func fetch(

/// Join `baseURL` and `path`, normalizing trailing/leading slashes so the result always has     /// exactly one separator (e.g. avoids `"https://api.test//users"` or `"https://api.testusers"`).

/// exactly one separator (e.g. avoids `"https://api.test//users"` or `"https://api.testusers"`).

do {             let agent = try await selectAgent(input, userId: userId, sessionId: sessionId)             let history = try await store.fetch(userId: userId, sessionId: sessionId, agentId: agent.id, maxMessages: maxMessages)

let agent = try await selectAgent(input, userId: userId, sessionId: sessionId)             let history = try await store.fetch(userId: userId, sessionId: sessionId, agentId: agent.id, maxMessages: maxMessages)             // Stamped before 

let history = try await store.fetch(userId: userId, sessionId: sessionId, agentId: agent.id, maxMessages: maxMessages)

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

/// Base URL of the Dakera server. Falls back to `DAKERA_URL`, then `http://localhost:3000`

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

self.url = url ?? ProcessInfo.processInfo.environment["DAKERA_URL"] ?? "http://localhost:3000"

[Credential-related source omitted]

/// Retriever backed by a self-hosted [Dakera](https://dakera.ai) memory server. /// /// It uses Dakera's text-query endpoint (server-side embedding) to fetch the documents most

func seedHistory() async {         guard let store else { return }         let history = (try? await store.fetch(userId: userId, sessionId: sessionId,

guard let store else { return }         let history = (try? await store.fetch(userId: userId, sessionId: sessionId,                                               agentId: slugify(name), maxMessages: maxMessages)) ?? []

let history = (try? await store.fetch(userId: userId, sessionId: sessionId,

public func fetch(

sortBy: [SortDescriptor(\.timestamp), SortDescriptor(\.seq)]         )         return try modelContext.fetch(descriptor).map { row in

)         return try modelContext.fetch(descriptor).map { row in             try decode(row.payload).attributed(agentId: row.agentId)

return try modelContext.fetch(descriptor).map { row in

sortBy: [SortDescriptor(\.seq)]         )         return try modelContext.fetch(descriptor)

)         return try modelContext.fetch(descriptor)     }

return try modelContext.fetch(descriptor)

)         descriptor.fetchLimit = 1         return try modelContext.fetch(descriptor).first?.role

descriptor.fetchLimit = 1         return try modelContext.fetch(descriptor).first?.role     }

return try modelContext.fetch(descriptor).first?.role

var descriptor = FetchDescriptor<StoredMessage>(sortBy: [SortDescriptor(\.seq, order: .reverse)])         descriptor.fetchLimit = 1         return (try modelContext.fetch(descriptor).first?.seq ?? 0) + 1

descriptor.fetchLimit = 1         return (try modelContext.fetch(descriptor).first?.seq ?? 0) + 1     }

return (try modelContext.fetch(descriptor).first?.seq ?? 0) + 1

public func fetch(

public func fetch(

public func fetch(

// Cold start: load raw history from the base store.         let history = try await base.fetch(

let history = try await base.fetch(

public func fetch(

userId: String, sessionId: String, agentId: String, maxMessages: Int?     ) async throws -> [ConversationMessage] {         try await base.fetch(userId: userId, sessionId: sessionId, agentId: agentId, maxMessages: maxMessages)

) async throws -> [ConversationMessage] {         try await base.fetch(userId: userId, sessionId: sessionId, agentId: agentId, maxMessages: maxMessages)     }

try await base.fetch(userId: userId, sessionId: sessionId, agentId: agentId, maxMessages: maxMessages)

extension MCPToolProvider {     /// Connect to an MCP server at the given URL string: `MCPServer(url: "https://…")`. An invalid

/// Connect to an MCP server at the given URL string: `MCPServer(url: "https://…")`. An invalid

// connecting — the one-liner the consumer wants instead of nesting `SDKMCPClient`. The string         // form parses the URL internally.         let viaString: any ToolProvider = MCPServer(url: "https://example.test/mcp",

// form parses the URL internally.         let viaString: any ToolProvider = MCPServer(url: "https://example.test/mcp",                                                     hostArguments: ["session_id": .string("S1")])

let viaString: any ToolProvider = MCPServer(url: "https://example.test/mcp",

// Compile-time + construction smoke: both URL overloads accept headers and forward them.         let viaString: any ToolProvider = MCPServer(             url: "https://example.test/mcp",

[Credential-related source omitted]

url: "https://example.test/mcp",

let viaURL: any ToolProvider = MCPServer(             url: URL(string: "https://example.test/mcp")!,

url: URL(string: "https://example.test/mcp")!,

let client = SDKMCPClient(             endpoint: URL(string: "https://example.test/mcp")!,

endpoint: URL(string: "https://example.test/mcp")!,

callResults: ["link": MCPCallResult(), "blobbed": MCPCallResult()],             resources: [                 "ui://link": MCPResourceContents(mimeType: "text/uri-list", text: "https://example.com/widget"),

resources: [                 "ui://link": MCPResourceContents(mimeType: "text/uri-list", text: "https://example.com/widget"),                 "ui://blob": MCPResourceContents(mimeType: "text/html;profile=mcp-app", blob: Data("<b/>".utf8)),

"ui://link": MCPResourceContents(mimeType: "text/uri-list", text: "https://example.com/widget"),

let provider = MCPToolProvider(client: mock)         _ = try await provider.listTools()         #expect(try await provider.call("link", arguments: .object([:])).ui?.template == .url(URL(string: "https://example.com/widget")!))

_ = try await provider.listTools()         #expect(try await provider.call("link", arguments: .object([:])).ui?.template == .url(URL(string: "https://example.com/widget")!))         #expect(try await provider.call("blobbed", arguments: .obj

#expect(try await provider.call("link", arguments: .object([:])).ui?.template == .url(URL(string: "https://example.com/widget")!))

@Test func joinsBaseURLPathWithOrWithoutTrailingSlash() async throws {         for base in ["https://host/v1", "https://host/v1/"] {

for base in ["https://host/v1", "https://host/v1/"] {

let client = ChatCompletionsClient(baseURL: URL(string: base)!, model: "gpt", transport: transport)             _ = try await collect(client)             #expect(transport.requests.first?.url?.absoluteString == "https://host/v1/chat/complet

_ = try await collect(client)             #expect(transport.requests.first?.url?.absoluteString == "https://host/v1/chat/completions")         }

#expect(transport.requests.first?.url?.absoluteString == "https://host/v1/chat/completions")

// Minimal conformer so the protocol-extension defaults can be exercised without a backend.     private struct StubStore: ChatStorage {         func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -

private struct StubStore: ChatStorage {         func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { [] }         func save(_ message: ConversationMessage, userId: String,

func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { [] }

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

let request = invoker.request         #expect(request?.httpMethod == "POST")         #expect(request?.url?.absoluteString == "http://localhost:3000/v1/namespaces/agent-mem/query-text")

#expect(request?.httpMethod == "POST")         #expect(request?.url?.absoluteString == "http://localhost:3000/v1/namespaces/agent-mem/query-text")         #expect(request?.value(forHTTPHeaderField: "X-API-Key") == "dk-test")

#expect(request?.url?.absoluteString == "http://localhost:3000/v1/namespaces/agent-mem/query-text")

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

)         _ = try await retriever.retrieve("q")         #expect(invoker.request?.url?.absoluteString == "http://host:3000/v1/namespaces/ns/query-text")

_ = try await retriever.retrieve("q")         #expect(invoker.request?.url?.absoluteString == "http://host:3000/v1/namespaces/ns/query-text")     }

#expect(invoker.request?.url?.absoluteString == "http://host:3000/v1/namespaces/ns/query-text")

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

}         let second = try DeviceChatStorage(userId: "u", baseURL: dir)         let fetched = try await second.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

let second = try DeviceChatStorage(userId: "u", baseURL: dir)         let fetched = try await second.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         #expect(fetched.map(\.parts) == [[.text("persist me")]])

let fetched = try await second.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

try await store.save(.init(role: .user, text: "one"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         try await store.save(.init(role: .user, text: "two"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)  /

try await store.save(.init(role: .user, text: "two"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)  // dropped         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

try await store.save(.init(role: role, text: "\(index)"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 3)         }         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

}         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         #expect(fetched.map(\.parts) == [[.text("3")], [.text("4")]])   // last even-count, most recent

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

let sports = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

@Test func fetchMissingReturnsEmpty() async throws {         let store = try DeviceChatStorage(userId: "u", inMemory: true)         let fetched = try await store.fetch(userId: "u", sessionId: "none", agentId: "x", maxMessages: 100)

let store = try DeviceChatStorage(userId: "u", inMemory: true)         let fetched = try await store.fetch(userId: "u", sessionId: "none", agentId: "x", maxMessages: 100)         #expect(fetched.isEmpty)

let fetched = try await store.fetch(userId: "u", sessionId: "none", agentId: "x", maxMessages: 100)

try await store.save(.init(role: .user, text: "hi"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         try await store.clear()         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMess

try await store.clear()         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         #expect(fetched.isEmpty)

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

let second = FileChatStorage(baseURL: dir)         let fetched = try await second.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

let fetched = try await second.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

try await store.save(.init(role: .user, text: "one"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         try await store.save(.init(role: .user, text: "two"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)  /

try await store.save(.init(role: .user, text: "two"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)  // dropped         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

try await store.save(.init(role: role, text: "\(index)"), userId: "u", sessionId: "s", agentId: "a", maxMessages: 3)         }         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

}         let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)         #expect(fetched.map(\.parts) == [[.text("3")], [.text("4")]])   // last even-count, most recent

let fetched = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 100)

let sports = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

let a = try await store.fetch(userId: "u", sessionId: "matchA", agentId: "companion", maxMessages: 100)

let b = try await store.fetch(userId: "u", sessionId: "matchB", agentId: "companion", maxMessages: 100)

let fetched = try await store.fetch(userId: "u", sessionId: "none", agentId: "x", maxMessages: 100)

try await store.save(.init(role: .user, text: "ok"), userId: "a/b", sessionId: "x/y", agentId: "c d", maxMessages: 100)         let fetched = try await store.fetch(userId: "a/b", sessionId: "x/y", agentId: "c d", maxMessages: 100)

let fetched = try await store.fetch(userId: "a/b", sessionId: "x/y", agentId: "c d", maxMessages: 100)

@Test func templateKeysAreExtractedInOrder() {         #expect(HTTPToolSpec.templateKeys(in: "https://api/{a}/x/{b}") == ["a", "b"])

#expect(HTTPToolSpec.templateKeys(in: "https://api/{a}/x/{b}") == ["a", "b"])

#expect(HTTPToolSpec.templateKeys(in: "https://api/none").isEmpty)

@Test func pathTemplatingFillsAndConsumesArgs() throws {         let spec = HTTPToolSpec(method: .get, url: "https://api.test/odds/{matchId}")

let spec = HTTPToolSpec(method: .get, url: "https://api.test/odds/{matchId}")

@Test func pathPlaceholderEncodesSlash() throws {         // A value containing '/' must not create extra path segments.         let spec = HTTPToolSpec(method: .get, url: "https://api.test/users/{id}/profile")

// A value containing '/' must not create extra path segments.         let spec = HTTPToolSpec(method: .get, url: "https://api.test/users/{id}/profile")         let request = try spec.makeRequest(arguments: ["id": "foo/bar"])

let spec = HTTPToolSpec(method: .get, url: "https://api.test/users/{id}/profile")

@Test func queryPlaceholderEncodesDelimiters() throws {         // A value containing '&' or '=' must not create extra query parameters.         let spec = HTTPToolSpec(method: .get, url: "https://api.test/search?q={query}")

// A value containing '&' or '=' must not create extra query parameters.         let spec = HTTPToolSpec(method: .get, url: "https://api.test/search?q={query}")         let request = try spec.makeRequest(arguments: ["query": "a&b=c"])

let spec = HTTPToolSpec(method: .get, url: "https://api.test/search?q={query}")

@Test func postSendsJSONBodyWithContentType() throws {         let spec = HTTPToolSpec(method: .post, url: "https://api.test/bets")

let spec = HTTPToolSpec(method: .post, url: "https://api.test/bets")

let spec = HTTPToolSpec(             method: .get,             url: "https://api.test/x",

method: .get,             url: "https://api.test/x",             headers: ["Accept": "application/json"],

url: "https://api.test/x",

// baseURL trailing '/' + path leading '/' must not produce a double slash.         let invoker = MockInvoker(status: 200, body: "{}")         let group = HTTPToolGroup(baseURL: "https://api.test/", invoker: invoker)

let invoker = MockInvoker(status: 200, body: "{}")         let group = HTTPToolGroup(baseURL: "https://api.test/", invoker: invoker)         let tool = group.get("users", "/users", "")

let group = HTTPToolGroup(baseURL: "https://api.test/", invoker: invoker)

let tool = group.get("users", "/users", "")         _ = try await tool.run(.object([:]))         #expect(invoker.request?.url?.absoluteString == "https://api.test/users")

_ = try await tool.run(.object([:]))         #expect(invoker.request?.url?.absoluteString == "https://api.test/users")     }

#expect(invoker.request?.url?.absoluteString == "https://api.test/users")

// Neither baseURL nor path has a separator — a '/' must be inserted.         let invoker = MockInvoker(status: 200, body: "{}")         let group = HTTPToolGroup(baseURL: "https://api.test", invoker: invoker)

let invoker = MockInvoker(status: 200, body: "{}")         let group = HTTPToolGroup(baseURL: "https://api.test", invoker: invoker)         let tool = group.get("items", "items", "")

let group = HTTPToolGroup(baseURL: "https://api.test", invoker: invoker)

let tool = group.get("items", "items", "")         _ = try await tool.run(.object([:]))         #expect(invoker.request?.url?.absoluteString == "https://api.test/items")

_ = try await tool.run(.object([:]))         #expect(invoker.request?.url?.absoluteString == "https://api.test/items")     }

#expect(invoker.request?.url?.absoluteString == "https://api.test/items")

spec: HTTPToolSpec(                 method: .get,                 url: "https://api.test/odds/{matchId}",

method: .get,                 url: "https://api.test/odds/{matchId}",                 hostArguments: ["session_id": "s-1"],

url: "https://api.test/odds/{matchId}",

name: "weather",             description: "",             spec: HTTPToolSpec(method: .get, url: "https://api.test/weather", invoker: invoker)

description: "",             spec: HTTPToolSpec(method: .get, url: "https://api.test/weather", invoker: invoker)         )

spec: HTTPToolSpec(method: .get, url: "https://api.test/weather", invoker: invoker)

@Test func emptyByDefault() async throws {         let store = InMemoryChatStorage()         #expect(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil).isEmpty)

let store = InMemoryChatStorage()         #expect(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil).isEmpty)     }

#expect(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil).isEmpty)

// The point of the type: hand it a conversation at init and a consumer fetches it as history.         let store = InMemoryChatStorage([user("what are the odds?"), assistant("PSG 2.5")])         let history = try await store.fetch(userId: "

let store = InMemoryChatStorage([user("what are the odds?"), assistant("PSG 2.5")])         let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(history) == ["what are the od

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

// without knowing the consumer's agentId.         let store = InMemoryChatStorage([user("hi"), assistant("hello")])         let a = try await store.fetch(userId: "u1", sessionId: "s1", agentId: "agent-x", maxMessages: nil)

let store = InMemoryChatStorage([user("hi"), assistant("hello")])         let a = try await store.fetch(userId: "u1", sessionId: "s1", agentId: "agent-x", maxMessages: nil)         let b = try await store.fetch(userId: "u2", sessionId: "s2"

let a = try await store.fetch(userId: "u1", sessionId: "s1", agentId: "agent-x", maxMessages: nil)

let b = try await store.fetch(userId: "u2", sessionId: "s2", agentId: "agent-y", maxMessages: nil)

let store = InMemoryChatStorage([user("q1"), assistant("a1")])         try await store.saveMessages([user("q2"), assistant("a2")], userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(try await store.fetch(user

try await store.saveMessages([user("q2"), assistant("a2")], userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q1", "a1

#expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q1", "a1", "q2", "a2"])

// Last stored is .assistant; a second .assistant save is dropped to keep roles alternating.         try await store.save(assistant("a1-dup"), userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(try await stor

try await store.save(assistant("a1-dup"), userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q1", "a1"])     }

#expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q1", "a1"])

let store = InMemoryChatStorage([user("q1"), assistant("a1"), user("q2"), assistant("a2")])         // maxMessages counts messages, rounding down to an even pair — keep the most recent 2.         let history = try await store.fetch(userId: 

// maxMessages counts messages, rounding down to an even pair — keep the most recent 2.         let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 2)         #expect(texts(history) == ["q2", "a2"])

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 2)

let store = InMemoryChatStorage(seed)         try await store.saveMessages([user("q4"), assistant("a4")], userId: "u", sessionId: "s", agentId: "a", maxMessages: 4)         #expect((try await store.fetch(userId: "u", sessionId: "s", agentId

try await store.saveMessages([user("q4"), assistant("a4")], userId: "u", sessionId: "s", agentId: "a", maxMessages: 4)         #expect((try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 4)).count == 4)    // view

#expect((try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: 4)).count == 4)    // view is trimmed…

#expect((try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)).count == 8)  // …but all 8 are kept

private let endpoint = URL(string: "https://collector.example/v1/traces")!

let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

let agent = Agent(name: "sports", model: MockLLMClient([.textDelta("hi"), .done(reason: .stop, usage: nil)]), saveChat: false)         _ = try await collect(Orchestrator(agents: [agent], store: store).route(.text("q"), userId: "u", sessionI

_ = try await collect(Orchestrator(agents: [agent], store: store).route(.text("q"), userId: "u", sessionId: "s"))         let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)         #expec

let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

try await run("q1")         try await run("q2")         let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

try await run("q2")         let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)         #expect(persisted.map(\.role) == [.user, .assistant, .user, .assistant])

let persisted = try await store.fetch(userId: "u", sessionId: "s", agentId: "sports", maxMessages: 100)

init(seed: [ConversationMessage] = []) { self.seed = seed }     var saved: [ConversationMessage] { lock.withLock { _saved } }     func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [Conversatio

var saved: [ConversationMessage] { lock.withLock { _saved } }     func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { seed }     func save(_ message: ConversationMessage,

func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { seed }

func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] {

let result = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let result = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let result = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

// Activate the buffer.         _ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

// Fetch from buffer — must contain the saved message.         let result = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let result = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

// Activate buffer with first summarization (callCount → 1).         _ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

// Activate buffer.         _ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

_ = try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

await #expect(throws: SummarizationFailed.self) {             try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

try await storage.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let invoker = RecordingInvoker(status: 200, body: #"{"ok":true}"#)         let tool = Tool.get(             "search", "https://api.test/search", "Search.",

let tool = Tool.get(             "search", "https://api.test/search", "Search.",             .string("q", required: true),

"search", "https://api.test/search", "Search.",

let invoker = RecordingInvoker(status: 200, body: "{}")         let api = HTTPToolGroup(             baseURL: "https://api.test",

let api = HTTPToolGroup(             baseURL: "https://api.test",             headers: ["X-Match-Id": "42"],

baseURL: "https://api.test",

_ = try await tool.run(["matchId": "777"])         #expect(invoker.request?.url?.absoluteString.contains("https://api.test/odds/777") == true)

#expect(invoker.request?.url?.absoluteString.contains("https://api.test/odds/777") == true)

// Group default would treat the body as success; the per-call override flags it as an error.         let invoker = RecordingInvoker(status: 200, body: #"{"error_code":"NOPE","error":"bad"}"#)         let api = HTTPToolGroup(baseURL: "https

let invoker = RecordingInvoker(status: 200, body: #"{"error_code":"NOPE","error":"bad"}"#)         let api = HTTPToolGroup(baseURL: "https://api.test", invoker: invoker)         let tool = api.get("x", "/x", "X.", response: .jsonEnvelopeErr

let api = HTTPToolGroup(baseURL: "https://api.test", invoker: invoker)

@Test func outputSchemaIsCarriedButNotInInput() {         let out: JSONValue = ["type": "object", "properties": ["sum": ["type": "integer"]]]         let tool = Tool.get("add", "https://api.test/add", "Add.", .integer("a", required: true), 

let out: JSONValue = ["type": "object", "properties": ["sum": ["type": "integer"]]]         let tool = Tool.get("add", "https://api.test/add", "Add.", .integer("a", required: true), outputSchema: out)         #expect(tool.definition.outputS

let tool = Tool.get("add", "https://api.test/add", "Add.", .integer("a", required: true), outputSchema: out)

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

private actor SpyStorage: ChatStorage {         private(set) var saveBatches: [[ConversationMessage]] = []         func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { [] 

private(set) var saveBatches: [[ConversationMessage]] = []         func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { [] }         func save(_ message: ConversationMessa

func fetch(userId: String, sessionId: String, agentId: String, maxMessages: Int?) async throws -> [ConversationMessage] { [] }

userId: "u", sessionId: "s", agentId: "a", maxMessages: nil         )         let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

)         let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)         #expect(texts(history) == ["pay [IBAN] or [CARD], mail [EMAIL]"])

let history = try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)

let store = TransformingChatStorage(wrapping: InMemoryChatStorage([user("q"), assistant("a")])) { _ in nil }         // A drop-everything transform must not affect what fetch/fetchAllChats return.         #expect(texts(try await store.fetch

// A drop-everything transform must not affect what fetch/fetchAllChats return.         #expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q", "a"])         #expect(texts(try await store.f

#expect(texts(try await store.fetch(userId: "u", sessionId: "s", agentId: "a", maxMessages: nil)) == ["q", "a"])

[Credential-related source omitted]

<p align="center">   <a href="https://github.com/2fastlabs/agent-squad"><img alt="GitHub Repo" src="https://img.shields.io/badge/GitHub-Repo-green.svg" /></a>

<a href="https://github.com/2fastlabs/agent-squad"><img alt="GitHub Repo" src="https://img.shields.io/badge/GitHub-Repo-green.svg" /></a>

<a href="https://www.npmjs.com/package/agent-squad"><img alt="npm" src="https://img.shields.io/npm/v/agent-squad.svg?style=flat-square"></a>

<a href="https://2fastlabs.github.io/agent-squad/"><img alt="Documentation" src="https://img.shields.io/badge/docs-book-blue.svg?style=flat-square"></a>

<p align="center">   <!-- GitHub Stats -->   <img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">

<!-- GitHub Stats -->   <img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">   <img src="https://img.shields.io/github/forks/2fastlabs/agent-squad?style=social" alt="GitHub forks">

<img src="https://img.shields.io/github/stars/2fastlabs/agent-squad?style=social" alt="GitHub stars">

<img src="https://img.shields.io/github/forks/2fastlabs/agent-squad?style=social" alt="GitHub forks">

<img src="https://img.shields.io/github/watchers/2fastlabs/agent-squad?style=social" alt="GitHub watchers">

<p align="center">   <!-- Repository Info -->   <img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">

<!-- Repository Info -->   <img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">   <img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">

<img src="https://img.shields.io/github/last-commit/2fastlabs/agent-squad" alt="Last Commit">   <img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">   <img src="https://img.shields.io/github/issues-pr/2fastlab

<img src="https://img.shields.io/github/issues/2fastlabs/agent-squad" alt="Issues">   <img src="https://img.shields.io/github/issues-pr/2fastlabs/agent-squad" alt="Pull Requests"> </p>

<img src="https://img.shields.io/github/issues-pr/2fastlabs/agent-squad" alt="Pull Requests">

<p align="center">   <!-- Package Stats -->   <a href="https://www.npmjs.com/package/agent-squad"><img src="https://img.shields.io/npm/dm/agent-squad?label=npm%20downloads" alt="npm Monthly Downloads"></a>

<!-- Package Stats -->   <a href="https://www.npmjs.com/package/agent-squad"><img src="https://img.shields.io/npm/dm/agent-squad?label=npm%20downloads" alt="npm Monthly Downloads"></a> </p>

<a href="https://www.npmjs.com/package/agent-squad"><img src="https://img.shields.io/npm/dm/agent-squad?label=npm%20downloads" alt="npm Monthly Downloads"></a>

Route requests with [Jev](https://docs.typesafe.ai/introduction), TypeSafe AI's decision model, instead of an LLM. Your agents become a typed `choice` question, and Jev returns the chosen agent plus a calibrated confidence. There's no outpu

[Credential-related source omitted]

[JevClassifier docs](https://2fastlabs.github.io/agent-squad/classifiers/built-in/jev-classifier) · [demos](https://github.com/2fastlabs/agent-squad/tree/main/examples/jev-demo/typescript)

![High-level architecture flow diagram](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/img/flow.jpg)

To quickly get a feel for the Agent Squad, we've provided a Demo App with a few basic agents. This interactive demo showcases the orchestrator's capabilities in a user-friendly interface. To learn more about setting up and running the demo 

![](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/img/demo-app.gif?raw=true)

Check out our [documentation](https://2fastlabs.github.io/agent-squad/) for comprehensive guides on setting up and using the Agent Squad!

We welcome contributions! Please see our [Contributing Guide](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/CONTRIBUTING.md) for more details.

This project is licensed under the Apache 2.0 licence - see the [LICENSE](https://raw.githubusercontent.com/2fastlabs/agent-squad/main/LICENSE) file for details.

## 📄 Font License This project uses the JetBrainsMono NF font, licensed under the SIL Open Font License 1.1. For full license details, see [FONT-LICENSE.md](https://github.com/JetBrains/JetBrainsMono/blob/master/OFL.txt).

For full license details, see [FONT-LICENSE.md](https://github.com/JetBrains/JetBrainsMono/blob/master/OFL.txt).

[Credential-related source omitted]

[Credential-related source omitted]

`url?` (falls back to `DAKERA_URL` then `http://localhost:3000`), `topK?` (default 10), `filter?`.

[Credential-related source omitted]

[Credential-related source omitted]

[Credential-related source omitted]

Executable file

Executable file

{           "type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"

"type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"         }

"url": "https://github.com/sponsors/NaturalIntelligence"

{           "type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"

"type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"         }

"url": "https://github.com/sponsors/NaturalIntelligence"

{           "type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"

"type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"         }

"url": "https://github.com/sponsors/NaturalIntelligence"

{           "type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"

"type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"         }

"url": "https://github.com/sponsors/NaturalIntelligence"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/babel"

"type": "opencollective",         "url": "https://opencollective.com/babel"       }

"url": "https://opencollective.com/babel"

"node_modules/@dakera-ai/dakera": {       "version": "0.11.102",       "resolved": "https://registry.npmjs.org/@dakera-ai/dakera/-/dakera-0.11.102.tgz",

"version": "0.11.102",       "resolved": "https://registry.npmjs.org/@dakera-ai/dakera/-/dakera-0.11.102.tgz",       "integrity": "sha512-7jhUFBWx6vn/l8xMbmbCYxHra77YnoE/YjMkWMzAtGd1g28xUWsHE3Ax5/5D3Xm7NqFMD7lpSTZxttg7v4rH8w==",

"resolved": "https://registry.npmjs.org/@dakera-ai/dakera/-/dakera-0.11.102.tgz",

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       },

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://eslint.org/donate"

"funding": {         "url": "https://eslint.org/donate"       }

"url": "https://eslint.org/donate"

"funding": {         "type": "github",         "url": "https://github.com/sponsors/nzakas"

"type": "github",         "url": "https://github.com/sponsors/nzakas"       }

"url": "https://github.com/sponsors/nzakas"

"funding": {         "type": "github",         "url": "https://github.com/sponsors/nzakas"

"type": "github",         "url": "https://github.com/sponsors/nzakas"       }

"url": "https://github.com/sponsors/nzakas"

"node_modules/@libsql/darwin-x64": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/darwin-x64/-/darwin-x64-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/darwin-x64/-/darwin-x64-0.4.7.tgz",       "integrity": "sha512-ezc7V75+eoyyH07BO9tIyJdqXXcRfZMbKcLCeF8+qWK5nP8wWuMcfOVywecsXGRbT99zc5eNra4NEx6z5PkSsA==",

"resolved": "https://registry.npmjs.org/@libsql/darwin-x64/-/darwin-x64-0.4.7.tgz",

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/node-fetch"

"type": "opencollective",         "url": "https://opencollective.com/node-fetch"       }

"url": "https://opencollective.com/node-fetch"

"node_modules/@libsql/linux-arm64-gnu": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-arm64-gnu/-/linux-arm64-gnu-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-arm64-gnu/-/linux-arm64-gnu-0.4.7.tgz",       "integrity": "sha512-WlX2VYB5diM4kFfNaYcyhw5y+UJAI3xcMkEUJZPtRDEIu85SsSFrQ+gvoKfcVh76B//ztSeEX2wl9yrjF7BBCA==",

"resolved": "https://registry.npmjs.org/@libsql/linux-arm64-gnu/-/linux-arm64-gnu-0.4.7.tgz",

"node_modules/@libsql/linux-arm64-musl": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-arm64-musl/-/linux-arm64-musl-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-arm64-musl/-/linux-arm64-musl-0.4.7.tgz",       "integrity": "sha512-6kK9xAArVRlTCpWeqnNMCoXW1pe7WITI378n4NpvU5EJ0Ok3aNTIC2nRPRjhro90QcnmLL1jPcrVwO4WD1U0xw==",

"resolved": "https://registry.npmjs.org/@libsql/linux-arm64-musl/-/linux-arm64-musl-0.4.7.tgz",

"node_modules/@libsql/linux-x64-gnu": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-x64-gnu/-/linux-x64-gnu-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-x64-gnu/-/linux-x64-gnu-0.4.7.tgz",       "integrity": "sha512-CMnNRCmlWQqqzlTw6NeaZXzLWI8bydaXDke63JTUCvu8R+fj/ENsLrVBtPDlxQ0wGsYdXGlrUCH8Qi9gJep0yQ==",

"resolved": "https://registry.npmjs.org/@libsql/linux-x64-gnu/-/linux-x64-gnu-0.4.7.tgz",

"node_modules/@libsql/linux-x64-musl": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-x64-musl/-/linux-x64-musl-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/linux-x64-musl/-/linux-x64-musl-0.4.7.tgz",       "integrity": "sha512-nI6tpS1t6WzGAt1Kx1n1HsvtBbZ+jHn0m7ogNNT6pQHZQj7AFFTIMeDQw/i/Nt5H38np1GVRNsFe99eSIMs9XA==",

"resolved": "https://registry.npmjs.org/@libsql/linux-x64-musl/-/linux-x64-musl-0.4.7.tgz",

"node_modules/@libsql/win32-x64-msvc": {       "version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/win32-x64-msvc/-/win32-x64-msvc-0.4.7.tgz",

"version": "0.4.7",       "resolved": "https://registry.npmjs.org/@libsql/win32-x64-msvc/-/win32-x64-msvc-0.4.7.tgz",       "integrity": "sha512-7pJzOWzPm6oJUxml+PCDRzYQ4A1hTMHAciTAHfFK4fkbDZX33nWPVG7Y3vqdKtslcwAzwmrNDc6sXy2nwWnbiw==",

"resolved": "https://registry.npmjs.org/@libsql/win32-x64-msvc/-/win32-x64-msvc-0.4.7.tgz",

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       }

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       }

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

},       "funding": {         "url": "https://github.com/sponsors/isaacs"

"funding": {         "url": "https://github.com/sponsors/isaacs"       }

"url": "https://github.com/sponsors/isaacs"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       },

"url": "https://opencollective.com/typescript-eslint"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"

"type": "opencollective",         "url": "https://opencollective.com/typescript-eslint"       }

"url": "https://opencollective.com/typescript-eslint"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

"funding": {         "type": "github",         "url": "https://github.com/sponsors/wooorm"

"type": "github",         "url": "https://github.com/sponsors/wooorm"       }

"url": "https://github.com/sponsors/wooorm"

"funding": {         "type": "github",         "url": "https://github.com/sponsors/wooorm"

"type": "github",         "url": "https://github.com/sponsors/wooorm"       }

"url": "https://github.com/sponsors/wooorm"

"funding": {         "type": "github",         "url": "https://github.com/sponsors/epoberezkin"

"type": "github",         "url": "https://github.com/sponsors/epoberezkin"       }

"url": "https://github.com/sponsors/epoberezkin"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/chalk/ansi-styles?sponsor=1"

"funding": {         "url": "https://github.com/chalk/ansi-styles?sponsor=1"       }

"url": "https://github.com/chalk/ansi-styles?sponsor=1"

{           "type": "opencollective",           "url": "https://opencollective.com/browserslist"

"type": "opencollective",           "url": "https://opencollective.com/browserslist"         },

"url": "https://opencollective.com/browserslist"

{           "type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/browserslist"

"type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/browserslist"         },

"url": "https://tidelift.com/funding/github/npm/browserslist"

{           "type": "github",           "url": "https://github.com/sponsors/ai"

"type": "github",           "url": "https://github.com/sponsors/ai"         }

"url": "https://github.com/sponsors/ai"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

{           "type": "opencollective",           "url": "https://opencollective.com/browserslist"

"type": "opencollective",           "url": "https://opencollective.com/browserslist"         },

"url": "https://opencollective.com/browserslist"

{           "type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/caniuse-lite"

"type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/caniuse-lite"         },

"url": "https://tidelift.com/funding/github/npm/caniuse-lite"

{           "type": "github",           "url": "https://github.com/sponsors/ai"

"type": "github",           "url": "https://github.com/sponsors/ai"         }

"url": "https://github.com/sponsors/ai"

},       "funding": {         "url": "https://github.com/chalk/chalk?sponsor=1"

"funding": {         "url": "https://github.com/chalk/chalk?sponsor=1"       }

"url": "https://github.com/chalk/chalk?sponsor=1"

{           "type": "github",           "url": "https://github.com/sponsors/sibiraj-s"

"type": "github",           "url": "https://github.com/sponsors/sibiraj-s"         }

"url": "https://github.com/sponsors/sibiraj-s"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://dotenvx.com"

"funding": {         "url": "https://dotenvx.com"       }

"url": "https://dotenvx.com"

},       "funding": {         "url": "https://github.com/sindresorhus/emittery?sponsor=1"

"funding": {         "url": "https://github.com/sindresorhus/emittery?sponsor=1"       }

"url": "https://github.com/sindresorhus/emittery?sponsor=1"

},       "funding": {         "url": "https://eslint.org/donate"

"funding": {         "url": "https://eslint.org/donate"       },

"url": "https://eslint.org/donate"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://opencollective.com/eslint"

"funding": {         "url": "https://opencollective.com/eslint"       }

"url": "https://opencollective.com/eslint"

},       "funding": {         "url": "https://github.com/sindresorhus/execa?sponsor=1"

"funding": {         "url": "https://github.com/sindresorhus/execa?sponsor=1"       }

"url": "https://github.com/sindresorhus/execa?sponsor=1"

{           "type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"

"type": "github",           "url": "https://github.com/sponsors/NaturalIntelligence"         },

"url": "https://github.com/sponsors/NaturalIntelligence"

{           "type": "paypal",           "url": "https://paypal.me/naturalintelligence"

"type": "paypal",           "url": "https://paypal.me/naturalintelligence"         }

"url": "https://paypal.me/naturalintelligence"

{           "type": "github",           "url": "https://github.com/sponsors/jimmywarting"

"type": "github",           "url": "https://github.com/sponsors/jimmywarting"         },

"url": "https://github.com/sponsors/jimmywarting"

{           "type": "paypal",           "url": "https://paypal.me/jimmywarting"

"type": "paypal",           "url": "https://paypal.me/jimmywarting"         }

"url": "https://paypal.me/jimmywarting"

{           "type": "individual",           "url": "https://github.com/sponsors/RubenVerborgh"

"type": "individual",           "url": "https://github.com/sponsors/RubenVerborgh"         }

"url": "https://github.com/sponsors/RubenVerborgh"

"license": "MIT",       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/isaacs"

"funding": {         "url": "https://github.com/sponsors/isaacs"       }

"url": "https://github.com/sponsors/isaacs"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/chalk/supports-color?sponsor=1"

"funding": {         "url": "https://github.com/chalk/supports-color?sponsor=1"       }

"url": "https://github.com/chalk/supports-color?sponsor=1"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

"license": "MIT",       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/mongoose"

"type": "opencollective",         "url": "https://opencollective.com/mongoose"       }

"url": "https://opencollective.com/mongoose"

{           "type": "github",           "url": "https://github.com/sponsors/jimmywarting"

"type": "github",           "url": "https://github.com/sponsors/jimmywarting"         },

"url": "https://github.com/sponsors/jimmywarting"

{           "type": "github",           "url": "https://paypal.me/jimmywarting"

"type": "github",           "url": "https://paypal.me/jimmywarting"         }

"url": "https://paypal.me/jimmywarting"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/jonschlinkert"

"funding": {         "url": "https://github.com/sponsors/jonschlinkert"       }

"url": "https://github.com/sponsors/jonschlinkert"

},       "funding": {         "url": "https://github.com/prettier/prettier?sponsor=1"

"funding": {         "url": "https://github.com/prettier/prettier?sponsor=1"       }

"url": "https://github.com/prettier/prettier?sponsor=1"

},       "funding": {         "url": "https://github.com/chalk/ansi-styles?sponsor=1"

"funding": {         "url": "https://github.com/chalk/ansi-styles?sponsor=1"       }

"url": "https://github.com/chalk/ansi-styles?sponsor=1"

{           "type": "individual",           "url": "https://github.com/sponsors/dubzzz"

"type": "individual",           "url": "https://github.com/sponsors/dubzzz"         },

"url": "https://github.com/sponsors/dubzzz"

{           "type": "opencollective",           "url": "https://opencollective.com/fast-check"

"type": "opencollective",           "url": "https://opencollective.com/fast-check"         }

"url": "https://opencollective.com/fast-check"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

"funding": {         "type": "opencollective",         "url": "https://opencollective.com/sinon"

"type": "opencollective",         "url": "https://opencollective.com/sinon"       }

"url": "https://opencollective.com/sinon"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

},       "funding": {         "url": "https://github.com/sponsors/ljharb"

"funding": {         "url": "https://github.com/sponsors/ljharb"       }

"url": "https://github.com/sponsors/ljharb"

},       "funding": {         "url": "https://github.com/sponsors/SuperchupuDev"

"funding": {         "url": "https://github.com/sponsors/SuperchupuDev"       }

"url": "https://github.com/sponsors/SuperchupuDev"

},       "funding": {         "url": "https://github.com/sponsors/jonschlinkert"

"funding": {         "url": "https://github.com/sponsors/jonschlinkert"       }

"url": "https://github.com/sponsors/jonschlinkert"

},       "funding": {         "url": "https://github.com/sponsors/sindresorhus"

"funding": {         "url": "https://github.com/sponsors/sindresorhus"       }

"url": "https://github.com/sponsors/sindresorhus"

{           "type": "opencollective",           "url": "https://opencollective.com/browserslist"

"type": "opencollective",           "url": "https://opencollective.com/browserslist"         },

"url": "https://opencollective.com/browserslist"

{           "type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/browserslist"

"type": "tidelift",           "url": "https://tidelift.com/funding/github/npm/browserslist"         },

"url": "https://tidelift.com/funding/github/npm/browserslist"

{           "type": "github",           "url": "https://github.com/sponsors/ai"

"type": "github",           "url": "https://github.com/sponsors/ai"         }

"url": "https://github.com/sponsors/ai"

"version": "9.0.1",       "funding": [         "https://github.com/sponsors/broofa",

"funding": [         "https://github.com/sponsors/broofa",         "https://github.com/sponsors/ctavan"

"https://github.com/sponsors/broofa",

"https://github.com/sponsors/ctavan"

},       "funding": {         "url": "https://github.com/chalk/wrap-ansi?sponsor=1"

"funding": {         "url": "https://github.com/chalk/wrap-ansi?sponsor=1"       }

"url": "https://github.com/chalk/wrap-ansi?sponsor=1"

Executable file

"author": {     "name": "2FastLabs",     "url": "https://github.com/2fastlabs"

"name": "2FastLabs",     "url": "https://github.com/2fastlabs"   },

"url": "https://github.com/2fastlabs"

"repository": {     "type": "git",     "url": "https://github.com/2fastlabs/agent-squad"

"type": "git",     "url": "https://github.com/2fastlabs/agent-squad"   },

"url": "https://github.com/2fastlabs/agent-squad"

},   "bugs": {     "url": "https://github.com/2fastlabs/agent-squad/issues"

"bugs": {     "url": "https://github.com/2fastlabs/agent-squad/issues"   },

"url": "https://github.com/2fastlabs/agent-squad/issues"

},   "homepage": "https://github.com/2fastlabs/agent-squad",   "scripts": {

"homepage": "https://github.com/2fastlabs/agent-squad",

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

// ToolChoice is only supported by Anthropic Claude 3 models and by Mistral AI Mistral Large.     // https://docs.aws.amazon.com/bedrock/latest/APIReference/API_runtime_ToolChoice.html

// https://docs.aws.amazon.com/bedrock/latest/APIReference/API_runtime_ToolChoice.html

Executable file

Executable file

[Credential-related source omitted]

[Credential-related source omitted]

try {         const response = await fetch(this.baseUrl, {

const response = await fetch(this.baseUrl, {

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

Executable file

[Credential-related source omitted]

/** Base URL of the Dakera server. Falls back to `DAKERA_URL`, then `http://localhost:3000`. */

/**  * Retriever backed by a self-hosted [Dakera](https://dakera.ai) memory server.

* Retriever backed by a self-hosted [Dakera](https://dakera.ai) memory server.  *  * Uses Dakera's text-query API (server-side embedding) to fetch the most relevant

[Credential-related source omitted]

[Credential-related source omitted]

);     }     const baseUrl = this.options.url || process.env.DAKERA_URL || "http://localhost:3000";

const baseUrl = this.options.url || process.env.DAKERA_URL || "http://localhost:3000";

Executable file

Executable file