@spec discover_tools(
  t(),
  keyword()
) :: {:ok, [map()]} | {:error, String.t()}

Discovers tools from the MCP server without converting to Functions.

Useful for inspecting available tools.

Parameters

• adapter - Adapter struct
• opts - Options (:refresh to force cache refresh)

Returns

• {:ok, tools} - List of tool maps
• {:error, reason} - Error message

Examples

iex> {:ok, tools} = Adapter.discover_tools(adapter)
iex> Enum.map(tools, & &1["name"])
["search", "fetch", "analyze"]

@spec get_config(t()) :: LangChain.MCP.Config.t()

Returns the adapter's configuration.

Examples

iex> config = Adapter.get_config(adapter)
iex> config.client
MyApp.MCPClient

@spec get_tool(t(), String.t()) :: {:ok, map()} | {:error, :not_found | String.t()}

Gets information about a specific tool.

Parameters

• adapter - Adapter struct
• tool_name - Name of the tool

Returns

• {:ok, tool} - Tool map
• {:error, :not_found} - Tool not found

Examples

iex> {:ok, tool} = Adapter.get_tool(adapter, "search")
iex> tool["description"]
"Search for information"

@spec new(keyword()) :: t()

Creates a new MCP adapter.

Options

See LangChain.MCP.Config.new!/1 for all available options.

Examples

iex> adapter = Adapter.new(client: MyApp.MCPClient)
%Adapter{config: %Config{...}}

iex> adapter = Adapter.new(
...>   client: MyApp.MCPClient,
...>   cache_tools: true,
...>   timeout: 60_000,
...>   async: true
...> )

@spec refresh_cache(t()) :: {:ok, t()} | {:error, String.t()}

Refreshes the tool cache for an adapter.

Only useful if caching is enabled.

Parameters

• adapter - Adapter struct

Returns

• {:ok, updated_adapter} - Adapter with refreshed cache
• {:error, reason} - Error message

Examples

iex> {:ok, updated_adapter} = Adapter.refresh_cache(adapter)

@spec to_functions(
  t(),
  keyword()
) :: [LangChain.Function.t()]

Discovers tools from the MCP server and converts them to LangChain Functions.

Parameters

• adapter - Adapter struct
• opts - Optional keyword list
  • :only - List of tool names to include
  • :except - List of tool names to exclude
  • :refresh - Force refresh cached tools (default: false)

Returns

• List of LangChain.Function.t() structs

Examples

# Get all tools
functions = Adapter.to_functions(adapter)

# Get specific tools
functions = Adapter.to_functions(adapter, only: ["search", "fetch"])

# Exclude tools
functions = Adapter.to_functions(adapter, except: ["admin_tool"])

# Force refresh cache
functions = Adapter.to_functions(adapter, refresh: true)

@spec tool_to_function(t(), map()) :: LangChain.Function.t()

Converts a single MCP tool to a LangChain Function.

Parameters

• adapter - Adapter struct
• tool - MCP tool map

Returns

• LangChain.Function.t() struct

Examples

iex> tool = %{
...>   "name" => "search",
...>   "description" => "Search for information",
...>   "inputSchema" => %{
...>     "type" => "object",
...>     "properties" => %{"query" => %{"type" => "string"}},
...>     "required" => ["query"]
...>   }
...> }
iex> function = Adapter.tool_to_function(adapter, tool)
iex> function.name
"search"

@spec update_config(
  t(),
  keyword()
) :: t()

Updates the adapter's configuration.

Parameters

• adapter - Adapter struct
• updates - Keyword list of config updates

Returns

• Updated adapter

Examples

iex> updated = Adapter.update_config(adapter, timeout: 60_000, async: true)
iex> updated.config.timeout
60_000

@spec validate_tools(t(), [String.t()]) :: :ok | {:error, [String.t()]}

Validates that all required tools are available on the MCP server.

Parameters

• adapter - Adapter struct
• tool_names - List of required tool names

Returns

• :ok - All tools available
• {:error, missing_tools} - List of missing tool names

Examples

iex> Adapter.validate_tools(adapter, ["search", "fetch"])
:ok

iex> Adapter.validate_tools(adapter, ["search", "nonexistent"])
{:error, ["nonexistent"]}

@spec wait_for_server_ready(pid(), timeout :: non_neg_integer()) ::
  :ok | {:error, :initialization_timeout | :invalid_client}

Waits for the associated server for a client to be ready.

If a client is started with start_link/1 the server initialization is asynchronous, so calling functions such as Adapter.discover_tools/2 or Adapter.to_functions/2 immediately after start link will produce a 'Server capabilities not set' error.

In this case, calling wait_for_server_ready/1 before calls to the Adapter ensures the server has time to initialize.

Parameters

• client_pid - The process ID for a Anubis client.
• timeout - Maximum time to wait in milliseconds (default: 5000)

Returns

• :ok - Server is ready
• {:error, :initialization_timeout} - Server didn't initialize within timeout
• {:error, :invalid_client} - The provided PID is not a valid Anubis client

Examples

{:ok, client_pid} =
    MCPClient.start_link(
      client_info: ...,
      capabilities: ...,
      protocol_version: ...,
      transport: ...
    )

case Adapter.wait_for_server_ready(client_pid) do
  :ok ->
    adapter = Adapter.new(client: client_pid)
    functions = Adapter.to_functions(adapter)
  {:error, reason} ->
    {:error, reason}
end